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

=act #15265 Enable OP_READ interest for pullMode early ResumeReading

Browse source
This commit is contained in:
Björn Antonsson 2014-05-28 16:50:24 +02:00
parent bd6cb390ac
commit 8beea8ee77
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/io/TcpConnection.scala
View file

@ -55,6 +55,8 @@ private[io] abstract class TcpConnection(val tcp: TcpExt, val channel: SocketCha
if (TraceLogging) log.debug("[{}] registered as connection handler", handler)
val info = ConnectionInfo(registration, handler, keepOpenOnPeerClosed, useResumeWriting)
// if we have resumed reading from pullMode while waiting for Register then register OP_READ interest
if (pullMode && !readingSuspended) resumeReading(info)
doRead(info, None) // immediately try reading, pullMode is handled by readingSuspended
context.setReceiveTimeout(Duration.Undefined)
context.become(connected(info))