You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by il...@apache.org on 2018/05/09 10:51:06 UTC

[incubator-dubbo] branch 2.5.x updated: enable tcp no delay for netty 3 server (#1746)

This is an automated email from the ASF dual-hosted git repository.

iluo pushed a commit to branch 2.5.x
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/2.5.x by this push:
     new 430fb4c  enable tcp no delay for netty 3 server (#1746)
430fb4c is described below

commit 430fb4c6c7a85f90c9817a6c5e11aebadb312770
Author: Jason Song <no...@gmail.com>
AuthorDate: Wed May 9 18:50:52 2018 +0800

    enable tcp no delay for netty 3 server (#1746)
---
 .../java/com/alibaba/dubbo/remoting/transport/netty/NettyServer.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/dubbo-remoting/dubbo-remoting-netty/src/main/java/com/alibaba/dubbo/remoting/transport/netty/NettyServer.java b/dubbo-remoting/dubbo-remoting-netty/src/main/java/com/alibaba/dubbo/remoting/transport/netty/NettyServer.java
index d08ff25..0d1103b 100644
--- a/dubbo-remoting/dubbo-remoting-netty/src/main/java/com/alibaba/dubbo/remoting/transport/netty/NettyServer.java
+++ b/dubbo-remoting/dubbo-remoting-netty/src/main/java/com/alibaba/dubbo/remoting/transport/netty/NettyServer.java
@@ -74,6 +74,7 @@ public class NettyServer extends AbstractServer implements Server {
         // https://issues.jboss.org/browse/NETTY-365
         // https://issues.jboss.org/browse/NETTY-379
         // final Timer timer = new HashedWheelTimer(new NamedThreadFactory("NettyIdleTimer", true));
+        bootstrap.setOption("child.tcpNoDelay", true);
         bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
             public ChannelPipeline getPipeline() {
                 NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this);
@@ -153,4 +154,4 @@ public class NettyServer extends AbstractServer implements Server {
         return channel.isBound();
     }
 
-}
\ No newline at end of file
+}

-- 
To stop receiving notification emails like this one, please contact
iluo@apache.org.