diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-01-26 17:02:58 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-01-26 17:02:58 +0000 |
| commit | 821b8310a5c46c9ff6900f1bae32d4348824e390 (patch) | |
| tree | 36e7a6f9f2bc61dbd75089f814c7b8d8e870d3b5 /java/perftests/src/test | |
| parent | d830e8e1709f7ac5270665492a121468f80a6c56 (diff) | |
| download | qpid-python-821b8310a5c46c9ff6900f1bae32d4348824e390.tar.gz | |
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
Diffstat (limited to 'java/perftests/src/test')
| -rw-r--r-- | java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java | 21 |
1 files changed, 11 insertions, 10 deletions
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) // { |