1 files changed, 22 insertions, 13 deletions

diff --git a/src/stable/server.cpp b/src/stable/server.cpp
index 160b3eb..3aa8a34 100644
--- a/src/stable/server.cpp
+++ b/src/stable/server.cpp
@@ -204,13 +204,29 @@ void Bu::Server::addClient( const Bu::ServerSocket *pSrv, Bu::Socket *pSocket )
         );
     {
         Bu::MutexLocker l( mClients );
-        if( hClients.has( iFdCli ) )
+        if( hClients.has( iFdCli ) || hSockets.has( iFdCli ) )
         {
-            Bu::println("!!!!!!!!! hClients has %1 already.").arg( iFdCli );
-        }
-        if( hSockets.has( iFdCli ) )
-        {
-            Bu::println("!!!!!!!!! hSockets has %1 already.").arg( iFdCli );
+            // Oops, it got closed and we haven't managed to get to it yet.
+            // We're not going to be able to write anyhting, we may as well
+            // just clean up.
+            //
+            // This can happen in a variety of situations, but mostly when
+            // we get a disconnect followed immediately be a reconnect.
+            struct epoll_event ev;
+            epoll_ctl( pCore->fdRead, EPOLL_CTL_DEL, iFdCli, &ev );
+            epoll_ctl( pCore->fdWrite, EPOLL_CTL_DEL, iFdCli, &ev );
+            Client *pOldClient = hClients.get( iFdCli );
+            Socket *pOldSocket = hSockets.get( iFdCli );
+
+            hClients.erase( iFdCli );
+            hSockets.erase( iFdCli );
+
+            onClosedConnection( pOldClient );
+            pOldClient->close();
+            pOldSocket->close();
+
+            delete pOldClient;
+            delete pOldSocket;
         }
         hClients.insert( iFdCli, pClient );
         hSockets.insert( iFdCli, pSocket );
@@ -558,13 +574,6 @@ void Bu::Server::IoWorker::handleWrite( Client *pClient, Socket *pSocket )
     }
 }
 
-void Bu::Server::IoWorker::close( Bu::Socket *pSocket )
-{
-//    Bu::Server::fd iFd;
-//    pSocket->getFd( iFd );
-//    rSrv.closeClient( iFd );
-}           
-
 /////////
 // ClientWorker
 ////