Home
last modified time | relevance | path

Searched refs:PayloadProtocolIdentifier (Results 1 – 12 of 12) sorted by relevance

/webrtc/sctp/src/chunk/
H A Dchunk_payload_data.rs20 pub enum PayloadProtocolIdentifier { enum
30 impl fmt::Display for PayloadProtocolIdentifier { implementation
44 impl From<u32> for PayloadProtocolIdentifier { implementation
45 fn from(v: u32) -> PayloadProtocolIdentifier { in from() argument
47 50 => PayloadProtocolIdentifier::Dcep, in from()
48 51 => PayloadProtocolIdentifier::String, in from()
49 53 => PayloadProtocolIdentifier::Binary, in from()
50 56 => PayloadProtocolIdentifier::StringEmpty, in from()
51 57 => PayloadProtocolIdentifier::BinaryEmpty, in from()
52 _ => PayloadProtocolIdentifier::Unknown, in from()
[all …]
/webrtc/data/src/data_channel/
H A Dmod.rs115 .write_sctp(&msg, PayloadProtocolIdentifier::Dcep) in client()
127 if ppi != PayloadProtocolIdentifier::Dcep { in server()
167 Ok((0, PayloadProtocolIdentifier::Unknown)) => { in read_data_channel()
181 PayloadProtocolIdentifier::Dcep => { in read_data_channel()
191 PayloadProtocolIdentifier::String | PayloadProtocolIdentifier::StringEmpty => { in read_data_channel()
198 PayloadProtocolIdentifier::StringEmpty | PayloadProtocolIdentifier::BinaryEmpty => { in read_data_channel()
275 (false, 0) => PayloadProtocolIdentifier::BinaryEmpty, in write_data_channel()
276 (false, _) => PayloadProtocolIdentifier::Binary, in write_data_channel()
277 (true, 0) => PayloadProtocolIdentifier::StringEmpty, in write_data_channel()
278 (true, _) => PayloadProtocolIdentifier::String, in write_data_channel()
[all …]
/webrtc/sctp/src/association/
H A Dassociation_test.rs211 if ppi != PayloadProtocolIdentifier::Dcep { in establish_session_pair()
338 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_ordered_reordered()
347 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_ordered_reordered()
430 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_ordered_fragmented_then_defragmented()
497 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_unordered_fragmented_then_defragmented()
567 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_unordered_ordered()
576 PayloadProtocolIdentifier::Binary, in test_assoc_reliable_unordered_ordered()
810 PayloadProtocolIdentifier::Binary, in test_assoc_unreliable_rexmit_ordered_no_fragment()
819 PayloadProtocolIdentifier::Binary, in test_assoc_unreliable_rexmit_ordered_no_fragment()
900 PayloadProtocolIdentifier::Binary, in test_assoc_unreliable_rexmit_ordered_fragment()
[all …]
H A Dmod.rs15 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
578 default_payload_type: PayloadProtocolIdentifier, in open_stream() argument
H A Dassociation_internal.rs1020 default_payload_type: PayloadProtocolIdentifier, in open_stream() argument
1955 if c.payload_type == PayloadProtocolIdentifier::Dcep { in check_partial_reliability_status()
/webrtc/sctp/src/stream/
H A Dstream_test.rs93 s.set_default_payload_type(PayloadProtocolIdentifier::Binary); in test_stream()
101 .write_sctp(&Bytes::from("world"), PayloadProtocolIdentifier::Binary) in test_stream()
113 payload_type: PayloadProtocolIdentifier::Binary, in test_stream()
132 payload_type: PayloadProtocolIdentifier::Binary, in test_stream()
181 payload_type: PayloadProtocolIdentifier::Binary, in test_poll_stream()
200 payload_type: PayloadProtocolIdentifier::Binary, in test_poll_stream()
H A Dmod.rs5 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
153 pub fn set_default_payload_type(&self, default_payload_type: PayloadProtocolIdentifier) { in set_default_payload_type() argument
186 pub async fn read_sctp(&self, p: &mut [u8]) -> Result<(usize, PayloadProtocolIdentifier)> { in read_sctp() argument
189 return Ok((0, PayloadProtocolIdentifier::Unknown)); in read_sctp()
275 pub async fn write_sctp(&self, p: &Bytes, ppi: PayloadProtocolIdentifier) -> Result<usize> { in write_sctp()
286 ppi: PayloadProtocolIdentifier, in prepare_write() argument
308 fn packetize(&self, raw: &Bytes, ppi: PayloadProtocolIdentifier) -> Vec<ChunkPayloadData> { in packetize()
316 ppi != PayloadProtocolIdentifier::Dcep && self.unordered.load(Ordering::SeqCst); in packetize()
/webrtc/sctp/src/queue/
H A Dqueue_test.rs454 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_ordered_fragments()
497 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_unordered_fragments()
554 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_ordered_and_unordered_fragments()
611 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_unordered_complete_skips_incomplete()
676 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_ignores_chunk_with_wrong_si()
700 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_ignores_chunk_with_stale_ssn()
723 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
750 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_should_fail_to_read_if_the_nex_ssn_is_not_ready()
778 let org_ppi = PayloadProtocolIdentifier::Binary; in test_reassembly_queue_detect_buffer_too_short()
955 ppi: PayloadProtocolIdentifier::default(), in test_chunk_set_incomplete_chunk_set_no_beginning()
[all …]
H A Dreassembly_queue.rs1 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
33 pub(crate) ppi: PayloadProtocolIdentifier,
38 pub(crate) fn new(ssn: u16, ppi: PayloadProtocolIdentifier) -> Self { in new()
256 pub(crate) fn read(&mut self, buf: &mut [u8]) -> Result<(usize, PayloadProtocolIdentifier)> { in read() argument
/webrtc/sctp/examples/
H A Dping.rs2 use webrtc_sctp::chunk::chunk_payload_data::PayloadProtocolIdentifier;
74 let stream = a.open_stream(0, PayloadProtocolIdentifier::String).await?; in main()
H A Dthroughput.rs7 use webrtc_sctp::chunk::chunk_payload_data::PayloadProtocolIdentifier;
120 .open_stream(0, PayloadProtocolIdentifier::Binary) in main()
/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()
515 let ppi = PayloadProtocolIdentifier::from(s.default_payload_type.load(Ordering::SeqCst)); in test_assoc_max_message_size_explicit()