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

Revert "HBASE-11492 The servers do not honor the tcpNoDelay option" 

This reverts commit 79676f15f4.
This commit is contained in:
Nicolas Liochon 2014-07-11 18:48:06 +02:00
parent b3da98a1a2
commit dd9f1cbf3a
1 changed files with 1 additions and 2 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,7 +30,6 @@ 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;
@ -753,7 +752,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.setOption(StandardSocketOptions.TCP_NODELAY, tcpNoDelay); channel.socket().setTcpNoDelay(tcpNoDelay);
channel.socket().setKeepAlive(tcpKeepAlive); channel.socket().setKeepAlive(tcpKeepAlive);
} catch (IOException ioe) { } catch (IOException ioe) {
channel.close(); channel.close();