Searched refs:queue (Results 1 – 7 of 7) sorted by relevance
135 let mut queue = self.queue[id].lock().await; in push() localVariable141 let mut queue = self.queue[id].lock().await; in push() localVariable142 queue.push_back(d); in push()146 let mut queue = self.queue[id].lock().await; in push() localVariable147 queue.push_back(d); in push()156 let mut queue = self.queue[id].lock().await; in reorder() localVariable157 inverse(&mut queue) in reorder()163 let mut queue = self.queue[id].lock().await; in drop_offset() localVariable181 let mut queue = self.queue[id].lock().await; in clear() localVariable182 queue.clear(); in clear()[all …]
94 queue: Arc<ChunkQueue>, // read-only field287 queue: Arc::new(ChunkQueue::new(queue_size)), in new()311 let queue = Arc::clone(&self.queue); in start() localVariable323 &queue, in start()415 if self.queue.push(c).await { in push()432 queue: &Arc<ChunkQueue>, in process_chunks()460 if let Some(c) = queue.peek().await { in process_chunks()475 if let Some(c) = queue.pop().await { in process_chunks()
10 pub(crate) mod queue; module
9 * Improve algorithm used to push to pending queue from O(n*log(n)) to O(log(n)) [#365](https://gith…22 * Fixed a possible bug when adding chunks to pending queue [#345](https://github.com/webrtc-rs/webr…
32 use crate::queue::control_queue::ControlQueue;33 use crate::queue::payload_queue::PayloadQueue;34 use crate::queue::pending_queue::PendingQueue;
7 use crate::queue::pending_queue::PendingQueue;8 use crate::queue::reassembly_queue::ReassemblyQueue;
217 "concurrent-queue",230 "concurrent-queue",260 "concurrent-queue",557 name = "concurrent-queue"1728 "concurrent-queue",