Add API in DeviceClock*Service to check if Timestamp can be issued.
- check local DeviceClockProviderService before trying to
store Port update information.
Change-Id: I22c94cb712d7001a227497b723780b6db3fbdf04
diff --git a/core/store/trivial/src/main/java/org/onlab/onos/store/trivial/impl/NoOpClockProviderService.java b/core/store/trivial/src/main/java/org/onlab/onos/store/trivial/impl/NoOpClockProviderService.java
index 64e5e16..d32ac53 100644
--- a/core/store/trivial/src/main/java/org/onlab/onos/store/trivial/impl/NoOpClockProviderService.java
+++ b/core/store/trivial/src/main/java/org/onlab/onos/store/trivial/impl/NoOpClockProviderService.java
@@ -15,13 +15,16 @@
*/
package org.onlab.onos.store.trivial.impl;
+import java.util.Set;
+
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Service;
import org.onlab.onos.mastership.MastershipTerm;
import org.onlab.onos.net.DeviceId;
import org.onlab.onos.net.device.DeviceClockProviderService;
-//FIXME: Code clone in onos-core-trivial, onos-core-hz-net
+import com.google.common.collect.Sets;
+
/**
* Dummy implementation of {@link DeviceClockProviderService}.
*/
@@ -29,7 +32,15 @@
@Service
public class NoOpClockProviderService implements DeviceClockProviderService {
+ private Set<DeviceId> registerdBefore = Sets.newConcurrentHashSet();
+
@Override
public void setMastershipTerm(DeviceId deviceId, MastershipTerm term) {
+ registerdBefore.add(deviceId);
+ }
+
+ @Override
+ public boolean isTimestampAvailable(DeviceId deviceId) {
+ return registerdBefore.contains(deviceId);
}
}