Ok...forgot a couple of things. Bu::ItoServer now monitors all client

connections and actually cleans up behind them when they're all done.  Seems
important.  It also will cleanup any lingering sockets that are laying around
at destruction time, although right now unless you force-stop the server thread
there is no way to interrupt it.  That'll come in a bit.

1 files changed, 9 insertions, 5 deletions

diff --git a/src/itoserver.h b/src/itoserver.h
index 19c34ca..60b15b4 100644
--- a/src/itoserver.h
+++ b/src/itoserver.h
@@ -7,6 +7,7 @@
 #include "bu/list.h"
 #include "bu/ito.h"
 #include "bu/itomutex.h"
+#include "bu/itoqueue.h"
 #include "bu/set.h"
 
 namespace Bu
@@ -36,6 +37,7 @@ namespace Bu
          */
         class ItoServer : public Ito
         {
+                friend class ItoClient;
         public:
                 ItoServer();
                 virtual ~ItoServer();
@@ -78,11 +80,13 @@ namespace Bu
                 fd_set fdActive;
                 typedef Hash<int,ServerSocket *> ServerHash;
                 ServerHash hServers;
-                //typedef Bu::Set<ItoClient *> ClientSet;
-                //ClientSet sClients;
-                //typedef Hash<int,Client *> ClientHash;
-                //ClientHash hClients;
-                ItoMutex im;
+                typedef Hash<int,ItoClient *> ClientHash;
+                typedef ItoQueue<ItoClient *> ClientQueue;
+                ClientHash hClients;
+                ClientQueue qClientCleanup;
+                ItoMutex imClients;
+
+                void clientCleanup( int iSocket );
         };
 }