Lines Matching refs:queue_event
350 mut queue_event: EventAsync, in handle_queue()
360 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_queue()
402 mut queue_event: EventAsync, in handle_reporting_queue()
412 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_reporting_queue()
451 mut queue_event: EventAsync, in handle_stats_queue()
459 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_stats_queue()
491 avail_desc = match queue.next_async(&mut queue_event).await { in handle_stats_queue()
542 mut queue_event: EventAsync, in handle_ws_op_queue()
563 .next_async(&mut queue_event) in handle_ws_op_queue()
638 mut queue_event: EventAsync, in handle_ws_data_queue()
646 .next_async_interruptable(&mut queue_event, &mut stop_rx) in handle_ws_data_queue()