}
Map<DOMDataTreeIdentifier, DOMDataTreeShardWriteTransaction> createTransactions() {
}
Map<DOMDataTreeIdentifier, DOMDataTreeShardWriteTransaction> createTransactions() {
+ Preconditions.checkState(!idToProducer.isEmpty(),
+ "Cannot create transaction since the producer is not mapped to any shard");
return Maps.transformValues(idToProducer, DOMDataTreeShardProducer::createTransaction);
}
}
return Maps.transformValues(idToProducer, DOMDataTreeShardProducer::createTransaction);
}
}
newRootShardReg.close();
}
newRootShardReg.close();
}
+ @Test(expected = IllegalStateException.class)
+ public void testEmptyShardMapProducer() throws Exception {
+ final ShardedDOMDataTree dataTree = new ShardedDOMDataTree();
+ final DOMDataTreeProducer producer = dataTree.createProducer(Collections.singletonList(ROOT_ID));
+ producer.createTransaction(false);
+ }
+
@Test
public void testSingleShardWrite() throws Exception {
final DOMDataTreeListener mockedDataTreeListener = Mockito.mock(DOMDataTreeListener.class);
@Test
public void testSingleShardWrite() throws Exception {
final DOMDataTreeListener mockedDataTreeListener = Mockito.mock(DOMDataTreeListener.class);