svn commit: r564729 - /tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java

[fhanik]

Author: fhanik
Date: Fri Aug 10 12:43:46 2007
New Revision: 564729

URL: http://svn.apache.org/viewvc?view=rev&rev=564729
Log:
oops, no one was supposed to know that I still debug with System.out

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?view=diff&rev=564729&r1=564728&r2=564729
==============================================================================
--- 
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java 
(original)
+++ 
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java 
Fri Aug 10 12:43:46 2007
@@ -720,7 +720,7 @@
             Map.Entry e = (Map.Entry) i.next();
             MapEntry entry = (MapEntry) super.get(e.getKey());
             if (entry.isPrimary() && inSet(member,entry.getBackupNodes())) {
-                System.out.println("[1] Primary choosing a new backup");
+                if (log.isDebugEnabled()) log.debug("[1] Primary choosing a 
new backup");
                 try {
                     Member[] backup = publishEntryInfo(entry.getKey(), 
entry.getValue());
                     entry.setBackupNodes(backup);
@@ -729,7 +729,7 @@
                     log.error("Unable to relocate[" + entry.getKey() + "] to a 
new backup node", x);
                 }
             } else if (member.equals(entry.getPrimary())) {
-                System.out.println("[2] Primary disappeared");
+                if (log.isDebugEnabled()) log.debug("[2] Primary disappeared");
                 entry.setPrimary(null);
             } //end if
             
@@ -739,7 +739,7 @@
                  entry.getBackupNodes().length == 1 &&
                  entry.getBackupNodes()[0].equals(member) ) {
                 //remove proxies that have no backup nor primaries
-                System.out.println("[3] Removing orphaned proxy");
+                if (log.isDebugEnabled()) log.debug("[3] Removing orphaned 
proxy");
                 i.remove();
             } else if ( entry.getPrimary() == null &&
                         entry.isBackup() &&
@@ -747,7 +747,7 @@
                         entry.getBackupNodes().length == 1 &&
                         
entry.getBackupNodes()[0].equals(channel.getLocalMember(false)) ) {
                 try {
-                    System.out.println("[4] Backup becoming primary");
+                    if (log.isDebugEnabled()) log.debug("[4] Backup becoming 
primary");
                     entry.setPrimary(channel.getLocalMember(false));
                     entry.setBackup(false);
                     entry.setProxy(false);



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]