[jboss-cvs] JBoss Messaging SVN: r3910 - branches/Branch_JBossMessaging_1_4_0_SP3_CP/src/main/org/jboss/messaging/core/impl/postoffice.

[jboss-cvs-commits at lists.jboss.org]

Author: jhowell at redhat.com
Date: 2008-03-21 14:38:16 -0400 (Fri, 21 Mar 2008)
New Revision: 3910

Modified:
   branches/Branch_JBossMessaging_1_4_0_SP3_CP/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
Log:
[JBMESSAGING-1254] added more verbose logging for membership changes

Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2008-03-21 15:54:31 UTC (rev 3909)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP/src/main/org/jboss/messaging/core/impl/postoffice/GroupMember.java	2008-03-21 18:38:16 UTC (rev 3910)
@@ -455,7 +455,7 @@
 
       public void viewAccepted(final View newView)
       {     	
-      	log.debug(this  + " got new view " + newView + ", old view is " + currentView);
+      	 log.info(this  + " got new view " + newView + ", old view is " + currentView);
 		      	
          if (newView instanceof MergeView)
          {
@@ -468,6 +468,7 @@
          
          currentView = newView;
          
+         log.info("I am (" + controlChannel.getLocalAddress() + ")");
          //If the first view shows we are the co-ordinator i.e. first node then we can create a latch
          //But only the first time and we don't want to do this after ready had been set to true
          //Otherwise it will never get released!
@@ -496,17 +497,24 @@
                if (!leftNodes.isEmpty())
                {
                	groupListener.nodesLeft(leftNodes);
+                log.info("Dead members: " + leftNodes.size() + " (" + leftNodes + ")");
                }
             }
-
+            List nodesAdded=new ArrayList();
             for (Iterator i = newView.getMembers().iterator(); i.hasNext(); )
             {
                Address address = (Address)i.next();
                if (oldView == null || !oldView.containsMember(address))
                {
                   groupListener.nodeJoined(address);
+                  nodesAdded.add(address);
                }
             }
+            if (!nodesAdded.isEmpty())
+            {
+            	log.info("New Members : " + nodesAdded.size()  + " (" + nodesAdded + ")");
+            }
+            log.info("All Members : " + newView.getMembers().size()  + " (" + newView.getMembers() + ")");
          }
          catch (Throwable e)
          {