diff options
Diffstat (limited to 'src/itoserver.h')
| -rw-r--r-- | src/itoserver.h | 18 | 
1 files changed, 9 insertions, 9 deletions
diff --git a/src/itoserver.h b/src/itoserver.h index 902c684..b1f5479 100644 --- a/src/itoserver.h +++ b/src/itoserver.h  | |||
| @@ -16,9 +16,9 @@ | |||
| 16 | 16 | ||
| 17 | #include "bu/string.h" | 17 | #include "bu/string.h" | 
| 18 | #include "bu/list.h" | 18 | #include "bu/list.h" | 
| 19 | #include "bu/ito.h" | 19 | #include "bu/thread.h" | 
| 20 | #include "bu/itomutex.h" | 20 | #include "bu/mutex.h" | 
| 21 | #include "bu/itoqueue.h" | 21 | #include "bu/synchroqueue.h" | 
| 22 | #include "bu/set.h" | 22 | #include "bu/set.h" | 
| 23 | 23 | ||
| 24 | #include "bu/clientlink.h" | 24 | #include "bu/clientlink.h" | 
| @@ -50,7 +50,7 @@ namespace Bu | |||
| 50 | * happening within the server itself, and actually makes it useful. | 50 | * happening within the server itself, and actually makes it useful. | 
| 51 | *@ingroup Threading Serving | 51 | *@ingroup Threading Serving | 
| 52 | */ | 52 | */ | 
| 53 | class ItoServer : public Ito | 53 | class ItoServer : public Thread | 
| 54 | { | 54 | { | 
| 55 | friend class ItoClient; | 55 | friend class ItoClient; | 
| 56 | friend class SrvClientLinkFactory; | 56 | friend class SrvClientLinkFactory; | 
| @@ -74,7 +74,7 @@ namespace Bu | |||
| 74 | 74 | ||
| 75 | private: | 75 | private: | 
| 76 | class SrvClientLink; | 76 | class SrvClientLink; | 
| 77 | class ItoClient : public Ito | 77 | class ItoClient : public Thread | 
| 78 | { | 78 | { | 
| 79 | friend class Bu::ItoServer::SrvClientLink; | 79 | friend class Bu::ItoServer::SrvClientLink; | 
| 80 | public: | 80 | public: | 
| @@ -82,7 +82,7 @@ namespace Bu | |||
| 82 | int nTimeoutSec, int nTimeoutUSec ); | 82 | int nTimeoutSec, int nTimeoutUSec ); | 
| 83 | virtual ~ItoClient(); | 83 | virtual ~ItoClient(); | 
| 84 | 84 | ||
| 85 | typedef ItoQueue<Bu::String *> StringQueue; | 85 | typedef SynchroQueue<Bu::String *> StringQueue; | 
| 86 | StringQueue qMsg; | 86 | StringQueue qMsg; | 
| 87 | 87 | ||
| 88 | protected: | 88 | protected: | 
| @@ -96,7 +96,7 @@ namespace Bu | |||
| 96 | int iPort; | 96 | int iPort; | 
| 97 | int nTimeoutSec; | 97 | int nTimeoutSec; | 
| 98 | int nTimeoutUSec; | 98 | int nTimeoutUSec; | 
| 99 | ItoMutex imProto; | 99 | Mutex imProto; | 
| 100 | }; | 100 | }; | 
| 101 | 101 | ||
| 102 | class SrvClientLink : public Bu::ClientLink | 102 | class SrvClientLink : public Bu::ClientLink | 
| @@ -129,10 +129,10 @@ namespace Bu | |||
| 129 | typedef Hash<int,TcpServerSocket *> ServerHash; | 129 | typedef Hash<int,TcpServerSocket *> ServerHash; | 
| 130 | ServerHash hServers; | 130 | ServerHash hServers; | 
| 131 | typedef Hash<int,ItoClient *> ClientHash; | 131 | typedef Hash<int,ItoClient *> ClientHash; | 
| 132 | typedef ItoQueue<ItoClient *> ClientQueue; | 132 | typedef SynchroQueue<ItoClient *> ClientQueue; | 
| 133 | ClientHash hClients; | 133 | ClientHash hClients; | 
| 134 | ClientQueue qClientCleanup; | 134 | ClientQueue qClientCleanup; | 
| 135 | ItoMutex imClients; | 135 | Mutex imClients; | 
| 136 | 136 | ||
| 137 | void clientCleanup( int iSocket ); | 137 | void clientCleanup( int iSocket ); | 
| 138 | }; | 138 | }; | 
