Lines Matching defs:sstfq
247 RF_Sstf_t *sstfq;
249 sstfq = RF_MallocAndAdd(sizeof(*sstfq), cl_list);
250 sstfq->dir = DIR_EITHER;
251 sstfq->allow_reverse = 1;
252 return ((void *) sstfq);
285 RF_Sstf_t *sstfq;
287 sstfq = (RF_Sstf_t *) qptr;
297 sstfq->left.qlen, sstfq->right.qlen,
298 sstfq->lopri.qlen);
301 do_sstf_ord_q(&sstfq->lopri.queue, &sstfq->lopri.qtail, req);
302 sstfq->lopri.qlen++;
304 if (req->sectorOffset < sstfq->last_sector) {
305 do_sstf_ord_q(&sstfq->left.queue, &sstfq->left.qtail, req);
306 sstfq->left.qlen++;
308 do_sstf_ord_q(&sstfq->right.queue, &sstfq->right.qtail, req);
309 sstfq->right.qlen++;
346 RF_Sstf_t *sstfq;
348 sstfq = (RF_Sstf_t *) qptr;
354 RF_ASSERT(QSUM(sstfq) == dq->queueLength);
357 sstfq->left.qlen, sstfq->right.qlen, sstfq->lopri.qlen);
360 if (sstfq->left.queue == NULL) {
361 RF_ASSERT(sstfq->left.qlen == 0);
362 if (sstfq->right.queue == NULL) {
363 RF_ASSERT(sstfq->right.qlen == 0);
364 if (sstfq->lopri.queue == NULL) {
365 RF_ASSERT(sstfq->lopri.qlen == 0);
374 req = closest_to_arm(&sstfq->lopri, sstfq->last_sector,
375 &sstfq->dir, sstfq->allow_reverse);
384 do_dequeue(&sstfq->lopri, req);
386 DO_BEST_DEQ(sstfq->last_sector, req, &sstfq->right);
389 if (sstfq->right.queue == NULL) {
390 RF_ASSERT(sstfq->right.qlen == 0);
391 DO_BEST_DEQ(sstfq->last_sector, req, &sstfq->left);
393 if (SNUM_DIFF(sstfq->last_sector, sstfq->right.queue->sectorOffset)
394 < SNUM_DIFF(sstfq->last_sector, sstfq->left.qtail->sectorOffset)) {
395 DO_HEAD_DEQ(req, &sstfq->right);
397 DO_TAIL_DEQ(req, &sstfq->left);
402 sstfq->last_sector = req->sectorOffset;
516 RF_Sstf_t *sstfq;
519 sstfq = (RF_Sstf_t *) qptr;
522 for (r = sstfq->lopri.queue; r; r = next) {
532 do_dequeue(&sstfq->lopri, r);
540 r->raidPtr->raidid, n, sstfq->left.qlen,
541 sstfq->right.qlen, sstfq->lopri.qlen);