Lines Matching defs:worker
70 #include "daemon/worker.h"
187 * @param wrk: worker that handles signals.
190 signal_handling_playback(struct worker* wrk)
452 daemon->env->worker = NULL;
468 daemon->env->worker = NULL;
513 * Clear and delete per-worker alloc caches, and free memory maintained in
537 * Allocate empty worker structures. With backptr and thread-number,
574 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
575 sizeof(struct worker*));
592 fatal_exit("could not create worker");
594 /* create per-worker alloc caches if not reusing existing ones. */
599 fatal_exit("could not allocate worker allocs");
604 fatal_exit("could not allocate worker alloc");
643 struct worker* worker = (struct worker*)arg;
645 log_thread_set(&worker->thread_num);
649 tube_close_write(worker->cmd);
650 close_other_pipes(worker->daemon, worker->thread_num);
653 if(worker->daemon->cfg->so_reuseport)
654 port_num = worker->thread_num % worker->daemon->num_ports;
658 if(!worker_init(worker, worker->daemon->cfg,
659 worker->daemon->ports[port_num], 0))
662 worker_work(worker);
804 /* first create all the worker structures, so we can pass
867 /* before stopping main worker, handle signals ourselves, so we
901 /* Unless we're trying to keep the cache, worker alloc_caches should be