base for mastership term implementation
Change-Id: Ie354096ad8835536839e3c1504e19a2cbff866c1
diff --git a/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java b/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java
index 255830c..a8d2052 100644
--- a/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java
+++ b/core/net/src/main/java/org/onlab/onos/cluster/impl/MastershipManager.java
@@ -12,6 +12,8 @@
import org.onlab.onos.cluster.MastershipListener;
import org.onlab.onos.cluster.MastershipService;
import org.onlab.onos.cluster.MastershipStore;
+import org.onlab.onos.cluster.MastershipTerm;
+import org.onlab.onos.cluster.MastershipTermService;
import org.onlab.onos.cluster.NodeId;
import org.onlab.onos.event.AbstractListenerRegistry;
import org.onlab.onos.event.EventDeliveryService;
@@ -103,6 +105,12 @@
return store.getDevices(nodeId);
}
+
+ @Override
+ public MastershipTermService requestTermService() {
+ return new InternalMastershipTermService();
+ }
+
@Override
public void addListener(MastershipListener listener) {
checkNotNull(listener);
@@ -124,4 +132,13 @@
}
}
+ private class InternalMastershipTermService implements MastershipTermService {
+
+ @Override
+ public MastershipTerm getMastershipTerm(DeviceId deviceId) {
+ return store.getTermFor(deviceId);
+ }
+
+ }
+
}