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

Debug and enable pipe notification

Browse Source 
svn:r1021
This commit is contained in:
Nick Mathewson 2009-01-19 19:46:03 +00:00
parent ddf3ee976d
commit 34d2fd0634
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
event.c
View File

@ -1043,7 +1043,11 @@ evthread_notify_base(struct event_base *base, ev_uint8_t msg)
char buf[1]; char buf[1];
int r; int r;
buf[0] = (char)msg; buf[0] = (char)msg;
#ifdef WIN32
r = send(base->th_notify_fd[1], buf, 1, 0); r = send(base->th_notify_fd[1], buf, 1, 0);
#else
r = write(base->th_notify_fd[1], buf, 1);
#endif
return (r < 0) ? -1 : 0; return (r < 0) ? -1 : 0;
} }
@ -1506,7 +1510,11 @@ evthread_notification_callback(int fd, short what, void *arg)
int n, i; int n, i;
/* we're draining the socket */ /* we're draining the socket */
#ifdef WIN32
while ((n = recv(fd, (char*)buf, sizeof(buf), 0)) != -1) { while ((n = recv(fd, (char*)buf, sizeof(buf), 0)) != -1) {
#else
while ((n = read(fd, (char*)buf, sizeof(buf))) != -1) {
#endif
for (i=0;i<n;++i) { for (i=0;i<n;++i) {
if (buf[i] == EVTHREAD_NOTIFY_MSG_RECALC) { if (buf[i] == EVTHREAD_NOTIFY_MSG_RECALC) {
/* ignore; this is just to make us call recalc/dispatch. */ /* ignore; this is just to make us call recalc/dispatch. */
@ -1550,10 +1558,10 @@ evthread_make_base_notifiable(struct event_base *base)
if (base->th_notify_fd[0] >= 0) if (base->th_notify_fd[0] >= 0)
return 0; return 0;
#if defined(XXX_EVENT_HAVE_PIPE) #if defined(_EVENT_HAVE_PIPE)
if ((base->evsel->features & EV_FEATURE_FDS)) { if ((base->evsel->features & EV_FEATURE_FDS)) {
if (pipe(base->th_notify_fd) < 0) if (pipe(base->th_notify_fd) < 0)
event_warn(1, "%s: pipe", __func__); event_warn("%s: pipe", __func__);
} }
if (base->th_notify_fd[0] < 0) if (base->th_notify_fd[0] < 0)
#endif #endif