private AbstractDOMDataBroker domBroker;
@Before
- public void setupStore() throws Exception{
- final InMemoryDOMDataStore operStore = new InMemoryDOMDataStore("OPER", MoreExecutors.newDirectExecutorService());
- final InMemoryDOMDataStore configStore = new InMemoryDOMDataStore("CFG", MoreExecutors.newDirectExecutorService());
+ public void setupStore() throws Exception {
+ final InMemoryDOMDataStore operStore = new InMemoryDOMDataStore("OPER",
+ MoreExecutors.newDirectExecutorService());
+ final InMemoryDOMDataStore configStore = new InMemoryDOMDataStore("CFG",
+ MoreExecutors.newDirectExecutorService());
schemaContext = TestModel.createTestContext();
operStore.onGlobalContextUpdated(schemaContext);
configStore.onGlobalContextUpdated(schemaContext);
- final ImmutableMap<LogicalDatastoreType, DOMStore> stores = ImmutableMap.<LogicalDatastoreType, DOMStore> builder() //
- .put(CONFIGURATION, configStore) //
- .put(OPERATIONAL, operStore) //
+ final ImmutableMap<LogicalDatastoreType, DOMStore> stores =
+ ImmutableMap.<LogicalDatastoreType, DOMStore>builder()
+ .put(CONFIGURATION, configStore)
+ .put(OPERATIONAL, operStore)
.build();
- final ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor());
+ final ListeningExecutorService executor = MoreExecutors.listeningDecorator(
+ Executors.newSingleThreadExecutor());
domBroker = new SerializedDOMDataBroker(stores, executor);
}
assertNotNull(txChain);
/**
- * We alocate new read-write transaction and write /test
- *
- *
+ * We alocate new read-write transaction and write /test.
*/
final DOMDataTreeWriteTransaction firstTx = allocateAndWrite(txChain);
/**
* First transaction is marked as ready, we are able to allocate chained
- * transactions
+ * transactions.
*/
final ListenableFuture<Void> firstWriteTxFuture = firstTx.submit();
assertTestContainerExists(secondReadTx);
/**
- *
* We alocate next transaction, which is still based on first one, but
* is read-write.
*
assertCommitSuccessful(firstWriteTxFuture);
/**
- *
* Allocates transaction from data store.
*
*/
assertTestContainerExists(storeReadTx);
/**
- * third transaction is sealed and commited
+ * third transaction is sealed and commited.
*/
final ListenableFuture<Void> thirdDeleteTxFuture = thirdDeleteTx.submit();
assertCommitSuccessful(thirdDeleteTxFuture);
listener.getSuccessFuture().get(1000, TimeUnit.MILLISECONDS);
}
+ @SuppressWarnings("checkstyle:IllegalCatch")
@Test
public void testTransactionChainNotSealed() throws InterruptedException, ExecutionException, TimeoutException {
final BlockingTransactionChainListener listener = new BlockingTransactionChainListener();
/**
* We alocate new read-write transaction and write /test
- *
- *
*/
allocateAndWrite(txChain);
future.get();
}
- private static void assertTestContainerExists(final DOMDataTreeReadTransaction readTx) throws InterruptedException,
- ExecutionException {
- final ListenableFuture<Optional<NormalizedNode<?, ?>>> readFuture = readTx.read(OPERATIONAL, TestModel.TEST_PATH);
+ private static void assertTestContainerExists(final DOMDataTreeReadTransaction readTx)
+ throws InterruptedException, ExecutionException {
+ final ListenableFuture<Optional<NormalizedNode<?, ?>>> readFuture =
+ readTx.read(OPERATIONAL, TestModel.TEST_PATH);
final Optional<NormalizedNode<?, ?>> readedData = readFuture.get();
assertTrue(readedData.isPresent());
}