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 | 35c74e967c960086d8ab0b884b27694a26efb848 (patch) | |
| tree | 2fd8de30108971dea3d533c82a3a45b780bc290c /qpid/java/perftests/src/test | |
| parent | 5dbc10eab6a3496c0c6e6b93e0e2b1e980838d3a (diff) | |
| download | qpid-python-35c74e967c960086d8ab0b884b27694a26efb848.tar.gz | |
Updated script details and added guard for trafficlight being null.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@500284 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests/src/test')
| -rw-r--r-- | qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java b/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java index a5647babff..bd39ec34a1 100644 --- a/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java +++ b/qpid/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) // { |