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

Switching to an orchestrated teardown on READ_TIMEOUT

Browse source
This commit is contained in:
Viktor Klang 2012-02-01 16:20:51 +01:00
parent 9421f37f96
commit e58d0d9940
3 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-remote/src/main/scala/akka/remote/netty/Client.scala
View file

@ -259,9 +259,8 @@ class ActiveRemoteClientHandler(
}
e.getState match {
case READER_IDLE ⇒ e.getChannel.close()
case WRITER_IDLE ⇒ e.getChannel.write(createHeartBeat(localAddress, client.netty.settings.SecureCookie))
case ALL_IDLE ⇒ e.getChannel.close()
case READER_IDLE | ALL_IDLE ⇒ runOnceNow { client.netty.shutdownClientConnection(remoteAddress) }
case WRITER_IDLE ⇒ e.getChannel.write(createHeartBeat(localAddress, client.netty.settings.SecureCookie))
}
}