diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/connection.cpp | 15 | ||||
-rw-r--r-- | src/fstring.h | 2 |
2 files changed, 10 insertions, 7 deletions
diff --git a/src/connection.cpp b/src/connection.cpp index f382d82..a5fac5b 100644 --- a/src/connection.cpp +++ b/src/connection.cpp | |||
@@ -13,6 +13,9 @@ | |||
13 | #include <errno.h> | 13 | #include <errno.h> |
14 | #include "exceptions.h" | 14 | #include "exceptions.h" |
15 | 15 | ||
16 | // Read buffer size...maybe fix wierd issues... | ||
17 | #define RBS (1024*10) | ||
18 | |||
16 | Connection::Connection() | 19 | Connection::Connection() |
17 | { | 20 | { |
18 | nSocket = -1; | 21 | nSocket = -1; |
@@ -201,15 +204,15 @@ bool Connection::open( const char *sAddr, int nPort ) | |||
201 | 204 | ||
202 | int Connection::readInput() | 205 | int Connection::readInput() |
203 | { | 206 | { |
204 | char buffer[2048]; | 207 | char buffer[RBS]; |
205 | int nbytes; | 208 | int nbytes; |
206 | int nTotalRead=0; | 209 | int nTotalRead=0; |
207 | 210 | ||
208 | for(;;) | 211 | for(;;) |
209 | { | 212 | { |
210 | //memset( buffer, 0, 2048 ); | 213 | //memset( buffer, 0, RBS ); |
211 | 214 | ||
212 | nbytes = read( nSocket, buffer, 2048 ); | 215 | nbytes = read( nSocket, buffer, RBS ); |
213 | if( nbytes < 0 && errno != 0 && errno != EAGAIN ) | 216 | if( nbytes < 0 && errno != 0 && errno != EAGAIN ) |
214 | { | 217 | { |
215 | printf("errno: %d, %s\n", errno, strerror( errno ) ); | 218 | printf("errno: %d, %s\n", errno, strerror( errno ) ); |
@@ -224,12 +227,12 @@ int Connection::readInput() | |||
224 | nTotalRead += nbytes; | 227 | nTotalRead += nbytes; |
225 | appendInput( buffer, nbytes ); | 228 | appendInput( buffer, nbytes ); |
226 | /* Data read. */ | 229 | /* Data read. */ |
227 | if( nbytes < 2048 ) | 230 | if( nbytes < RBS ) |
228 | { | 231 | { |
229 | break; | 232 | break; |
230 | } | 233 | } |
231 | 234 | ||
232 | /* New test, if data is divisible by 2048 bytes on some libs the | 235 | /* New test, if data is divisible by RBS bytes on some libs the |
233 | * read could block, this keeps it from happening. | 236 | * read could block, this keeps it from happening. |
234 | */ | 237 | */ |
235 | { | 238 | { |
@@ -358,7 +361,7 @@ bool Connection::clearInput() | |||
358 | 361 | ||
359 | bool Connection::writeOutput() | 362 | bool Connection::writeOutput() |
360 | { | 363 | { |
361 | //int nBytes = TEMP_FAILURE_RETRY( write( nSocket, xOutputBuf.getData(), min( 2048, xOutputBuf.getLength() ) ) ); | 364 | //int nBytes = TEMP_FAILURE_RETRY( write( nSocket, xOutputBuf.getData(), min( RBS, xOutputBuf.getLength() ) ) ); |
362 | int nBytes = TEMP_FAILURE_RETRY( write( nSocket, xOutputBuf.getData(), xOutputBuf.getLength() ) ); | 365 | int nBytes = TEMP_FAILURE_RETRY( write( nSocket, xOutputBuf.getData(), xOutputBuf.getLength() ) ); |
363 | if( nBytes < 0 ) | 366 | if( nBytes < 0 ) |
364 | { | 367 | { |
diff --git a/src/fstring.h b/src/fstring.h index f0462cb..c5397cc 100644 --- a/src/fstring.h +++ b/src/fstring.h | |||
@@ -170,7 +170,7 @@ public: | |||
170 | nLength = nNewSize; | 170 | nLength = nNewSize; |
171 | } | 171 | } |
172 | 172 | ||
173 | long getSize() | 173 | long getSize() const |
174 | { | 174 | { |
175 | return nLength; | 175 | return nLength; |
176 | } | 176 | } |