Searched refs:process_queue (Results 1 – 15 of 15) sorted by relevance
89 self.process_queue()105 self.process_queue()107 def process_queue(self): member in open_usb_transport.UsbPacketSink
36 fn process_queue(&mut self) -> bool { in process_queue() method106 needs_interrupt |= self.process_queue(); in run()
72 fn process_queue(&mut self) -> P9Result<()> { in process_queue() method117 self.process_queue()?; in run()
83 fn process_queue(&mut self) -> NeedsInterrupt { in process_queue() method148 needs_interrupt |= self.process_queue(); in run()
92 def process_queue(): function117 t1 = threading.Thread(target=process_queue, daemon=True)119 t2 = threading.Thread(target=process_queue, daemon=True)140 def process_queue(): function146 t = threading.Thread(target=process_queue)
639 pub fn process_queue(&mut self, mem: &GuestMemory, queue: &dyn QueueReader) -> bool { in process_queue() method886 if self.state.process_queue(&self.mem, &self.cursor_queue) { in run()917 if ctrl_available && self.state.process_queue(&self.mem, &self.ctrl_queue) { in run()
214 fn process_queue( in process_queue() method350 self.process_queue(0, &mut flush_timer, &mut flush_timer_armed); in run()
59 let needs_interrupt = state.process_queue(&mem, &reader); in run_ctrl_queue()
14832 struct sk_buff_head process_queue; member40083 struct sk_buff_head___2 process_queue; member
109112 struct sk_buff_head process_queue; member
14587 struct sk_buff_head process_queue; member
96215 struct sk_buff_head process_queue; member