Author: fhanik
Date: Sun Jan 28 13:34:21 2007
New Revision: 500890
URL: http://svn.apache.org/viewvc?view=rev&rev=500890
Log:
minor change
Modified:
tomcat/tc6.0.x/trunk/test/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java
Modified:
tomcat/tc6.0.x/trunk/test/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java
URL:
http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/test/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java?view=diff&rev=500890&r1=500889&r2=500890
==============================================================================
---
tomcat/tc6.0.x/trunk/test/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java
(original)
+++
tomcat/tc6.0.x/trunk/test/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java
Sun Jan 28 13:34:21 2007
@@ -55,7 +55,9 @@
threads[x] = new Thread() {
public void run() {
try {
+ long start = System.currentTimeMillis();
for (int i = 0; i < msgCount; i++) channel1.send(new
Member[] {channel2.getLocalMember(false)}, Data.createRandomData(),0);
+ System.out.println("Thread["+this.getName()+"] sent
"+msgCount+" messages in "+(System.currentTimeMillis()-start)+" ms.");
}catch ( Exception x ) {
x.printStackTrace();
return;
@@ -69,8 +71,8 @@
for (int x=0; x<threads.length; x++ ) { threads[x].join();}
//sleep for 50 sec, let the other messages in
long start = System.currentTimeMillis();
- while ( (System.currentTimeMillis()-start)<120000 &&
msgCount*threadCount!=listener1.count) Thread.sleep(500);
- System.err.println("Finished NO_ACK");
+ while ( (System.currentTimeMillis()-start)<15000 &&
msgCount*threadCount!=listener1.count) Thread.sleep(500);
+ System.err.println("Finished NO_ACK ["+listener1.count+"]");
assertEquals("Checking success
messages.",msgCount*threadCount,listener1.count);
}
@@ -81,7 +83,9 @@
threads[x] = new Thread() {
public void run() {
try {
+ long start = System.currentTimeMillis();
for (int i = 0; i < msgCount; i++)
channel1.send(new Member[] {channel2.getLocalMember(false)},
Data.createRandomData(),GroupChannel.SEND_OPTIONS_ASYNCHRONOUS);
+ System.out.println("Thread["+this.getName()+"]
sent "+msgCount+" messages in "+(System.currentTimeMillis()-start)+" ms.");
}catch ( Exception x ) {
x.printStackTrace();
return;
@@ -96,7 +100,7 @@
//sleep for 50 sec, let the other messages in
long start = System.currentTimeMillis();
while ( (System.currentTimeMillis()-start)<15000 &&
msgCount*threadCount!=listener1.count) Thread.sleep(500);
- System.err.println("Finished ASYNC MULTI THREAD");
+ System.err.println("Finished ASYNC MULTI THREAD
["+listener1.count+"]");
assertEquals("Checking success
messages.",msgCount*threadCount,listener1.count);
}
public void testDataSendASYNC() throws Exception {
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
