Searched defs:queue (Results 1 – 3 of 3) sorted by relevance
78 queue: [Mutex<VecDeque<Bytes>>; 2], field135 let mut queue = self.queue[id].lock().await; in push() localVariable141 let mut queue = self.queue[id].lock().await; in push() localVariable146 let mut queue = self.queue[id].lock().await; in push() localVariable156 let mut queue = self.queue[id].lock().await; in reorder() localVariable163 let mut queue = self.queue[id].lock().await; in drop_offset() localVariable181 let mut queue = self.queue[id].lock().await; in clear() localVariable193 let mut queue = self.queue[id].lock().await; in tick() localVariable
10 pub(crate) mod queue; module
94 queue: Arc<ChunkQueue>, // read-only field311 let queue = Arc::clone(&self.queue); in start() localVariable