Merge branch 'bug/connection_closed' of github.com:jedesah/rediscala …

…into jedesah-bug/connection_closed Conflicts: project/Rediscala.scala
etaty · Oct 15, 2014 · 3aa9400 · 3aa9400
2 parents b5f1769 + ec0d293
commit 3aa9400
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/scala/redis/actors/RedisWorkerIO.scala b/src/main/scala/redis/actors/RedisWorkerIO.scala
@@ -83,8 +83,10 @@ abstract class RedisWorkerIO(val address: InetSocketAddress) extends Actor with
     }
     case a: InetSocketAddress => onAddressChanged(a)
     case c: ConnectionClosed => {
-      if(sender == tcpWorker)
+      if(sender == tcpWorker) {
+        tcpWorker ! ConfirmedClose // close the sending direction of the connection (TCP FIN)
         onConnectionClosed(c)
+      }
       else
         onClosingConnectionClosed()
     }