Lines Matching refs:queues
136 struct bufq_state *queues[UDF_SHED_MAX]; member
260 bufq_put(priv->queues[newqueue], eccline->buf); in udf_push_eccline()
279 buf = bufq_peek(priv->queues[queued_on]); in udf_peek_eccline()
313 buf = bufq_get(priv->queues[queued_on]); in udf_pop_eccline()
356 ret = bufq_cancel(priv->queues[eccline->queued_on], eccline->buf); in udf_unqueue_eccline()
1299 if (bufq_peek(priv->queues[UDF_SHED_READING])) in udf_discstrat_thread()
1301 if (bufq_peek(priv->queues[UDF_SHED_WRITING])) in udf_discstrat_thread()
1303 if (bufq_peek(priv->queues[UDF_SHED_SEQWRITING])) in udf_discstrat_thread()
1323 work = (bufq_peek(priv->queues[UDF_SHED_WAITING]) != NULL); in udf_discstrat_thread()
1324 work |= (bufq_peek(priv->queues[UDF_SHED_READING]) != NULL); in udf_discstrat_thread()
1325 work |= (bufq_peek(priv->queues[UDF_SHED_WRITING]) != NULL); in udf_discstrat_thread()
1326 work |= (bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) != NULL); in udf_discstrat_thread()
1329 (bufq_peek(priv->queues[UDF_SHED_READING]) != NULL), in udf_discstrat_thread()
1330 (bufq_peek(priv->queues[UDF_SHED_WRITING]) != NULL), in udf_discstrat_thread()
1331 (bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) != NULL), in udf_discstrat_thread()
1339 KASSERT(bufq_peek(priv->queues[UDF_SHED_WAITING]) == NULL); in udf_discstrat_thread()
1340 KASSERT(bufq_peek(priv->queues[UDF_SHED_IDLE]) == NULL); in udf_discstrat_thread()
1341 KASSERT(bufq_peek(priv->queues[UDF_SHED_READING]) == NULL); in udf_discstrat_thread()
1342 KASSERT(bufq_peek(priv->queues[UDF_SHED_WRITING]) == NULL); in udf_discstrat_thread()
1343 KASSERT(bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) == NULL); in udf_discstrat_thread()
1437 bufq_alloc(&priv->queues[UDF_SHED_WAITING], "fcfs", in udf_discstrat_init_rmw()
1439 bufq_alloc(&priv->queues[UDF_SHED_READING], "disksort", in udf_discstrat_init_rmw()
1441 bufq_alloc(&priv->queues[UDF_SHED_WRITING], "disksort", in udf_discstrat_init_rmw()
1443 bufq_alloc(&priv->queues[UDF_SHED_SEQWRITING], "disksort", 0); in udf_discstrat_init_rmw()
1446 bufq_alloc(&priv->queues[UDF_SHED_IDLE], "fcfs", 0); in udf_discstrat_init_rmw()
1447 bufq_alloc(&priv->queues[UDF_SHED_FREE], "fcfs", 0); in udf_discstrat_init_rmw()