| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 1 use crate::chunk::chunk_payload_data::ChunkPayloadData;
12 pub(crate) chunk_map: HashMap<u32, ChunkPayloadData>,
27 pub(crate) fn can_push(&self, p: &ChunkPayloadData, cumulative_tsn: u32) -> bool { in can_push() argument
31 pub(crate) fn push_no_check(&mut self, p: ChunkPayloadData) { in push_no_check() argument
63 pub(crate) fn push(&mut self, p: ChunkPayloadData, cumulative_tsn: u32) -> bool { in push() argument
76 pub(crate) fn pop(&mut self, tsn: u32) -> Option<ChunkPayloadData> { in pop() argument
90 pub(crate) fn get(&self, tsn: u32) -> Option<&ChunkPayloadData> { in get() argument
93 pub(crate) fn get_mut(&mut self, tsn: u32) -> Option<&mut ChunkPayloadData> { in get_mut() argument
|
| H A D | queue_test.rs | 13 ChunkPayloadData { in make_payload()
217 ChunkPayloadData { in make_data_chunk()
456 let chunk = ChunkPayloadData { in test_reassembly_queue_ordered_fragments()
469 let chunk = ChunkPayloadData { in test_reassembly_queue_ordered_fragments()
499 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments()
513 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments()
526 let chunk = ChunkPayloadData { in test_reassembly_queue_unordered_fragments()
936 cset.push(ChunkPayloadData { in test_chunk_set_push_dup_chunks_to_chunk_set()
971 ChunkPayloadData { in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn()
976 ChunkPayloadData { in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn()
[all …]
|
| H A D | pending_queue.rs | 9 use crate::chunk::chunk_payload_data::ChunkPayloadData;
24 pub(crate) type PendingBaseQueue = VecDeque<ChunkPayloadData>;
67 pub(crate) async fn push(&self, c: ChunkPayloadData) { in push() argument
94 pub(crate) async fn append(&self, chunks: Vec<ChunkPayloadData>) { in append() argument
116 async fn append_large(&self, chunks: Vec<ChunkPayloadData>) { in append_large() argument
139 fn append_unlimited(&self, chunks: Vec<ChunkPayloadData>, total_user_data_len: usize) { in append_unlimited() argument
166 pub(crate) fn peek(&self) -> Option<ChunkPayloadData> { in peek() argument
194 ) -> Option<ChunkPayloadData> { in pop() argument
|
| H A D | reassembly_queue.rs | 1 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
8 fn sort_chunks_by_tsn(c: &mut [ChunkPayloadData]) { in sort_chunks_by_tsn() argument
34 pub(crate) chunks: Vec<ChunkPayloadData>,
46 pub(crate) fn push(&mut self, chunk: ChunkPayloadData) -> bool { in push()
115 pub(crate) unordered_chunks: Vec<ChunkPayloadData>,
136 pub(crate) fn push(&mut self, chunk: ChunkPayloadData) -> bool { in push()
228 let chunks: Vec<ChunkPayloadData> = self in find_complete_unordered_chunk_set()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 92 pub struct ChunkPayloadData { struct
123 impl Default for ChunkPayloadData { argument
125 ChunkPayloadData { in default()
147 impl fmt::Display for ChunkPayloadData { implementation
153 impl Chunk for ChunkPayloadData { implementation
203 Ok(ChunkPayloadData { in unmarshal()
249 impl ChunkPayloadData { impl
|
| H A D | chunk_test.rs | 648 .downcast_ref::<ChunkPayloadData>() in test_payload_data_marshal_unmarshal()
747 .downcast_ref::<ChunkPayloadData>() in test_select_ack_chunk_followed_by_a_payload_data_chunk()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 72 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_one_abandoned()
102 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
113 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
124 a.inflight_queue.push_no_check(ChunkPayloadData { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
209 ChunkPayloadData { in test_handle_forward_tsn_forward_1for1_missing()
259 ChunkPayloadData { in test_handle_forward_tsn_forward_1for2_missing()
346 let to_be_ignored = ChunkPayloadData { in test_assoc_create_new_stream()
|
| /webrtc/sctp/src/stream/ |
| H A D | stream_test.rs | 108 s.handle_data(ChunkPayloadData { in test_stream()
127 s.handle_data(ChunkPayloadData { in test_stream()
176 sc.handle_data(ChunkPayloadData { in test_poll_stream()
195 sc.handle_data(ChunkPayloadData { in test_poll_stream()
|
| H A D | mod.rs | 5 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
207 pub(crate) async fn handle_data(&self, pd: ChunkPayloadData) { in handle_data() argument
287 ) -> Result<Vec<ChunkPayloadData>> { in prepare_write() argument
308 fn packetize(&self, raw: &Bytes, ppi: PayloadProtocolIdentifier) -> Vec<ChunkPayloadData> { in packetize() argument
329 let chunk = ChunkPayloadData { in packetize()
490 async fn send_payload_data(&self, chunks: Vec<ChunkPayloadData>) -> Result<()> { in send_payload_data()
511 let c = ChunkPayloadData { in send_reset_request()
|
| /webrtc/sctp/src/ |
| H A D | packet.rs | 11 use crate::chunk::chunk_payload_data::ChunkPayloadData;
124 CT_PAYLOAD_DATA => Box::new(ChunkPayloadData::unmarshal(&raw.slice(offset..))?), in unmarshal()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 894 async fn handle_data(&mut self, d: &ChunkPayloadData) -> Result<Vec<Packet>> { in handle_data()
1728 let c = ChunkPayloadData { in send_reset_request()
1805 ) -> Option<ChunkPayloadData> { in move_pending_data_chunk_to_inflight_queue() argument
1843 async fn pop_pending_data_chunks_to_send(&mut self) -> (Vec<ChunkPayloadData>, Vec<u16>) { in pop_pending_data_chunks_to_send() argument
1917 fn bundle_data_chunks_into_packets(&self, chunks: Vec<ChunkPayloadData>) -> Vec<Packet> { in bundle_data_chunks_into_packets()
1945 fn check_partial_reliability_status(&self, c: &ChunkPayloadData) { in check_partial_reliability_status() argument
2119 } else if let Some(c) = chunk_any.downcast_ref::<ChunkPayloadData>() { in handle_chunk()
|
| H A D | mod.rs | 15 use crate::chunk::chunk_payload_data::{ChunkPayloadData, PayloadProtocolIdentifier};
|
| H A D | association_test.rs | 2515 chunks: vec![Box::<ChunkPayloadData>::default()], in test_association_handle_packet_before_init()
|