293 rf_DiskIOEnqueue(RF_DiskQueue_t *queue, RF_DiskQueueData_t *req, int pri)  in rf_DiskIOEnqueue()  argument
304 	RF_LOCK_QUEUE_MUTEX(queue, "DiskIOEnqueue");  in rf_DiskIOEnqueue()
305 	if (RF_OK_TO_DISPATCH(queue, req)) {  in rf_DiskIOEnqueue()
306 		Dprintf2("Dispatching pri %d regular op to c %d (ok to dispatch)\n", pri, queue->col);  in rf_DiskIOEnqueue()
307 		rf_DispatchKernelIO(queue, req);  in rf_DiskIOEnqueue()
309 		queue->queueLength++;	/* increment count of number of requests waiting in this queue */  in rf_DiskIOEnqueue()
310 		Dprintf2("Enqueueing pri %d regular op to c %d (not ok to dispatch)\n", pri, queue->col);  in rf_DiskIOEnqueue()
311 		req->queue = (void *) queue;  in rf_DiskIOEnqueue()
312 		(queue->qPtr->Enqueue) (queue->qHdr, req, pri);  in rf_DiskIOEnqueue()
314 	RF_UNLOCK_QUEUE_MUTEX(queue, "DiskIOEnqueue");  in rf_DiskIOEnqueue()
320 rf_DiskIOComplete(RF_DiskQueue_t *queue, RF_DiskQueueData_t *req, int status)  in rf_DiskIOComplete()  argument
324 	RF_LOCK_QUEUE_MUTEX(queue, "DiskIOComplete");  in rf_DiskIOComplete()
325 	queue->numOutstanding--;  in rf_DiskIOComplete()
326 	RF_ASSERT(queue->numOutstanding >= 0);  in rf_DiskIOComplete()
332 	while (!done && !RF_QUEUE_FULL(queue)) {  in rf_DiskIOComplete()
333 		req = (queue->qPtr->Dequeue) (queue->qHdr);  in rf_DiskIOComplete()
335 …	Dprintf2("DiskIOComplete: extracting pri %d req from queue at c %d\n", req->priority, queue->col);  in rf_DiskIOComplete()
336 			queue->queueLength--;	/* decrement count of number of requests waiting in this queue */  in rf_DiskIOComplete()
337 			RF_ASSERT(queue->queueLength >= 0);  in rf_DiskIOComplete()
338 			if (RF_OK_TO_DISPATCH(queue, req)) {  in rf_DiskIOComplete()
339 …IOComplete: dispatching pri %d regular req to c %d (ok to dispatch)\n", req->priority, queue->col);  in rf_DiskIOComplete()
340 				rf_DispatchKernelIO(queue, req);  in rf_DiskIOComplete()
344 …	Dprintf2("DiskIOComplete: re-enqueueing pri %d regular req to c %d\n", req->priority, queue->col);  in rf_DiskIOComplete()
345 				queue->queueLength++;  in rf_DiskIOComplete()
346 				(queue->qPtr->Enqueue) (queue->qHdr, req, req->priority);  in rf_DiskIOComplete()
355 	RF_UNLOCK_QUEUE_MUTEX(queue, "DiskIOComplete");  in rf_DiskIOComplete()
363 rf_DiskIOPromote(RF_DiskQueue_t *queue, RF_StripeNum_t parityStripeID,  in rf_DiskIOPromote()  argument
368 	if (!queue->qPtr->Promote)  in rf_DiskIOPromote()
370 	RF_LOCK_QUEUE_MUTEX(queue, "DiskIOPromote");  in rf_DiskIOPromote()
371 	retval = (queue->qPtr->Promote) (queue->qHdr, parityStripeID, which_ru);  in rf_DiskIOPromote()
372 	RF_UNLOCK_QUEUE_MUTEX(queue, "DiskIOPromote");  in rf_DiskIOPromote()