Lines Matching refs:in_queue
877 in_queue: VecDeque<(u32 /* vfd_id */, WlRecv)>, field
902 in_queue: VecDeque::new(), in new()
1077 self.in_queue.push_back((vfd_id, WlRecv::Hup)); in process_wait_context()
1084 for (dest_vfd_id, q) in &self.in_queue { in close()
1097 self.in_queue.retain(|&(id, _)| id != vfd_id); in close()
1270 self.in_queue.push_back((vfd_id, WlRecv::Hup)); in recv()
1281 self.in_queue.push_back(( in recv()
1289 self.in_queue.push_back((vfd_id, WlRecv::Data { buf })); in recv()
1385 if let Some(q) = self.in_queue.front() { in next_recv()
1436 if let Some(q) = self.in_queue.front() { in pop_recv()
1461 self.in_queue.pop_front(); in pop_recv()
1468 in_queue: Queue, field
1477 in_queue: Queue, in new()
1488 in_queue, in new()
1557 in_desc_chains.extend(self.in_queue.iter(&self.mem).filter(|d| { in run()
1571 self.in_queue.add_used(&self.mem, reject, 0); in run()
1640 self.in_queue in run()
1645 self.in_queue.add_used(&self.mem, index, 0); in run()
1658 self.interrupt.signal_used_queue(self.in_queue.vector); in run()