You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2007/06/27 16:23:53 UTC
svn commit: r551175 -
/incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java
Author: ritchiem
Date: Wed Jun 27 07:23:52 2007
New Revision: 551175
URL: http://svn.apache.org/viewvc?view=rev&rev=551175
Log:
Allowed more of the constants to be set via system properties.
Modified:
incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java
Modified: incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java?view=diff&rev=551175&r1=551174&r2=551175
==============================================================================
--- incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java (original)
+++ incubator/qpid/branches/M2/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedTestClient.java Wed Jun 27 07:23:52 2007
@@ -425,7 +425,7 @@
class SustainedRateAdapter implements MessageListener, Runnable
{
private SustainedTestClient _client;
- private long _batchVariance = 3; //no. batches to allow drifting
+ private long _batchVariance = Integer.getInteger("batchVariance", 3); //no. batches to allow drifting
private long _timeVariance = TEN_MILLI_SEC * 5; // no. nanos between send and report delay (10ms)
private volatile long _delay; //in nanos
private long _sent;
@@ -434,9 +434,11 @@
private static final long NO_CLIENT_SLEEP = 1000; // 1s
private volatile boolean NO_CLIENTS = true;
private int _delayShifting;
- private static final int REPORTS_WITHOUT_CHANGE = 5;
+ private final int REPORTS_WITHOUT_CHANGE = Integer.getInteger("stableReportCount", 5);
private boolean _warmedup = false;
private static final long EXPECTED_TIME_PER_BATCH = 100000L;
+ private int _warmUpBatches = Integer.getInteger("warmUpBatches", 10);
+
SustainedRateAdapter(SustainedTestClient client)
{
@@ -492,8 +494,6 @@
}
CountDownLatch _warmup = new CountDownLatch(1);
-
- int _warmUpBatches = Integer.getInteger("warmUpBatches", 10);
int _numBatches = 10000;