Home | History | Annotate | Download | only in udf

Lines Matching defs:queues

136 	struct bufq_state	 *queues[UDF_SHED_MAX];
260 	bufq_put(priv->queues[newqueue], eccline->buf);
279 		buf = bufq_peek(priv->queues[queued_on]);
313 		buf = bufq_get(priv->queues[queued_on]);
356 	ret = bufq_cancel(priv->queues[eccline->queued_on], eccline->buf);
1299 			if (bufq_peek(priv->queues[UDF_SHED_READING]))
1301 			if (bufq_peek(priv->queues[UDF_SHED_WRITING]))
1303 			if (bufq_peek(priv->queues[UDF_SHED_SEQWRITING]))
1323 		work  = (bufq_peek(priv->queues[UDF_SHED_WAITING]) != NULL);
1324 		work |= (bufq_peek(priv->queues[UDF_SHED_READING]) != NULL);
1325 		work |= (bufq_peek(priv->queues[UDF_SHED_WRITING]) != NULL);
1326 		work |= (bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) != NULL);
1329 			(bufq_peek(priv->queues[UDF_SHED_READING]) != NULL),
1330 			(bufq_peek(priv->queues[UDF_SHED_WRITING]) != NULL),
1331 			(bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) != NULL),
1339 	KASSERT(bufq_peek(priv->queues[UDF_SHED_WAITING]) == NULL);
1340 	KASSERT(bufq_peek(priv->queues[UDF_SHED_IDLE]) == NULL);
1341 	KASSERT(bufq_peek(priv->queues[UDF_SHED_READING]) == NULL);
1342 	KASSERT(bufq_peek(priv->queues[UDF_SHED_WRITING]) == NULL);
1343 	KASSERT(bufq_peek(priv->queues[UDF_SHED_SEQWRITING]) == NULL);
1432 	/* initialise main queues */
1437 	bufq_alloc(&priv->queues[UDF_SHED_WAITING], "fcfs",
1439 	bufq_alloc(&priv->queues[UDF_SHED_READING], "disksort",
1441 	bufq_alloc(&priv->queues[UDF_SHED_WRITING], "disksort",
1443 	bufq_alloc(&priv->queues[UDF_SHED_SEQWRITING], "disksort", 0);
1445 	/* initialise administrative queues */
1446 	bufq_alloc(&priv->queues[UDF_SHED_IDLE], "fcfs", 0);
1447 	bufq_alloc(&priv->queues[UDF_SHED_FREE], "fcfs", 0);