Lines Matching defs:worker
146 PRThread *thread; /* this worker objects thread */
159 PRCList list; /* head of worker list */
169 CSPool_t pool; /* statistics on worker threads */
171 struct /* controlling worker counts */
645 CSWorker_t *worker = PR_NEWZAP(CSWorker_t);
646 worker->server = server;
647 PR_INIT_CLIST(&worker->element);
648 worker->thread = PR_CreateThread(
649 PR_USER_THREAD, Worker, worker,
652 if (NULL == worker->thread)
654 PR_DELETE(worker);
659 ("\tCreateWorker(0x%p): create new worker (0x%p)\n",
660 PR_CurrentThread(), worker->thread));
671 CSWorker_t *worker = (CSWorker_t*)arg;
672 CSServer_t *server = worker->server;
680 PR_APPEND_LINK(&worker->element, &server->list);
726 ** Create another worker of the total number of workers is
771 PR_REMOVE_AND_INIT_LINK(&worker->element);
775 PR_DELETE(worker); /* destruction of the "worker" object */
815 ** Create the first worker (actually, a thread that accepts
817 ** From this point on, additional worker threads are created
818 ** as they are needed by existing worker threads.
845 ** Get all the worker threads to exit. They know how to
856 CSWorker_t *worker = (CSWorker_t*)head;
859 ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker));
860 rv = PR_Interrupt(worker->thread);
992 case 'w': /* minimum server worker threads */
995 case 'W': /* maximum server worker threads */