diff options
author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2021-01-27 08:21:04 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-01-27 08:21:04 +0100 |
commit | fb99ec84858f2c68fcc0d22bc182c0aad3c0cb83 (patch) | |
tree | 7f64b3acaf5ae13d7853904524195f1f282b3b70 /messagebus | |
parent | 04d4b44edba74f6a11f1dd2710004ea0331c50d9 (diff) | |
parent | c60c8eda6c469854167e625335e360d78d6b4f42 (diff) |
Merge pull request #16089 from vespa-engine/jonmv/document-protocol-super-config
Jonmv/document protocol super config
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/test/SimpleMessage.java | 2 | ||||
-rw-r--r-- | messagebus/src/test/java/com/yahoo/messagebus/DynamicThrottlePolicyTest.java | 5 |
2 files changed, 3 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/test/SimpleMessage.java b/messagebus/src/main/java/com/yahoo/messagebus/test/SimpleMessage.java index 0e77d94497e..f87bcdbe1bb 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/test/SimpleMessage.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/test/SimpleMessage.java @@ -5,7 +5,7 @@ import com.yahoo.messagebus.Message; import com.yahoo.text.Utf8String; /** - * @author <a href="mailto:havardpe@yahoo-inc.com">Haavard Pettersen</a> + * @author havardpe */ public class SimpleMessage extends Message { 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); |