Author: rgreig
Date: Thu Feb 1 02:18:36 2007
New Revision: 502182
URL: http://svn.apache.org/viewvc?view=rev&rev=502182
Log:
(Submitted by Rupert Smith) Added comments as a reminder of improvements to be
made to the tests.
Modified:
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
Modified:
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java?view=diff&rev=502182&r1=502181&r2=502182
==============================================================================
---
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
(original)
+++
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
Thu Feb 1 02:18:36 2007
@@ -87,7 +87,8 @@
* @todo Use read/write lock in the onmessage, not for reading writing but to
make use of a shared and exlcusive lock
* pair. Obtian read lock on all messages, before decrementing the
message count. At the end of the on message
* method add a block that obtains the write lock for the very last
message, releases any waiting producer. Means
- * that the last message waits until all other messages have been
handled before releasing producers.
+ * that the last message waits until all other messages have been
handled before releasing producers but allows
+ * messages to be processed concurrently, unlike the current
synchronized block.
*
* @todo Set the timeout to be per message correlation id. Restart it every
time a message is received (with matching id).
* Means that timeout is measuring situations whether a particular ping
stream has pasued for too long, rather than
