From 821b8310a5c46c9ff6900f1bae32d4348824e390 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Fri, 26 Jan 2007 17:02:58 +0000 Subject: Updated script details and added guard for trafficlight being null. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@500284 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/ping/PingAsyncTestPerf.java | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) (limited to 'java/perftests/src/test') diff --git a/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java b/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java index a5647babff..bd39ec34a1 100644 --- a/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java +++ b/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java @@ -33,7 +33,6 @@ import junit.framework.Test; import junit.framework.TestSuite; import org.apache.log4j.Logger; -import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.TimeUnit; import java.util.concurrent.CountDownLatch; @@ -267,18 +266,20 @@ public class PingAsyncTestPerf extends PingTestPerf //implements TimingControlle // // CountDownLatch count = _perThreadSetup._pingItselfClient.getEndLock(message.getJMSCorrelationID()); // -// int messagesLeft = (int) count.getCount() - 1;// minus one as we haven't yet counted the current message -// -// if ((messagesLeft % _batchSize) == 0) -// { -// doDone(_batchSize); -// } -// else if (messagesLeft == 0) +// if (count != null) // { -// doDone(_totalMessages % _batchSize); +// int messagesLeft = (int) count.getCount() - 1;// minus one as we haven't yet counted the current message +// +// if ((messagesLeft % _batchSize) == 0) +// { +// doDone(_batchSize); +// } +// else if (messagesLeft == 0) +// { +// doDone(_totalMessages % _batchSize); +// } // } // -// // } // catch (JMSException e) // { -- cgit v1.2.1