X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.c;h=a343e93e00e4fa5176bb8145a67d5452ce913523;hb=ccf3507349789d9142580e96453883ce04cc2939;hp=a2abda5523dd8306a85d075c17c79537d50da014;hpb=69d77699072d43a5292ac4b8af55e7d401e21f80;p=pazpar2-moved-to-github.git diff --git a/src/eventl.c b/src/eventl.c index a2abda5..a343e93 100644 --- a/src/eventl.c +++ b/src/eventl.c @@ -127,7 +127,7 @@ static void work_handler(void *work_data) static void run_fun(iochan_man_t man, IOCHAN p) { - if (!p->destroyed && p->this_event) + if (p->this_event) { if (man->sel_thread) { @@ -222,37 +222,35 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) int force_event = p->force_event; time_t now = time(0); - if (p->thread_users > 0) + if (p->thread_users > 0 || p->destroyed) { yaz_log(man->log_level, "eventl: skip chan=%p users=%d", p, p->thread_users); continue; } p->this_event = 0; p->force_event = 0; - if (!p->destroyed && ((p->max_idle && now - p->last_event > - p->max_idle) || force_event == EVENT_TIMEOUT)) + + if ((p->max_idle && now - p->last_event > p->max_idle) + || force_event == EVENT_TIMEOUT) { p->last_event = now; p->this_event |= EVENT_TIMEOUT; } if (p->fd >= 0) { - if (!p->destroyed && (FD_ISSET(p->fd, &in) || - force_event == EVENT_INPUT)) + if (FD_ISSET(p->fd, &in) || force_event == EVENT_INPUT) { p->last_event = now; yaz_log(YLOG_DEBUG, "Eventl input event"); p->this_event |= EVENT_INPUT; } - if (!p->destroyed && (FD_ISSET(p->fd, &out) || - force_event == EVENT_OUTPUT)) + if (FD_ISSET(p->fd, &out) || force_event == EVENT_OUTPUT) { p->last_event = now; yaz_log(YLOG_DEBUG, "Eventl output event"); p->this_event |= EVENT_OUTPUT; } - if (!p->destroyed && (FD_ISSET(p->fd, &except) || - force_event == EVENT_EXCEPT)) + if (FD_ISSET(p->fd, &except) || force_event == EVENT_EXCEPT) { p->last_event = now; p->this_event |= EVENT_EXCEPT;