| /webrtc/util/src/vnet/ |
| H A D | chunk.rs | 103 fn user_data(&self) -> Vec<u8>; in user_data() method
145 pub(crate) user_data: Vec<u8>, field
190 fn user_data(&self) -> Vec<u8> { in user_data() method
191 self.user_data.clone() in user_data()
204 user_data: self.user_data.clone(), in clone_to()
238 user_data: vec![], in new()
249 user_data: Vec<u8>, // only with PSH flag field
297 fn user_data(&self) -> Vec<u8> { in user_data() method
298 self.user_data.clone() in user_data()
312 user_data: self.user_data.clone(), in clone_to()
[all …]
|
| H A D | conn.rs | 85 let user_data = chunk.user_data(); in recv_from() localVariable
86 let n = std::cmp::min(buf.len(), user_data.len()); in recv_from()
87 buf[..n].copy_from_slice(&user_data[..n]); in recv_from()
125 chunk.user_data = buf.to_vec(); in send_to()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_payload_data.rs | 102 pub(crate) user_data: Bytes, field
134 user_data: Bytes::new(), in default()
199 let user_data = raw.slice( in unmarshal() localVariable
213 user_data, in unmarshal()
231 writer.extend_from_slice(&self.user_data); in marshal_to()
241 PAYLOAD_DATA_HEADER_SIZE + self.user_data.len() in value_length()
|
| /webrtc/sctp/src/queue/ |
| H A D | queue_test.rs | 15 user_data: { in make_payload()
222 user_data: { in make_data_chunk()
461 user_data: Bytes::from_static(b"ABC"), in test_reassembly_queue_ordered_fragments()
505 user_data: Bytes::from_static(b"ABC"), in test_reassembly_queue_unordered_fragments()
532 user_data: Bytes::from_static(b"H"), in test_reassembly_queue_unordered_fragments()
561 user_data: Bytes::from_static(b"ABC"), in test_reassembly_queue_ordered_and_unordered_fragments()
619 user_data: Bytes::from_static(b"IN"), in test_reassembly_queue_unordered_complete_skips_incomplete()
685 user_data: Bytes::from_static(b"IN"), in test_reassembly_queue_ignores_chunk_with_wrong_si()
708 user_data: Bytes::from_static(b"IN"), in test_reassembly_queue_ignores_chunk_with_stale_ssn()
730 user_data: Bytes::from_static(b"IN"), in test_reassembly_queue_should_fail_to_read_incomplete_chunk()
[all …]
|
| H A D | reassembly_queue.rs | 144 self.n_bytes += chunk.user_data.len(); in push()
162 self.n_bytes += chunk.user_data.len(); in push()
282 let to_copy = c.user_data.len(); in read()
286 buf[n_written..n_written + n].copy_from_slice(&c.user_data[..n]); in read()
309 n + s.chunks.iter().fold(0, |acc, c| acc + c.user_data.len()) in forward_tsn_for_ordered()
337 self.subtract_num_bytes(self.unordered_chunks[i].user_data.len()); in forward_tsn_for_unordered()
|
| H A D | payload_queue.rs | 33 self.n_bytes += p.user_data.len(); in push_no_check()
81 self.n_bytes -= c.user_data.len(); in pop()
146 let n = c.user_data.len(); in mark_as_acked()
148 c.user_data.clear(); in mark_as_acked()
|
| H A D | pending_queue.rs | 68 let user_data_len = c.user_data.len(); in push()
99 let total_user_data_len = chunks.iter().fold(0, |acc, c| acc + c.user_data.len()); in append()
121 let user_data_len = chunk.user_data.len(); in append_large()
241 let user_data_len = p.user_data.len(); in pop()
|
| /webrtc/util/src/vnet/chunk/ |
| H A D | chunk_test.rs | 41 c.user_data = "Hello".as_bytes().to_vec(); in test_chunk_udp()
53 c.user_data[0] = b'!'; // oroginal: "Hello" -> "Hell!" in test_chunk_udp()
54 assert_eq!(cloned.user_data(), "Hello".as_bytes(), "should match"); in test_chunk_udp()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 78 user_data: Bytes::from_static(b"ABC"), in test_create_forward_tsn_forward_one_abandoned()
108 user_data: Bytes::from_static(b"ABC"), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
119 user_data: Bytes::from_static(b"DEF"), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
130 user_data: Bytes::from_static(b"123"), in test_create_forward_tsn_forward_two_abandoned_with_the_same_si()
215 user_data: Bytes::from_static(b"ABC"), in test_handle_forward_tsn_forward_1for1_missing()
265 user_data: Bytes::from_static(b"ABC"), in test_handle_forward_tsn_forward_1for2_missing()
351 user_data: Bytes::from_static(b"ABC"), in test_assoc_create_new_stream()
|
| /webrtc/sctp/src/stream/ |
| H A D | stream_test.rs | 112 user_data: Bytes::from_static(&[0, 1, 2, 3, 4]), in test_stream()
131 user_data: Bytes::from_static(&[5, 6, 7, 8, 9]), in test_stream()
180 user_data: Bytes::from_static(&[0, 1, 2, 3, 4]), in test_poll_stream()
199 user_data: Bytes::from_static(&[5, 6, 7, 8, 9]), in test_poll_stream()
|
| H A D | mod.rs | 327 let user_data = raw.slice(i..i + fragment_size); in packetize() localVariable
331 user_data, in packetize()
515 user_data: Bytes::new(), in send_reset_request()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 16 chunk.user_data = c.user_data(); in write()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 441 let data_chunk_size = DATA_CHUNK_HEADER_SIZE + c.user_data.len() as u32; in gather_outbound_fast_retransmission_packets()
900 d.user_data.len() in handle_data()
1105 let n_bytes_acked = c.user_data.len() as i64; in process_selective_ack()
1732 user_data: Bytes::new(), in send_reset_request()
1827 c.user_data.len(), in move_pending_data_chunk_to_inflight_queue()
1862 c.user_data.len(), in pop_pending_data_chunks_to_send()
1928 if bytes_in_packet + c.user_data.len() as u32 > self.mtu { in bundle_data_chunks_into_packets()
1934 bytes_in_packet += DATA_CHUNK_HEADER_SIZE + c.user_data.len() as u32; in bundle_data_chunks_into_packets()
2011 if i == 0 && self.rwnd < c.user_data.len() as u32 { in get_data_packets_to_retransmit()
2014 } else if bytes_to_send + c.user_data.len() > awnd as usize { in get_data_packets_to_retransmit()
[all …]
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 342 c.user_data = vec![i]; // 1-byte seq num in test_router_standalone_add_chunk_filter()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 569 c.user_data = b"Hello!".to_vec(); in test_net_virtual_loopback2()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_vnet_test.rs | 908 let raw = c.user_data(); in test_write_use_valid_pair()
|