make sure ovsdb connected node appears in operds

[ovsdb.git] / library / impl / src / main / java / org / opendaylight / ovsdb / lib / impl / OvsdbConnectionService.java

diff --git a/library/impl/src/main/java/org/opendaylight/ovsdb/lib/impl/OvsdbConnectionService.java b/library/impl/src/main/java/org/opendaylight/ovsdb/lib/impl/OvsdbConnectionService.java
index cd76a00fb0e18695a75ba0d2a5435afa7e90bfe3..8d03975f95a520bce1811d5a074a50edf04fa08f 100644 (file)
--- a/library/impl/src/main/java/org/opendaylight/ovsdb/lib/impl/OvsdbConnectionService.java
+++ b/library/impl/src/main/java/org/opendaylight/ovsdb/lib/impl/OvsdbConnectionService.java
@@ -407,19 +407,28 @@ public class OvsdbConnectionService implements AutoCloseable, OvsdbConnection {
             });
     }
 
+    @SuppressWarnings("checkstyle:IllegalCatch")
     private static void handleNewPassiveConnection(final OvsdbClient client) {
         ListenableFuture<List<String>> echoFuture = client.echo();
         LOG.debug("Send echo message to probe the OVSDB switch {}",client.getConnectionInfo());
         Futures.addCallback(echoFuture, new FutureCallback<List<String>>() {
             @Override
-            public void onSuccess(@Nullable final List<String> result) {
-                LOG.debug("Probe was successful to OVSDB switch {}",client.getConnectionInfo());
-                List<OvsdbClient> clientsFromSameNode = getPassiveClientsFromSameNode(client);
+            public void onSuccess(@Nullable List<String> result) {
+                LOG.info("Probe was successful to OVSDB switch {}",client.getConnectionInfo());
+                //List<OvsdbClient> clientsFromSameNode = getPassiveClientsFromSameNode(client);
+                try {
+                    getPassiveClientsFromSameNode(client);
+                } catch (Throwable throwable) {
+                    LOG.error("Failed to get passive clients from same node", throwable);
+                }
+                notifyListenerForPassiveConnection(client);
+                /*
                 if (clientsFromSameNode.size() == 0) {
                     notifyListenerForPassiveConnection(client);
                 } else {
                     STALE_PASSIVE_CONNECTION_SERVICE.handleNewPassiveConnection(client, clientsFromSameNode);
                 }
+                */
             }
 
             @Override