Searched defs:ChunkPayloadData (Results 1 – 7 of 7) sorted by relevance
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 92 pub struct ChunkPayloadData { struct
93 pub(crate) unordered: bool,
94 pub(crate) beginning_fragment: bool,
95 pub(crate) ending_fragment: bool,
96 pub(crate) immediate_sack: bool,
98 pub(crate) tsn: u32,
99 pub(crate) stream_identifier: u16,
123 impl Default for ChunkPayloadData { argument
147 impl fmt::Display for ChunkPayloadData { implementation
153 impl Chunk for ChunkPayloadData { implementation
[all …]
|
| /webrtc/sctp/src/queue/ |
| H A D | payload_queue.rs | 27 pub(crate) fn can_push(&self, p: &ChunkPayloadData, cumulative_tsn: u32) -> bool { in can_push()
31 pub(crate) fn push_no_check(&mut self, p: ChunkPayloadData) { in push_no_check()
63 pub(crate) fn push(&mut self, p: ChunkPayloadData, cumulative_tsn: u32) -> bool { in push()
76 pub(crate) fn pop(&mut self, tsn: u32) -> Option<ChunkPayloadData> { in pop()
90 pub(crate) fn get(&self, tsn: u32) -> Option<&ChunkPayloadData> { in get()
93 pub(crate) fn get_mut(&mut self, tsn: u32) -> Option<&mut ChunkPayloadData> { in get_mut()
|
| H A D | pending_queue.rs | 67 pub(crate) async fn push(&self, c: ChunkPayloadData) { in push()
94 pub(crate) async fn append(&self, chunks: Vec<ChunkPayloadData>) { in append()
116 async fn append_large(&self, chunks: Vec<ChunkPayloadData>) { in append_large()
139 fn append_unlimited(&self, chunks: Vec<ChunkPayloadData>, total_user_data_len: usize) { in append_unlimited()
166 pub(crate) fn peek(&self) -> Option<ChunkPayloadData> { in peek()
194 ) -> Option<ChunkPayloadData> { in pop()
|
| H A D | reassembly_queue.rs | 8 fn sort_chunks_by_tsn(c: &mut [ChunkPayloadData]) { in sort_chunks_by_tsn()
|
| H A D | queue_test.rs | 12 fn make_payload(tsn: u32, n_bytes: usize) -> ChunkPayloadData { in make_payload()
201 fn make_data_chunk(tsn: u32, unordered: bool, frag: usize) -> ChunkPayloadData { in make_data_chunk()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 207 pub(crate) async fn handle_data(&self, pd: ChunkPayloadData) { in handle_data()
287 ) -> Result<Vec<ChunkPayloadData>> { in prepare_write()
308 fn packetize(&self, raw: &Bytes, ppi: PayloadProtocolIdentifier) -> Vec<ChunkPayloadData> { in packetize()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 1805 ) -> Option<ChunkPayloadData> { in move_pending_data_chunk_to_inflight_queue()
1843 async fn pop_pending_data_chunks_to_send(&mut self) -> (Vec<ChunkPayloadData>, Vec<u16>) { in pop_pending_data_chunks_to_send()
1945 fn check_partial_reliability_status(&self, c: &ChunkPayloadData) { in check_partial_reliability_status()
|