Home
last modified time | relevance | path

Searched refs:start (Results 1 – 25 of 59) sorted by relevance

123

/webrtc/sctp/src/chunk/
H A Dchunk_selective_ack.rs40 pub(crate) start: u16, field
47 write!(f, "{} - {}", self.start, self.end) in fmt()
119 let start = reader.get_u16(); in unmarshal() localVariable
121 gap_ack_blocks.push(GapAckBlock { start, end }); in unmarshal()
143 writer.put_u16(g.start); in marshal_to()
/webrtc/.github/actions-rs/
H A Dgrcov.yml13 excl-start: "mod tests \\{"
15 excl-br-start: "mod tests \\{"
/webrtc/sctp/src/timer/
H A Dtimer_test.rs43 let ok = rt.start(); in test_ack_timer_start_and_stop()
62 let ok = rt.start(); in test_ack_timer_start_and_stop()
237 let ok = rt.start(30).await; in test_rtx_timer_callback_interval()
262 let ok = rt.start(interval).await; in test_rtx_timer_last_start_wins()
290 let ok = rt.start(interval).await; in test_rtx_timer_stop_right_after_start()
315 let ok = rt.start(interval).await; in test_rtx_timer_start_stop_then_start()
319 let ok = rt.start(interval).await; in test_rtx_timer_start_stop_then_start()
344 let ok = rt.start(30).await; in test_rtx_timer_start_and_stop_in_atight_loop()
381 let ok = rt.start(interval).await; in test_rtx_timer_should_stop_after_rtx_failure()
475 let ok = rt.start(20).await; in test_rtx_timer_stop_timer_that_is_not_running_is_noop()
[all …]
H A Dack_timer.rs33 pub(crate) fn start(&mut self) -> bool { in start() method
/webrtc/mdns/src/message/
H A Dbuilder.rs31 pub start: usize, field
54 start: 0, in new()
153 msg = q.pack(msg, &mut self.compression, self.start)?; in add_question()
182 let (mut msg, len_off) = r.header.pack(msg, &mut self.compression, self.start)?; in add_resource()
185 msg = body.pack(msg, &mut self.compression, self.start)?; in add_resource()
/webrtc/stun/src/agent/
H A Dagent_test.rs13 a.start(m.transaction_id, Instant::now())?; in test_agent_process_in_transaction()
76 a.start(id, deadline)?; in test_agent_start()
78 let result = a.start(id, deadline); in test_agent_start()
93 let result = a.start(id, deadline); in test_agent_start()
142 a.start(id, deadline)?; in test_agent_stop()
/webrtc/interceptor/src/nack/generator/
H A Dgenerator_stream.rs176 for start in tests { in test_generator_stream()
200 let seq = start.wrapping_add(*n); in test_generator_stream()
207 let seq = start.wrapping_add(*n); in test_generator_stream()
214 let seq = start.wrapping_add(*n); in test_generator_stream()
218 start, in test_generator_stream()
229 let seq = start.wrapping_add(*n); in test_generator_stream()
236 let want = last_consecutive.wrapping_add(start); in test_generator_stream()
/webrtc/turn/src/client/periodic_timer/
H A Dperiodic_timer_test.rs22 let ok = rt.start(dummy1).await; in test_periodic_timer()
28 let ok = rt.start(dummy2).await; in test_periodic_timer()
/webrtc/interceptor/src/nack/responder/
H A Dresponder_stream.rs109 for start in tests { in test_responder_stream()
114 let seq = start.wrapping_add(*n); in test_responder_stream()
127 let seq = start.wrapping_add(*n); in test_responder_stream()
142 let seq = start.wrapping_add(*n); in test_responder_stream()
/webrtc/stun/src/
H A Dclient.rs27 fn start( in start() method
41 fn start( in start() method
86 start: Instant, field
279 fn start( in start() method
403 Client::start( in run()
418 collector.start(self.settings.rto_rate, Arc::clone(&client_agent_tx))?; in run()
442 start: Instant::now(), in send()
446 let d = t.next_timeout(t.start); in send()
H A Dagent.rs193 pub fn start(&mut self, id: TransactionId, deadline: Instant) -> Result<()> { in start() method
270 ClientAgent::Start(tid, deadline) => agent.start(tid, deadline), in run()
/webrtc/sctp/src/queue/
H A Dpayload_queue.rs117 b.start = diff; in get_gap_ack_blocks()
118 b.end = b.start; in get_gap_ack_blocks()
124 b.start = diff; in get_gap_ack_blocks()
137 s += format!(",{}-{}", b.start, b.end).as_str(); in get_gap_ack_blocks_string()
H A Dqueue_test.rs82 let gab1 = vec![GapAckBlock { start: 1, end: 6 }]; in test_payload_queue_get_gap_ack_block()
87 assert_eq!(gab2[0].start, gab1[0].start); in test_payload_queue_get_gap_ack_block()
94 GapAckBlock { start: 1, end: 6 }, in test_payload_queue_get_gap_ack_block()
95 GapAckBlock { start: 8, end: 9 }, in test_payload_queue_get_gap_ack_block()
101 assert_eq!(gab2[0].start, gab1[0].start); in test_payload_queue_get_gap_ack_block()
103 assert_eq!(gab2[1].start, gab1[1].start); in test_payload_queue_get_gap_ack_block()
/webrtc/examples/examples/ice-restart/
H A DREADME.md17 Open [http://localhost:8080](http://localhost:8080). This will automatically start a PeerConnection…
22 …d pair every 3 seconds. Note how the uFrag/uPwd/Port change everytime you start the Restart proces…
/webrtc/ice/src/agent/
H A Dagent_selector.rs17 async fn start(&self); in start() method
41 async fn start(&self); in start() method
157 pub(crate) async fn start(&self) { in start() method
159 ControllingSelector::start(self).await; in start()
161 ControlledSelector::start(self).await; in start()
215 async fn start(&self) { in start() method
407 async fn start(&self) {} in start() method
/webrtc/.github/workflows/
H A Dgrcov.yml71 --excl-start "#\\[cfg\\(test\\)\\]" \
72 --excl-br-start "#\\[cfg\\(test\\)\\]" \
/webrtc/webrtc/src/peer_connection/operation/
H A Dmod.rs55 Operations::start(l, ops_tx, ops_rx, close_rx).await; in new()
108 pub(crate) async fn start( in start() method
/webrtc/examples/examples/offer-answer/
H A DREADME.md24 You should see them connect and start to exchange messages.
/webrtc/rtp/src/codecs/h264/
H A Dmod.rs40 fn next_ind(nalu: &Bytes, start: usize) -> (isize, isize) { in next_ind()
43 for (i, &b) in nalu[start..].iter().enumerate() { in next_ind()
48 return ((start + i - zero_count) as isize, zero_count as isize + 1); in next_ind()
/webrtc/examples/examples/ortc/
H A Dortc.rs184 ice.start(&remote_signal.ice_parameters, Some(ice_role)) in main()
188 dtls.start(remote_signal.dtls_parameters).await?; in main()
191 sctp.start(remote_signal.sctp_capabilities).await?; in main()
/webrtc/turn/src/client/
H A Dperiodic_timer.rs43 pub async fn start<T: 'static + PeriodicTimerTimeoutHandler + std::marker::Send>( in start() method
/webrtc/turn/src/allocation/
H A Dpermission.rs30 pub(crate) async fn start(&mut self, lifetime: Duration) { in start() method
H A Dchannel_bind.rs34 pub(crate) async fn start(&mut self, lifetime: Duration) { in start() method
/webrtc/mdns/src/conn/
H A Dmod.rs127 DnsConn::start( in server()
243 async fn start( in start() method
282 if let Err(err) = p.start(&b[..n]) { in start()
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs127 let start = SystemTime::now(); in create_responder() localVariable
136 let elapsed = SystemTime::now().duration_since(start); in create_responder()

123