Function io_wait_loop_poll

io_wait_loop.h:69–122

! \brief io_wait_loop_x style function * wait for io using poll() * \param h io_wait handle * \param t timeout in s * \param repeat if !=0 handle_io will be called until it returns <=0 * \return number of IO events handled on success (can be 0), -1 on error */

 * \return number of IO events handled on success (can be 0), -1 on error
 */
inline static int io_wait_loop_poll(io_wait_h* h, int t, int repeat)
{
	int n, r;
	int ret;
	struct fd_map *e;
	unsigned int curr_time;

again:
		ret=n=poll(h->fd_array, h->fd_no, t*1000);
		if (n==-1){
			if (errno==EINTR) goto again; /* signal, ignore it */
			else{
				LM_ERR("[%s] poll: %s [%d]\n",h->name, strerror(errno), errno);
				goto error;
			}
		}

		curr_time = get_ticks();

		for (r=h->fd_no-1; (r>=0) ; r--){
			if (h->fd_array[r].revents & POLLOUT) {
				/* sanity checks */
				if ((h->fd_array[r].fd >= h->max_fd_no)||
						(h->fd_array[r].fd < 0)){
					LM_CRIT("[%s] bad fd %d (no in the 0 - %d range)\n",
						h->name, h->fd_array[r].fd, h->max_fd_no);
					/* try to continue anyway */
					h->fd_array[r].events=0; /* clear the events */
					continue;
				}
				handle_io(get_fd_map(h, h->fd_array[r].fd),r,IO_WATCH_WRITE);
			} else if (h->fd_array[r].revents & (POLLIN|POLLERR|POLLHUP)){
				/* sanity checks */
				if ((h->fd_array[r].fd >= h->max_fd_no)||
						(h->fd_array[r].fd < 0)){
					LM_CRIT("[%s] bad fd %d (no in the 0 - %d range)\n",
						h->name,h->fd_array[r].fd, h->max_fd_no);
					/* try to continue anyway */
					h->fd_array[r].events=0; /* clear the events */
					continue;
				}

				while((handle_io(get_fd_map(h, h->fd_array[r].fd), r,
				IO_WATCH_READ) > 0)
						 && repeat);
			} else if ( (e=get_fd_map(h, h->fd_array[r].fd))!=NULL &&
			e->timeout!=0 && e->timeout<=curr_time ) {
				e->timeout = 0;
				handle_io( e, r, IO_WATCH_TIMEOUT);
			}
		}
error:
	return ret;
}