From 412173a23c88a49ebaeb982e0c7eeddc5662b8cc Mon Sep 17 00:00:00 2001 From: Mike Buland Date: Sat, 29 Jul 2023 00:19:13 -0700 Subject: Many bugfixes. It's almost working! --- src/stable/server.h | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src/stable/server.h') diff --git a/src/stable/server.h b/src/stable/server.h index d66d9d5..e2b7d53 100644 --- a/src/stable/server.h +++ b/src/stable/server.h @@ -22,6 +22,7 @@ #include "bu/hash.h" #include "bu/synchroqueue.h" #include "bu/thread.h" +#include "bu/counterevent.h" #include "bu/config.h" @@ -137,8 +138,7 @@ namespace Bu class IoWorker : public Bu::Thread { public: - IoWorker( Server &rSrv, EventQueue &qIoEvent, - EventQueue &qClientEvent ); + IoWorker( Server &rSrv ); virtual ~IoWorker(); protected: @@ -151,14 +151,13 @@ namespace Bu private: Server &rSrv; - EventQueue &qIoEvent; - EventQueue &qClientEvent; }; + friend class Bu::Server::IoWorker; class ClientWorker : public Bu::Thread { public: - ClientWorker( Server &rSrv, EventQueue &qEvent ); + ClientWorker( Server &rSrv ); virtual ~ClientWorker(); protected: @@ -166,8 +165,8 @@ namespace Bu private: Server &rSrv; - EventQueue &qEvent; }; + friend class Bu::Server::ClientWorker; int nTimeoutSec; int nTimeoutUSec; @@ -189,6 +188,7 @@ namespace Bu typedef List ClientWorkerList; IoWorkerList lIoWorker; ClientWorkerList lClientWorker; + Bu::CounterEvent evIoCycle; }; } -- cgit v1.2.3