diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-11-30 10:48:53 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-11-30 10:48:53 +0000 |
commit | 0ce8cff36323291e87333b5a931116e7bba3e907 (patch) | |
tree | ef6cd120304a3977da758aa85ada56b7b761ee42 /messagebus/src | |
parent | 5cc3e198413e36051d8914cc9f285475abd2ec6e (diff) |
wakeup_trigger_count -> transport_events_before_wakeup
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java | 2 | ||||
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java | 10 |
2 files changed, 6 insertions, 6 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java index 0f2bc07a366..1c41f87d1ee 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetwork.java @@ -88,7 +88,7 @@ public class RPCNetwork implements Network, MethodHandler { this.slobroksConfig = slobrokConfig; identity = params.getIdentity(); orb = new Supervisor(new Transport("mbus-rpc-" + identity.getServicePrefix(), params.getNumNetworkThreads(), - shouldEnableTcpNodelay(params.getOptimization()), params.getWakeupTriggerCount())); + shouldEnableTcpNodelay(params.getOptimization()), params.getTransportEventsBeforeWakeup())); orb.setMaxInputBufferSize(params.getMaxInputBufferSize()); orb.setMaxOutputBufferSize(params.getMaxOutputBufferSize()); targetPool = new RPCTargetPool(params.getConnectionExpireSecs(), params.getNumTargetsPerSpec()); diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java index 86f426a0a7f..db22363785d 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java @@ -22,7 +22,7 @@ public class RPCNetworkParams { private int numTargetsPerSpec = 1; private int numNetworkThreads = 2; - private int wakeupTriggerCount = 1; + private int transportEventsBeforeWakeup = 1; public enum Optimization {LATENCY, THROUGHPUT} Optimization optimization = Optimization.LATENCY; @@ -219,12 +219,12 @@ public class RPCNetworkParams { return this; } - public int getWakeupTriggerCount() { - return wakeupTriggerCount; + public int getTransportEventsBeforeWakeup() { + return transportEventsBeforeWakeup; } - public RPCNetworkParams setWakeupTriggerCount(int wakeupTriggerCount) { - this.wakeupTriggerCount = wakeupTriggerCount; + public RPCNetworkParams setTransportEventsBeforeWakeup(int transportEventsBeforeWakeup) { + this.transportEventsBeforeWakeup = transportEventsBeforeWakeup; return this; } } |