st->i=0;
st->finished=False;
- register_for_poll(st,log_from_fd_beforepoll,log_from_fd_afterpoll,1,
+ register_for_poll(st,log_from_fd_beforepoll,log_from_fd_afterpoll,
prefix);
}
fatal_perror("start_signal_handling: fcntl(O_NONBLOCK)");
}
- register_for_poll(NULL,signal_beforepoll,signal_afterpoll,1,"signal");
+ register_for_poll(NULL,signal_beforepoll,signal_afterpoll,"signal");
signal_handling=True;
/* Register signal handlers for all the signals we're interested in */
}
register_for_poll(st, resolver_beforepoll, resolver_afterpoll,
- ADNS_POLLFDS_RECOMMENDED+5,"resolver");
+ "resolver");
return new_closure(&st->cl);
}
beforepoll_fn *before;
afterpoll_fn *after;
void *state;
- int32_t max_nfds;
int32_t nfds;
cstring_t desc;
LIST_ENTRY(poll_interest) entry;
}
void register_for_poll(void *st, beforepoll_fn *before,
- afterpoll_fn *after, int32_t max_nfds, cstring_t desc)
+ afterpoll_fn *after, cstring_t desc)
{
struct poll_interest *i;
i->before=before;
i->after=after;
i->state=st;
- i->max_nfds=max_nfds;
i->nfds=0;
i->desc=desc;
LIST_INSERT_HEAD(®, i, entry);
/* Register interest in the main loop of the program. Before a call
to poll() your supplied beforepoll function will be called. After
- the call to poll() the supplied afterpoll function will be called.
- max_nfds is a _hint_ about the maximum number of struct pollfd
- structures you may require - you can always ask for more in
- *nfds_io. */
+ the call to poll() the supplied afterpoll function will be called. */
extern void register_for_poll(void *st, beforepoll_fn *before,
- afterpoll_fn *after, int32_t max_nfds,
- cstring_t desc);
+ afterpoll_fn *after, cstring_t desc);
/***** END of scheduling support */
/* We are interested in poll(), but only for timeouts. We don't have
any fds of our own. */
- register_for_poll(st, site_beforepoll, site_afterpoll, 0, "site");
+ register_for_poll(st, site_beforepoll, site_afterpoll, "site");
st->timeout=0;
st->remote_capabilities=0;
if (newphase==PHASE_RUN) {
userv_invoke_userv(st);
/* Register for poll() */
- register_for_poll(st, userv_beforepoll, userv_afterpoll, 2,
+ register_for_poll(st, userv_beforepoll, userv_afterpoll,
st->slip.nl.name);
}
if (newphase==PHASE_SHUTDOWN) {
}
/* Register for poll() */
- register_for_poll(st, tun_beforepoll, tun_afterpoll, 1, st->nl.name);
+ register_for_poll(st, tun_beforepoll, tun_afterpoll, st->nl.name);
}
static list_t *tun_create(closure_t *self, struct cloc loc, dict_t *context,
for (i=0; i<st->n_socks; i++)
udp_make_socket(st,&st->socks[i]);
- register_for_poll(st,udp_beforepoll,udp_afterpoll,MAX_SOCKETS,"udp");
+ register_for_poll(st,udp_beforepoll,udp_afterpoll,"udp");
}
static list_t *udp_apply(closure_t *self, struct cloc loc, dict_t *context,