diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-11 23:44:23 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-02-12 05:45:53 +0000 |
| commit | 519fc4209460f28de8d4954c1a50402d4af6b02b (patch) | |
| tree | 73551717ce2012235510b531d42d207bb5c7867d /clustercontroller-core | |
| parent | 93e7f6bcba5d8cbc0d9700ec64dc6540eb935ef2 (diff) | |
Use small buffers where size matters more than speed.
Diffstat (limited to 'clustercontroller-core')
2 files changed, 3 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 4441501da01..4eca82c81d2 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,8 @@ public class RPCCommunicator implements Communicator { private final int fleetControllerIndex; public static Supervisor createRealSupervisor() { - return new Supervisor(new Transport("rpc-communicator")); + return new Supervisor(new Transport("rpc-communicator")).enableSmallBuffers(); + } public RPCCommunicator(Supervisor supervisor, 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 519f4c2d171..edaaca0605d 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)); + supervisor = new Supervisor(new Transport("rpc" + port)).enableSmallBuffers(); addMethods(); log.log(Level.FINE, "Fleetcontroller " + fleetControllerIndex + ": Attempting to bind to port " + port); acceptor = supervisor.listen(new Spec(port)); |