X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=singleton-service%2Fmdsal-singleton-dom-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fsingleton%2Fdom%2Fimpl%2FPlaceholderGroup.java;fp=singleton-service%2Fmdsal-singleton-dom-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fsingleton%2Fdom%2Fimpl%2FPlaceholderGroup.java;h=9d8db85b81c04299d2b8cbd1e33e6f2949d61616;hb=7f9b0106ec941370a6af0afdc583086ab0a2cd7f;hp=be2faad72e3af733b29def9d0b96d9c1c6dbab8f;hpb=16093a00c04f9f1bc07d35306f4163f74c28dc15;p=mdsal.git diff --git a/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/PlaceholderGroup.java b/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/PlaceholderGroup.java index be2faad72e..9d8db85b81 100644 --- a/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/PlaceholderGroup.java +++ b/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/PlaceholderGroup.java @@ -16,8 +16,8 @@ import com.google.common.util.concurrent.ListenableFuture; import java.util.ArrayList; import java.util.List; import org.opendaylight.mdsal.eos.common.api.CandidateAlreadyRegisteredException; +import org.opendaylight.mdsal.eos.common.api.EntityOwnershipChange; import org.opendaylight.mdsal.eos.common.api.GenericEntity; -import org.opendaylight.mdsal.eos.common.api.GenericEntityOwnershipChange; import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration; import org.opendaylight.yangtools.concepts.HierarchicalIdentifier; import org.slf4j.Logger; @@ -27,17 +27,17 @@ import org.slf4j.LoggerFactory; * Intermediate place-holder to catch user requests while asynchronous shutdown of previous incarnation of * a {@link ClusterSingletonServiceGroup} finishes. */ -final class PlaceholderGroup

, E extends GenericEntity

, - C extends GenericEntityOwnershipChange> extends ClusterSingletonServiceGroup { +final class PlaceholderGroup

, E extends GenericEntity

> + extends ClusterSingletonServiceGroup { private static final Logger LOG = LoggerFactory.getLogger(PlaceholderGroup.class); private final List services = new ArrayList<>(0); - private final ClusterSingletonServiceGroup previous; + private final ClusterSingletonServiceGroup previous; private final ListenableFuture closeFuture; - private volatile ClusterSingletonServiceGroup successor; + private volatile ClusterSingletonServiceGroup successor; - PlaceholderGroup(final ClusterSingletonServiceGroup previous, final ListenableFuture closeFuture) { + PlaceholderGroup(final ClusterSingletonServiceGroup previous, final ListenableFuture closeFuture) { this.previous = requireNonNull(previous); this.closeFuture = requireNonNull(closeFuture); } @@ -68,15 +68,15 @@ final class PlaceholderGroup

, E extends Gene } @Override - void ownershipChanged(final C ownershipChange) { + void ownershipChanged(final EntityOwnershipChange ownershipChange) { // This really should not happen, but let's be defensive - final ClusterSingletonServiceGroup local = successor; + final var local = successor; (local == null ? previous : local).ownershipChanged(ownershipChange); } @Override ListenableFuture closeClusterSingletonGroup() { - final ClusterSingletonServiceGroup local = successor; + final var local = successor; return local == null ? closeFuture : local.closeClusterSingletonGroup(); } @@ -87,7 +87,7 @@ final class PlaceholderGroup

, E extends Gene return services; } - void setSuccessor(final ClusterSingletonServiceGroup successor) { + void setSuccessor(final ClusterSingletonServiceGroup successor) { verifyNoSuccessor(); this.successor = verifyNotNull(successor); LOG.debug("{}: successor set to {}", this, successor);