X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Fpoll.c;h=08e5d4671a6032edf14c63a6b5996e2d1a2b191e;hp=4bd35c0170577d10280e48a38f02ce5b2d80837c;hb=4437d37d1844243b154c4323413e18c50e3b8779;hpb=91c35d653aea231aff9efc3eef6a6ab6662dd129 diff --git a/src/poll.c b/src/poll.c index 4bd35c0..08e5d46 100644 --- a/src/poll.c +++ b/src/poll.c @@ -1,8 +1,6 @@ -/* - * Copyright (C) 1995-2007, Index Data ApS +/* This file is part of the YAZ toolkit. + * Copyright (C) 1995-2010 Index Data * See the file LICENSE for details. - * - * $Id: poll.c,v 1.3 2007-11-10 08:59:31 adam Exp $ */ /** * \file @@ -65,6 +63,10 @@ int yaz_poll_select(struct yaz_poll_fd *fds, int num_fds, int sec, int nsec) enum yaz_poll_mask mask = fds[i].input_mask; int fd = fds[i].fd; + /* Timeout events */ + if (fd < 0) + continue; + if (mask & yaz_poll_read) FD_SET(fd, &input); if (mask & yaz_poll_write) @@ -82,18 +84,17 @@ int yaz_poll_select(struct yaz_poll_fd *fds, int num_fds, int sec, int nsec) { for (i = 0; i < num_fds; i++) { - enum yaz_poll_mask mask = 0; + enum yaz_poll_mask mask = yaz_poll_none; int fd = fds[i].fd; if (!r) - mask += yaz_poll_timeout; - else - { + yaz_poll_add(mask, yaz_poll_timeout); + else if (fd >= 0) { if (FD_ISSET(fd, &input)) - mask += yaz_poll_read; + yaz_poll_add(mask, yaz_poll_read); if (FD_ISSET(fd, &output)) - mask += yaz_poll_write; + yaz_poll_add(mask, yaz_poll_write); if (FD_ISSET(fd, &except)) - mask += yaz_poll_except; + yaz_poll_add(mask, yaz_poll_except); } fds[i].output_mask = mask; } @@ -131,17 +132,19 @@ int yaz_poll_poll(struct yaz_poll_fd *fds, int num_fds, int sec, int nsec) { for (i = 0; i < num_fds; i++) { - enum yaz_poll_mask mask = 0; + enum yaz_poll_mask mask = yaz_poll_none; if (!r) - mask += yaz_poll_timeout; + yaz_poll_add(mask, yaz_poll_timeout); else { if (pollfds[i].revents & POLLIN) - mask += yaz_poll_read; + yaz_poll_add(mask, yaz_poll_read); if (pollfds[i].revents & POLLOUT) - mask += yaz_poll_write; - if (pollfds[i].revents & POLLERR) - mask += yaz_poll_except; + yaz_poll_add(mask, yaz_poll_write); + if (pollfds[i].revents & ~(POLLIN | POLLOUT)) + { + yaz_poll_add(mask, yaz_poll_except); + } } fds[i].output_mask = mask; } @@ -163,6 +166,7 @@ int yaz_poll(struct yaz_poll_fd *fds, int num_fds, int sec, int nsec) /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil * End: * vim: shiftwidth=4 tabstop=8 expandtab