summaryrefslogtreecommitdiff
path: root/java/perftests
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2007-11-13 00:14:13 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2007-11-13 00:14:13 +0000
commitf7d7f64d422830e3be0b181eb69ab31b1a373ad6 (patch)
treede2bb0dab21d642751b0e077ee7a089eba4640aa /java/perftests
parent9db33e1d2526f8e66b601e3d45fde4d965bc88a3 (diff)
downloadqpid-python-f7d7f64d422830e3be0b181eb69ab31b1a373ad6.tar.gz
modified to collect memory stats before the test.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594360 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests')
-rw-r--r--java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java1
-rw-r--r--java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java1
2 files changed, 2 insertions, 0 deletions
diff --git a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
index 4d6923f0dd..e220aec9e1 100644
--- a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
+++ b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
@@ -68,6 +68,7 @@ public class MessageConsumerTest extends Options implements Runnable
{
boolean run = true;
_startTime = System.currentTimeMillis();
+ runReaper(false);
try
{
while(run)
diff --git a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
index b0caa45845..794031f346 100644
--- a/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
+++ b/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
@@ -65,6 +65,7 @@ public class MessageProducerTest extends Options implements Runnable
{
boolean run = true;
_startTime = System.currentTimeMillis();
+ runReaper(false);
try
{
while(run)