X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fbroker%2Fimpl%2FDOMDataTreeListenerTest.java;h=57dbf83f8c02a8c6fd26d0f9088377b618324c99;hp=bad492769fe1d9f0adca6c30c466a974321a6036;hb=b4bf55727093657662d8c16a50fa85f87978a586;hpb=20a32e6459fd1e27e7669bf1ebc7742b96787b94 diff --git a/opendaylight/md-sal/sal-dom-broker/src/test/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMDataTreeListenerTest.java b/opendaylight/md-sal/sal-dom-broker/src/test/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMDataTreeListenerTest.java index bad492769f..57dbf83f8c 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/test/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMDataTreeListenerTest.java +++ b/opendaylight/md-sal/sal-dom-broker/src/test/java/org/opendaylight/controller/md/sal/dom/broker/impl/DOMDataTreeListenerTest.java @@ -22,16 +22,15 @@ import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.CountDownLatch; +import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; -import javax.annotation.Nonnull; import org.junit.After; import org.junit.Before; import org.junit.Test; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitDeadlockException; -import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; import org.opendaylight.controller.md.sal.dom.api.DOMDataBrokerExtension; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService; @@ -133,7 +132,7 @@ public class DOMDataTreeListenerTest { final DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit(); + writeTx.commit(); latch.await(5, TimeUnit.SECONDS); @@ -149,7 +148,7 @@ public class DOMDataTreeListenerTest { } @Test - public void replaceContainerContainerInTreeTest() throws InterruptedException, TransactionCommitFailedException { + public void replaceContainerContainerInTreeTest() throws InterruptedException, ExecutionException { final CountDownLatch latch = new CountDownLatch(2); DOMDataTreeChangeService dataTreeChangeService = getDOMDataTreeChangeService(); @@ -157,14 +156,14 @@ public class DOMDataTreeListenerTest { DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit().checkedGet(); + writeTx.commit().get(); final TestDataTreeListener listener = new TestDataTreeListener(latch); final ListenerRegistration listenerReg = dataTreeChangeService .registerDataTreeChangeListener(ROOT_DATA_TREE_ID, listener); writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER_2); - writeTx.submit(); + writeTx.commit(); latch.await(5, TimeUnit.SECONDS); @@ -188,7 +187,7 @@ public class DOMDataTreeListenerTest { } @Test - public void deleteContainerContainerInTreeTest() throws InterruptedException, TransactionCommitFailedException { + public void deleteContainerContainerInTreeTest() throws InterruptedException, ExecutionException { final CountDownLatch latch = new CountDownLatch(2); DOMDataTreeChangeService dataTreeChangeService = getDOMDataTreeChangeService(); @@ -196,7 +195,7 @@ public class DOMDataTreeListenerTest { DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit().checkedGet(); + writeTx.commit().get(); final TestDataTreeListener listener = new TestDataTreeListener(latch); final ListenerRegistration listenerReg = dataTreeChangeService @@ -204,7 +203,7 @@ public class DOMDataTreeListenerTest { writeTx = domBroker.newWriteOnlyTransaction(); writeTx.delete(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH); - writeTx.submit(); + writeTx.commit(); latch.await(5, TimeUnit.SECONDS); @@ -228,7 +227,7 @@ public class DOMDataTreeListenerTest { } @Test - public void replaceChildListContainerInTreeTest() throws InterruptedException, TransactionCommitFailedException { + public void replaceChildListContainerInTreeTest() throws InterruptedException, ExecutionException { final CountDownLatch latch = new CountDownLatch(2); DOMDataTreeChangeService dataTreeChangeService = getDOMDataTreeChangeService(); @@ -236,7 +235,7 @@ public class DOMDataTreeListenerTest { DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit().checkedGet(); + writeTx.commit().get(); final TestDataTreeListener listener = new TestDataTreeListener(latch); final ListenerRegistration listenerReg = dataTreeChangeService @@ -244,7 +243,7 @@ public class DOMDataTreeListenerTest { writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.OUTER_LIST_PATH, OUTER_LIST_2); - writeTx.submit(); + writeTx.commit(); latch.await(5, TimeUnit.SECONDS); @@ -272,7 +271,7 @@ public class DOMDataTreeListenerTest { } @Test - public void rootModificationChildListenerTest() throws InterruptedException, TransactionCommitFailedException { + public void rootModificationChildListenerTest() throws InterruptedException, ExecutionException { final CountDownLatch latch = new CountDownLatch(2); DOMDataTreeChangeService dataTreeChangeService = getDOMDataTreeChangeService(); @@ -280,7 +279,7 @@ public class DOMDataTreeListenerTest { DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit().checkedGet(); + writeTx.commit().get(); final TestDataTreeListener listener = new TestDataTreeListener(latch); final ListenerRegistration listenerReg = dataTreeChangeService @@ -288,7 +287,7 @@ public class DOMDataTreeListenerTest { writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER_2); - writeTx.submit().checkedGet(); + writeTx.commit().get(); latch.await(1, TimeUnit.SECONDS); @@ -312,7 +311,7 @@ public class DOMDataTreeListenerTest { } @Test - public void listEntryChangeNonRootRegistrationTest() throws InterruptedException, TransactionCommitFailedException { + public void listEntryChangeNonRootRegistrationTest() throws InterruptedException, ExecutionException { final CountDownLatch latch = new CountDownLatch(2); DOMDataTreeChangeService dataTreeChangeService = getDOMDataTreeChangeService(); @@ -320,7 +319,7 @@ public class DOMDataTreeListenerTest { DOMDataWriteTransaction writeTx = domBroker.newWriteOnlyTransaction(); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.TEST_PATH, TEST_CONTAINER); - writeTx.submit().checkedGet(); + writeTx.commit().get(); final TestDataTreeListener listener = new TestDataTreeListener(latch); final ListenerRegistration listenerReg = dataTreeChangeService @@ -349,7 +348,7 @@ public class DOMDataTreeListenerTest { outerListEntry2); writeTx.put(LogicalDatastoreType.CONFIGURATION, TestModel.OUTER_LIST_PATH.node(outerListEntryId3), outerListEntry3); - writeTx.submit(); + writeTx.commit(); latch.await(5, TimeUnit.SECONDS); @@ -434,7 +433,7 @@ public class DOMDataTreeListenerTest { } @Override - public void onDataTreeChanged(@Nonnull final Collection changes) { + public void onDataTreeChanged(final Collection changes) { receivedChanges.add(changes); latch.countDown(); }