Lines Matching defs:worker
70 #include "daemon/worker.h"
187 * @param wrk: worker that handles signals.
190 signal_handling_playback(struct worker* wrk)
451 daemon->env->worker = NULL;
467 daemon->env->worker = NULL;
512 * Clear and delete per-worker alloc caches, and free memory maintained in
536 * Allocate empty worker structures. With backptr and thread-number,
573 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
574 sizeof(struct worker*));
591 fatal_exit("could not create worker");
593 /* create per-worker alloc caches if not reusing existing ones. */
598 fatal_exit("could not allocate worker allocs");
603 fatal_exit("could not allocate worker alloc");
642 struct worker* worker = (struct worker*)arg;
644 log_thread_set(&worker->thread_num);
648 tube_close_write(worker->cmd);
649 close_other_pipes(worker->daemon, worker->thread_num);
652 if(worker->daemon->cfg->so_reuseport)
653 port_num = worker->thread_num % worker->daemon->num_ports;
657 if(!worker_init(worker, worker->daemon->cfg,
658 worker->daemon->ports[port_num], 0))
661 worker_work(worker);
803 /* first create all the worker structures, so we can pass
866 /* before stopping main worker, handle signals ourselves, so we
904 /* Unless we're trying to keep the cache, worker alloc_caches should be