import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.TimeUnit;
+import javax.annotation.Nonnull;
import org.opendaylight.controller.cluster.datastore.DistributedDataStore;
import org.opendaylight.controller.cluster.datastore.config.Configuration;
import org.opendaylight.controller.cluster.datastore.config.ModuleShardConfiguration;
return Optional.of(new EntityOwnershipState(isOwner, hasOwner));
}
+ @Override
+ public boolean isCandidateRegistered(@Nonnull Entity entity) {
+ return registeredEntities.get(entity) != null;
+ }
+
private DataTree getLocalEntityOwnershipShardDataTree() {
if(localEntityOwnershipShardDataTree == null) {
try {