diff options
| author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2021-01-28 08:31:04 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-28 08:31:04 +0100 |
| commit | 2e2e2edeb3ea99f2c04925070cf44601e2cd94fb (patch) | |
| tree | 51b8ba2272b299ab676cdae6e04b3f050979ac12 /messagebus/src/test/java/com/yahoo | |
| parent | e4a2b4d09f15ef07c41c35520a23e0970895b2aa (diff) | |
Revert "Jonmv/reapply document protocol super config [run-systemtest]"
Diffstat (limited to 'messagebus/src/test/java/com/yahoo')
| -rw-r--r-- | messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java b/messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java index 63747803e75..7f48edfd48c 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_000L * scaleFactor; + long operations = 3_000 * 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_000L * scaleFactor; + long operations = 5_000 * 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,6 +319,7 @@ 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); |