Home
last modified time | relevance | path

Searched refs:ppi (Results 1 – 6 of 6) sorted by relevance

/webrtc/sctp/src/association/
H A Dassociation_test.rs205 let (n, ppi) = s1.read_sctp(&mut buf).await?; in establish_session_pair()
211 if ppi != PayloadProtocolIdentifier::Dcep { in establish_session_pair()
271 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_simple()
358 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_ordered_reordered()
367 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_ordered_reordered()
585 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_unordered_ordered()
594 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_unordered_ordered()
674 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_retransmission()
679 let (n, ppi) = s1.read_sctp(&mut buf).await?; in test_assoc_reliable_retransmission()
1850 Ok((n, ppi)) => { in test_assoc_reset_close_one_way()
[all …]
/webrtc/data/src/data_channel/
H A Dmod.rs125 let (n, ppi) = stream.read_sctp(&mut buf).await?; in server()
127 if ppi != PayloadProtocolIdentifier::Dcep { in server()
128 return Err(Error::InvalidPayloadProtocolIdentifier(ppi as u8)); in server()
166 let (mut n, ppi) = match self.stream.read_sctp(buf).await { in read_data_channel()
171 Ok((n, ppi)) => (n, ppi), in read_data_channel()
180 match ppi { in read_data_channel()
197 match ppi { in read_data_channel()
274 let ppi = match (is_string, data_len) { in write_data_channel() localVariable
284 .write_sctp(&Bytes::from_static(&[0]), ppi) in write_data_channel()
288 let n = self.stream.write_sctp(data, ppi).await?; in write_data_channel()
/webrtc/sctp/src/queue/
H A Dreassembly_queue.rs33 pub(crate) ppi: PayloadProtocolIdentifier, field
38 pub(crate) fn new(ssn: u16, ppi: PayloadProtocolIdentifier) -> Self { in new()
41 ppi, in new()
297 Ok((n_written, cset.ppi)) in read()
H A Dqueue_test.rs484 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_fragments()
487 assert_eq!(ppi, org_ppi, "should have valid ppi"); in test_reassembly_queue_ordered_fragments()
542 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_fragments()
545 assert_eq!(ppi, org_ppi, "should have valid ppi"); in test_reassembly_queue_unordered_fragments()
591 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
594 assert_eq!(ppi, org_ppi, "should have valid ppi"); in test_reassembly_queue_ordered_and_unordered_fragments()
598 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_ordered_and_unordered_fragments()
601 assert_eq!(ppi, org_ppi, "should have valid ppi"); in test_reassembly_queue_ordered_and_unordered_fragments()
663 let (n, ppi) = rq.read(&mut buf)?; in test_reassembly_queue_unordered_complete_skips_incomplete()
955 ppi: PayloadProtocolIdentifier::default(), in test_chunk_set_incomplete_chunk_set_no_beginning()
[all …]
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs469 let ppi = PayloadProtocolIdentifier::from(s.default_payload_type.load(Ordering::SeqCst)); in test_assoc_max_message_size_default() localVariable
471 if let Err(err) = s.write_sctp(&p.slice(..65536), ppi).await { in test_assoc_max_message_size_default()
481 if let Err(err) = s.write_sctp(&p.slice(..65537), ppi).await { in test_assoc_max_message_size_default()
515 let ppi = PayloadProtocolIdentifier::from(s.default_payload_type.load(Ordering::SeqCst)); in test_assoc_max_message_size_explicit() localVariable
517 if let Err(err) = s.write_sctp(&p.slice(..30000), ppi).await { in test_assoc_max_message_size_explicit()
527 if let Err(err) = s.write_sctp(&p.slice(..30001), ppi).await { in test_assoc_max_message_size_explicit()
/webrtc/sctp/src/stream/
H A Dmod.rs275 pub async fn write_sctp(&self, p: &Bytes, ppi: PayloadProtocolIdentifier) -> Result<usize> { in write_sctp()
276 let chunks = self.prepare_write(p, ppi)?; in write_sctp()
286 ppi: PayloadProtocolIdentifier, in prepare_write()
305 Ok(self.packetize(p, ppi)) in prepare_write()
308 fn packetize(&self, raw: &Bytes, ppi: PayloadProtocolIdentifier) -> Vec<ChunkPayloadData> { in packetize()
316 ppi != PayloadProtocolIdentifier::Dcep && self.unordered.load(Ordering::SeqCst); in packetize()
336 payload_type: ppi, in packetize()