[ONOS-5778] OVSDB protocol-OVSDB controller connection failure (maximum retry exceeded failure)
handling
+ checkstyle error fixed
+ changing 'log.info'-> 'log.warn' (applying module owner's comment)
Change-Id: I43aff90a15d7e0b82029fa11ed5dacaa358cb337
diff --git a/protocols/ovsdb/api/src/main/java/org/onosproject/ovsdb/controller/OvsdbController.java b/protocols/ovsdb/api/src/main/java/org/onosproject/ovsdb/controller/OvsdbController.java
index a0d1c4d..08d405e 100644
--- a/protocols/ovsdb/api/src/main/java/org/onosproject/ovsdb/controller/OvsdbController.java
+++ b/protocols/ovsdb/api/src/main/java/org/onosproject/ovsdb/controller/OvsdbController.java
@@ -19,6 +19,7 @@
import org.onlab.packet.TpPort;
import java.util.List;
+import java.util.function.Consumer;
/**
* Abstraction of an ovsdb controller. Serves as an one stop shop for obtaining
@@ -76,4 +77,13 @@
* @param port port number
*/
void connect(IpAddress ip, TpPort port);
+
+ /**
+ * Connect to the ovsdb server with given ip address, port number, and connection failure handler.
+ *
+ * @param ip ip address
+ * @param port port number
+ * @param failhandler connection failure handler
+ */
+ void connect(IpAddress ip, TpPort port, Consumer<Exception> failhandler);
}
diff --git a/protocols/ovsdb/api/src/test/java/org/onosproject/ovsdb/controller/driver/OvsdbControllerAdapter.java b/protocols/ovsdb/api/src/test/java/org/onosproject/ovsdb/controller/driver/OvsdbControllerAdapter.java
index 0a3ebf8..6d7d4fb 100644
--- a/protocols/ovsdb/api/src/test/java/org/onosproject/ovsdb/controller/driver/OvsdbControllerAdapter.java
+++ b/protocols/ovsdb/api/src/test/java/org/onosproject/ovsdb/controller/driver/OvsdbControllerAdapter.java
@@ -28,6 +28,7 @@
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Consumer;
/**
* Test Adapter for OvsdbController.
@@ -72,4 +73,9 @@
public void connect(IpAddress ip, TpPort port) {
}
+
+ @Override
+ public void connect(IpAddress ip, TpPort port, Consumer<Exception> failhandler) {
+
+ }
}