Lines Matching defs:pq
9795 idn_protoqueue_t *pq;
9806 pq = &idn.protocol.p_serverq[*id];
9808 ASSERT(pq->q_id == *id);
9810 PR_PROTO("%s: id %d starting up (pq = 0x%p)\n",
9811 proc, pq->q_id, (void *)pq);
9815 mutex_enter(&pq->q_mutex);
9817 while (((jl = pq->q_joblist) == NULL) && !pq->q_die)
9818 cv_wait(&pq->q_cv, &pq->q_mutex);
9820 pq->q_joblist = pq->q_joblist_tail = NULL;
9822 if (pq->q_die) {
9827 pq->q_threadp = NULL;
9828 mutex_exit(&pq->q_mutex);
9830 proc, pq->q_id);
9835 sema_v(pq->q_morgue);
9839 mutex_exit(&pq->q_mutex);
9859 register idn_protoqueue_t *pq;
9866 pq = idn.protocol.p_serverq;
9867 for (i = 0; i < idn.nservers; pq++, i++) {
9868 mutex_enter(&pq->q_mutex);
9869 pq->q_die = 1;
9870 cv_signal(&pq->q_cv);
9871 mutex_exit(&pq->q_mutex);
9916 idn_protoqueue_t *pq;
9926 pq = &idn.protocol.p_serverq[serverid];
9933 mutex_enter(&pq->q_mutex);
9937 if (!pq->q_die) {
9938 if (pq->q_joblist_tail) {
9939 pq->q_joblist_tail->j_next = jp;
9940 pq->q_joblist_tail = jp;
9942 pq->q_joblist = pq->q_joblist_tail = jp;
9945 cv_signal(&pq->q_cv);
9951 mutex_exit(&pq->q_mutex);