jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix detection of connections that are closed by the server

This commit is contained in:
Toon Schoenmakers 2015-11-06 15:17:41 +01:00
parent e6cf349605
commit 1cc86e79e8
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/tcpbuffer.h
View File

@ -376,8 +376,9 @@ public:
// when the buffer is very small, we use a lower limit of 512 bytes // when the buffer is very small, we use a lower limit of 512 bytes
if (ioctl(socket, FIONREAD, &available) != 0) return -1; if (ioctl(socket, FIONREAD, &available) != 0) return -1;
// no need to read anything if there is no input // if no bytes are available, it could mean that the connection was closed
if (available == 0) return 0; // by the remote client, so we do have to call read() anyway, assume a default buffer
if (available == 0) available = 1;
// add a new buffer // add a new buffer
_buffers.emplace_back(available); _buffers.emplace_back(available);