cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-09-08 11:53:00 -04:00
Code Issues Packages Projects Releases Wiki Activity

allow the write callback to called even if there is no buffered data

Browse Source 
svn:r96
This commit is contained in:
Niels Provos 2004-03-23 04:05:37 +00:00
parent 5908bd7213
commit 246d8583c0
2 changed files with 20 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
evbuffer.c
View File

@ -85,7 +85,7 @@ static void
bufferevent_writecb(int fd, short event, void *arg)
{
struct bufferevent *bufev = arg;
int res;
int res = 0;
short what = EVBUFFER_WRITE;
if (event == EV_TIMEOUT) {
@ -93,29 +93,33 @@ bufferevent_writecb(int fd, short event, void *arg)
goto error;
}
res = evbuffer_write(bufev->input, fd);
if (res == -1) {
if (errno == EAGAIN || errno == EINTR)
goto reschedule;
/* error case */
what |= EVBUFFER_ERROR;
} else if (res == 0) {
/* eof case */
what |= EVBUFFER_EOF;
if (EVBUFFER_LENGTH(bufev->output)) {
res = evbuffer_write(bufev->output, fd);
if (res == -1) {
if (errno == EAGAIN || errno == EINTR)
goto reschedule;
/* error case */
what |= EVBUFFER_ERROR;
} else if (res == 0) {
/* eof case */
what |= EVBUFFER_EOF;
}
if (res <= 0)
goto error;
}
if (res <= 0)
goto error;
if (EVBUFFER_LENGTH(bufev->output) != 0)
bufferevent_add(&bufev->ev_write, bufev->timeout_write);
/* Invoke the user callback if our buffer is drained */
if (EVBUFFER_LENGTH(bufev->output) == 0)
(*bufev->writecb)(bufev, bufev->cbarg);
return;
reschedule:
/* Do not call if we call user callback before, we may be deleted */
if (EVBUFFER_LENGTH(bufev->output) != 0) {
if (EVBUFFER_LENGTH(bufev->output) != 0)
bufferevent_add(&bufev->ev_write, bufev->timeout_write);
}
return;
error:

1
event.h
View File

@ -175,6 +175,7 @@ struct evbuffer {
size_t off;
};
/* Just for error reporting - use other constants otherwise */
#define EVBUFFER_READ 0x01
#define EVBUFFER_WRITE 0x02
#define EVBUFFER_EOF 0x10