mirror of
https://github.com/cuberite/libevent.git
synced 2025-09-10 13:04:23 -04:00
some cleanup
svn:r56
This commit is contained in:
parent
d5009e8ad6
commit
34d794b293
@ -102,13 +102,15 @@ multiple_write_cb(int fd, short event, void *arg)
|
|||||||
len = write(fd, wbuf + woff, len);
|
len = write(fd, wbuf + woff, len);
|
||||||
if (len == -1) {
|
if (len == -1) {
|
||||||
fprintf(stderr, "%s: write\n", __func__);
|
fprintf(stderr, "%s: write\n", __func__);
|
||||||
|
if (usepersist)
|
||||||
|
event_del(ev);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
woff += len;
|
woff += len;
|
||||||
|
|
||||||
if (woff >= sizeof(wbuf)) {
|
if (woff >= sizeof(wbuf)) {
|
||||||
shutdown(pair[0], SHUT_WR);
|
shutdown(fd, SHUT_WR);
|
||||||
if (usepersist)
|
if (usepersist)
|
||||||
event_del(ev);
|
event_del(ev);
|
||||||
return;
|
return;
|
||||||
@ -125,11 +127,9 @@ multiple_read_cb(int fd, short event, void *arg)
|
|||||||
int len;
|
int len;
|
||||||
|
|
||||||
len = read(fd, rbuf + roff, sizeof(rbuf) - roff);
|
len = read(fd, rbuf + roff, sizeof(rbuf) - roff);
|
||||||
if (len == -1) {
|
if (len == -1)
|
||||||
fprintf(stderr, "%s: read\n", __func__);
|
fprintf(stderr, "%s: read\n", __func__);
|
||||||
return;
|
if (len <= 0) {
|
||||||
}
|
|
||||||
if (len == 0) {
|
|
||||||
if (usepersist)
|
if (usepersist)
|
||||||
event_del(ev);
|
event_del(ev);
|
||||||
return;
|
return;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user