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

fix race condition when trying to assert closed channel on the server side

Browse source
This commit is contained in:
Johannes Rudolph 2013-01-21 18:26:56 +01:00
parent 54c3d77db2
commit e853a1d2ae
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-io/src/test/scala/akka/io/TcpConnectionSpec.scala
View file

@ -161,6 +161,8 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
closeCommander.expectMsg(Closed)
assertThisConnectionActorTerminated()
nioSelector.select(2000)
val buffer = ByteBuffer.allocate(1)
serverSideChannel.read(buffer) must be(-1)
}
@ -207,6 +209,7 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
connectionHandler.expectNoMsg(100.millis) // not yet
val buffer = ByteBuffer.allocate(1)
nioSelector.select(2000)
serverSideChannel.read(buffer) must be(-1)
serverSideChannel.close()