1553 		TAILQ_INIT(&stream->operations[DISPATCH_IO_RANDOM]);  in _dispatch_stream_init()
1554 		TAILQ_INIT(&stream->operations[DISPATCH_IO_STREAM]);  in _dispatch_stream_init()
1568 	dispatch_assert(TAILQ_EMPTY(&stream->operations[DISPATCH_IO_STREAM]));  in _dispatch_stream_dispose()
1569 	dispatch_assert(TAILQ_EMPTY(&stream->operations[DISPATCH_IO_RANDOM]));  in _dispatch_stream_dispose()
1606 	TAILQ_INIT(&disk->operations);  in _dispatch_disk_init()
1607 	disk->cur_rq = TAILQ_FIRST(&disk->operations);  in _dispatch_disk_init()
1622 	dispatch_assert(TAILQ_EMPTY(&disk->operations));  in _dispatch_disk_dispose()
1636 	return  !(TAILQ_EMPTY(&stream->operations[DISPATCH_IO_RANDOM])) ||  in _dispatch_stream_operation_avail()
1637 			!(TAILQ_EMPTY(&stream->operations[DISPATCH_IO_STREAM]));  in _dispatch_stream_operation_avail()
1649 	TAILQ_INSERT_TAIL(&stream->operations[op->params.type], op, operation_list);  in _dispatch_stream_enqueue_operation()
1666 			TAILQ_INSERT_TAIL(&disk->operations, op, operation_list);  in _dispatch_disk_enqueue_operation()
1670 		TAILQ_INSERT_TAIL(&disk->operations, op, operation_list);  in _dispatch_disk_enqueue_operation()
1682 	TAILQ_REMOVE(&stream->operations[op->params.type], op, operation_list);  in _dispatch_stream_complete_operation()
1709 			TAILQ_INSERT_TAIL(&disk->operations, op_next, operation_list);  in _dispatch_disk_complete_operation()
1712 	TAILQ_REMOVE(&disk->operations, op, operation_list);  in _dispatch_disk_complete_operation()
1730 		if (!TAILQ_EMPTY(&stream->operations[DISPATCH_IO_STREAM])) {  in _dispatch_stream_pick_next_operation()
1731 			op = TAILQ_FIRST(&stream->operations[DISPATCH_IO_STREAM]);  in _dispatch_stream_pick_next_operation()
1732 		} else if (!TAILQ_EMPTY(&stream->operations[DISPATCH_IO_RANDOM])) {  in _dispatch_stream_pick_next_operation()
1733 			op = TAILQ_FIRST(&stream->operations[DISPATCH_IO_RANDOM]);  in _dispatch_stream_pick_next_operation()
1746 			op = TAILQ_FIRST(&stream->operations[DISPATCH_IO_RANDOM]);  in _dispatch_stream_pick_next_operation()
1758 	if (!TAILQ_EMPTY(&disk->operations)) {  in _dispatch_disk_pick_next_operation()
1760 			op = TAILQ_FIRST(&disk->operations);  in _dispatch_disk_pick_next_operation()
1766 					op = TAILQ_FIRST(&disk->operations);  in _dispatch_disk_pick_next_operation()
1785 	typeof(*stream->operations) *operations;  in _dispatch_stream_cleanup_operations()
1786 	operations = &stream->operations[DISPATCH_IO_RANDOM];  in _dispatch_stream_cleanup_operations()
1787 	TAILQ_FOREACH_SAFE(op, operations, operation_list, tmp) {  in _dispatch_stream_cleanup_operations()
1792 	operations = &stream->operations[DISPATCH_IO_STREAM];  in _dispatch_stream_cleanup_operations()
1793 	TAILQ_FOREACH_SAFE(op, operations, operation_list, tmp) {  in _dispatch_stream_cleanup_operations()
1809 	TAILQ_FOREACH_SAFE(op, &disk->operations, operation_list, tmp) {  in _dispatch_disk_cleanup_operations()