-/*\r
- * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.\r
- *\r
- * This program and the accompanying materials are made available under the\r
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
- * and is available at http://www.eclipse.org/legal/epl-v10.html\r
- */\r
-\r
-package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors;\r
-\r
-import static org.junit.Assert.assertEquals;\r
-import static org.junit.Assert.assertFalse;\r
-import static org.junit.Assert.assertTrue;\r
-import static org.junit.Assert.assertNotNull;\r
-import static org.mockito.Mockito.verify;\r
-import static org.mockito.Mockito.when;\r
-\r
-import org.junit.Before;\r
-import org.junit.Test;\r
-import org.mockito.Mockito;\r
-import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;\r
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;\r
-import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;\r
-import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;\r
-import org.opendaylight.controller.md.sal.binding.test.AbstractDataBrokerTest;\r
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;\r
-import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;\r
-import org.opendaylight.groupbasedpolicy.neutron.mapper.util.MappingUtils;\r
-import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;\r
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContextId;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.UniqueId;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.MacAddressType;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPortBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.VppEndpoint;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.vpp.endpoint._interface.type.choice.VhostUserCase;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.Ports;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.PortBuilder;\r
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;\r
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;\r
-\r
-import com.google.common.base.Optional;\r
-\r
-public class PortHandlerTest extends AbstractDataBrokerTest {\r
-\r
- private DataBroker dataBroker;\r
- private PortHandler portHandler;\r
- private ReadWriteTransaction rwTx;\r
- private BindingTransactionChain transactionChain;\r
-\r
- private final Port port = new PortBuilder().setUuid(new Uuid("00000000-1111-2222-3333-444444444444")).build();\r
- private final BaseEndpointByPort bebp = new BaseEndpointByPortBuilder().setContextId(\r
- new ContextId("aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa"))\r
- .setAddress("00:11:11:11:11:11")\r
- .setPortId(new UniqueId("00000000-1111-2222-3333-444444444444"))\r
- .setContextType(MappingUtils.L2_BRDIGE_DOMAIN)\r
- .setAddressType(MacAddressType.class)\r
- .build();\r
-\r
- @Before\r
- public void init() {\r
- dataBroker = Mockito.spy(getDataBroker());\r
- transactionChain = dataBroker.createTransactionChain(portHandler);\r
- when(dataBroker.createTransactionChain(portHandler)).thenReturn(transactionChain);\r
- portHandler = new PortHandler(dataBroker);\r
- rwTx = Mockito.spy(dataBroker.newReadWriteTransaction());\r
- when(transactionChain.newWriteOnlyTransaction()).thenReturn(rwTx);\r
- }\r
-\r
- @Test\r
- public void buildVppEpTest() {\r
- VppEndpoint vppEp = portHandler.buildVppEp(bebp);\r
- assertEquals(vppEp.getAddress(),bebp.getAddress());\r
- assertEquals(vppEp.getAddressType(), bebp.getAddressType());\r
- assertEquals(vppEp.getContextId(), bebp.getContextId());\r
- assertEquals(vppEp.getContextType(), bebp.getContextType());\r
- assertTrue(vppEp.getInterfaceTypeChoice() instanceof VhostUserCase);\r
- VhostUserCase vhostUserCase = (VhostUserCase) vppEp.getInterfaceTypeChoice();\r
- assertNotNull(vhostUserCase);\r
- assertEquals(vhostUserCase.getSocket(), bebp.getPortId().getValue());\r
- }\r
-\r
- @Test\r
- public void createWildcartedPortIidTest() throws TransactionCommitFailedException {\r
- InstanceIdentifier<Port> iid = portHandler.createWildcartedPortIid();\r
- Class<?>[] expectedTypes = {Neutron.class, Ports.class, Port.class};\r
- TestUtils.assertPathArgumentTypes(iid.getPathArguments(), expectedTypes);\r
- assertEquals(iid.getTargetType(), Port.class);\r
- }\r
-\r
- @Test\r
- public void processCreatedDataTest() throws Exception {\r
- portHandler.processCreatedData(port, bebp);\r
- ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();\r
- Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,\r
- TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);\r
- assertTrue(optVppEp.isPresent());\r
- }\r
-\r
- @Test\r
- public void processUpdatedTest() throws Exception {\r
- ReadWriteTransaction tx = dataBroker.newReadWriteTransaction();\r
- tx.put(LogicalDatastoreType.OPERATIONAL, TestUtils.createBaseEpByPortIid(port.getUuid()), bebp, true);\r
- DataStoreHelper.submitToDs(tx);\r
- portHandler.processUpdated(port, port);\r
- ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();\r
- Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,\r
- TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);\r
- assertTrue(optVppEp.isPresent());\r
- verify(rwTx).submit();\r
- }\r
-\r
- @Test\r
- public void processDeletedTest() throws Exception {\r
- ReadWriteTransaction tx = dataBroker.newReadWriteTransaction();\r
- tx.put(LogicalDatastoreType.OPERATIONAL, TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)),\r
- portHandler.buildVppEp(bebp));\r
- DataStoreHelper.submitToDs(tx);\r
- portHandler.processDeleted(bebp);\r
- ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();\r
- Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,\r
- TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);\r
- assertFalse(optVppEp.isPresent());\r
- verify(rwTx).submit();\r
- }\r
-}\r
+/*
+ * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Matchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mockito;
+import org.mockito.invocation.InvocationOnMock;
+import org.mockito.stubbing.Answer;
+import org.opendaylight.controller.md.sal.binding.api.BindingTransactionChain;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
+import org.opendaylight.controller.md.sal.binding.api.ReadTransaction;
+import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
+import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
+import org.opendaylight.controller.md.sal.binding.test.AbstractDataBrokerTest;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
+import org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.SocketInfo;
+import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.VppEndpoint;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425._interface.attributes._interface.type.choice.VhostUserCase;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.Ports;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+import com.google.common.base.Optional;
+
+public class PortHandlerTest extends AbstractDataBrokerTest {
+
+ private DataBroker dataBroker;
+ private PortHandler portHandler;
+ private BindingTransactionChain transactionChain;
+
+ private Port port;
+ private BaseEndpointByPort bebp;
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Before
+ public void init() {
+ port = TestUtils.createValidVppPort();
+ bebp = TestUtils.createBaseEndpointByPortForPort();
+ dataBroker = Mockito.spy(getDataBroker());
+ transactionChain = mock(BindingTransactionChain.class);
+ when(dataBroker.createTransactionChain(any(PortHandler.class))).thenReturn(transactionChain);
+ portHandler = new PortHandler(dataBroker);
+ when(transactionChain.newReadOnlyTransaction()).thenAnswer(new Answer<ReadTransaction>() {
+
+ @Override
+ public ReadTransaction answer(InvocationOnMock invocation) throws Throwable {
+ return dataBroker.newReadOnlyTransaction();
+ }
+ });
+ when(transactionChain.newWriteOnlyTransaction()).thenAnswer(new Answer<WriteTransaction>() {
+
+ @Override
+ public WriteTransaction answer(InvocationOnMock invocation) throws Throwable {
+ return dataBroker.newWriteOnlyTransaction();
+ }
+ });
+ }
+
+ @Test
+ public void testBuildVhostUserEndpoint() {
+ VppEndpoint vppEp = portHandler.buildVppEndpoint(port, bebp);
+ assertEquals(vppEp.getAddress(), bebp.getAddress());
+ assertEquals(vppEp.getAddressType(), bebp.getAddressType());
+ assertEquals(vppEp.getContextId(), bebp.getContextId());
+ assertEquals(vppEp.getContextType(), bebp.getContextType());
+ assertTrue(vppEp.getInterfaceTypeChoice() instanceof VhostUserCase);
+ VhostUserCase vhostUserCase = (VhostUserCase) vppEp.getInterfaceTypeChoice();
+ assertNotNull(vhostUserCase);
+ assertEquals(TestUtils.TEST_SOCKET, vhostUserCase.getSocket());
+ }
+
+ @Test
+ public void testBuildVhostUserEndpoint_notValidVppEp() {
+ port = TestUtils.createNonVppPort();
+ thrown.expect(NullPointerException.class);
+ portHandler.buildVppEndpoint(port, bebp);
+ }
+
+ @Test
+ public void testCreateWildcartedPortIid() throws TransactionCommitFailedException {
+ InstanceIdentifier<Port> iid = portHandler.createWildcartedPortIid();
+ Class<?>[] expectedTypes = {Neutron.class, Ports.class, Port.class};
+ TestUtils.assertPathArgumentTypes(iid.getPathArguments(), expectedTypes);
+ assertEquals(iid.getTargetType(), Port.class);
+ }
+
+ @Test
+ public void testProcessCreatedData() throws Exception {
+ portHandler.processCreatedData(port, bebp);
+ ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
+ Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
+ TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);
+ assertTrue(optVppEp.isPresent());
+ }
+
+ @Test
+ public void testProcessCreatedData_notValidVppEp() throws Exception {
+ port = TestUtils.createNonVppPort();
+ portHandler.processCreatedData(port, bebp);
+ ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
+ Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
+ TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);
+ assertFalse(optVppEp.isPresent());
+ }
+
+ @Test
+ public void testProcessUpdated() throws Exception {
+ WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
+ putVppEp(port, bebp, tx);
+ putBaseEpByPort(port, bebp, tx);
+ DataStoreHelper.submitToDs(tx);
+ portHandler.processUpdated(port, port);
+ ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
+ Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
+ TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);
+ assertTrue(optVppEp.isPresent());
+ }
+
+ @Test
+ public void testProcessUpdated_notValidVppEpAnymore() throws Exception {
+ Port delta = TestUtils.createNonVppPort();
+ ReadWriteTransaction tx = dataBroker.newReadWriteTransaction();
+ putVppEp(port, bebp, tx);
+ putBaseEpByPort(port, bebp, tx);
+ DataStoreHelper.submitToDs(tx);
+ portHandler.processUpdated(port, delta);
+ ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
+ Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
+ TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);
+ assertFalse(optVppEp.isPresent());
+ }
+
+ @Test
+ public void testProcessDeleted() throws Exception {
+ ReadWriteTransaction tx = dataBroker.newReadWriteTransaction();
+ putVppEp(port, bebp, tx);
+ DataStoreHelper.submitToDs(tx);
+ portHandler.processDeleted(bebp);
+ ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
+ Optional<VppEndpoint> optVppEp = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
+ TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)), rTx);
+ assertFalse(optVppEp.isPresent());
+ }
+
+ private void putVppEp(Port port, BaseEndpointByPort bebp, WriteTransaction rwTx) {
+ rwTx.put(LogicalDatastoreType.CONFIGURATION, TestUtils.createVppEpIid(TestUtils.createVppEndpointKey(bebp)),
+ portHandler.buildVppEndpoint(port, bebp));
+ }
+
+ private void putBaseEpByPort(Port port, BaseEndpointByPort bebp, WriteTransaction rwTx) {
+ rwTx.put(LogicalDatastoreType.OPERATIONAL, TestUtils.createBaseEpByPortIid(port.getUuid()), bebp, true);
+ }
+}
Code Review / groupbasedpolicy.git / blobdiff