| /webrtc/media/src/io/ivf_writer/ |
| H A D | ivf_writer_test.rs | 154 for (msg1, _msg2, packet, err, seen_key_frame, count) in add_packet_test_case { in test_ivf_writer_add_packet_and_close()
160 assert_eq!(writer.count, 0, "Writer's packet count should initialize 0"); in test_ivf_writer_add_packet_and_close()
170 if count == 1 { in test_ivf_writer_add_packet_and_close()
171 assert_eq!(writer.count, 0); in test_ivf_writer_add_packet_and_close()
172 } else if count == 2 { in test_ivf_writer_add_packet_and_close()
173 assert_eq!(writer.count, 1); in test_ivf_writer_add_packet_and_close()
177 if count == 1 { in test_ivf_writer_add_packet_and_close()
178 assert_eq!(writer.count, 0); in test_ivf_writer_add_packet_and_close()
179 } else if count == 2 { in test_ivf_writer_add_packet_and_close()
180 assert_eq!(writer.count, 1); in test_ivf_writer_add_packet_and_close()
[all …]
|
| H A D | mod.rs | 16 count: u64, field
27 count: 0, in new()
98 self.writer.write_u64::<LittleEndian>(self.count)?; // PTS in write_rtp()
99 self.count += 1; in write_rtp()
116 self.writer.write_u32::<LittleEndian>(self.count as u32)?; in close()
|
| /webrtc/rtcp/src/ |
| H A D | header.rs | 93 pub count: u8, field
110 if self.count > 31 { in marshal_to()
126 | (self.count << COUNT_SHIFT); in marshal_to()
161 let count = (b0 >> COUNT_SHIFT) & COUNT_MASK; in unmarshal() localVariable
167 count, in unmarshal()
190 count: 1, in test_header_unmarshal()
204 count: 1, in test_header_unmarshal()
218 count: 0, in test_header_unmarshal()
259 count: 31, in test_header_roundtrip()
269 count: 28, in test_header_roundtrip()
[all …]
|
| H A D | packet.rs | 98 PacketType::TransportSpecificFeedback => match h.count { in unmarshaller()
104 PacketType::PayloadSpecificFeedback => match h.count { in unmarshaller()
|
| /webrtc/turn/src/client/binding/ |
| H A D | binding_test.rs | 30 let count = 100; in test_binding_manager_method() localVariable
32 for i in 0..count { in test_binding_manager_method()
47 assert_eq!(count, m.size() as u16, "should match"); in test_binding_manager_method()
48 assert_eq!(count, m.addr_map.len() as u16, "should match"); in test_binding_manager_method()
50 for i in 0..count { in test_binding_manager_method()
|
| /webrtc/util/src/buffer/ |
| H A D | mod.rs | 25 count: usize, field
114 count: 0, in new()
137 if (b.limit_count > 0 && b.count >= b.limit_count) in write()
175 b.count += 1; in write()
208 let count = ((n1 as usize) << 8) | n2 as usize; in read() localVariable
211 let mut copied = count; in read()
226 b.head += count; in read()
238 b.count -= 1; in read()
240 if copied < count { in read()
287 pub async fn count(&self) -> usize { in count() method
[all …]
|
| H A D | buffer_test.rs | 167 assert_eq!(buffer.count().await, 0); in test_buffer_limit_count()
172 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
176 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
184 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
191 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
196 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
204 assert_eq!(buffer.count().await, 2); in test_buffer_limit_count()
210 assert_eq!(buffer.count().await, 1); in test_buffer_limit_count()
215 assert_eq!(buffer.count().await, 0); in test_buffer_limit_count()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 260 let count = Arc::new(AtomicUsize::new(0)); in test_rtp_transceiver_set_direction_causing_negotiation() localVariable
263 let count = count.clone(); in test_rtp_transceiver_set_direction_causing_negotiation() localVariable
265 let count = count.clone(); in test_rtp_transceiver_set_direction_causing_negotiation() localVariable
267 count.fetch_add(1, Ordering::SeqCst); in test_rtp_transceiver_set_direction_causing_negotiation()
288 assert_eq!(count.load(Ordering::SeqCst), 0); in test_rtp_transceiver_set_direction_causing_negotiation()
298 assert_eq!(count.load(Ordering::SeqCst), 0); in test_rtp_transceiver_set_direction_causing_negotiation()
307 assert_eq!(count.load(Ordering::SeqCst), 1); in test_rtp_transceiver_set_direction_causing_negotiation()
|
| /webrtc/rtcp/src/goodbye/ |
| H A D | mod.rs | 39 count: self.sources.len() as u8, in header()
161 let reason_offset = HEADER_LENGTH + header.count as usize * SSRC_LENGTH; in unmarshal()
167 let mut sources = Vec::with_capacity(header.count as usize); in unmarshal()
168 for _ in 0..header.count { in unmarshal()
|
| /webrtc/ice/src/url/ |
| H A D | mod.rs | 177 if q_args.count() > 0 { in parse_url()
183 if q_args.count() > 0 { in parse_url()
189 if q_args.count() > 1 { in parse_url()
207 if q_args.count() > 1 { in parse_url()
|
| /webrtc/mdns/src/message/ |
| H A D | builder.rs | 125 let (count, err) = match section { in increment_section_count()
135 if *count == u16::MAX { in increment_section_count()
138 *count += 1; in increment_section_count()
|
| /webrtc/rtcp/src/receiver_report/ |
| H A D | mod.rs | 53 count: self.reports.len() as u8, in header()
203 let mut reports = Vec::with_capacity(header.count as usize); in unmarshal()
204 for _ in 0..header.count { in unmarshal()
|
| /webrtc/rtcp/src/sender_report/ |
| H A D | mod.rs | 88 count: self.reports.len() as u8, in header()
268 let mut reports = Vec::with_capacity(header.count as usize); in unmarshal()
269 for _ in 0..header.count { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/picture_loss_indication/ |
| H A D | mod.rs | 39 count: FORMAT_PLI, in header()
119 if h.packet_type != PacketType::PayloadSpecificFeedback || h.count != FORMAT_PLI { in unmarshal()
|
| H A D | picture_loss_indication_test.rs | 140 count: FORMAT_PLI, in test_picture_loss_indication_unmarshal_header()
|
| /webrtc/rtcp/src/transport_feedbacks/rapid_resynchronization_request/ |
| H A D | mod.rs | 41 count: FORMAT_RRR, in header()
122 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_RRR { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/full_intra_request/ |
| H A D | mod.rs | 46 count: FORMAT_FIR, in header()
136 if h.packet_type != PacketType::PayloadSpecificFeedback || h.count != FORMAT_FIR { in unmarshal()
|
| H A D | full_intra_request_test.rs | 186 count: FORMAT_FIR, in test_full_intra_request_unmarshal_header()
|
| /webrtc/rtcp/src/payload_feedbacks/slice_loss_indication/ |
| H A D | mod.rs | 54 count: FORMAT_SLI, in header()
144 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_SLI { in unmarshal()
|
| /webrtc/rtcp/src/payload_feedbacks/receiver_estimated_maximum_bitrate/ |
| H A D | mod.rs | 61 count: FORMAT_REMB, in header()
215 if header.packet_type != PacketType::PayloadSpecificFeedback || header.count != FORMAT_REMB in unmarshal()
|
| /webrtc/media/src/io/sample_builder/ |
| H A D | sample_sequence_location.rs | 53 pub(crate) fn count(&self) -> u16 { in count() method
|
| H A D | mod.rs | 166 while (self.too_old(&self.filled) || (self.filled.count() > self.max_late)) in purge_buffers()
313 self.dropped_packets += consume.count(); in build_sample()
315 self.padding_packets += consume.count(); in build_sample()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtcp_test.rs | 197 let count = expected_ssrc.len(); in test_session_srtcp_replay_protection() localVariable
201 while i < count { in test_session_srtcp_replay_protection()
|
| /webrtc/rtcp/src/transport_feedbacks/transport_layer_nack/ |
| H A D | mod.rs | 130 count: FORMAT_TLN, in header()
217 if h.packet_type != PacketType::TransportSpecificFeedback || h.count != FORMAT_TLN { in unmarshal()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 477 let count = nack.nacks.iter().flat_map(|p| p.into_iter()).count() as u64; in read() localVariable
481 e.generic_rtcp.nack_count.map(|v| v + count).or(Some(count)); in read()
644 let count = nack.nacks.iter().flat_map(|p| p.into_iter()).count() as u64; in write() localVariable
647 e.nack_count = e.nack_count.map(|v| v + count).or(Some(count)); in write()
|