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

Merge pull request #21560 from akka/wip-21538-postStop-patriknw

Browse source 
complete the Future[Done] in AeronSink in finally, #21538
This commit is contained in:
Patrik Nordwall 2016-09-28 10:25:04 +02:00 • committed by GitHub
commit 9b72f42fa2
1 changed files with 9 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-remote/src/main/scala/akka/remote/artery/AeronSink.scala
View file

@ -122,12 +122,15 @@ class AeronSink(
}
override def postStop(): Unit = {
taskRunner.command(Remove(addOfferTask.task))
flightRecorder.loFreq(AeronSink_TaskRunnerRemoved, channelMetadata)
pub.close()
flightRecorder.loFreq(AeronSink_PublicationClosed, channelMetadata)
completed.complete(completedValue)
flightRecorder.loFreq(AeronSink_Stopped, channelMetadata)
try {
taskRunner.command(Remove(addOfferTask.task))
flightRecorder.loFreq(AeronSink_TaskRunnerRemoved, channelMetadata)
pub.close()
flightRecorder.loFreq(AeronSink_PublicationClosed, channelMetadata)
} finally {
flightRecorder.loFreq(AeronSink_Stopped, channelMetadata)
completed.complete(completedValue)
}
}
// InHandler