Searched refs:event_queue (Results 1 – 3 of 3) sorted by relevance
290 while (event_queue.size() > 0) { in handle_no_ops()302 event_queue.pop(); in handle_no_ops()332 if (event_queue.size() == 0) { in wait_for_event()344 event_queue.pop(); in wait_for_command_complete_event()363 event_queue.pop(); in setBufferSizes()414 event_queue.pop(); in sendAndCheckHCI()520 if (event_queue.size() == 0) { in wait_for_completed_packets_event()526 event_queue.pop(); in wait_for_completed_packets_event()557 event_queue.pop(); in enterLoopbackMode()611 event_queue.pop(); in TEST_P()[all …]
302 while (event_queue.size() > 0) { in handle_no_ops()314 event_queue.pop(); in handle_no_ops()344 if (event_queue.size() == 0) { in wait_for_event()356 event_queue.pop(); in wait_for_command_complete_event()375 event_queue.pop(); in setBufferSizes()426 event_queue.pop(); in sendAndCheckHCI()543 if (event_queue.size() == 0) { in wait_for_completed_packets_event()549 event_queue.pop(); in wait_for_completed_packets_event()580 event_queue.pop(); in enterLoopbackMode()634 event_queue.pop(); in TEST_P()[all …]
43 self.event_queue = SimpleQueue()49 self.event_queue.put(self.filter_fn(event))52 return self.event_queue77 self.event_queue = SimpleQueue()83 return self.event_queue151 self.event_queue.put(event)194 current_event = self.event_queue.get(timeout=remaining.total_seconds())