Lines Matching defs:pthread
39 #include <pthread.h>
138 _pq_remove(pq_queue_t *pq, pthread_t pthread)
140 int prio = pthread->active_priority;
147 PQ_ASSERT_IN_RUNQ(pthread, "_pq_remove: Not in priority queue");
157 TAILQ_REMOVE(&pq->pq_lists[prio].pl_head, pthread, pqe);
160 pthread->flags &= ~THR_FLAGS_IN_RUNQ;
167 _pq_insert_head(pq_queue_t *pq, pthread_t pthread)
176 PQ_ASSERT_NOT_QUEUED(pthread,
179 prio = pthread->active_priority;
180 TAILQ_INSERT_HEAD(&pq->pq_lists[prio].pl_head, pthread, pqe);
186 pthread->flags |= THR_FLAGS_IN_RUNQ;
193 _pq_insert_tail(pq_queue_t *pq, pthread_t pthread)
202 PQ_ASSERT_NOT_QUEUED(pthread,
205 prio = pthread->active_priority;
206 TAILQ_INSERT_TAIL(&pq->pq_lists[prio].pl_head, pthread, pqe);
212 pthread->flags |= THR_FLAGS_IN_RUNQ;
222 pthread_t pthread = NULL;
231 (pthread == NULL)) {
232 if ((pthread = TAILQ_FIRST(&pql->pl_head)) == NULL) {
245 return (pthread);
257 pthread_t pthread = NULL;
266 pql != NULL && pthread == NULL; pql = pqlnext) {
267 if ((pthread = TAILQ_FIRST(&pql->pl_head)) == NULL) {
288 while (pthread != NULL && !DBG_CAN_RUN(pthread)) {
289 pthread = TAILQ_NEXT(pthread, pqe);
291 if (pthread == NULL)
297 return (pthread);