Lines Matching defs:runq
154 run_queue_t runq,
1194 other_runnable = processor->runq.count > 0 || rt_runq.count > 0;
1210 register run_queue_t runq = &rt_runq;
1213 q = runq->queues + runq->highq;
1219 thread->runq = PROCESSOR_NULL;
1220 runq->count--; runq->urgency--;
1221 assert(runq->urgency >= 0);
1223 if (runq->highq != IDLEPRI)
1224 clrbit(MAXPRI - runq->highq, runq->bitmap);
1225 runq->highq = MAXPRI - ffsbit(runq->bitmap);
1241 (processor->runq.highq < thread->sched_pri &&
1250 pset_count_hint(pset, processor, processor->runq.count);
1261 if (processor->runq.count > 0 && processor->runq.highq >= rt_runq.highq) {
1264 thread = run_queue_dequeue(&processor->runq, SCHED_HEADQ);
1269 pset_count_hint(pset, processor, processor->runq.count);
1317 if (processor->runq.count > 0 || rt_runq.count > 0)
1607 assert(self->runq == PROCESSOR_NULL);
1980 thread->runq = PROCESSOR_NULL;
2037 thread->runq = RT_RUNQ;
2105 run_queue_t rq = &processor->runq;
2124 thread->runq = processor;
2297 ( thread->sched_pri <= BASEPRI_DEFAULT && cset->low_count->runq.count < processor->runq.count))) {
2399 assert(thread->runq == PROCESSOR_NULL);
2492 run_queue_t rq = &processor->runq;
2508 thread->runq = PROCESSOR_NULL;
2551 run_queue_t runq;
2554 runq = &rt_runq;
2555 if (runq->highq >= BASEPRI_RTQUEUES)
2558 if (runq->highq > processor->current_pri) {
2559 if (runq->urgency > 0)
2565 runq = &processor->runq;
2566 if (runq->highq > processor->current_pri) {
2567 if (runq->urgency > 0)
2574 runq = &rt_runq;
2575 if (runq->highq >= processor->current_pri) {
2576 if (runq->urgency > 0)
2582 runq = &processor->runq;
2583 if (runq->highq >= processor->current_pri) {
2584 if (runq->urgency > 0)
2650 if (rq != thread->runq)
2651 panic("run_queue_check: thread runq");
2682 processor_t processor = thread->runq;
2701 rq = &processor->runq;
2709 if (processor == thread->runq) {
2727 thread->runq = PROCESSOR_NULL;
2734 assert(thread->runq == PROCESSOR_NULL);
2757 run_queue_t rq = &processor->runq;
2768 thread->runq = PROCESSOR_NULL;
2813 if (processor->runq.count > 0) {
2872 while (processor->next_thread == THREAD_NULL && processor->runq.count == 0 && rt_runq.count == 0 &&
2901 if ( processor->runq.highq > new_thread->sched_pri ||
3150 * Scan a runq for candidate threads.
3156 run_queue_t runq)
3162 if ((count = runq->count) > 0) {
3163 q = runq->queues + runq->highq;
3201 restart_needed = runq_scan(&processor->runq);