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%2FClusterSingletonServiceGroupImpl.java;h=1d83e09e9db769666c15fad6c7439a5ab8f167b4;hb=0a31ba669d9ac4bc0451dcbc9017e1e3645b316c;hp=7570a4bbfeb3e08a19078c31af97eec5e5905db5;hpb=c241dcfa5322ac10810a1068ccd2eb57f6f2dbb2;p=mdsal.git diff --git a/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/ClusterSingletonServiceGroupImpl.java b/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/ClusterSingletonServiceGroupImpl.java index 7570a4bbfe..1d83e09e9d 100644 --- a/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/ClusterSingletonServiceGroupImpl.java +++ b/singleton-service/mdsal-singleton-dom-impl/src/main/java/org/opendaylight/mdsal/singleton/dom/impl/ClusterSingletonServiceGroupImpl.java @@ -31,9 +31,7 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReference; -import javax.annotation.CheckReturnValue; import javax.annotation.concurrent.GuardedBy; -import javax.annotation.concurrent.ThreadSafe; import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.mdsal.eos.common.api.CandidateAlreadyRegisteredException; import org.opendaylight.mdsal.eos.common.api.EntityOwnershipChangeState; @@ -49,7 +47,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** - * Implementation of {@link ClusterSingletonServiceGroup} on top of the Entitiy Ownership Service. Since EOS is atomic + * Implementation of {@link ClusterSingletonServiceGroup} on top of the Entity Ownership Service. Since EOS is atomic * in its operation and singleton services incur startup and most notably cleanup, we need to do something smart here. * *

@@ -70,7 +68,6 @@ import org.slf4j.LoggerFactory; * @param the GenericEntityOwnershipListener type * @param the GenericEntityOwnershipService type */ -@ThreadSafe final class ClusterSingletonServiceGroupImpl

, E extends GenericEntity

, C extends GenericEntityOwnershipChange, G extends GenericEntityOwnershipListener, S extends GenericEntityOwnershipService> extends ClusterSingletonServiceGroup { @@ -280,7 +277,6 @@ final class ClusterSingletonServiceGroupImpl

, E extends Generi reconcileState(); } - @CheckReturnValue @Override ListenableFuture unregisterService(final ClusterSingletonServiceRegistration reg) { final ClusterSingletonService service = reg.getInstance(); @@ -332,7 +328,7 @@ final class ClusterSingletonServiceGroupImpl

, E extends Generi if (isDirty()) { if (!tryLock()) { - LOG.debug("Service group {} postponing ownership change sync"); + LOG.debug("Service group {} postponing ownership change sync", identifier); return; }