diff options
Diffstat (limited to '')
| -rw-r--r-- | src/cache.h | 4 | ||||
| -rw-r--r-- | src/client.cpp | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/cache.h b/src/cache.h index 926556d..d4b1900 100644 --- a/src/cache.h +++ b/src/cache.h | |||
| @@ -154,12 +154,12 @@ namespace Bu | |||
| 154 | 154 | ||
| 155 | bool operator==( const Ptr &rRhs ) const | 155 | bool operator==( const Ptr &rRhs ) const |
| 156 | { | 156 | { |
| 157 | return pData == rRhs.pData; | 157 | return pCache == rRhs.pCache && kId == rRhs.kId; |
| 158 | } | 158 | } |
| 159 | 159 | ||
| 160 | bool operator!=( const Ptr &rRhs ) const | 160 | bool operator!=( const Ptr &rRhs ) const |
| 161 | { | 161 | { |
| 162 | return pData != rRhs.pData; | 162 | return pCache != rRhs.pCache || kId != rRhs.kId; |
| 163 | } | 163 | } |
| 164 | 164 | ||
| 165 | private: | 165 | private: |
diff --git a/src/client.cpp b/src/client.cpp index 02e51de..795e09b 100644 --- a/src/client.cpp +++ b/src/client.cpp | |||
| @@ -14,7 +14,7 @@ | |||
| 14 | #include "bu/clientlinkfactory.h" | 14 | #include "bu/clientlinkfactory.h" |
| 15 | 15 | ||
| 16 | /** Read buffer size. */ | 16 | /** Read buffer size. */ |
| 17 | #define RBS (1024*2) | 17 | #define RBS (1500) // 1500 is the nominal MTU for ethernet, it's a good guess |
| 18 | 18 | ||
| 19 | Bu::Client::Client( Bu::TcpSocket *pSocket, | 19 | Bu::Client::Client( Bu::TcpSocket *pSocket, |
| 20 | class Bu::ClientLinkFactory *pfLink ) : | 20 | class Bu::ClientLinkFactory *pfLink ) : |
| @@ -82,10 +82,10 @@ void Bu::Client::processInput() | |||
| 82 | 82 | ||
| 83 | void Bu::Client::processOutput() | 83 | void Bu::Client::processOutput() |
| 84 | { | 84 | { |
| 85 | char buf[RBS]; | ||
| 85 | if( qbWrite.getSize() > 0 ) | 86 | if( qbWrite.getSize() > 0 ) |
| 86 | { | 87 | { |
| 87 | int nAmnt = RBS; | 88 | int nAmnt = RBS; |
| 88 | char *buf = new char[nAmnt]; | ||
| 89 | nAmnt = qbWrite.peek( buf, nAmnt ); | 89 | nAmnt = qbWrite.peek( buf, nAmnt ); |
| 90 | int nReal = pTopStream->write( buf, nAmnt ); | 90 | int nReal = pTopStream->write( buf, nAmnt ); |
| 91 | qbWrite.seek( nReal ); | 91 | qbWrite.seek( nReal ); |
