diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-12 09:21:05 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-12 09:21:05 +0000 |
| commit | b0087080fd6766e6eb303317156b3fa8fd7d87e9 (patch) | |
| tree | 59672271095eae55e9fdc9c4849b0c1c7ebc46f2 /clustercontroller-core | |
| parent | 519fc4209460f28de8d4954c1a50402d4af6b02b (diff) | |
enableSmallBuffers -> useSmallBuffers
Diffstat (limited to 'clustercontroller-core')
2 files changed, 2 insertions, 2 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java index 4eca82c81d2..bb45de37ce3 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java @@ -54,7 +54,7 @@ public class RPCCommunicator implements Communicator { private final int fleetControllerIndex; public static Supervisor createRealSupervisor() { - return new Supervisor(new Transport("rpc-communicator")).enableSmallBuffers(); + return new Supervisor(new Transport("rpc-communicator")).useSmallBuffers(); } diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java index edaaca0605d..3a432e57f1f 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java @@ -99,7 +99,7 @@ public class RpcServer { disconnect(); log.log(Level.FINE, "Fleetcontroller " + fleetControllerIndex + ": Connecting RPC server."); if (supervisor != null) disconnect(); - supervisor = new Supervisor(new Transport("rpc" + port)).enableSmallBuffers(); + supervisor = new Supervisor(new Transport("rpc" + port)).useSmallBuffers(); addMethods(); log.log(Level.FINE, "Fleetcontroller " + fleetControllerIndex + ": Attempting to bind to port " + port); acceptor = supervisor.listen(new Spec(port)); |