diff options
Diffstat (limited to '')
-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 | }; |