--- /dev/null
+/*
+ * Copyright (c) 2017 Ericsson India Global Services Pvt Ltd. 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.genius.itm.tests;
+
+import static org.opendaylight.mdsal.binding.testutils.AssertDataObjects.assertEqualBeans;
+
+import com.google.common.base.Optional;
+import com.google.common.util.concurrent.CheckedFuture;
+import java.util.ArrayList;
+import java.util.List;
+import javax.inject.Inject;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.MethodRule;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
+import org.opendaylight.genius.datastoreutils.SingleTransactionDataBroker;
+import org.opendaylight.genius.itm.cli.TepCommandHelper;
+import org.opendaylight.genius.itm.globals.ITMConstants;
+import org.opendaylight.genius.itm.impl.ItmUtils;
+import org.opendaylight.genius.itm.tests.xtend.ExpectedDefTransportZoneObjects;
+import org.opendaylight.genius.itm.tests.xtend.ExpectedTepNotHostedTransportZoneObjects;
+import org.opendaylight.genius.itm.tests.xtend.ExpectedTransportZoneObjects;
+import org.opendaylight.infrautils.inject.guice.testutils.GuiceRule;
+import org.opendaylight.infrautils.testutils.LogRule;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfig;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfigBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZonesBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TepsNotHostedInTransportZone;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.Vteps;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfo;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+/**
+ * Component tests for ITM TEP Auto Config feature.
+ */
+public class ItmTepAutoConfigTest {
+
+ public @Rule LogRule logRule = new LogRule();
+ public @Rule MethodRule guice = new GuiceRule(ItmTestModule.class);
+
+ TransportZone transportZone;
+ TransportZones transportZones;
+
+ // list objects
+ List<TransportZone> transportZoneList = new ArrayList<>();
+
+ // InstanceIdentifier objects building
+
+ // TransportZones Iid
+ InstanceIdentifier<TransportZones> tzonesPath = InstanceIdentifier.builder(TransportZones.class).build();
+
+ @Inject DataBroker dataBroker;
+
+ @Before
+ public void start() throws InterruptedException {
+ transportZone = new TransportZoneBuilder().setZoneName(ItmTestConstants.TZ_NAME)
+ .setTunnelType(ItmTestConstants.TUNNEL_TYPE_VXLAN).setKey(new TransportZoneKey(ItmTestConstants.TZ_NAME))
+ .build();
+ transportZoneList.add(transportZone);
+ transportZones = new TransportZonesBuilder().setTransportZone(transportZoneList).build();
+ }
+
+ // Common method created for code-reuse
+ private InstanceIdentifier<TransportZone> processDefTzOnItmConfig(boolean defTzEnabledFlag,
+ String defTzTunnelType) throws Exception {
+ ItmConfig itmConfigObj = null;
+ if (defTzTunnelType != null) {
+ // set def-tz-enabled flag and def-tz-tunnel-type
+ itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(defTzEnabledFlag)
+ .setDefTzTunnelType(defTzTunnelType).build();
+ } else {
+ // set def-tz-enabled flag only
+ itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(defTzEnabledFlag).build();
+ }
+ // Create TepCommandHelper object which creates/deletes default-TZ based
+ // on def-tz-enabled flag
+ TepCommandHelper tepCmdHelper = new TepCommandHelper(dataBroker, itmConfigObj);
+ tepCmdHelper.start();
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ITMConstants.DEFAULT_TRANSPORT_ZONE);
+
+ return tzonePath;
+ }
+
+ @Test
+ public void defTzEnabledFalseConfigTest() throws Exception {
+ InstanceIdentifier<ItmConfig> iid = InstanceIdentifier.create(ItmConfig.class);
+
+ // set def-tz-enabled flag to false
+ ItmConfig itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(false).build();
+
+ // write into config DS
+ CheckedFuture<Void, TransactionCommitFailedException> futures =
+ ItmTepAutoConfigTestUtil.writeItmConfig(iid, itmConfigObj, dataBroker);
+ futures.get();
+
+ // read from config DS
+ boolean defTzEnabled = SingleTransactionDataBroker.syncReadOptionalAndTreatReadFailedExceptionAsAbsentOptional(
+ dataBroker, LogicalDatastoreType.CONFIGURATION, iid).get().isDefTzEnabled();
+ Assert.assertEquals(defTzEnabled, false);
+ }
+
+ @Test
+ public void defTzEnabledTrueConfigTest() throws Exception {
+ InstanceIdentifier<ItmConfig> iid = InstanceIdentifier.create(ItmConfig.class);
+
+ // set def-tz-enabled flag to true
+ ItmConfig itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(true).build();
+
+ // write into config DS
+ CheckedFuture<Void, TransactionCommitFailedException> futures =
+ ItmTepAutoConfigTestUtil.writeItmConfig(iid, itmConfigObj, dataBroker);
+ futures.get();
+
+ // read from config DS
+ boolean defTzEnabled = SingleTransactionDataBroker.syncReadOptionalAndTreatReadFailedExceptionAsAbsentOptional(
+ dataBroker, LogicalDatastoreType.CONFIGURATION, iid).get().isDefTzEnabled();
+ Assert.assertEquals(defTzEnabled, true);
+ }
+
+ @Test
+ public void defTzCreationTestWithDefTzEnabledTrueAndVxlanTunnelType() throws Exception {
+ // set def-tz-enabled flag to true
+ boolean defTzEnabledFlag = true;
+ // set def-tz-tunnel-type to VXLAN
+ String defTzTunnelType = ITMConstants.TUNNEL_TYPE_VXLAN;
+
+ InstanceIdentifier<TransportZone> tzonePath = processDefTzOnItmConfig(defTzEnabledFlag,
+ defTzTunnelType);
+ Assert.assertNotNull(tzonePath);
+
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithVxlanTunnelType(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+ }
+
+ @Test
+ public void defTzCreationTestWithDefTzEnabledTrueAndGreTunnelType() throws Exception {
+ // set def-tz-enabled flag to true
+ boolean defTzEnabledFlag = true;
+ // set def-tz-tunnel-type to GRE
+ String defTzTunnelType = ITMConstants.TUNNEL_TYPE_GRE;
+
+ InstanceIdentifier<TransportZone> tzonePath = processDefTzOnItmConfig(defTzEnabledFlag,
+ defTzTunnelType);
+ Assert.assertNotNull(tzonePath);
+
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithGreTunnelType(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+ }
+
+ @Test
+ public void defTzCreationFailedTestWithDefTzEnabledFalse() throws Exception {
+ // set def-tz-enabled flag to false
+ boolean defTzEnabledFlag = false;
+ // set def-tz-tunnel-type to GRE
+ String defTzTunnelType = null;
+
+ InstanceIdentifier<TransportZone> tzonePath = processDefTzOnItmConfig(defTzEnabledFlag,
+ defTzTunnelType);
+ Assert.assertNotNull(tzonePath);
+
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).get());
+ }
+
+ @Test
+ public void defTzRecreationTestOnTunnelTypeChange() throws Exception {
+ // set def-tz-enabled flag to true
+ boolean defTzEnabledFlag = true;
+ // set def-tz-tunnel-type to VXLAN
+ String defTzTunnelType = ITMConstants.TUNNEL_TYPE_VXLAN;
+
+ InstanceIdentifier<TransportZone> tzonePath = processDefTzOnItmConfig(defTzEnabledFlag,
+ defTzTunnelType);
+ Assert.assertNotNull(tzonePath);
+
+ // check default-TZ is created with VXLAN tunnel type
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithVxlanTunnelType().getTunnelType(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, tzonePath)
+ .checkedGet().get().getTunnelType());
+
+ // now, change def-tz-tunnel-type to GRE
+ defTzTunnelType = ITMConstants.TUNNEL_TYPE_GRE;
+
+ tzonePath = processDefTzOnItmConfig(defTzEnabledFlag, defTzTunnelType);
+ Assert.assertNotNull(tzonePath);
+
+ // check default-TZ is re-created with GRE tunnel type
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithGreTunnelType().getTunnelType(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, tzonePath)
+ .checkedGet().get().getTunnelType());
+ }
+
+ @Test
+ public void defTzDeletionTest() throws Exception {
+ // create default-TZ first by setting def-tz-enabled flag to true
+ ItmConfig itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(true)
+ .setDefTzTunnelType(ITMConstants.TUNNEL_TYPE_GRE).build();
+
+ TepCommandHelper tepCmdHelper = new TepCommandHelper(dataBroker, itmConfigObj);
+ tepCmdHelper.start();
+
+ // Create TepCommandHelper object which creates/deletes default-TZ based on def-tz-enabled flag
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ITMConstants.DEFAULT_TRANSPORT_ZONE);
+ Assert.assertNotNull(tzonePath);
+
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithGreTunnelType(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+
+ // now delete default-TZ first by setting def-tz-enabled flag to false
+ itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(false).build();
+
+ // Create TepCommandHelper object which creates/deletes default-TZ based on def-tz-enabled flag
+ tepCmdHelper = new TepCommandHelper(dataBroker, itmConfigObj);
+ tepCmdHelper.start();
+
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).get());
+ }
+
+ @Test
+ public void testAddDeleteTepForDefTz() throws Exception {
+ // create default-TZ first by setting def-tz-enabled flag to true
+ ItmConfig itmConfigObj = new ItmConfigBuilder().setDefTzEnabled(true)
+ .setDefTzTunnelType(ITMConstants.TUNNEL_TYPE_VXLAN).build();
+
+ TepCommandHelper tepCmdHelper = new TepCommandHelper(dataBroker, itmConfigObj);
+ tepCmdHelper.start();
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ITMConstants.DEFAULT_TRANSPORT_ZONE);
+ Assert.assertNotNull(tzonePath);
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+
+ // add TEP into default-TZ
+ CheckedFuture<Void, TransactionCommitFailedException> futures =
+ ItmTepAutoConfigTestUtil.addTep(ItmTestConstants.DEF_TZ_TEP_IP,
+ ItmTestConstants.DEF_BR_DPID,
+ ITMConstants.DEFAULT_TRANSPORT_ZONE, false, dataBroker);
+ futures.get();
+
+ InstanceIdentifier<Vteps> vtepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ITMConstants.DEFAULT_TRANSPORT_ZONE, ItmTestConstants.INT_DEF_BR_DPID,
+ ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(vtepPath);
+
+ // check TEP is added into default-TZ
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithTep(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+
+ // remove tep from default-TZ
+ futures = ItmTepAutoConfigTestUtil.deleteTep(ItmTestConstants.DEF_TZ_TEP_IP,
+ ItmTestConstants.DEF_BR_DPID, ITMConstants.DEFAULT_TRANSPORT_ZONE, dataBroker);
+ futures.get();
+
+ // check TEP is deleted from default-TZ
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, vtepPath).get());
+ }
+
+ @Test
+ public void testAddDeleteTepForTz() throws Exception {
+ // create TZ
+ ItmUtils.syncWrite(LogicalDatastoreType.CONFIGURATION, tzonesPath, transportZones, dataBroker);
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ItmTestConstants.TZ_NAME);
+ Assert.assertNotNull(tzonePath);
+
+ // check TZ is created
+ Assert.assertEquals(ItmTestConstants.TZ_NAME, dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get().getZoneName());
+
+ // add tep
+ CheckedFuture<Void, TransactionCommitFailedException> futures =
+ ItmTepAutoConfigTestUtil.addTep(ItmTestConstants.NB_TZ_TEP_IP,
+ ItmTestConstants.DEF_BR_DPID, ItmTestConstants.TZ_NAME, false, dataBroker);
+ futures.get();
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+
+ InstanceIdentifier<Vteps> vtepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ItmTestConstants.TZ_NAME, ItmTestConstants.INT_DEF_BR_DPID, ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(vtepPath);
+
+ // check TEP is added into TZ that is already created.
+ assertEqualBeans(ExpectedTransportZoneObjects.newTransportZone(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+
+ // remove tep
+ futures = ItmTepAutoConfigTestUtil.deleteTep(ItmTestConstants.NB_TZ_TEP_IP,
+ ItmTestConstants.DEF_BR_DPID, ItmTestConstants.TZ_NAME, dataBroker);
+ futures.get();
+
+ // check TEP is deleted
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, vtepPath).get());
+
+ // for safe side, check TZ is present
+ Assert.assertEquals(ItmTestConstants.TZ_NAME, dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get().getZoneName());
+ }
+
+ @Test
+ public void tepAddDeleteFromDefTzViaSouthboundTest() throws Exception {
+ String tepIp = ItmTestConstants.DEF_TZ_TEP_IP;
+ // create Network topology node with tep-ip set into ExternalIds list
+ // OvsdbNodeListener would be automatically listen on Node to add TEP
+ ConnectionInfo connInfo = OvsdbTestUtil.getConnectionInfo(ItmTestConstants.OVSDB_CONN_PORT,
+ ItmTestConstants.LOCALHOST_IP);
+ CheckedFuture<Void, TransactionCommitFailedException> future =
+ OvsdbTestUtil.createNode(connInfo,tepIp,ITMConstants.DEFAULT_TRANSPORT_ZONE,dataBroker);
+ future.get();
+
+ // add bridge into node
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.DEF_BR_NAME,
+ ItmTestConstants.DEF_BR_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ITMConstants.DEFAULT_TRANSPORT_ZONE);
+ Assert.assertNotNull(tzonePath);
+
+ // check TEP is added into default-TZ
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithTep(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, tzonePath)
+ .checkedGet().get());
+
+ // test TEP delete now,
+ // pass tep-ip with NULL value, tep-ip paramtere in external_ids will not be set.
+ tepIp = null;
+ future = OvsdbTestUtil.updateNode(connInfo, tepIp, ITMConstants.DEFAULT_TRANSPORT_ZONE,
+ null, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+
+ InstanceIdentifier<Vteps> vtepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ITMConstants.DEFAULT_TRANSPORT_ZONE, ItmTestConstants.INT_DEF_BR_DPID,
+ ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(vtepPath);
+
+ // check TEP is deleted from default-TZ when TEP-Ip is removed from southbound
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, vtepPath).get());
+ }
+
+ @Test
+ public void tepAddDeleteFromNbTzViaSouthboundTest() throws Exception {
+ // create Transport-zone in advance
+ ItmUtils.syncWrite(LogicalDatastoreType.CONFIGURATION, tzonesPath, transportZones,
+ dataBroker);
+
+ String tepIp = ItmTestConstants.NB_TZ_TEP_IP;
+ // create Network topology node with tep-ip set into ExternalIds list
+ // OvsdbNodeListener would be automatically listen on Node to add TEP
+ ConnectionInfo connInfo = OvsdbTestUtil.getConnectionInfo(ItmTestConstants.OVSDB_CONN_PORT,
+ ItmTestConstants.LOCALHOST_IP);
+ CheckedFuture<Void, TransactionCommitFailedException> future = OvsdbTestUtil.createNode(
+ connInfo, tepIp, ItmTestConstants.TZ_NAME, dataBroker);
+ future.get();
+
+ // add bridge into node
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.DEF_BR_NAME,
+ ItmTestConstants.DEF_BR_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ItmTestConstants.TZ_NAME);
+ Assert.assertNotNull(tzonePath);
+
+ // check TEP is added into NB configured TZ
+ assertEqualBeans(ExpectedTransportZoneObjects.newTransportZone(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, tzonePath)
+ .checkedGet().get());
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+
+ InstanceIdentifier<Vteps> vtepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ItmTestConstants.TZ_NAME, ItmTestConstants.INT_DEF_BR_DPID, ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(vtepPath);
+
+ // test TEP delete now,
+ // pass tep-ip with NULL value, tep-ip paramtere in external_ids will not be set.
+ tepIp = null;
+ future = OvsdbTestUtil.updateNode(connInfo, tepIp, ItmTestConstants.TZ_NAME, null, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ // check TEP is deleted from default-TZ when TEP-Ip is removed from southbound
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, vtepPath).get());
+ }
+
+ @Test
+ public void tzAddDeleteToNotHostedViaSouthboundTest() throws Exception {
+ // create Network topology node
+ ConnectionInfo connInfo = OvsdbTestUtil.getConnectionInfo(ItmTestConstants.OVSDB_CONN_PORT,
+ ItmTestConstants.LOCALHOST_IP);
+ CheckedFuture<Void, TransactionCommitFailedException> future = OvsdbTestUtil.createNode(
+ connInfo, ItmTestConstants.NOT_HOSTED_TZ_TEP_IP, ItmTestConstants.NOT_HOSTED_TZ_NAME,
+ dataBroker);
+ future.get();
+
+ // add bridge into node
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.DEF_BR_NAME,
+ ItmTestConstants.NOT_HOSTED_DEF_BR_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<TepsNotHostedInTransportZone> notHostedtzPath = ItmTepAutoConfigTestUtil
+ .getTepNotHostedInTZIid(ItmTestConstants.NOT_HOSTED_TZ_NAME);
+ Assert.assertNotNull(notHostedtzPath);
+
+ // check not hosted
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION,
+ notHostedtzPath).checkedGet().get());
+
+ future = OvsdbTestUtil.updateNode(connInfo, ItmTestConstants.NOT_HOSTED_TZ_TEP_IP, null,
+ ItmTestConstants.DEF_BR_NAME, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ Assert.assertEquals(Optional.absent(),dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, notHostedtzPath).get());
+ }
+
+ @Test
+ public void tepUpdateForTzTest() throws Exception {
+ String tepIp = ItmTestConstants.DEF_TZ_TEP_IP;
+ // create Network topology node with tep-ip set into ExternalIds list
+ // OvsdbNodeListener would be automatically listen on Node to add TEP
+ ConnectionInfo connInfo = OvsdbTestUtil.getConnectionInfo(ItmTestConstants.OVSDB_CONN_PORT,
+ ItmTestConstants.LOCALHOST_IP);
+ CheckedFuture<Void, TransactionCommitFailedException> future = OvsdbTestUtil.createNode(
+ connInfo, tepIp, ITMConstants.DEFAULT_TRANSPORT_ZONE, dataBroker);
+ future.get();
+
+ // add bridge into node
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.DEF_BR_NAME,
+ ItmTestConstants.DEF_BR_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ // iid for default-TZ
+ InstanceIdentifier<TransportZone> defTzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ITMConstants.DEFAULT_TRANSPORT_ZONE);
+ Assert.assertNotNull(defTzonePath);
+
+ // check TEP is added into default-TZ
+ assertEqualBeans(ExpectedDefTransportZoneObjects.newDefTzWithTep(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, defTzonePath)
+ .checkedGet().get());
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+ InstanceIdentifier<Vteps> oldVTepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ITMConstants.DEFAULT_TRANSPORT_ZONE, ItmTestConstants.INT_DEF_BR_DPID,
+ ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(oldVTepPath);
+
+ // create Transport-zone TZA
+ ItmUtils.syncWrite(LogicalDatastoreType.CONFIGURATION, tzonesPath, transportZones,
+ dataBroker);
+
+ // iid for TZA configured from NB
+ InstanceIdentifier<TransportZone> tzaTzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ItmTestConstants.TZ_NAME);
+ Assert.assertNotNull(tzaTzonePath);
+
+ // update OVSDB node with tzname=TZA in ExternalIds list
+ String tzName = ItmTestConstants.TZ_NAME;
+ OvsdbTestUtil.updateNode(connInfo, tepIp, tzName, null, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ // check old TEP which was in default-TZ is deleted
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, oldVTepPath).get());
+
+ // check TEP is updated and now it is added into TZA transport-zone when tzname is updated
+ // to TZA from southbound
+ assertEqualBeans(ExpectedTransportZoneObjects.updatedTransportZone(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION,tzaTzonePath)
+ .checkedGet().get());
+ }
+
+ @Test
+ public void tepUpdateForBrNameTest() throws Exception {
+ // create Transport-zone in advance
+ ItmUtils.syncWrite(LogicalDatastoreType.CONFIGURATION, tzonesPath, transportZones, dataBroker);
+
+ String tepIp = ItmTestConstants.NB_TZ_TEP_IP;
+ // prepare OVSDB node with tep-ip set into ExternalIds list
+ // OvsdbNodeListener would be automatically listen on Node to add TEP
+ ConnectionInfo connInfo = OvsdbTestUtil.getConnectionInfo(ItmTestConstants.OVSDB_CONN_PORT,
+ ItmTestConstants.LOCALHOST_IP);
+ CheckedFuture<Void, TransactionCommitFailedException> future = OvsdbTestUtil.createNode(
+ connInfo, tepIp, ItmTestConstants.TZ_NAME, dataBroker);
+ future.get();
+
+ // add bridge into node
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.DEF_BR_NAME,
+ ItmTestConstants.DEF_BR_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<TransportZone> tzonePath = ItmTepAutoConfigTestUtil.getTzIid(
+ ItmTestConstants.TZ_NAME);
+ Assert.assertNotNull(tzonePath);
+
+ // check TEP is added into TZ
+ assertEqualBeans(ExpectedTransportZoneObjects.newTransportZone(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzonePath).checkedGet().get());
+
+ IpPrefix subnetMaskObj = ItmUtils.getDummySubnet();
+
+ InstanceIdentifier<Vteps> oldVTepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ItmTestConstants.TZ_NAME, ItmTestConstants.INT_DEF_BR_DPID, ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(oldVTepPath);
+
+ // add new bridge br2
+ future = OvsdbTestUtil.addBridgeIntoNode(connInfo, ItmTestConstants.BR2_NAME,
+ ItmTestConstants.BR2_DPID, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ // update OVSDB node with br-name=br2 in ExternalIds column
+ String brName = ItmTestConstants.BR2_NAME;
+ future = OvsdbTestUtil.updateNode(connInfo, ItmTestConstants.NB_TZ_TEP_IP,
+ ItmTestConstants.TZ_NAME, brName, dataBroker);
+ future.get();
+ // wait for OvsdbNodeListener to perform config DS update through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<Vteps> newVTepPath = ItmTepAutoConfigTestUtil.getTepIid(subnetMaskObj,
+ ItmTestConstants.TZ_NAME, ItmTestConstants.INT_BR2_DPID, ITMConstants.DUMMY_PORT);
+ Assert.assertNotNull(newVTepPath);
+
+ // check old TEP having default-bridge-DPID is deleted
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, oldVTepPath).get());
+
+ // check TEP is updated with dpnId of br2 when br-name is updated to br2 from southbound
+ Assert.assertEquals(ItmTestConstants.INT_BR2_DPID, dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, newVTepPath).checkedGet().get().getDpnId());
+ }
+
+ @Test
+ public void tepAddIntoTepsNotHostedListTest() throws Exception {
+ // add into not hosted list
+ CheckedFuture<Void, TransactionCommitFailedException> future =
+ ItmTepAutoConfigTestUtil.addTep(ItmTestConstants.NOT_HOSTED_TZ_TEP_IP,
+ ItmTestConstants.NOT_HOSTED_TZ_TEPDPN_ID, ItmTestConstants.NOT_HOSTED_TZ_NAME, false, dataBroker);
+ future.get();
+ InstanceIdentifier<TepsNotHostedInTransportZone> notHostedPath =
+ ItmTepAutoConfigTestUtil.getTepNotHostedInTZIid(ItmTestConstants.NOT_HOSTED_TZ_NAME);
+ Assert.assertNotNull(notHostedPath);
+
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, notHostedPath)
+ .checkedGet().get());
+ }
+
+ @Test
+ public void tepDeleteFromTepsNotHostedListTest() throws Exception {
+ // add into not hosted list
+ CheckedFuture<Void, TransactionCommitFailedException> future =
+ ItmTepAutoConfigTestUtil.addTep(ItmTestConstants.NOT_HOSTED_TZ_TEP_IP,
+ ItmTestConstants.NOT_HOSTED_TZ_TEPDPN_ID, ItmTestConstants.NOT_HOSTED_TZ_NAME, false, dataBroker);
+ future.get();
+ InstanceIdentifier<TepsNotHostedInTransportZone> notHostedPath =
+ ItmTepAutoConfigTestUtil.getTepNotHostedInTZIid(ItmTestConstants.NOT_HOSTED_TZ_NAME);
+ Assert.assertNotNull(notHostedPath);
+
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, notHostedPath).checkedGet().get());
+
+ //delete from not hosted list
+ future = ItmTepAutoConfigTestUtil.deleteTep(ItmTestConstants.NOT_HOSTED_TZ_TEP_IP,
+ ItmTestConstants.NOT_HOSTED_TZ_TEPDPN_ID, ItmTestConstants.NOT_HOSTED_TZ_NAME, dataBroker);
+ future.get();
+
+ Assert.assertEquals(Optional.absent(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, notHostedPath).get());
+ }
+
+ @Test
+ public void tepMoveFromTepsNotHostedListToTzTest() throws Exception {
+ // add into not hosted list
+ CheckedFuture<Void, TransactionCommitFailedException> future =
+ ItmTepAutoConfigTestUtil.addTep(ItmTestConstants.NOT_HOSTED_TZ_TEP_IP,
+ ItmTestConstants.NOT_HOSTED_TZ_TEPDPN_ID, ItmTestConstants.NOT_HOSTED_TZ_NAME, false,
+ dataBroker);
+ future.get();
+ InstanceIdentifier<TepsNotHostedInTransportZone> notHostedPath =
+ ItmTepAutoConfigTestUtil.getTepNotHostedInTZIid(ItmTestConstants.NOT_HOSTED_TZ_NAME);
+ Assert.assertNotNull(notHostedPath);
+
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone(),
+ dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, notHostedPath).checkedGet().get());
+
+ // create the same TZ
+ TransportZone transportZoneNorth = new TransportZoneBuilder().setZoneName(ItmTestConstants.NOT_HOSTED_TZ_NAME)
+ .setTunnelType(ItmTestConstants.TUNNEL_TYPE_VXLAN)
+ .setKey(new TransportZoneKey(ItmTestConstants.NOT_HOSTED_TZ_NAME)).build();
+ Assert.assertNotNull(transportZoneNorth);
+
+ ItmUtils.syncWrite(LogicalDatastoreType.CONFIGURATION, ItmTepAutoConfigTestUtil
+ .getTzIid(ItmTestConstants.NOT_HOSTED_TZ_NAME), transportZoneNorth, dataBroker);
+
+ // wait for TransportZoneListener to perform config DS update
+ // for TEP movement through transaction
+ Thread.sleep(1000);
+
+ InstanceIdentifier<TransportZone> tzPath = ItmTepAutoConfigTestUtil.getTzIid(
+ ItmTestConstants.NOT_HOSTED_TZ_NAME);
+ Assert.assertNotNull(tzPath);
+
+ // check TZ is Moved
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone().getUnknownVteps()
+ .get(0).getIpAddress().getIpv4Address().getValue(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzPath).checkedGet().get().getSubnets().get(0)
+ .getVteps().get(0).getIpAddress().getIpv4Address().getValue());
+
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone().getUnknownVteps()
+ .get(0).getDpnId(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, tzPath).checkedGet().get().getSubnets().get(0)
+ .getVteps().get(0).getDpnId());
+
+ assertEqualBeans(ExpectedTepNotHostedTransportZoneObjects.newTepNotHostedTransportZone().getZoneName(),
+ dataBroker.newReadOnlyTransaction().read(LogicalDatastoreType.CONFIGURATION, tzPath)
+ .checkedGet().get().getZoneName());
+
+ // check TZ is removed
+ Assert.assertEquals(Optional.absent(), dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.CONFIGURATION, notHostedPath).get());
+ }
+}
--- /dev/null
+/*
+ * Copyright (c) 2017 Ericsson India Global Services Pvt Ltd. 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.genius.itm.tests;
+
+import com.google.common.util.concurrent.CheckedFuture;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
+import org.opendaylight.ovsdb.utils.southbound.utils.SouthboundUtils;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.DatapathId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeName;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeRef;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfo;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfoBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.OpenvswitchExternalIds;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.OpenvswitchExternalIdsBuilder;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
+
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class OvsdbTestUtil {
+ /* methods */
+ public static ConnectionInfo getConnectionInfo(int port, String strIpAddress) {
+ IpAddress ipAddress = new IpAddress(new Ipv4Address(strIpAddress));
+ PortNumber portNumber = new PortNumber(port);
+
+ ConnectionInfo connectionInfo =
+ new ConnectionInfoBuilder().setRemoteIp(ipAddress).setRemotePort(portNumber).build();
+
+ return connectionInfo;
+ }
+
+ public static CheckedFuture<Void, TransactionCommitFailedException> createNode(
+ ConnectionInfo connectionInfo, String tepIp, String tzName, DataBroker dataBroker)
+ throws Exception {
+ final InstanceIdentifier<Node> iid = SouthboundUtils.createInstanceIdentifier(connectionInfo);
+
+ // build Node using its builder class
+ NodeBuilder nodeBuilder = new NodeBuilder();
+ NodeId ovsdbNodeId = SouthboundUtils.createNodeId(connectionInfo.getRemoteIp(),
+ connectionInfo.getRemotePort());
+ nodeBuilder.setNodeId(ovsdbNodeId);
+
+ // build OvsdbNodeAugmentation for Node
+ OvsdbNodeAugmentationBuilder ovsdbNodeAugBuilder = new OvsdbNodeAugmentationBuilder();
+ ovsdbNodeAugBuilder.setConnectionInfo(connectionInfo);
+
+ // create map of key-val pairs
+ Map<String, String> externalIds = new HashMap<>();
+ if (tepIp != null && !tepIp.isEmpty()) {
+ externalIds.put(ItmTestConstants.EXTERNAL_ID_TEP_IP_KEY, tepIp);
+ }
+
+ if (tzName != null) {
+ externalIds.put(ItmTestConstants.EXTERNAL_ID_TZNAME_KEY, tzName);
+ }
+
+ // get map-keys into set.
+ Set<String> externalIdKeys = externalIds.keySet();
+
+ List<OpenvswitchExternalIds> externalIdsList = new ArrayList<>();
+ String externalIdValue = null;
+ for (String externalIdKey : externalIdKeys) {
+ externalIdValue = externalIds.get(externalIdKey);
+ if (externalIdKey != null && externalIdValue != null) {
+ externalIdsList.add(new OpenvswitchExternalIdsBuilder().setExternalIdKey(externalIdKey)
+ .setExternalIdValue(externalIdValue).build());
+ }
+ }
+
+ // set ExternalIds list into Node
+ ovsdbNodeAugBuilder.setOpenvswitchExternalIds(externalIdsList);
+ // add OvsdbNodeAugmentation into Node
+ nodeBuilder.addAugmentation(OvsdbNodeAugmentation.class, ovsdbNodeAugBuilder.build());
+ Node ovsdbNode = nodeBuilder.build();
+
+ WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
+ transaction.put(LogicalDatastoreType.OPERATIONAL, iid, ovsdbNode, true);
+ return transaction.submit();
+ }
+
+ public static CheckedFuture<Void, TransactionCommitFailedException> updateNode(
+ ConnectionInfo connectionInfo, String tepIp, String tzName, String brName,
+ DataBroker dataBroker) throws Exception {
+ final InstanceIdentifier<Node> iid = SouthboundUtils.createInstanceIdentifier(connectionInfo);
+
+ Node oldOvsdbNode = dataBroker.newReadOnlyTransaction()
+ .read(LogicalDatastoreType.OPERATIONAL, iid).checkedGet().get();
+
+ // build Node using its builder class
+ NodeBuilder nodeBuilder = new NodeBuilder();
+ nodeBuilder.setNodeId(oldOvsdbNode.getNodeId());
+
+ // build OvsdbNodeAugmentation for Node
+ OvsdbNodeAugmentationBuilder ovsdbNodeAugBuilder = new OvsdbNodeAugmentationBuilder();
+ ovsdbNodeAugBuilder.setConnectionInfo(connectionInfo);
+
+ // create map of key-val pairs
+ Map<String, String> externalIds = new HashMap<>();
+ if (tepIp != null && !tepIp.isEmpty()) {
+ externalIds.put(ItmTestConstants.EXTERNAL_ID_TEP_IP_KEY, tepIp);
+ }
+
+ if (tzName != null) {
+ externalIds.put(ItmTestConstants.EXTERNAL_ID_TZNAME_KEY, tzName);
+ }
+
+ if (brName != null && !brName.isEmpty()) {
+ externalIds.put(ItmTestConstants.EXTERNAL_ID_BR_NAME_KEY, brName);
+ }
+
+ // get map-keys into set.
+ Set<String> externalIdKeys = externalIds.keySet();
+
+ List<OpenvswitchExternalIds> externalIdsList = new ArrayList<>();
+ String externalIdValue = null;
+ for (String externalIdKey : externalIdKeys) {
+ externalIdValue = externalIds.get(externalIdKey);
+ if (externalIdKey != null && externalIdValue != null) {
+ externalIdsList.add(new OpenvswitchExternalIdsBuilder().setExternalIdKey(externalIdKey)
+ .setExternalIdValue(externalIdValue).build());
+ }
+ }
+
+ // set ExternalIds list into Node
+ ovsdbNodeAugBuilder.setOpenvswitchExternalIds(externalIdsList);
+ // add OvsdbNodeAugmentation into Node
+ nodeBuilder.addAugmentation(OvsdbNodeAugmentation.class, ovsdbNodeAugBuilder.build());
+ Node ovsdbNode = nodeBuilder.build();
+
+ //ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
+ WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
+ transaction.put(LogicalDatastoreType.OPERATIONAL, iid, ovsdbNode, true);
+ return transaction.submit();
+ }
+
+ public static CheckedFuture<Void, TransactionCommitFailedException> addBridgeIntoNode(
+ ConnectionInfo connectionInfo, String bridgeName, String dpid, DataBroker dataBroker) throws Exception {
+ NodeId ovsdbNodeId = SouthboundUtils.createNodeId(connectionInfo.getRemoteIp(),
+ connectionInfo.getRemotePort());
+ NodeKey nodeKey = new NodeKey(ovsdbNodeId);
+
+ NodeBuilder bridgeNodeBuilder = new NodeBuilder();
+
+ InstanceIdentifier<Node> bridgeIid = SouthboundUtils.createInstanceIdentifier(nodeKey, bridgeName);
+
+ NodeId bridgeNodeId = SouthboundUtils.createManagedNodeId(bridgeIid);
+ bridgeNodeBuilder.setNodeId(bridgeNodeId);
+ OvsdbBridgeAugmentationBuilder ovsdbBridgeAugmentationBuilder = new OvsdbBridgeAugmentationBuilder();
+ ovsdbBridgeAugmentationBuilder.setBridgeName(new OvsdbBridgeName(bridgeName))
+ .setDatapathId(new DatapathId(dpid));
+ ovsdbBridgeAugmentationBuilder.setManagedBy(new OvsdbNodeRef(
+ SouthboundUtils.createInstanceIdentifier(nodeKey.getNodeId())));
+
+ bridgeNodeBuilder.addAugmentation(OvsdbBridgeAugmentation.class, ovsdbBridgeAugmentationBuilder.build());
+
+ Node bridgeNode = bridgeNodeBuilder.build();
+
+ WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
+ tx.merge(LogicalDatastoreType.OPERATIONAL, bridgeIid,
+ bridgeNode, true);
+ return tx.submit();
+ }
+}
Code Review / genius.git / commitdiff