X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fclustering%2Fservices_implementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fservices_implementation%2Finternal%2FClusterGlobalManager.java;fp=opendaylight%2Fclustering%2Fservices_implementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fservices_implementation%2Finternal%2FClusterGlobalManager.java;h=ce33ac8639cf89977c1c1f7f79d19e15a2da3dae;hp=8211846dd65dccc23126b58f22b930c21ce6d0c4;hb=1d125367e70817a6c6fdcb253a00a0cfaa7d7e3e;hpb=124579fbc8cc5cd149b216a285ac1ee9d3f99f6e diff --git a/opendaylight/clustering/services_implementation/src/main/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusterGlobalManager.java b/opendaylight/clustering/services_implementation/src/main/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusterGlobalManager.java index 8211846dd6..ce33ac8639 100644 --- a/opendaylight/clustering/services_implementation/src/main/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusterGlobalManager.java +++ b/opendaylight/clustering/services_implementation/src/main/java/org/opendaylight/controller/clustering/services_implementation/internal/ClusterGlobalManager.java @@ -9,8 +9,36 @@ package org.opendaylight.controller.clustering.services_implementation.internal; +import java.util.Map; +import org.opendaylight.controller.clustering.services.ICacheUpdateAware; import org.opendaylight.controller.clustering.services.IClusterGlobalServices; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; -public class ClusterGlobalManager extends ClusterManagerCommon implements - IClusterGlobalServices { +public class ClusterGlobalManager + extends ClusterManagerCommon + implements IClusterGlobalServices { + protected static final Logger logger = LoggerFactory.getLogger(ClusterGlobalManager.class); + + @Override + void setCacheUpdateAware(Map props, ICacheUpdateAware s) { + logger.trace("setCacheUpdateAware"); + if (props.get("containerName") != null) { + // If we got a reference with the containerName property + // that is not what we are looking for, so filter it out. + return; + } + super.setCacheUpdateAware(props, s); + } + + @Override + void unsetCacheUpdateAware(Map props, ICacheUpdateAware s) { + logger.trace("unsetCacheUpdateAware"); + if (props.get("containerName") != null) { + // If we got a reference with the containerName property + // that is not what we are looking for, so filter it out. + return; + } + super.unsetCacheUpdateAware(props, s); + } }