Lines Matching refs:tp
126 PRThreadPool *tp;
134 PRThreadPool *tp;
145 PRThreadPool *tp;
176 jobp = PR_QueueJob_Read(sp->tp, &sp->iod, serve_client_read, sp,
185 jobp = PR_QueueJob_Write(sp->tp, &sp->iod, serve_client_write, sp,
217 jobp = PR_QueueJob_Read(sp->tp, &sp->iod, serve_client_read, sp,
268 sp->tp = scp->tp;
273 jobp = PR_QueueJob_Read(sp->tp, &sp->iod, serve_client_read, sp,
283 PRThreadPool *tp = sp->tp;
294 jobp = PR_QueueJob_Timer(tp, PR_MillisecondsToInterval(500),
315 PRThreadPool *tp = (PRThreadPool *) arg;
380 sp->tp = tp;
384 jobp = PR_QueueJob_Accept(tp, &sp->iod, TCP_Server_Accept, sp,
441 sp->tp = tp;
445 jobp = PR_QueueJob_Timer(tp, PR_MillisecondsToInterval(5000),
453 jobp = PR_QueueJob_Accept(tp, &sp->iod, TCP_Server_Accept, sp,
463 PRThreadPool *tp = sp->tp;
489 scp->tp = sp->tp;
494 jobp = PR_QueueJob(tp, Serve_Client, scp,
506 jobp = PR_QueueJob_Accept(tp, &sp->iod, TCP_Server_Accept, sp,
511 jobp = PR_QueueJob_Timer(tp, PR_MillisecondsToInterval(500),
538 PR_ShutdownThreadPool(sp->tp);
554 PRThreadPool *tp = NULL;
588 tp = PR_CreateThreadPool(initial_threads, max_threads, stacksize);
589 if (NULL == tp) {
594 jobp = PR_QueueJob(tp, TCP_Server, tp, PR_TRUE);
599 rv = PR_JoinThreadPool(tp);