Lines Matching full:workers

2  * daemon/daemon.c - collection of workers that handles requests.
39  * The daemon consists of global settings and a number of workers.
573 	daemon->workers = (struct worker**)calloc((size_t)daemon->num, 
575 	if(!daemon->workers)
587 		if(!(daemon->workers[i] = worker_create(daemon, i,
624 				tube_close_read(daemon->workers[i]->cmd);
627 				tube_delete(daemon->workers[i]->cmd);
628 				daemon->workers[i]->cmd = NULL;
677 		ub_thread_create(&daemon->workers[i]->thr_id,
678 			thread_start, daemon->workers[i]);
681 		tube_close_read(daemon->workers[i]->cmd);
699 		worker_send_cmd(daemon->workers[i], worker_cmd_quit);
705 		ub_thread_join(daemon->workers[i]->thr_id);
810 	if(!worker_init(daemon->workers[0], daemon->cfg, daemon->ports[0], 1))
814 	/* Now create the threads and init the workers.
824 	if(!worker_init(daemon->workers[0], daemon->cfg, daemon->ports[0], 1))
827 	signal_handling_playback(daemon->workers[0]);
842 	worker_work(daemon->workers[0]);
844 	if (daemon->workers[0]->need_to_exit)
857 	daemon->reuse_cache = daemon->workers[0]->reuse_cache;
858 	daemon->need_to_exit = daemon->workers[0]->need_to_exit;
901 		worker_delete(daemon->workers[i]);
902 	free(daemon->workers);
903 	daemon->workers = NULL;
905 	 * cleared and freed here. We do this after deleting workers to
907 	 * of workers. */