Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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 4f3d5bbab9
commit 79676f15f4
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
View File

@ -30,6 +30,7 @@ import java.net.InetSocketAddress;
import java.net.ServerSocket; import java.net.ServerSocket;
import java.net.Socket; import java.net.Socket;
import java.net.SocketException; import java.net.SocketException;
import java.net.StandardSocketOptions;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.nio.channels.CancelledKeyException; import java.nio.channels.CancelledKeyException;
@ -752,7 +753,7 @@ public class RpcServer implements RpcServerInterface {
while ((channel = server.accept()) != null) { while ((channel = server.accept()) != null) {
try { try {
channel.configureBlocking(false); channel.configureBlocking(false);
channel.socket().setTcpNoDelay(tcpNoDelay); channel.setOption(StandardSocketOptions.TCP_NODELAY, tcpNoDelay);
channel.socket().setKeepAlive(tcpKeepAlive); channel.socket().setKeepAlive(tcpKeepAlive);
} catch (IOException ioe) { } catch (IOException ioe) {
channel.close(); channel.close();