It actually works. Now to make it fast fast.

1 files changed, 3 insertions, 1 deletions

diff --git a/src/stable/server.cpp b/src/stable/server.cpp
index 3f03a63..7c44c11 100644
--- a/src/stable/server.cpp
+++ b/src/stable/server.cpp
@@ -297,6 +297,7 @@ void Bu::Server::shutdown()
 
 void Bu::Server::closeClient( fd iSocket )
 {
+    Bu::MutexLocker l( mClients );
     BU_PROFILE_START("closeClient");
     Bu::Client *pClient = hClients.get( iSocket );
     Bu::Socket *pSocket = hSockets.get( iSocket );
@@ -421,7 +422,7 @@ void Bu::Server::IoWorker::handleRead( Client *pClient, Socket *pSocket )
         {
             Bu::println("IoWorker::handleRead: exception, closing: %1").arg( e.what() );
             close( pSocket );
-            break;
+            return;
         }
     }
     BU_PROFILE_END("client.read");
@@ -492,6 +493,7 @@ void Bu::Server::ClientWorker::run()
         Bu::println("Processing input...");
         pClient->processInput();
         Bu::println("Processing input complete.");
+        Bu::println("*** ClientBuf: input: %1b, output: %2b").arg( pClient->getInputSize() ).arg( pClient->getOutputSize() );
         delete pEv;
     }
 }