mempool/ckpool
mempool/ckpool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Handle all poll revents with a recv and invalidate clients that don't respond

Browse Source
This commit is contained in:
Con Kolivas 2014-05-02 08:25:56 +10:00
parent 5721ec1dcf
commit bfb90fa632
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/connector.c
View File

@ -162,9 +162,12 @@ retry:
ret = recv(client->fd, client->buf + client->bufofs, buflen, flags);
if (ret < 1) {
/* Nothing else ready to be read */
if (!ret)
if (!ret && flags)
return;
/* We should have something to read if called since poll set
* this fd's revents status so if there's nothing it means the
* client has disconnected. */
LOGINFO("Client fd %d disconnected", client->fd);
invalidate_client(ckp, ci, client);
return;
@ -260,7 +263,7 @@ repoll:
for (i = 0; i < nfds; i++) {
int fd;
if (!(fds[i].revents & POLLIN))
if (!fds[i].revents)
continue;
client = NULL;