X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-dom-it%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Ftest%2Fconnect%2Fdom%2FCrossBrokerMountPointTest.java;h=74c0ade8aa37d4c70b20fd49dc84b96114ae28a0;hp=23e6053a1fb73952b130b23ef401cbe5074c6d94;hb=4f82c49691f091f0ba6b09a07525edb246f17321;hpb=dea515c8870769408b9bea29f555d6b71ff43211 diff --git a/opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/connect/dom/CrossBrokerMountPointTest.java b/opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/connect/dom/CrossBrokerMountPointTest.java index 23e6053a1f..74c0ade8aa 100644 --- a/opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/connect/dom/CrossBrokerMountPointTest.java +++ b/opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/connect/dom/CrossBrokerMountPointTest.java @@ -9,16 +9,21 @@ package org.opendaylight.controller.sal.binding.test.connect.dom; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertTrue; + import com.google.common.base.Optional; import com.google.common.util.concurrent.CheckedFuture; import com.google.common.util.concurrent.Futures; -import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.MoreExecutors; import java.util.Collections; import java.util.Map; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.TimeoutException; import org.junit.Before; import org.junit.Test; -import org.opendaylight.controller.md.sal.common.api.TransactionStatus; +import org.opendaylight.controller.md.sal.binding.api.DataBroker; +import org.opendaylight.controller.md.sal.binding.api.MountPoint; +import org.opendaylight.controller.md.sal.binding.api.MountPointService; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException; import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener; @@ -31,8 +36,6 @@ import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction; import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction; import org.opendaylight.controller.md.sal.dom.api.DOMMountPointService; import org.opendaylight.controller.md.sal.dom.api.DOMTransactionChain; -import org.opendaylight.controller.sal.binding.api.mount.MountProviderInstance; -import org.opendaylight.controller.sal.binding.api.mount.MountProviderService; import org.opendaylight.controller.sal.binding.test.util.BindingBrokerTestFactory; import org.opendaylight.controller.sal.binding.test.util.BindingTestContext; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.md.sal.of.migration.test.model.rev150210.List11SimpleAugment; @@ -48,7 +51,6 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controll import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.common.QName; -import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; @@ -63,7 +65,7 @@ public class CrossBrokerMountPointTest { private static final TopLevelListKey TLL_KEY = new TopLevelListKey(TLL_NAME); - private static final Map TLL_KEY_BI = Collections. singletonMap(TLL_NAME_QNAME, + private static final Map TLL_KEY_BI = Collections.singletonMap(TLL_NAME_QNAME, TLL_NAME); private static final InstanceIdentifier TLL_INSTANCE_ID_BA = InstanceIdentifier.builder(Top.class) // @@ -84,34 +86,34 @@ public class CrossBrokerMountPointTest { Cont.QNAME.getLocalName()); private static final org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier TLL_INSTANCE_ID_BI = // - org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.builder() // + YangInstanceIdentifier.builder() // .node(Top.QNAME) // .node(TopLevelList.QNAME) // .nodeWithKey(TopLevelList.QNAME, TLL_KEY_BI) // .build(); - private static final org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier GROUP_STATISTICS_ID_BI = org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier - // + private static final org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier GROUP_STATISTICS_ID_BI = + YangInstanceIdentifier .builder(TLL_INSTANCE_ID_BI) - .nodeWithKey(QName.create(TllComplexAugment.QNAME, "list1"), QName.create(TllComplexAugment.QNAME, "attr-str"), - LIST1_KEY.getAttrStr()) - .nodeWithKey(QName.create(TllComplexAugment.QNAME, "list1-1"), QName.create(TllComplexAugment.QNAME, "attr-int"), - LIST11_KEY.getAttrInt()) + .nodeWithKey(QName.create(TllComplexAugment.QNAME, "list1"), + QName.create(TllComplexAugment.QNAME, "attr-str"), LIST1_KEY.getAttrStr()) + .nodeWithKey(QName.create(TllComplexAugment.QNAME, "list1-1"), + QName.create(TllComplexAugment.QNAME, "attr-int"), LIST11_KEY.getAttrInt()) .node(AUG_CONT).build(); private BindingTestContext testContext; - private MountProviderService bindingMountPointService; + private MountPointService bindingMountPointService; private DOMMountPointService domMountPointService; @Before public void setup() { final BindingBrokerTestFactory testFactory = new BindingBrokerTestFactory(); - testFactory.setExecutor(MoreExecutors.sameThreadExecutor()); + testFactory.setExecutor(MoreExecutors.newDirectExecutorService()); testFactory.setStartWithParsedSchema(true); testContext = testFactory.getTestContext(); testContext.start(); - bindingMountPointService = testContext.getBindingMountProviderService(); + bindingMountPointService = testContext.getBindingMountPointService(); domMountPointService = testContext.getDomMountProviderService(); // biRpcInvoker = testContext.getDomRpcInvoker(); @@ -122,14 +124,15 @@ public class CrossBrokerMountPointTest { } @Test - public void testMountPoint() { + public void testMountPoint() throws ReadFailedException, TimeoutException { final Integer attrIntValue = 500; domMountPointService.createMountPoint(TLL_INSTANCE_ID_BI) .addService(DOMDataBroker.class, new DOMDataBroker() { @Override - public ListenerRegistration registerDataChangeListener(final LogicalDatastoreType store, - final YangInstanceIdentifier path, final DOMDataChangeListener listener, final DataChangeScope triggeringScope) { + public ListenerRegistration registerDataChangeListener( + final LogicalDatastoreType store, final YangInstanceIdentifier path, + final DOMDataChangeListener listener, final DataChangeScope triggeringScope) { throw new UnsupportedOperationException(); } @@ -145,16 +148,19 @@ public class CrossBrokerMountPointTest { @Override public CheckedFuture>, ReadFailedException> read( final LogicalDatastoreType store, final YangInstanceIdentifier path) { - if(store == LogicalDatastoreType.OPERATIONAL && path.getLastPathArgument().equals(GROUP_STATISTICS_ID_BI.getLastPathArgument())) { + if (store == LogicalDatastoreType.OPERATIONAL && path.getLastPathArgument() + .equals(GROUP_STATISTICS_ID_BI.getLastPathArgument())) { final ContainerNode data = Builders.containerBuilder() .withNodeIdentifier(new NodeIdentifier(AUG_CONT)) - .withChild(ImmutableNodes.leafNode(QName.create(AUG_CONT, "attr-int"), attrIntValue)) + .withChild(ImmutableNodes.leafNode(QName.create(AUG_CONT, "attr-int"), + attrIntValue)) .build(); return Futures.immediateCheckedFuture(Optional.>of(data)); } - return Futures.immediateFailedCheckedFuture(new ReadFailedException(TLL_NAME, new Exception())); + return Futures.immediateFailedCheckedFuture(new ReadFailedException(TLL_NAME, + new Exception())); } @Override @@ -173,11 +179,6 @@ public class CrossBrokerMountPointTest { return false; } - @Override - public ListenableFuture> commit() { - return null; - } - @Override public void delete(final LogicalDatastoreType store, final YangInstanceIdentifier path) { throw new UnsupportedOperationException(); @@ -219,13 +220,15 @@ public class CrossBrokerMountPointTest { } }).register(); + final Optional bindingMountPoint = bindingMountPointService.getMountPoint(TLL_INSTANCE_ID_BA); + assertTrue(bindingMountPoint.isPresent()); + final Optional dataBroker = bindingMountPoint.get().getService(DataBroker.class); + assertTrue(dataBroker.isPresent()); - final MountProviderInstance bindingMountPoint = bindingMountPointService.getMountPoint(TLL_INSTANCE_ID_BA); - assertNotNull(bindingMountPoint); - - final Cont data = (Cont) bindingMountPoint.readOperationalData(AUG_CONT_ID_BA); - assertNotNull(data); - assertEquals(attrIntValue ,data.getAttrInt()); + final Optional data = dataBroker.get().newReadWriteTransaction().read(LogicalDatastoreType.OPERATIONAL, + AUG_CONT_ID_BA).checkedGet(5, TimeUnit.SECONDS); + assertTrue(data.isPresent()); + assertEquals(attrIntValue ,data.get().getAttrInt()); } }