diff options
| author | Mike Buland <eichlan@xagasoft.com> | 2011-01-10 21:04:17 +0000 |
|---|---|---|
| committer | Mike Buland <eichlan@xagasoft.com> | 2011-01-10 21:04:17 +0000 |
| commit | 2ba3f84ab559da02a11aa000b3cecb3b3668af61 (patch) | |
| tree | 266f450b512f607ec54d54af4fa8c13fdbe7ef91 /src/client.cpp | |
| parent | ea18007633b31901f2ae275cc0576c3f7ce99fc9 (diff) | |
| parent | 3611f253f6fdfa4954d374ab85ddaa7f799c130c (diff) | |
| download | libbu++-2ba3f84ab559da02a11aa000b3cecb3b3668af61.tar.gz libbu++-2ba3f84ab559da02a11aa000b3cecb3b3668af61.tar.bz2 libbu++-2ba3f84ab559da02a11aa000b3cecb3b3668af61.tar.xz libbu++-2ba3f84ab559da02a11aa000b3cecb3b3668af61.zip | |
Merged in the core branch. This is a major update that fixes many things, and
changes many others, including source files that were deleted and renamed.
Before doing this update, I reccomend a full clean, or even a fresh checkout.
Things to note, most outstanding about this update:
- Bu::Socket was changed to Bu::TcpSocket and the default mode is blocking.
- All templatized container classes are SharedCore now, which is good, but
SharedCore is inherently non-reentrant safe. However, all SharedCore classes
have a "clone" function that return a non-shared copy of the object, safe for
passing into a reentrant safe function accessing shared memory.
Diffstat (limited to 'src/client.cpp')
| -rw-r--r-- | src/client.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/client.cpp b/src/client.cpp index becd1bd..b635c8b 100644 --- a/src/client.cpp +++ b/src/client.cpp | |||
| @@ -6,7 +6,7 @@ | |||
| 6 | */ | 6 | */ |
| 7 | 7 | ||
| 8 | #include "bu/client.h" | 8 | #include "bu/client.h" |
| 9 | #include "bu/socket.h" | 9 | #include "bu/tcpsocket.h" |
| 10 | #include <stdlib.h> | 10 | #include <stdlib.h> |
| 11 | #include <errno.h> | 11 | #include <errno.h> |
| 12 | #include "bu/protocol.h" | 12 | #include "bu/protocol.h" |
| @@ -16,7 +16,8 @@ | |||
| 16 | /** Read buffer size. */ | 16 | /** Read buffer size. */ |
| 17 | #define RBS (1024*2) | 17 | #define RBS (1024*2) |
| 18 | 18 | ||
| 19 | Bu::Client::Client( Bu::Socket *pSocket, class Bu::ClientLinkFactory *pfLink ) : | 19 | Bu::Client::Client( Bu::TcpSocket *pSocket, |
| 20 | class Bu::ClientLinkFactory *pfLink ) : | ||
| 20 | pTopStream( pSocket ), | 21 | pTopStream( pSocket ), |
| 21 | pSocket( pSocket ), | 22 | pSocket( pSocket ), |
| 22 | pProto( NULL ), | 23 | pProto( NULL ), |
| @@ -59,7 +60,7 @@ void Bu::Client::processInput() | |||
| 59 | break; | 60 | break; |
| 60 | } | 61 | } |
| 61 | } | 62 | } |
| 62 | catch( Bu::SocketException &e ) | 63 | catch( Bu::TcpSocketException &e ) |
| 63 | { | 64 | { |
| 64 | pTopStream->close(); | 65 | pTopStream->close(); |
| 65 | bWantsDisconnect = true; | 66 | bWantsDisconnect = true; |
| @@ -195,7 +196,7 @@ long Bu::Client::getOutputSize() | |||
| 195 | return qbWrite.getSize(); | 196 | return qbWrite.getSize(); |
| 196 | } | 197 | } |
| 197 | 198 | ||
| 198 | const Bu::Socket *Bu::Client::getSocket() const | 199 | const Bu::TcpSocket *Bu::Client::getSocket() const |
| 199 | { | 200 | { |
| 200 | return pSocket; | 201 | return pSocket; |
| 201 | } | 202 | } |
