You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by fh...@apache.org on 2006/07/07 20:50:42 UTC
svn commit: r419953 -
/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Author: fhanik
Date: Fri Jul 7 11:50:41 2006
New Revision: 419953
URL: http://svn.apache.org/viewvc?rev=419953&view=rev
Log:
Added trace statements
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java?rev=419953&r1=419952&r2=419953&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java Fri Jul 7 11:50:41 2006
@@ -22,7 +22,6 @@
import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
@@ -45,6 +44,7 @@
import org.apache.catalina.tribes.membership.MemberImpl;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.catalina.tribes.util.Arrays;
/**
* <p>Title: </p>
@@ -138,6 +138,7 @@
log.warn("Unable to encode mapContextName[" + mapContextName + "] using getBytes(" + chset +") using default getBytes()", x);
this.mapContextName = mapContextName.getBytes();
}
+ if ( log.isTraceEnabled() ) log.trace("Created Lazy Map with name:"+mapContextName+", bytes:"+Arrays.toString(this.mapContextName));
//create an rpc channel and add the map as a listener
this.rpcChannel = new RpcChannel(this.mapContextName, channel, this);
@@ -517,10 +518,13 @@
}
public boolean accept(Serializable msg, Member sender) {
+ if ( log.isTraceEnabled() ) log.trace("Map accepting...."+msg);
+ boolean result = false;
if (msg instanceof MapMessage) {
- return Arrays.equals(mapContextName, ( (MapMessage) msg).getMapId());
+ result = Arrays.equals(mapContextName, ( (MapMessage) msg).getMapId());
}
- return false;
+ if ( log.isTraceEnabled() ) log.trace("Msg accepted["+result+"]...."+msg);
+ return result;
}
public void mapMemberAdded(Member member) {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org