diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-06 12:15:30 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-07-06 12:15:30 +0200 |
commit | 71354c405ee87632caa6bb229f064ba0bf1cd3b7 (patch) | |
tree | 9953833f1959d63f136a8d5355153c9ad86b3fd6 /config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java | |
parent | f93264f1055023d08bc3a5da57b6d7c539393c21 (diff) |
- Control number of rpc targets.
- Control number of write events before waking up thread.
- For mbus in java, mbus in c++ and the rpc connection towards content nodes.
Diffstat (limited to 'config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java')
-rw-r--r-- | config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java index 5f189a63701..5d64dfe7041 100644 --- a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java +++ b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java @@ -80,6 +80,12 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea private boolean sharedStringRepoNoReclaim = false; private boolean mbus_dispatch_on_decode = true; private boolean mbus_dispatch_on_encode = true; + private int mbus_java_num_targets = 1; + private int mbus_java_events_before_wakeup = 1; + private int mbus_cpp_num_targets = 1; + private int mbus_cpp_events_before_wakeup = 1; + private int rpc_num_targets = 1; + private int rpc_events_before_wakeup = 1; private int mbus_threads = 4; private int mbus_network_threads = 1; private Architecture adminClusterNodeResourcesArchitecture = Architecture.getDefault(); @@ -141,6 +147,12 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea @Override public boolean mbusDispatchOnEncode() { return mbus_dispatch_on_encode; } @Override public int mbusNetworkThreads() { return mbus_network_threads; } @Override public int mbusThreads() { return mbus_threads; } + @Override public int mbusJavaRpcNumTargets() { return mbus_java_num_targets; } + @Override public int mbusJavaEventsBeforeWakeup() { return mbus_java_events_before_wakeup; } + @Override public int mbusCppRpcNumTargets() { return mbus_cpp_num_targets; } + @Override public int mbusCppEventsBeforeWakeup() { return mbus_cpp_events_before_wakeup; } + @Override public int rpcNumTargets() { return rpc_num_targets; } + @Override public int rpcEventsBeforeWakeup() { return rpc_events_before_wakeup; } public TestProperties sharedStringRepoNoReclaim(boolean sharedStringRepoNoReclaim) { @@ -385,6 +397,31 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea this.mbus_network_threads = value; return this; } + public TestProperties setMbusJavaRpcNumTargets(int value) { + this.mbus_java_num_targets = value; + return this; + } + public TestProperties setMbusJavaEventsBeforeWakeup(int value) { + this.mbus_java_events_before_wakeup = value; + return this; + } + public TestProperties setMbusCppEventsBeforeWakeup(int value) { + this.mbus_cpp_events_before_wakeup = value; + return this; + } + public TestProperties setMbusCppRpcNumTargets(int value) { + this.mbus_cpp_num_targets = value; + return this; + } + public TestProperties setRpcNumTargets(int value) { + this.rpc_num_targets = value; + return this; + } + public TestProperties setRpcEventsBeforeWakeup(int value) { + this.rpc_events_before_wakeup = value; + return this; + } + public TestProperties setAdminClusterNodeResourcesArchitecture(Architecture architecture) { this.adminClusterNodeResourcesArchitecture = architecture; return this; |