hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nkey...@apache.org
Subject git commit: HBASE-11492 The servers do not honor the tcpNoDelay option
Date Fri, 11 Jul 2014 12:15:13 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 4f3d5bbab -> 79676f15f


HBASE-11492 The servers do not honor the tcpNoDelay option


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/79676f15
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/79676f15
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/79676f15

Branch: refs/heads/master
Commit: 79676f15f4c63504d60ca9b7046cb7346e9c3df6
Parents: 4f3d5bb
Author: Nicolas Liochon <nkeywal@gmail.com>
Authored: Fri Jul 11 14:15:08 2014 +0200
Committer: Nicolas Liochon <nkeywal@gmail.com>
Committed: Fri Jul 11 14:15:08 2014 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/79676f15/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
----------------------------------------------------------------------
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 0cb002f..d6be4a8 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,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();


Mime
View raw message