From daa16b9c4d9c93cd4458c30fd97328af856b5f0d Mon Sep 17 00:00:00 2001 From: Nicolas Liochon Date: Fri, 11 Jul 2014 18:43:46 +0200 Subject: [PATCH] Revert "HBASE-11492 The servers do not honor the tcpNoDelay option" This reverts commit c80b4510443552d13f21f5eda62f94daff318565. --- .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java index d6be4a8e15f..0cb002f6b3a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java @@ -30,7 +30,6 @@ import java.net.InetSocketAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; -import java.net.StandardSocketOptions; import java.net.UnknownHostException; import java.nio.ByteBuffer; import java.nio.channels.CancelledKeyException; @@ -753,7 +752,7 @@ public class RpcServer implements RpcServerInterface { while ((channel = server.accept()) != null) { try { channel.configureBlocking(false); - channel.setOption(StandardSocketOptions.TCP_NODELAY, tcpNoDelay); + channel.socket().setTcpNoDelay(tcpNoDelay); channel.socket().setKeepAlive(tcpKeepAlive); } catch (IOException ioe) { channel.close();