Lines Matching defs:Queue
347 mut queue: Queue, in handle_queue()
399 mut queue: Queue, in handle_reporting_queue()
448 mut queue: Queue, in handle_stats_queue()
455 ) -> Queue { in handle_stats_queue()
539 mut queue: Queue, in handle_ws_op_queue()
544 ) -> Result<Queue> { in handle_ws_op_queue()
635 mut queue: Queue, in handle_ws_data_queue()
641 ) -> Result<Queue> { in handle_ws_data_queue()
792 fn new(inflate: Queue, deflate: Queue) -> Self { in new()
815 fn new(inflate: Queue, deflate: Queue) -> Self { in new()
827 fn apply_if_some<F, R>(queue_opt: Option<Queue>, mut func: F) in apply_if_some()
837 fn from(queues: Box<PausedQueues>) -> BTreeMap<usize, Queue> { in from() argument
866 inflate_queue: Queue, in run_worker()
867 deflate_queue: Queue, in run_worker()
868 stats_queue: Option<Queue>, in run_worker()
869 reporting_queue: Option<Queue>, in run_worker()
870 ws_data_queue: Option<Queue>, in run_worker()
871 ws_op_queue: Option<Queue>, in run_worker()
1294 mut queues: BTreeMap<usize, Queue>, in get_queues_from_map() argument
1297 queues: &mut BTreeMap<usize, Queue>, in get_queues_from_map() argument
1300 ) -> anyhow::Result<Queue> { in get_queues_from_map()
1458 queues: BTreeMap<usize, Queue>, in activate() argument
1469 fn virtio_sleep(&mut self) -> anyhow::Result<Option<BTreeMap<usize, Queue>>> { in virtio_sleep() argument
1484 queues_state: Option<(GuestMemory, Interrupt, BTreeMap<usize, Queue>)>, in virtio_wake() argument