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

act: TcpConnection: ignore late signals from SelectionHandler while shutting down (#26996)

Browse source
This commit is contained in:
Johannes Rudolph 2019-05-27 13:34:32 +02:00 • committed by Arnout Engelen
parent 7bd0cc746f
commit 1bc9a5f388
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -197,7 +197,8 @@ private[io] abstract class TcpConnection(val tcp: TcpExt, val channel: SocketCha
/** stopWith sets this state while waiting for the SelectionHandler to execute the `cancelAndClose` thunk */
def unregistering: Receive = {
case Unregistered => context.stop(self) // postStop will notify interested parties
case Unregistered => context.stop(self) // postStop will notify interested parties
case ChannelReadable | ChannelWritable | ChannelAcceptable | ChannelConnectable => // ignore, we are going away soon anyway
}
// AUXILIARIES and IMPLEMENTATION