Author: rupertlssmith
Date: Fri Aug 17 09:46:11 2007
New Revision: 567083
URL: http://svn.apache.org/viewvc?view=rev&rev=567083
Log:
Added fix for latency testing, moving time stamping close to message send.
Modified:
incubator/qpid/branches/M2/java/perftests/pom.xml
incubator/qpid/branches/M2/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
Modified: incubator/qpid/branches/M2/java/perftests/pom.xml
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/perftests/pom.xml?view=diff&rev=567083&r1=567082&r2=567083
==============================================================================
--- incubator/qpid/branches/M2/java/perftests/pom.xml (original)
+++ incubator/qpid/branches/M2/java/perftests/pom.xml Fri Aug 17 09:46:11 2007
@@ -323,7 +323,7 @@
Non-tx, and 1 msg per tx.
Persistent and non-persistent.
No rate limiting.
- Message sizes from 128 bytes to 1 Meg.
+ Message size 256 bytes.
-->
<TQB-Qpid-01-1C> -n TQB-Qpid-01 -d1M -s[1000]
-c[1] -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=256
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=false
numConsumers=1 </TQB-Qpid-01-1C>
<TQB-Qpid-01-2C> -n TQB-Qpid-01 -d1M -s[1000]
-c[1] -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=256
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=false
numConsumers=2 </TQB-Qpid-01-2C>
@@ -353,6 +353,15 @@
<PQB-Qpid-02-16C>-n PQB-Qpid-02 -d1M -s[1000]
-c[1] -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=true pubsub=false
transacted=false commitBatchSize=1 batchSize=1000 messageSize=256
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=false
numConsumers=16</PQB-Qpid-02-16C>
<PQB-Qpid-02-32C>-n PQB-Qpid-02 -d1M -s[1000]
-c[1] -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=true pubsub=false
transacted=false commitBatchSize=1 batchSize=1000 messageSize=256
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=false
numConsumers=32</PQB-Qpid-02-32C>
+ <TQB-Qpid-01-1CL>-n TQB-Qpid-01 -d1M -s[1000]
-c[1] -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=256
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=false
numConsumers=1 </TQB-Qpid-01-1CL>
+
+ <!--
+ Bench mark 2. P2P messaging 1:1, scaled up from 1
to 32 times. Queues not shared, just one to one throughput.
+ Non-tx, and 1 msg per tx.
+ Persistent and non-persistent.
+ No rate limiting.
+ Message size from 128 bytes to 1 Meg.
+ -->
<TQB-Qpid-01-512b>-n TQB-Qpid-01-512b -d1M -s[1000]
-c[1,32],samples=6,exp -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=512
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=true
</TQB-Qpid-01-512b>
<TQB-Qpid-01-1K>-n TQB-Qpid-01-1K -d1M -s[1000]
-c[1,32],samples=6,exp -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=1024
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=true
</TQB-Qpid-01-1K>
<TQB-Qpid-01-5K>-n TQB-Qpid-01-5K -d1M -s[1000]
-c[1,32],samples=6,exp -o $QPID_WORK/results -t testAsyncPingOk
org.apache.qpid.ping.PingAsyncTestPerf persistent=false pubsub=false
transacted=true commitBatchSize=1 batchSize=1000 messageSize=5120
destinationCount=1 rate=0 maxPending=80000000 uniqueDests=true
</TQB-Qpid-01-5K>
Modified:
incubator/qpid/branches/M2/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java?view=diff&rev=567083&r1=567082&r2=567083
==============================================================================
---
incubator/qpid/branches/M2/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
(original)
+++
incubator/qpid/branches/M2/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
Fri Aug 17 09:46:11 2007
@@ -1178,6 +1178,7 @@
{
int num = numSent.incrementAndGet();
message.setIntProperty("MSG_NUM", num);
+ setTimestamp(message);
_producer.send(message);
// log.info("Message " + num + " sent.");
}
@@ -1185,6 +1186,7 @@
{
int num = numSent.incrementAndGet();
message.setIntProperty("MSG_NUM", num);
+ setTimestamp(message);
_producer.send(destination, message);
// log.info("Message " + num + " sent.");
}
@@ -1222,7 +1224,7 @@
{
// Generate a sample message and time stamp it.
Message msg = getTestMessage(_replyDestination, _messageSize,
_persistent);
- setTimestamp(msg);
+ // setTimestamp(msg);
// Send the message and wait for a reply.
pingAndWaitForReply(msg, TX_BATCH_SIZE_DEFAULT, TIMEOUT_DEFAULT,
null);
@@ -1273,7 +1275,7 @@
// Timestamp the message in nanoseconds.
- setTimestamp(msg);
+ // setTimestamp(msg);
return msg;
}
