svn commit: r1587892 - /tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java

[markt]

Author: markt
Date: Wed Apr 16 12:34:58 2014
New Revision: 1587892

URL: http://svn.apache.org/r1587892
Log:
Better debugging. Makes it clear if one listener or all listeners failed.

Modified:
    
tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java

Modified: 
tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java?rev=1587892&r1=1587891&r2=1587892&view=diff
==============================================================================
--- 
tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java
 (original)
+++ 
tomcat/trunk/test/org/apache/catalina/tribes/group/TestGroupChannelMemberArrival.java
 Wed Apr 16 12:34:58 2014
@@ -18,9 +18,8 @@ package org.apache.catalina.tribes.group
 
 import java.util.ArrayList;
 
-import static org.junit.Assert.assertEquals;
-
 import org.junit.After;
+import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -74,13 +73,25 @@ public class TestGroupChannelMemberArriv
         Thread.sleep(5000);
         System.out.println(System.currentTimeMillis()
                 + " All channels started.");
+        StringBuilder arrivalLengthErrors = new StringBuilder();
         for (int i = listeners.length - 1; i >= 0; i--) {
             TestMbrListener listener = listeners[i];
             synchronized (listener.members) {
-                assertEquals("Checking member arrival length (" + listener.name
-                        + ")", channels.length - 1, listener.members.size());
+                if (channels.length - 1 != listener.members.size()) {
+                    arrivalLengthErrors.append("Checking member arrival length 
for [");
+                    arrivalLengthErrors.append(listener.name);
+                    arrivalLengthErrors.append("]. Was [");
+                    arrivalLengthErrors.append(listener.members.size());
+                    arrivalLengthErrors.append("] but should have been [");
+                    arrivalLengthErrors.append(channels.length - 1);
+                    arrivalLengthErrors.append("]");
+                    arrivalLengthErrors.append('\n');
+                }
             }
         }
+        // Note if this fails for all listeners check multicast is working with
+        // org.apache.catalina.tribes.TesterMulticast
+        Assert.assertTrue(arrivalLengthErrors.toString(), 
arrivalLengthErrors.length() == 0);
         System.out.println(System.currentTimeMillis()
                 + " Members arrival counts checked.");
     }



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org