You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2013/12/03 11:01:12 UTC
svn commit: r1547329 -
/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Author: kfujino
Date: Tue Dec 3 10:01:11 2013
New Revision: 1547329
URL: http://svn.apache.org/r1547329
Log:
Add log message of session relocation when member disappeared.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java?rev=1547329&r1=1547328&r2=1547329&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java Tue Dec 3 10:01:11 2013
@@ -767,7 +767,9 @@ public abstract class AbstractReplicated
return; //the member was not part of our map.
}
}
-
+ if (log.isInfoEnabled())
+ log.info("Member["+member+"] disappeared. Related map entries will be relocated to the new node.");
+ long start = System.currentTimeMillis();
Iterator<Map.Entry<K,MapEntry<K,V>>> i = innerMap.entrySet().iterator();
while (i.hasNext()) {
Map.Entry<K,MapEntry<K,V>> e = i.next();
@@ -815,6 +817,8 @@ public abstract class AbstractReplicated
}
} //while
+ long complete = System.currentTimeMillis() - start;
+ if (log.isInfoEnabled()) log.info("Relocation of map entries was complete in " + complete + " ms.");
}
public int getNextBackupIndex() {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org