X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openstack%2Fnet-virt%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fovsdb%2Fopenstack%2Fnetvirt%2Fimpl%2FSouthboundImpl.java;h=fb7f8e1224e599a0b2ceca4ab9aa35763812a7df;hb=362b826eb59458765c054a8e0005cbaf6b6b65e5;hp=da708b879b056e736e50628c8cb792f875f23172;hpb=6633a5e6977a2238b5538ab482dfee742cd70127;p=netvirt.git diff --git a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/SouthboundImpl.java b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/SouthboundImpl.java index da708b879b..fb7f8e1224 100644 --- a/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/SouthboundImpl.java +++ b/openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/SouthboundImpl.java @@ -20,12 +20,12 @@ import org.opendaylight.ovsdb.openstack.netvirt.MdsalHelper; import org.opendaylight.ovsdb.openstack.netvirt.NetworkHandler; import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbTables; import org.opendaylight.ovsdb.openstack.netvirt.api.Southbound; +import org.opendaylight.ovsdb.utils.mdsal.utils.MdsalUtils; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.*; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.BridgeExternalIds; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.BridgeOtherConfigs; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.BridgeOtherConfigsBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.BridgeOtherConfigsKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntryBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntry; @@ -63,9 +63,9 @@ import com.google.common.collect.ImmutableBiMap; */ public class SouthboundImpl implements Southbound { private static final Logger LOG = LoggerFactory.getLogger(SouthboundImpl.class); - private DataBroker databroker = null; + private final DataBroker databroker; private static final String PATCH_PORT_TYPE = "patch"; - private MdsalUtils mdsalUtils = null; + private final MdsalUtils mdsalUtils; /** * Class constructor setting the data broker. @@ -175,7 +175,7 @@ public class SouthboundImpl implements Southbound { public boolean addBridge(Node ovsdbNode, String bridgeName, List controllersStr, final Class dpType) { - boolean result = false; + boolean result; LOG.info("addBridge: node: {}, bridgeName: {}, controller(s): {}", ovsdbNode, bridgeName, controllersStr); ConnectionInfo connectionInfo = getConnectionInfo(ovsdbNode); @@ -216,11 +216,10 @@ public class SouthboundImpl implements Southbound { } public boolean deleteBridge(Node ovsdbNode) { - boolean result = false; InstanceIdentifier bridgeIid = MdsalHelper.createInstanceIdentifier(ovsdbNode.getNodeId()); - result = mdsalUtils.delete(LogicalDatastoreType.CONFIGURATION, bridgeIid); + boolean result = mdsalUtils.delete(LogicalDatastoreType.CONFIGURATION, bridgeIid); LOG.info("deleteBridge node: {}, bridgeName: {} result : {}", ovsdbNode, ovsdbNode.getNodeId(),result); return result; } @@ -258,15 +257,12 @@ public class SouthboundImpl implements Southbound { } public Node getBridgeNode(Node node, String bridgeName) { - Node bridgeNode = null; OvsdbBridgeAugmentation bridge = extractBridgeAugmentation(node); if (bridge != null && bridge.getBridgeName().getValue().equals(bridgeName)) { - bridgeNode = node; + return node; } else { - bridgeNode = readBridgeNode(node, bridgeName); + return readBridgeNode(node, bridgeName); } - - return bridgeNode; } public String getBridgeUuid(Node node, String name) { @@ -284,21 +280,6 @@ public class SouthboundImpl implements Southbound { ovsdbBridgeAugmentationBuilder.setManagedBy(new OvsdbNodeRef(connectionNodePath)); } - private void setControllersForBridge(Node ovsdbNode, String bridgeName, List controllersString) { - ConnectionInfo connectionInfo = getConnectionInfo(ovsdbNode); - if (connectionInfo != null) { - for (ControllerEntry controllerEntry : createControllerEntries(controllersString)) { - InstanceIdentifier iid = - MdsalHelper.createInstanceIdentifier(ovsdbNode.getKey(), bridgeName) - .augmentation(OvsdbBridgeAugmentation.class) - .child(ControllerEntry.class, controllerEntry.getKey()); - - boolean result = mdsalUtils.put(LogicalDatastoreType.CONFIGURATION, iid, controllerEntry); - LOG.info("addController: result: {}", result); - } - } - } - private List createControllerEntries(List controllersStr) { List controllerEntries = new ArrayList<>(); if (controllersStr != null) { @@ -711,7 +692,7 @@ public class SouthboundImpl implements Southbound { public String getOptionsValue(List options, String key) { String value = null; for (Options option : options) { - if (option.getKey().equals(key)) { + if (option.getOption().equals(key)) { value = option.getValue(); } }