Merge branch 'jedesah-bug/connection_closed'

etaty · Oct 15, 2014 · b0a01a0 · b0a01a0
2 parents 3741e1f + 3aa9400
commit b0a01a0
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
@@ -85,8 +85,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()
     }