Searched refs:process_queue (Results 1 – 8 of 8) sorted by relevance
43 fn process_queue(&mut self) -> bool { in process_queue() method113 needs_interrupt |= self.process_queue(); in run()
83 fn process_queue(&mut self) -> NeedsInterrupt { in process_queue() method148 needs_interrupt |= self.process_queue(); in run()
88 fn process_queue(&mut self) -> P9Result<()> { in process_queue() method134 self.process_queue()?; in run()
146 fn process_queue(&mut self) -> bool { in process_queue() method211 needs_interrupt |= self.process_queue(); in run()
312 fn process_queue( in process_queue() method448 self.process_queue(0, &mut flush_timer, &mut flush_timer_armed); in run()
155 fn process_queue(&mut self) -> Result<()> { in process_queue() method233 if let Err(e) = self.process_queue() { in run()
74 def process_queue(): function99 t1 = threading.Thread(target=process_queue, daemon=True)101 t2 = threading.Thread(target=process_queue, daemon=True)122 def process_queue(): function129 t = threading.Thread(target=process_queue)
521 fn process_queue(&mut self, mem: &GuestMemory, queue: &mut Queue) -> bool { in process_queue() method782 if self.state.process_queue(&self.mem, &mut self.cursor_queue) { in run()810 if ctrl_available && self.state.process_queue(&self.mem, &mut self.ctrl_queue) { in run()