Searched refs:ordered_queue (Results 1 – 1 of 1) sorted by relevance
39 ordered_queue: RwLock<PendingBaseQueue>, field80 let mut ordered_queue = self.ordered_queue.write(); in push() localVariable130 let mut ordered_queue = self.ordered_queue.write(); in append_large() localVariable153 let mut ordered_queue = self.ordered_queue.write(); in append_unlimited() localVariable158 ordered_queue.extend(chunks); in append_unlimited()172 let ordered_queue = self.ordered_queue.read(); in peek() localVariable186 let ordered_queue = self.ordered_queue.read(); in peek() localVariable187 ordered_queue.get(0).cloned() in peek()200 let mut ordered_queue = self.ordered_queue.write(); in pop() localVariable201 ordered_queue.pop_front() in pop()[all …]