From 9a7dde29dc1bc1f699508ad9c0335f4d7abf319f Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Mon, 31 Jul 2023 11:16:58 -0700
Subject: It actually works. Now to make it fast fast.

---
 src/stable/server.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'src/stable/server.cpp')

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;
     }
 }
-- 
cgit v1.2.3