Lines Matching refs:queue

120 	_r_ = (_q_)->queue; \
122 (_q_)->queue = (_r_)->next; \
126 RF_ASSERT((_q_)->queue == NULL); \
130 RF_ASSERT((_q_)->queue->prev == (_r_)); \
131 (_q_)->queue->prev = NULL; \
142 RF_ASSERT((_r_) == (_q_)->queue); \
144 (_q_)->queue = NULL; \
153 if (SNUM_DIFF((_q_)->queue->sectorOffset,_l_) \
164 closest_to_arm(RF_SstfQ_t *queue, RF_SectorNum_t arm_pos, int *dir, int allow_reverse) in closest_to_arm() argument
171 for (r = queue->queue; r; r = r->next) { in closest_to_arm()
238 return (queue->queue); in closest_to_arm()
293 dq = (RF_DiskQueue_t *) req->queue; in rf_SstfEnqueue()
301 do_sstf_ord_q(&sstfq->lopri.queue, &sstfq->lopri.qtail, req); in rf_SstfEnqueue()
305 do_sstf_ord_q(&sstfq->left.queue, &sstfq->left.qtail, req); in rf_SstfEnqueue()
308 do_sstf_ord_q(&sstfq->right.queue, &sstfq->right.qtail, req); in rf_SstfEnqueue()
315 do_dequeue(RF_SstfQ_t *queue, RF_DiskQueueData_t *req) in do_dequeue() argument
324 if (req == queue->queue) { in do_dequeue()
325 DO_HEAD_DEQ(req2, queue); in do_dequeue()
328 if (req == queue->qtail) { in do_dequeue()
329 DO_TAIL_DEQ(req2, queue); in do_dequeue()
335 queue->qlen--; in do_dequeue()
353 dq = (RF_DiskQueue_t *) req->queue; in rf_SstfDequeue()
360 if (sstfq->left.queue == NULL) { in rf_SstfDequeue()
362 if (sstfq->right.queue == NULL) { in rf_SstfDequeue()
364 if (sstfq->lopri.queue == NULL) { in rf_SstfDequeue()
389 if (sstfq->right.queue == NULL) { in rf_SstfDequeue()
393 if (SNUM_DIFF(sstfq->last_sector, sstfq->right.queue->sectorOffset) in rf_SstfDequeue()
417 dq = (RF_DiskQueue_t *) req->queue; in rf_ScanDequeue()
424 if (scanq->left.queue == NULL) { in rf_ScanDequeue()
426 if (scanq->right.queue == NULL) { in rf_ScanDequeue()
428 if (scanq->lopri.queue == NULL) { in rf_ScanDequeue()
442 if (scanq->right.queue == NULL) { in rf_ScanDequeue()
444 RF_ASSERT(scanq->left.queue); in rf_ScanDequeue()
448 RF_ASSERT(scanq->right.queue); in rf_ScanDequeue()
449 RF_ASSERT(scanq->left.queue); in rf_ScanDequeue()
473 dq = (RF_DiskQueue_t *) req->queue; in rf_CscanDequeue()
481 if (cscanq->right.queue) { in rf_CscanDequeue()
485 if (cscanq->left.queue == NULL) { in rf_CscanDequeue()
487 if (cscanq->lopri.queue == NULL) { in rf_CscanDequeue()
503 cscanq->left.queue = cscanq->left.qtail = NULL; in rf_CscanDequeue()
522 for (r = sstfq->lopri.queue; r; r = next) { in rf_SstfPromote()