for (unsigned proto = IO_UDP; proto <= IO_TCP; ++proto) {
dt_unit_t *tu = s->handlers[proto].handler.unit;
for (unsigned i = 0; i < tu->size; ++i) {
- s->handlers[proto].handler.thread_state[i] |= ServerReload;
s->handlers[proto].handler.thread_id[i] = thread_count++;
}
}
typedef enum {
ServerIdle = 0 << 0, /*!< Server is idle. */
ServerRunning = 1 << 0, /*!< Server is running. */
- ServerReload = 1 << 1 /*!< Server reload requested. */
} server_state;
/*!
}
iohandler_t *handler = (iohandler_t *)thread->data;
- unsigned *iostate = &handler->thread_state[dt_get_id(thread)];
int ret = KNOT_EOK;
update_sweep_timer(&next_sweep);
update_tcp_conf(&tcp);
-/* XXX This should likely be removed. */
- /* Check handler state. */
- if (*iostate & ServerReload) {
- *iostate &= ~ServerReload;
- ref_release(ref);
- }
-/* XXX */
-
-/* XXX The return value isn't checked. */
+ /* Set descriptors for the configured interfaces. */
+/* XXX The return value isn't used. */
+/* XXX Server_set_ifaces() needs to be cleaned and moved to this file. */
server_set_ifaces(handler->server, &tcp.set, IO_TCP, tcp.thread_id);
if (tcp.set.n == 0) {
goto finish; /* Terminate on zero interfaces. */
/* Prepare structures for bound sockets. */
unsigned thr_id = dt_get_id(thread);
iohandler_t *handler = (iohandler_t *)thread->data;
- unsigned *iostate = &handler->thread_state[thr_id];
void *rq = _udp_init();
ifacelist_t *ifaces = NULL;
struct pollfd *fds = NULL;
nfds_t nfds = 0;
-/* XXX This should likely be removed. */
- /* Check handler state. */
- if (*iostate & ServerReload) {
- *iostate &= ~ServerReload;
- }
/* XXX */
-
udp.thread_id = handler->thread_id[thr_id];
rcu_read_lock();
ifaces = handler->server->ifaces;