From 8beea8ee778139b85d31d8a86009187a2b194245 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bjo=CC=88rn=20Antonsson?= Date: Wed, 28 May 2014 16:50:24 +0200 Subject: [PATCH] =act #15265 Enable OP_READ interest for pullMode early ResumeReading --- akka-actor/src/main/scala/akka/io/TcpConnection.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/akka-actor/src/main/scala/akka/io/TcpConnection.scala b/akka-actor/src/main/scala/akka/io/TcpConnection.scala index 6557264dca..fba775f98a 100644 --- a/akka-actor/src/main/scala/akka/io/TcpConnection.scala +++ b/akka-actor/src/main/scala/akka/io/TcpConnection.scala @@ -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))