X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.c;h=2e39b3ab122b6732ab36dd0a24f0402750ed131f;hb=0d45377ca625dc66907c18bb3f524f9d6c354236;hp=39c243a7b5c407f9a5d744603a241d900933818f;hpb=be1eadea83fa92186638cdbf7b014ac98cd5a039;p=pazpar2-moved-to-github.git diff --git a/src/eventl.c b/src/eventl.c index 39c243a..2e39b3a 100644 --- a/src/eventl.c +++ b/src/eventl.c @@ -255,7 +255,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) { p->poll_offset = i; fds[i].client_data = p; - fds[i].fd = p->fd; + fds[i].fd = -1; fds[i].input_mask = 0; if (p->thread_users > 0) continue; @@ -269,7 +269,10 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) fds[i].input_mask |= yaz_poll_write; if (p->flags & EVENT_EXCEPT) fds[i].input_mask |= yaz_poll_except; + if (fds[i].input_mask) + fds[i].fd = p->fd; } + assert(i == no_fds); yaz_log(man->log_level, "yaz_poll begin nofds=%d", no_fds); res = yaz_poll(fds, no_fds, tv_sec, 0); yaz_log(man->log_level, "yaz_poll returned res=%d", res); @@ -280,7 +283,7 @@ static int event_loop(iochan_man_t man, IOCHAN *iochans) else { yaz_log(YLOG_ERRNO | YLOG_WARN, "poll"); - return 0; + abort(); } } if (man->sel_fd != -1)