Return-Path: Delivered-To: apmail-tomcat-dev-archive@www.apache.org Received: (qmail 92145 invoked from network); 3 Jul 2006 22:23:57 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 3 Jul 2006 22:23:57 -0000 Received: (qmail 6342 invoked by uid 500); 3 Jul 2006 22:23:53 -0000 Delivered-To: apmail-tomcat-dev-archive@tomcat.apache.org Received: (qmail 6309 invoked by uid 500); 3 Jul 2006 22:23:52 -0000 Mailing-List: contact dev-help@tomcat.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: "Tomcat Developers List" Delivered-To: mailing list dev@tomcat.apache.org Received: (qmail 6297 invoked by uid 500); 3 Jul 2006 22:23:52 -0000 Delivered-To: apmail-jakarta-tomcat-dev@jakarta.apache.org Received: (qmail 6294 invoked by uid 99); 3 Jul 2006 22:23:52 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 03 Jul 2006 15:23:52 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: local policy) Received: from [140.211.166.113] (HELO eris.apache.org) (140.211.166.113) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 03 Jul 2006 15:23:51 -0700 Received: by eris.apache.org (Postfix, from userid 65534) id 8C6361A983A; Mon, 3 Jul 2006 15:23:31 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r418865 - /tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java Date: Mon, 03 Jul 2006 22:23:30 -0000 To: tomcat-dev@jakarta.apache.org From: fhanik@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20060703222331.8C6361A983A@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: fhanik Date: Mon Jul 3 15:23:27 2006 New Revision: 418865 URL: http://svn.apache.org/viewvc?rev=418865&view=rev Log: minor changes Modified: tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java Modified: tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java?rev=418865&r1=418864&r2=418865&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java (original) +++ tomcat/container/tc5.5.x/modules/groupcom/test/java/org/apache/catalina/tribes/test/channel/TestDataIntegrity.java Mon Jul 3 15:23:27 2006 @@ -23,11 +23,12 @@ * @version 1.0 */ public class TestDataIntegrity extends TestCase { - int msgCount = 10000; + int msgCount = 1000; int threadCount = 8; GroupChannel channel1; GroupChannel channel2; Listener listener1; + int threadCounter = 0; protected void setUp() throws Exception { super.setUp(); channel1 = new GroupChannel(); @@ -53,17 +54,21 @@ threads[x] = new Thread() { public void run() { try { - for (int i = 0; i < msgCount; i++) channel1.send(channel1.getMembers(), Data.createRandomData(),GroupChannel.SEND_OPTIONS_ASYNCHRONOUS); + for (int i = 0; i < msgCount; i++) channel1.send(channel1.getMembers(), Data.createRandomData(),0); }catch ( Exception x ) { x.printStackTrace(); return; + } finally { + threadCounter++; } } }; } for (int x=0; x