| /webrtc/sctp/src/queue/ |
| H A D | queue_test.rs | 75 pq.push(make_payload(1, 0), 0); in test_payload_queue_get_gap_ack_block()
76 pq.push(make_payload(2, 0), 0); in test_payload_queue_get_gap_ack_block()
77 pq.push(make_payload(3, 0), 0); in test_payload_queue_get_gap_ack_block()
78 pq.push(make_payload(4, 0), 0); in test_payload_queue_get_gap_ack_block()
79 pq.push(make_payload(5, 0), 0); in test_payload_queue_get_gap_ack_block()
80 pq.push(make_payload(6, 0), 0); in test_payload_queue_get_gap_ack_block()
90 pq.push(make_payload(8, 0), 0); in test_payload_queue_get_gap_ack_block()
91 pq.push(make_payload(9, 0), 0); in test_payload_queue_get_gap_ack_block()
465 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
478 let complete = rq.push(chunk); in test_reassembly_queue_ordered_fragments()
[all …]
|
| H A D | reassembly_queue.rs | 46 pub(crate) fn push(&mut self, chunk: ChunkPayloadData) -> bool { in push() method
55 self.chunks.push(chunk); in push()
136 pub(crate) fn push(&mut self, chunk: ChunkPayloadData) -> bool { in push() method
145 self.unordered_chunks.push(chunk); in push()
151 self.unordered.push(cset); in push()
167 return s.push(chunk); in push()
174 let ok = cset.push(chunk); in push()
175 self.ordered.push(cset); in push()
|
| H A D | payload_queue.rs | 63 pub(crate) fn push(&mut self, p: ChunkPayloadData, cumulative_tsn: u32) -> bool { in push() method
67 self.dup_tsn.push(p.tsn); in push()
122 gap_ack_blocks.push(b); in get_gap_ack_blocks()
129 gap_ack_blocks.push(b); in get_gap_ack_blocks()
|
| /webrtc/mdns/src/message/ |
| H A D | name.rs | 55 msg.push(0); in pack()
76 msg.push((i - begin) as u8); in pack()
92 msg.push(((ptr >> 8) | 0xC0) as u8); in pack()
93 msg.push((ptr & 0xFF) as u8); in pack()
106 msg.push(0); in pack()
153 name.push('.'); in unpack_compressed()
183 name.push('.'); in unpack_compressed()
|
| /webrtc/dtls/src/fragment_buffer/ |
| H A D | fragment_buffer_test.rs | 126 let status = fragment_buffer.push(&frag)?; in test_fragment_buffer()
160 fragment_buffer.push(&[ in test_fragment_buffer_overflow()
166 let result = fragment_buffer.push(&big_buffer); in test_fragment_buffer_overflow()
|
| /webrtc/util/src/vnet/chunk_queue/ |
| H A D | chunk_queue_test.rs | 22 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
35 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
38 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
|
| /webrtc/interceptor/src/twcc/ |
| H A D | mod.rs | 50 self.received_packets.push(PktInfo { in record()
80 pkts.push(p); in build_feedback_packet()
88 pkts.push(p); in build_feedback_packet()
132 self.chunks.push(self.last_chunk.encode()); in get_rtcp()
153 self.chunks.push(self.last_chunk.encode()); in add_received()
169 self.chunks.push(self.last_chunk.encode()); in add_received()
172 self.deltas.push(RecvDelta { in add_received()
215 self.deltas.push(delta); in add()
|
| /webrtc/turn/src/proto/ |
| H A D | proto_test.rs | 22 data.push(b); in test_chrome_alloc_request()
30 messages.push(m); in test_chrome_alloc_request()
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_rtp.rs | 83 write_errs.push(Error::Util(err)); in write_rtp_with_extensions()
111 write_errs.push(Error::Rtp(err)); in write_rtp_with_extensions()
123 write_errs.push(err); in write_rtp_with_extensions()
127 write_errs.push(Error::new("track binding has none write_stream".to_owned())); in write_rtp_with_extensions()
151 bindings.push(Arc::new(TrackBinding { in bind()
|
| /webrtc/util/src/vnet/ |
| H A D | router.rs | 147 self.push(from_parent).await; in on_inbound_chunk()
178 mapped_ips.push(ip); in set_router()
181 local_ips.push(*loc_ip); in set_router()
257 static_ips.push(ip); in new()
263 static_ips.push(ip); in new()
385 self.children.push(child); in add_router()
407 router_internal.chunk_filters.push(filter); in add_chunk_filter()
415 if self.queue.push(c).await { in push()
510 p.push(to_parent).await; in process_chunks()
538 ips.push(ip); in add_nic()
[all …]
|
| H A D | chunk.rs | 27 digits.push(b"0123456789abcdefghijklmnopqrstuvwxyz"[digit]); in base36()
73 sa.push("FIN"); in fmt()
76 sa.push("SYN"); in fmt()
79 sa.push("RST"); in fmt()
82 sa.push("PSH"); in fmt()
85 sa.push("ACK"); in fmt()
|
| /webrtc/stun/src/ |
| H A D | uattrs.rs | 22 s.push(t.to_string()); in fmt()
57 .push(AttrType(u16::from_be_bytes([v[first], v[first + 1]]))); in get_from()
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 63 delay_res.push(delay); in on_inbound_chunk()
233 nics.push(nic); in test_router_standalone_routing()
241 r.push(c).await; in test_router_standalone_routing()
313 nics.push(nic); in test_router_standalone_add_chunk_filter()
343 r.push(Box::new(c)).await; in test_router_standalone_add_chunk_filter()
416 nics.push(nic); in delay_sub_test()
425 r.push(c).await; in delay_sub_test()
561 ips.push(ip); in test_router_one_child()
564 nics.push(nic); in test_router_one_child()
565 rs.push(r); in test_router_one_child()
[all …]
|
| /webrtc/rtp/src/codecs/vp9/ |
| H A D | mod.rs | 127 payloads.push(out.freeze()); in payload()
375 self.pdiff.push(b >> 1); in parse_ref_indices()
449 self.pgtid.push(b >> 5); in parse_ssdata()
450 self.pgu.push(b & 0x10 != 0); in parse_ssdata()
457 self.pgpdiff.push(vec![]); in parse_ssdata()
462 self.pgpdiff[i].push(b); in parse_ssdata()
|
| /webrtc/rtp/src/ |
| H A D | header.rs | 98 csrc.push(raw_packet.get_u32()); in unmarshal()
137 extensions.push(Extension { in unmarshal()
161 extensions.push(Extension { in unmarshal()
173 extensions.push(Extension { in unmarshal()
373 self.extensions.push(Extension { id, payload }); in set_extension()
385 self.extensions.push(Extension { id, payload }); in set_extension()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_builder_test.rs | 1209 s.push(p) in test_sample_builder()
1233 s.push(Packet { in test_sample_builder_max_late()
1241 s.push(Packet { in test_sample_builder_max_late()
1249 s.push(Packet { in test_sample_builder_max_late()
1268 s.push(Packet { in test_sample_builder_max_late()
1276 s.push(Packet { in test_sample_builder_max_late()
1284 s.push(Packet { in test_sample_builder_max_late()
1305 s.push(Packet { in test_sample_builder_max_late()
1393 s.push(Packet { in test_sample_builder_clean_reference()
1401 s.push(Packet { in test_sample_builder_clean_reference()
[all …]
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_forward_tsn.rs | 41 res.push(format!("New Cumulative TSN: {}", self.new_cumulative_tsn)); in fmt()
43 res.push(format!(" - si={}, ssn={}", s.identifier, s.sequence)); in fmt()
82 streams.push(s); in unmarshal()
|
| H A D | chunk_error.rs | 39 res.push(format!(" - {cause}")); in fmt()
69 error_causes.push(e); in unmarshal()
|
| H A D | chunk_abort.rs | 37 res.push(format!(" - {cause}")); in fmt()
67 error_causes.push(e); in unmarshal()
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_message_certificate_request.rs | 58 certificate_types.push(cert_type); in unmarshal()
68 signature_hash_algorithms.push(SignatureHashAlgorithm { hash, signature }); in unmarshal()
|
| /webrtc/webrtc/src/api/media_engine/ |
| H A D | mod.rs | 309 codecs.push(codec); in add_codec()
364 self.header_extensions.push(MediaEngineHeaderExtension { in register_header_extension()
395 v.capability.rtcp_feedback.push(feedback.clone()); in register_feedback()
400 a.capability.rtcp_feedback.push(feedback.clone()); in register_feedback()
623 exact_matches.push(codec); in update_from_remote_description()
625 partial_matches.push(codec); in update_from_remote_description()
685 header_extensions.push(RTCRtpHeaderExtensionParameters { in get_rtp_parameters_by_kind()
713 header_extensions.push(RTCRtpHeaderExtensionParameters { in get_rtp_parameters_by_kind()
726 header_extensions.push(RTCRtpHeaderExtensionParameters { in get_rtp_parameters_by_kind()
751 header_extensions.push(RTCRtpHeaderExtensionParameters { in get_rtp_parameters_by_kind()
[all …]
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_cc/ |
| H A D | mod.rs | 277 symbol_list.push(get_nbits_from_byte(b0, 2 + i, 1).into()); in unmarshal()
281 symbol_list.push(get_nbits_from_byte(b1, i, 1).into()) in unmarshal()
287 symbol_list.push(get_nbits_from_byte(b0, 2 + i * 2, 2).into()); in unmarshal()
291 symbol_list.push(get_nbits_from_byte(b1, i * 2, 2).into()); in unmarshal()
630 recv_deltas.push(RecvDelta { in unmarshal()
650 recv_deltas.push(RecvDelta { in unmarshal()
663 recv_deltas.push(RecvDelta { in unmarshal()
678 packet_chunks.push(initial_packet_status); in unmarshal()
|
| /webrtc/interceptor/src/ |
| H A D | chain.rs | 20 self.interceptors.push(icpr); in add()
95 errs.push(err); in close()
|
| /webrtc/sdp/src/description/ |
| H A D | common.rs | 38 parts.push(t.to_string()); in fmt()
41 parts.push(r.to_string()); in fmt()
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 338 raw_packets.push(p); in gather_data_packets_to_retransmit()
358 raw_packets.push(p); in gather_outbound_data_and_reconfig_packets()
399 raw_packets.push(p); in gather_outbound_data_and_reconfig_packets()
469 raw_packets.push(p); in gather_outbound_fast_retransmission_packets()
482 raw_packets.push(p); in gather_outbound_sack_packets()
526 raw_packets.push(p); in gather_outbound_shutdown_packets()
536 raw_packets.push(p); in gather_outbound_shutdown_packets()
544 raw_packets.push(p); in gather_outbound_shutdown_packets()
972 reply.push(resp); in handle_peer_last_tsn_and_acknowledgement()
1626 pp.push(p); in handle_reconfig()
[all …]
|