wakeup_trigger_count -> transport_events_before_wakeup

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;
     }
 }