Home
last modified time | relevance | path

Searched refs:q (Results 1 – 9 of 9) sorted by relevance

/webrtc/util/src/vnet/chunk_queue/
H A Dchunk_queue_test.rs17 let q = ChunkQueue::new(0); in test_chunk_queue() localVariable
19 let d = q.peek().await; in test_chunk_queue()
22 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
25 let d = q.pop().await; in test_chunk_queue()
31 let d = q.pop().await; in test_chunk_queue()
34 let q = ChunkQueue::new(1); in test_chunk_queue() localVariable
35 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
38 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
41 let d = q.peek().await; in test_chunk_queue()
/webrtc/mdns/src/message/
H A Dmod.rs249 let v: Vec<String> = self.questions.iter().map(|q| q.to_string()).collect(); in fmt()
253 let v: Vec<String> = self.answers.iter().map(|q| q.to_string()).collect(); in fmt()
257 let v: Vec<String> = self.authorities.iter().map(|q| q.to_string()).collect(); in fmt()
261 let v: Vec<String> = self.additionals.iter().map(|q| q.to_string()).collect(); in fmt()
H A Dbuilder.rs144 pub fn add_question(&mut self, q: &Question) -> Result<()> { in add_question()
153 msg = q.pack(msg, &mut self.compression, self.start)?; in add_question()
H A Dparser.rs137 Ok(q) => qs.push(q), in all_questions()
H A Dmessage_test.rs1049 for q in &msg.questions { in test_builder()
1050 b.add_question(q)?; in test_builder()
/webrtc/sctp/src/association/
H A Dassociation_test.rs276 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_simple() localVariable
379 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_ordered_reordered() localVariable
446 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_ordered_fragmented_then_defragmented() localVariable
513 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_unordered_fragmented_then_defragmented() localVariable
606 let q = s0.reassembly_queue.lock().await; in test_assoc_reliable_unordered_ordered() localVariable
1109 q.unordered.len(), in test_assoc_unreliable_rexmit_unordered_fragment()
1114 q.unordered_chunks.len(), in test_assoc_unreliable_rexmit_unordered_fragment()
1289 q.unordered.len(), in test_assoc_unreliable_rexmit_timed_unordered()
1294 q.unordered_chunks.len(), in test_assoc_unreliable_rexmit_timed_unordered()
1478 q.is_readable() in test_assoc_congestion_control_congestion_avoidance()
[all …]
/webrtc/mdns/src/conn/
H A Dmod.rs302 let q = match p.question() { in run() localVariable
303 Ok(q) => q, in run()
316 if *local_name == q.name.data { in run()
342 send_answer(socket, &interface_addr, &q.name.data, src.ip(), dst_addr).await in run()
/webrtc/util/src/conn/
H A Dconn_bridge_test.rs208 let mut q = VecDeque::new(); in test_bridge_inverse_error() localVariable
209 q.push_back(MSG1.clone()); in test_bridge_inverse_error()
210 assert!(!inverse(&mut q)); in test_bridge_inverse_error()
H A Dconn_bridge.rs117 let q = self.queue[id].lock().await; in len() localVariable
118 q.len() in len()