X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=southbound%2Fsouthbound-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fovsdb%2Fsouthbound%2FSouthboundProvider.java;h=a5a6df82d396ff33c319c607acc0fefdc3878c64;hb=50e7f939993fa9da3c80a1c8d166629a4868af9c;hp=5f5bad6d4a369ceb6287c67ff0ff5cb83683625c;hpb=ebb862cc3997a95466c029cc3810446fbc37ff57;p=ovsdb.git diff --git a/southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/SouthboundProvider.java b/southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/SouthboundProvider.java index 5f5bad6d4..a5a6df82d 100644 --- a/southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/SouthboundProvider.java +++ b/southbound/southbound-impl/src/main/java/org/opendaylight/ovsdb/southbound/SouthboundProvider.java @@ -7,6 +7,8 @@ */ package org.opendaylight.ovsdb.southbound; +import com.google.common.base.Optional; +import com.google.common.util.concurrent.CheckedFuture; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction; import org.opendaylight.controller.md.sal.common.api.clustering.CandidateAlreadyRegisteredException; @@ -33,9 +35,6 @@ import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.google.common.base.Optional; -import com.google.common.util.concurrent.CheckedFuture; - public class SouthboundProvider implements AutoCloseable { private static final Logger LOG = LoggerFactory.getLogger(SouthboundProvider.class); @@ -152,8 +151,8 @@ public class SouthboundProvider implements AutoCloseable { public void handleOwnershipChange(EntityOwnershipChange ownershipChange) { if (ownershipChange.isOwner()) { LOG.info("*This* instance of OVSDB southbound provider is set as a MASTER instance"); - LOG.info("Initialize OVSDB topology {} in operational and config data store if not already present" - ,SouthboundConstants.OVSDB_TOPOLOGY_ID); + LOG.info("Initialize OVSDB topology {} in operational and config data store if not already present", + SouthboundConstants.OVSDB_TOPOLOGY_ID); initializeOvsdbTopology(LogicalDatastoreType.OPERATIONAL); initializeOvsdbTopology(LogicalDatastoreType.CONFIGURATION); } else { @@ -176,6 +175,7 @@ public class SouthboundProvider implements AutoCloseable { public void close() { this.listenerRegistration.close(); } + @Override public void ownershipChanged(EntityOwnershipChange ownershipChange) { sp.handleOwnershipChange(ownershipChange);