Kyoshiro/bip
1
0
Fork 0
forked from bip/bip
Code Pull Requests Activity

Damn old backlog bug finally fixed. Happiness. Joy.

Browse Source
This commit is contained in:
nohar 2005-05-23 06:27:26 +00:00
parent 152e5324d5
commit abd979fb01
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/connection.c
View File

@ -209,28 +209,36 @@ static int _write_socket_SSL(connection_t *cn, char* message)
} }
#endif #endif
static int _write_socket(connection_t *cn, char* message) static int _write_socket(connection_t *cn, char *message)
{ {
size_t size; size_t size;
size_t tcount = 0; size_t tcount = 0;
ssize_t count; ssize_t count;
size = strlen(message); size = strlen(message);
while ((count = write(cn->handle, ((const char*)message) + tcount, do {
while ((count = write(cn->handle,
((const char *)message) + tcount,
size - tcount)) > 0) { size - tcount)) > 0) {
tcount += count; tcount += count;
if (tcount == size) if (tcount == size)
break; break;
} }
} while (count < 0 &&
(errno == EAGAIN || errno == EINTR || errno == EINPROGRESS));
if (count <= 0 && tcount > 0) if (count <= 0 && tcount > 0)
fatal("shit happens\n"); fatal("shit happens errno:%d count:%d tcount:%d (%s)\n", errno,
count, tcount, message);
if (count <= 0) { if (count <= 0) {
/* /*
* if no fatal error, return WRITE_KEEP, which makes caller * if no fatal error, return WRITE_KEEP, which makes caller
* keep line in its FIFO * keep line in its FIFO
*/ *
* Cannot do: we might have written a partial line
*
if (errno == EAGAIN || errno == EINTR || errno == EINPROGRESS) if (errno == EAGAIN || errno == EINTR || errno == EINPROGRESS)
return WRITE_KEEP; return WRITE_KEEP;
*/
if (cn_is_connected(cn)) { if (cn_is_connected(cn)) {
mylog(LOG_DEBUG, "write(fd %d) : %s", cn->handle, mylog(LOG_DEBUG, "write(fd %d) : %s", cn->handle,