raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge pull request #18113 from rsujak/tcpNoDelayFix

Browse source 
akka-remote - TcpNoDelay should have been set on child channels in NettyTransport
This commit is contained in:
Patrik Nordwall 2015-08-14 13:40:09 +02:00
commit 5c6304e2eb
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote/src/main/scala/akka/remote/transport/netty/NettyTransport.scala
View file

@ -365,7 +365,7 @@ class NettyTransport(val settings: NettyTransportSettings, val system: ExtendedA
private def setupBootstrap[B <: Bootstrap](bootstrap: B, pipelineFactory: ChannelPipelineFactory): B = {
bootstrap.setPipelineFactory(pipelineFactory)
bootstrap.setOption("backlog", settings.Backlog)
bootstrap.setOption("tcpNoDelay", settings.TcpNodelay)
bootstrap.setOption("child.tcpNoDelay", settings.TcpNodelay)
bootstrap.setOption("child.keepAlive", settings.TcpKeepalive)
bootstrap.setOption("reuseAddress", settings.TcpReuseAddr)
if (isDatagram) bootstrap.setOption("receiveBufferSizePredictorFactory", new FixedReceiveBufferSizePredictorFactory(ReceiveBufferSize.get))