Lines Matching refs:worker
190 signal_handling_playback(struct worker* wrk) in signal_handling_playback()
452 daemon->env->worker = NULL; in daemon_privileged()
468 daemon->env->worker = NULL; in daemon_setup_modules()
568 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
569 sizeof(struct worker*)); in daemon_create_workers()
637 struct worker* worker = (struct worker*)arg; in thread_start() local
639 log_thread_set(&worker->thread_num); in thread_start()
643 tube_close_write(worker->cmd); in thread_start()
644 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
647 if(worker->daemon->cfg->so_reuseport) in thread_start()
648 port_num = worker->thread_num % worker->daemon->num_ports; in thread_start()
652 if(!worker_init(worker, worker->daemon->cfg, in thread_start()
653 worker->daemon->ports[port_num], 0)) in thread_start()
656 worker_work(worker); in thread_start()