SEBA-989-Instance coordination and state distribution mechanism in IgmpStatisticsManager
Change-Id: Ibf3f3a2c5c91c010ef909692eea913f95ee7a92e
diff --git a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpLeadershipManager.java b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpLeadershipManager.java
index 4f2e7bb..c40bca2 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpLeadershipManager.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpLeadershipManager.java
@@ -17,6 +17,7 @@
import org.onosproject.cluster.ClusterService;
import org.onosproject.cluster.LeadershipService;
+import org.onosproject.cluster.Leadership;
import org.onosproject.cluster.NodeId;
import org.onosproject.mastership.MastershipService;
import org.onosproject.net.DeviceId;
@@ -69,4 +70,24 @@
}
return true;
}
+
+ @Override
+ public NodeId getLocalNodeId() {
+ return clusterService.getLocalNode().id();
+ }
+
+ @Override
+ public NodeId getLeader(String topic) {
+ return leadershipService.getLeader(topic);
+ }
+
+ @Override
+ public Leadership runForLeadership(String topic) {
+ return leadershipService.runForLeadership(topic);
+ }
+
+ @Override
+ public void withdraw(String topic) {
+ leadershipService.withdraw(topic);
+ }
}