diff options
Diffstat (limited to 'src/stable/client.h')
-rw-r--r-- | src/stable/client.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/stable/client.h b/src/stable/client.h index abe807e..0ff7914 100644 --- a/src/stable/client.h +++ b/src/stable/client.h | |||
@@ -15,6 +15,7 @@ | |||
15 | #include "bu/clientbuf.h" | 15 | #include "bu/clientbuf.h" |
16 | #include "bu/mutex.h" | 16 | #include "bu/mutex.h" |
17 | #include "bu/readwritemutex.h" | 17 | #include "bu/readwritemutex.h" |
18 | #include "bu/serverinterface.h" | ||
18 | 19 | ||
19 | #ifndef PROFILE_BU_SERVER | 20 | #ifndef PROFILE_BU_SERVER |
20 | // #define PROFILE_BU_SERVER 1 | 21 | // #define PROFILE_BU_SERVER 1 |
@@ -37,10 +38,13 @@ namespace Bu | |||
37 | { | 38 | { |
38 | friend class Server; | 39 | friend class Server; |
39 | public: | 40 | public: |
40 | Client( Bu::ClientLinkFactory *pfLink ); | 41 | Client( int iId, const Bu::ServerInterface &rServer ); |
41 | virtual ~Client(); | 42 | virtual ~Client(); |
42 | 43 | ||
44 | int getId() const; | ||
45 | |||
43 | void processInput(); | 46 | void processInput(); |
47 | void outputReady(); | ||
44 | 48 | ||
45 | Bu::size write( const Bu::String &sData ); | 49 | Bu::size write( const Bu::String &sData ); |
46 | Bu::size write( const void *pData, Bu::size nBytes ); | 50 | Bu::size write( const void *pData, Bu::size nBytes ); |
@@ -116,9 +120,10 @@ namespace Bu | |||
116 | Bu::Protocol *pProto; | 120 | Bu::Protocol *pProto; |
117 | Bu::ClientBuf cbBuffer; | 121 | Bu::ClientBuf cbBuffer; |
118 | bool bWantsDisconnect; | 122 | bool bWantsDisconnect; |
119 | class Bu::ClientLinkFactory *pfLink; | ||
120 | mutable Bu::Mutex mProto; | 123 | mutable Bu::Mutex mProto; |
121 | mutable Bu::Mutex mDisconnect; | 124 | mutable Bu::Mutex mDisconnect; |
125 | int iId; | ||
126 | Bu::ServerInterface xServer; | ||
122 | }; | 127 | }; |
123 | } | 128 | } |
124 | 129 | ||