Lines Matching defs:worker
148 PRThread *thread; /* this worker objects thread */
161 PRCList list; /* head of worker list */
171 CSPool_t pool; /* statistics on worker threads */
173 struct /* controlling worker counts */
860 CSWorker_t *worker = PR_NEWZAP(CSWorker_t);
861 worker->server = server;
862 PR_INIT_CLIST(&worker->element);
864 Worker, worker, DEFAULT_SERVER_PRIORITY, PR_UNJOINABLE_THREAD);
865 if (PR_FAILURE == rv) PR_DELETE(worker);
868 ("\tCreateWorker(0x%p): create new worker (0x%p)\n",
869 PR_CurrentThread(), worker->thread));
879 CSWorker_t *worker = (CSWorker_t*)arg;
880 CSServer_t *server = worker->server;
883 PRThread *me = worker->thread = PR_CurrentThread();
890 PR_APPEND_LINK(&worker->element, &server->list);
936 ** Create another worker of the total number of workers is
981 PR_REMOVE_AND_INIT_LINK(&worker->element);
985 PR_DELETE(worker); /* destruction of the "worker" object */
1022 ** Create the first worker (actually, a thread that accepts
1024 ** From this point on, additional worker threads are created
1025 ** as they are needed by existing worker threads.
1052 ** Get all the worker threads to exit. They know how to
1063 CSWorker_t *worker = (CSWorker_t*)head;
1066 ("\tServer(0x%p): interrupting worker(0x%p)\n", me, worker));
1067 rv = PR_Interrupt(worker->thread);
1209 case 'w': /* minimum server worker threads */
1212 case 'W': /* maximum server worker threads */