import org.opendaylight.mdsal.eos.common.api.CandidateAlreadyRegisteredException;
import org.opendaylight.mdsal.eos.common.api.GenericEntity;
import org.opendaylight.mdsal.eos.common.api.GenericEntityOwnershipChange;
-import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonService;
+import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
import org.opendaylight.yangtools.concepts.Path;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
C extends GenericEntityOwnershipChange<P, E>> extends ClusterSingletonServiceGroup<P, E, C> {
private static final Logger LOG = LoggerFactory.getLogger(PlaceholderGroup.class);
- private final List<ClusterSingletonService> services = new ArrayList<>(0);
+ private final List<ClusterSingletonServiceRegistration> services = new ArrayList<>(0);
private final ClusterSingletonServiceGroup<P, E, C> previous;
private final ListenableFuture<?> closeFuture;
}
@Override
- void registerService(final ClusterSingletonService service) {
+ void registerService(final ClusterSingletonServiceRegistration reg) {
verifyNoSuccessor();
- services.add(service);
- LOG.debug("{}: added service {}", this, service);
+ services.add(reg);
+ LOG.debug("{}: added service {}", this, reg.getInstance());
}
@Override
- boolean unregisterService(final ClusterSingletonService service) {
+ boolean unregisterService(final ClusterSingletonServiceRegistration reg) {
verifyNoSuccessor();
- services.remove(service);
- LOG.debug("{}: removed service {}", this, service);
+ services.remove(reg);
+ LOG.debug("{}: removed service {}", this, reg.getInstance());
return false;
}
}
// Note: this is a leaked structure, the caller can reuse it at will, but has to regard
- List<ClusterSingletonService> getServices() {
+ List<ClusterSingletonServiceRegistration> getServices() {
verifyNoSuccessor();
LOG.trace("{}: returning services {}", this, services);
return services;