Author: fhanik
Date: Fri Jul 7 10:53:51 2006
New Revision: 419939
URL: http://svn.apache.org/viewvc?rev=419939&view=rev
Log:
Updated test case to properly work
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java?rev=419939&r1=419938&r2=419939&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestRemoteProcessException.java
Fri Jul 7 10:53:51 2006
@@ -7,6 +7,7 @@
import org.apache.catalina.tribes.ChannelListener;
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.group.GroupChannel;
+import java.io.PrintStream;
/**
* <p>Title: </p>
@@ -53,6 +54,8 @@
assertEquals("Checking failure messages.",errC,listener1.errCnt);
assertEquals("Checking success messages.",nerrC,listener1.noErrCnt);
assertEquals("Checking all
messages.",msgCount,listener1.noErrCnt+listener1.errCnt);
+ System.out.println("Listener 1 stats:");
+ listener1.printStats(System.out);
}
public static class Listener implements ChannelListener {
@@ -70,21 +73,23 @@
if (d.error) {
errCnt++;
if ( (errCnt % 100) == 0) {
- System.err.println("NORMAL:" + noErrCnt);
- System.err.println("FAILURES:" + errCnt);
- System.err.println("TOTAL:" + errCnt+noErrCnt);
+ printStats(System.err);
}
throw new IllegalArgumentException();
} else {
noErrCnt++;
if ( (noErrCnt % 100) == 0) {
- System.err.println("NORMAL:" + noErrCnt);
- System.err.println("FAILURES:" + errCnt);
- System.err.println("TOTAL:" + errCnt+noErrCnt);
+ printStats(System.err);
}
}
}
}
+
+ public void printStats(PrintStream stream) {
+ stream.println("NORMAL:" + noErrCnt);
+ stream.println("FAILURES:" + errCnt);
+ stream.println("TOTAL:" + (errCnt+noErrCnt));
+ }
}
public static class Data implements Serializable {
@@ -102,6 +107,7 @@
d.key = (byte)i;
d.data = new byte[length];
Arrays.fill(d.data,d.key);
+ d.error = error;
return d;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
