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 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 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);