aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-01-27 09:05:04 +0100
committerJon Marius Venstad <venstad@gmail.com>2021-01-27 09:05:04 +0100
commit9c25a72c7f18808d8a1e0efdc96916ad9c598fe0 (patch)
tree7f64b3acaf5ae13d7853904524195f1f282b3b70 /messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
parent9c33b487fb942394ad945e854a877a9de0b7aff4 (diff)
Revert "Revert "Jonmv/document protocol super config""
This reverts commit d7359f7c72ff06889af594431baf4075e2b4da78.
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java')
-rw-r--r--messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java5
1 files changed, 2 insertions, 3 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
index 7f48edfd48c..63747803e75 100644
--- a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
+++ b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java
@@ -101,7 +101,7 @@ public class DynamicThrottlePolicyTest {
CustomTimer timer = new CustomTimer();
DynamicThrottlePolicy policy = new DynamicThrottlePolicy(timer);
int scaleFactor = (int) Math.pow(10, i);
- long operations = 3_000 * scaleFactor;
+ long operations = 3_000L * scaleFactor;
int workPerSuccess = 6;
int numberOfWorkers = 1;
int maximumTasksPerWorker = 100000;
@@ -124,7 +124,7 @@ public class DynamicThrottlePolicyTest {
CustomTimer timer = new CustomTimer();
DynamicThrottlePolicy policy = new DynamicThrottlePolicy(timer);
int scaleFactor = (int) Math.pow(10, i);
- long operations = 5_000 * scaleFactor;
+ long operations = 5_000L * scaleFactor;
// workPerSuccess determines the latency of the simulated server, which again determines the impact of the
// synthetic attractors of the algorithm, around latencies which give (close to) integer log10(1 / latency).
// With a value of 5, the impact is that the algorithm is pushed upwards slightly above 10k window size,
@@ -319,7 +319,6 @@ public class DynamicThrottlePolicyTest {
.collect(toUnmodifiableList());
}
- /** Performs a tick, and returns whether work was done. */
void tick() {
for (int i = 0; i < numberOfWorkers; i++)
tick(i);