aboutsummaryrefslogtreecommitdiff
path: root/src/stable/server.cpp
diff options
context:
space:
mode:
authorMike Buland <eichlan@xagasoft.com>2023-07-31 11:16:58 -0700
committerMike Buland <eichlan@xagasoft.com>2023-07-31 11:16:58 -0700
commit9a7dde29dc1bc1f699508ad9c0335f4d7abf319f (patch)
treeeb3ab95cf784c799d85df81eb5b631b6a04c1730 /src/stable/server.cpp
parent412173a23c88a49ebaeb982e0c7eeddc5662b8cc (diff)
downloadlibbu++-9a7dde29dc1bc1f699508ad9c0335f4d7abf319f.tar.gz
libbu++-9a7dde29dc1bc1f699508ad9c0335f4d7abf319f.tar.bz2
libbu++-9a7dde29dc1bc1f699508ad9c0335f4d7abf319f.tar.xz
libbu++-9a7dde29dc1bc1f699508ad9c0335f4d7abf319f.zip
It actually works. Now to make it fast fast.
Diffstat (limited to 'src/stable/server.cpp')
-rw-r--r--src/stable/server.cpp4
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()
297 297
298void Bu::Server::closeClient( fd iSocket ) 298void Bu::Server::closeClient( fd iSocket )
299{ 299{
300 Bu::MutexLocker l( mClients );
300 BU_PROFILE_START("closeClient"); 301 BU_PROFILE_START("closeClient");
301 Bu::Client *pClient = hClients.get( iSocket ); 302 Bu::Client *pClient = hClients.get( iSocket );
302 Bu::Socket *pSocket = hSockets.get( iSocket ); 303 Bu::Socket *pSocket = hSockets.get( iSocket );
@@ -421,7 +422,7 @@ void Bu::Server::IoWorker::handleRead( Client *pClient, Socket *pSocket )
421 { 422 {
422 Bu::println("IoWorker::handleRead: exception, closing: %1").arg( e.what() ); 423 Bu::println("IoWorker::handleRead: exception, closing: %1").arg( e.what() );
423 close( pSocket ); 424 close( pSocket );
424 break; 425 return;
425 } 426 }
426 } 427 }
427 BU_PROFILE_END("client.read"); 428 BU_PROFILE_END("client.read");
@@ -492,6 +493,7 @@ void Bu::Server::ClientWorker::run()
492 Bu::println("Processing input..."); 493 Bu::println("Processing input...");
493 pClient->processInput(); 494 pClient->processInput();
494 Bu::println("Processing input complete."); 495 Bu::println("Processing input complete.");
496 Bu::println("*** ClientBuf: input: %1b, output: %2b").arg( pClient->getInputSize() ).arg( pClient->getOutputSize() );
495 delete pEv; 497 delete pEv;
496 } 498 }
497} 499}