diff options
Diffstat (limited to 'lib/select.c')
| -rw-r--r-- | lib/select.c | 221 |
1 files changed, 0 insertions, 221 deletions
diff --git a/lib/select.c b/lib/select.c index daa591eae..28bb141b1 100644 --- a/lib/select.c +++ b/lib/select.c @@ -482,227 +482,6 @@ int Curl_poll(struct pollfd ufds[], unsigned int nfds, int timeout_ms) return r; } -/* - * This is a wrapper around select(). It uses poll() when a fine - * poll() is available, in order to avoid limits with FD_SETSIZE, - * otherwise select() is used. An error is returned if select() is - * being used and a the number of file descriptors is larger than - * FD_SETSIZE. A NULL timeout pointer makes this function wait - * indefinitely, unles no valid file descriptor is given, when this - * happens the NULL timeout is ignored and the function times out - * immediately. When compiled with CURL_ACKNOWLEDGE_EINTR defined, - * EINTR condition is honored and function might exit early without - * awaiting timeout, otherwise EINTR will be ignored. - * - * Return values: - * -1 = system call error or nfds > FD_SETSIZE - * 0 = timeout - * N = number of file descriptors kept in file descriptor sets. - */ -int Curl_select(int nfds, - fd_set *fds_read, fd_set *fds_write, fd_set *fds_excep, - struct timeval *timeout) -{ - struct timeval initial_tv; - int timeout_ms; - int pending_ms = 0; - int error; - int r; -#ifdef HAVE_POLL_FINE - struct pollfd small_fds[SMALL_POLLNFDS]; - struct pollfd *poll_fds; - int ix; - int fd; - int poll_nfds = 0; -#else - struct timeval pending_tv; - struct timeval *ptimeout; -#endif - int ret = 0; - - if ((nfds < 0) || - ((nfds > 0) && (!fds_read && !fds_write && !fds_excep))) { - SET_SOCKERRNO(EINVAL); - return -1; - } - - if (timeout) { - if ((timeout->tv_sec < 0) || - (timeout->tv_usec < 0) || - (timeout->tv_usec >= 1000000)) { - SET_SOCKERRNO(EINVAL); - return -1; - } - timeout_ms = (int)(timeout->tv_sec * 1000) + - (int)(timeout->tv_usec / 1000); - } - else { - timeout_ms = -1; - } - - if ((!nfds) || (!fds_read && !fds_write && !fds_excep)) { - r = wait_ms(timeout_ms); - return r; - } - - /* Avoid initial timestamp, avoid gettimeofday() call, when elapsed - time in this function does not need to be measured. This happens - when function is called with a zero timeout in the timeval struct - referenced argument or when a NULL pointer is received as timeval - reference indicating a blocking call should be performed. */ - - if (timeout_ms > 0) { - pending_ms = timeout_ms; - initial_tv = curlx_tvnow(); - } - -#ifdef HAVE_POLL_FINE - - if (fds_read || fds_write || fds_excep) { - fd = nfds; - while (fd--) { - if ((fds_read && (0 != FD_ISSET(fd, fds_read))) || - (fds_write && (0 != FD_ISSET(fd, fds_write))) || - (fds_excep && (0 != FD_ISSET(fd, fds_excep)))) - poll_nfds++; - } - } - - if (!poll_nfds) - poll_fds = NULL; - else if (poll_nfds <= SMALL_POLLNFDS) - poll_fds = small_fds; - else { - poll_fds = malloc(poll_nfds * sizeof(struct pollfd)); - if (!poll_fds) { - SET_SOCKERRNO(ENOBUFS); - return -1; - } - } - - if (poll_fds) { - int events; - ix = 0; - fd = nfds; - while (fd--) { - events = 0; - if (fds_read && (0 != FD_ISSET(fd, fds_read))) - events |= (POLLRDNORM|POLLIN); - if (fds_write && (0 != FD_ISSET(fd, fds_write))) - events |= (POLLWRNORM|POLLOUT); - if (fds_excep && (0 != FD_ISSET(fd, fds_excep))) - events |= (POLLRDBAND|POLLPRI); - if (events) { - poll_fds[ix].events = events; - poll_fds[ix].fd = fd; - poll_fds[ix].revents = 0; - ix++; - if(ix == poll_nfds) - /* since we know this is the total amount of descriptors with - interesting actions, we can skip the rest of the loop at this - point */ - break; - } - } - } - - do { - if (timeout_ms < 0) - pending_ms = -1; - else if (!timeout_ms) - pending_ms = 0; - r = poll(poll_fds, poll_nfds, pending_ms); - if (r != -1) - break; - error = SOCKERRNO; - if ((error == EINVAL) || error_is_EINTR) - break; - if (timeout_ms > 0) { - pending_ms = timeout_ms - elapsed_ms; - if (pending_ms <= 0) - break; - } - } while (r == -1); - - if (r < 0) - ret = -1; - - if (r > 0) { - ix = poll_nfds; - while (ix--) { - if (poll_fds[ix].revents & POLLNVAL) { - SET_SOCKERRNO(EBADF); - ret = -1; - break; - } - } - } - - if (!ret) { - ix = poll_nfds; - while (ix--) { - if (fds_read && (0 != FD_ISSET(poll_fds[ix].fd, fds_read))) { - if (0 == (poll_fds[ix].revents & (POLLRDNORM|POLLERR|POLLHUP|POLLIN))) - FD_CLR(poll_fds[ix].fd, fds_read); - else - ret++; - } - if (fds_write && (0 != FD_ISSET(poll_fds[ix].fd, fds_write))) { - if (0 == (poll_fds[ix].revents & (POLLWRNORM|POLLERR|POLLHUP|POLLOUT))) - FD_CLR(poll_fds[ix].fd, fds_write); - else - ret++; - } - if (fds_excep && (0 != FD_ISSET(poll_fds[ix].fd, fds_excep))) { - if (0 == (poll_fds[ix].revents & (POLLRDBAND|POLLERR|POLLHUP|POLLPRI))) - FD_CLR(poll_fds[ix].fd, fds_excep); - else - ret++; - } - } - } - - if (poll_fds && (poll_nfds > SMALL_POLLNFDS)) - free(poll_fds); - -#else /* HAVE_POLL_FINE */ - - VERIFY_NFDS(nfds); - - ptimeout = (timeout_ms < 0) ? NULL : &pending_tv; - - do { - if (timeout_ms > 0) { - pending_tv.tv_sec = pending_ms / 1000; - pending_tv.tv_usec = (pending_ms % 1000) * 1000; - } - else if (!timeout_ms) { - pending_tv.tv_sec = 0; - pending_tv.tv_usec = 0; - } - r = select(nfds, fds_read, fds_write, fds_excep, ptimeout); - if (r != -1) - break; - error = SOCKERRNO; - if ((error == EINVAL) || (error == EBADF) || error_is_EINTR) - break; - if (timeout_ms > 0) { - pending_ms = timeout_ms - elapsed_ms; - if (pending_ms <= 0) - break; - } - } while (r == -1); - - if (r < 0) - ret = -1; - else - ret = r; - -#endif /* HAVE_POLL_FINE */ - - return ret; -} - #ifdef TPF /* * This is a replacement for select() on the TPF platform. |