diff options
author | Mike Buland <eichlan@xagasoft.com> | 2011-10-23 07:43:50 +0000 |
---|---|---|
committer | Mike Buland <eichlan@xagasoft.com> | 2011-10-23 07:43:50 +0000 |
commit | da1e0ef0772b078bd295301bd675afdee00d40e9 (patch) | |
tree | 7d1703bbb5c2d76e6e6300e51f0ed1e09704af4f /src/itoserver.h | |
parent | 208b983734d7431699f4bd3534e08321e42ada86 (diff) | |
download | libbu++-da1e0ef0772b078bd295301bd675afdee00d40e9.tar.gz libbu++-da1e0ef0772b078bd295301bd675afdee00d40e9.tar.bz2 libbu++-da1e0ef0772b078bd295301bd675afdee00d40e9.tar.xz libbu++-da1e0ef0772b078bd295301bd675afdee00d40e9.zip |
Switched ito* to synchro*, except the server, I'm thinking of takeing the core
in a different direction anyway.
Added the Deflate class, it uses zlib, and can do raw (headerless) deflate
streams, zlib format, or gzip format. It's easy to use and quite versitile.
Diffstat (limited to 'src/itoserver.h')
-rw-r--r-- | src/itoserver.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/itoserver.h b/src/itoserver.h index 75b3349..b1f5479 100644 --- a/src/itoserver.h +++ b/src/itoserver.h | |||
@@ -18,7 +18,7 @@ | |||
18 | #include "bu/list.h" | 18 | #include "bu/list.h" |
19 | #include "bu/thread.h" | 19 | #include "bu/thread.h" |
20 | #include "bu/mutex.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" |
@@ -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: |
@@ -129,7 +129,7 @@ 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 | Mutex imClients; | 135 | Mutex imClients; |