HBASE-11492 The servers do not honor the tcpNoDelay option

This commit is contained in:
Nicolas Liochon 2014-07-11 14:15:08 +02:00
parent 9a74122a5c
commit c80b451044
1 changed files with 2 additions and 1 deletions

View File

@ -30,6 +30,7 @@ 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;
@ -752,7 +753,7 @@ public class RpcServer implements RpcServerInterface {
while ((channel = server.accept()) != null) {
try {
channel.configureBlocking(false);
channel.socket().setTcpNoDelay(tcpNoDelay);
channel.setOption(StandardSocketOptions.TCP_NODELAY, tcpNoDelay);
channel.socket().setKeepAlive(tcpKeepAlive);
} catch (IOException ioe) {
channel.close();