X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fclustering%2Fservices_implementation%2Fsrc%2Fmain%2Fjava%2Forg%2Finfinispan%2Finterceptors%2Fdistribution%2FBaseDistributionInterceptor.java;h=d495e454a6207b86856d0587bcbc7b7b813b2fe9;hb=4f623c74a703a31e787387b536981dcb344ca4f9;hp=e10563797da69cd6bd37a336d54c0294f6f1d4ec;hpb=6b64494fd8e4654a298312afb4b8e6e827b75d5d;p=controller.git diff --git a/opendaylight/clustering/services_implementation/src/main/java/org/infinispan/interceptors/distribution/BaseDistributionInterceptor.java b/opendaylight/clustering/services_implementation/src/main/java/org/infinispan/interceptors/distribution/BaseDistributionInterceptor.java index e10563797d..d495e454a6 100644 --- a/opendaylight/clustering/services_implementation/src/main/java/org/infinispan/interceptors/distribution/BaseDistributionInterceptor.java +++ b/opendaylight/clustering/services_implementation/src/main/java/org/infinispan/interceptors/distribution/BaseDistributionInterceptor.java @@ -22,6 +22,13 @@ */ package org.infinispan.interceptors.distribution; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.List; +import java.util.Map; +import java.util.Set; + import org.infinispan.CacheException; import org.infinispan.commands.FlagAffectedCommand; import org.infinispan.commands.remote.ClusteredGetCommand; @@ -47,7 +54,6 @@ import org.infinispan.transaction.xa.GlobalTransaction; import org.infinispan.util.logging.Log; import org.infinispan.util.logging.LogFactory; -import java.util.*; /** * Base class for distribution of entries across a cluster. @@ -134,9 +140,9 @@ public abstract class BaseDistributionInterceptor extends ClusteringInterceptor rpcManager.invokeRemotely(recipientGenerator.generateRecipients(), command, rpcManager.getDefaultRpcOptions(isSync)); } else { - log.errorf("Didn't invoke RPC because primaryOwner (%s) didn't match this node (%s)", primaryOwner, + log.tracef("Didn't invoke RPC because primaryOwner (%s) didn't match this node (%s)", primaryOwner, rpcManager.getAddress()); - log.errorf("Hashcode is (%s) for Key (%s) .. it could be inconsistent in the cluster!", + log.tracef("Hashcode is (%s) for Key (%s)", command.getKey().hashCode(), command.getKey()); } return returnValue;