Home
last modified time | relevance | path

Searched refs:now (Results 1 – 25 of 89) sorted by relevance

1234

/webrtc/interceptor/src/report/sender/
H A Dsender_stream.rs25 self.last_rtp_time_time = now; in process_rtp()
34 ntp_time: unix2ntp(now), in generate_report()
50 now: Option<FnTimeGen>, field
60 now: Option<FnTimeGen>, in new()
64 now, in new()
78 internal.process_rtp(now, pkt); in process_rtp()
83 now: SystemTime, in generate_report()
86 internal.generate_report(now) in generate_report()
95 let now = if let Some(f) = &self.now { in write() localVariable
98 SystemTime::now() in write()
[all …]
H A Dmod.rs17 pub(crate) now: Option<FnTimeGen>, field
62 let now = if let Some(f) = &internal.now { in run() localVariable
65 SystemTime::now() in run()
72 let pkt = stream.generate_report(now).await; in run()
136 self.internal.now.clone(), in bind_local_stream()
H A Dsender_test.rs13 Arc::new(move || mt.now()) in test_sender_interceptor_before_any_packet()
44 ntp_time: unix2ntp(mt.now()), in test_sender_interceptor_before_any_packet()
65 Arc::new(move || mt.now()) in test_sender_interceptor_after_rtp_packets()
108 ntp_time: unix2ntp(mt.now()), in test_sender_interceptor_after_rtp_packets()
129 Arc::new(move || mt.now()) in test_sender_interceptor_after_rtp_packets_overflow()
210 ntp_time: unix2ntp(mt.now()), in test_sender_interceptor_after_rtp_packets_overflow()
/webrtc/interceptor/src/report/receiver/
H A Dreceiver_stream.rs71 let d = now in process_rtp()
81 self.last_rtp_time_time = now; in process_rtp()
150 now: Option<FnTimeGen>, field
160 now: Option<FnTimeGen>, in new()
165 now, in new()
189 internal.process_rtp(now, pkt); in process_rtp()
194 now: SystemTime, in process_sender_report()
203 internal.generate_report(now) in generate_report()
216 let now = if let Some(f) = &self.now { in read() localVariable
219 SystemTime::now() in read()
[all …]
H A Dmod.rs17 pub(crate) now: Option<FnTimeGen>, field
35 let now = if let Some(f) = &self.internal.now { in read() localVariable
38 SystemTime::now() in read()
51 stream.process_sender_report(now, sr); in read()
101 let now = if let Some(f) = &internal.now { in run() localVariable
104 SystemTime::now() in run()
111 let pkt = stream.generate_report(now); in run()
191 self.internal.now.clone(), in bind_remote_stream()
H A Dreceiver_test.rs13 Arc::new(move || mt.now()) in test_receiver_interceptor_before_any_packet()
65 Arc::new(move || mt.now()) in test_receiver_interceptor_after_rtp_packets()
130 Arc::new(move || mt.now()) in test_receiver_interceptor_after_rtp_and_rtcp_packets()
170 ntp_time: unix2ntp(now), in test_receiver_interceptor_after_rtp_and_rtcp_packets()
214 Arc::new(move || mt.now()) in test_receiver_interceptor_overflow()
288 Arc::new(move || mt.now()) in test_receiver_interceptor_overflow_five_pkts()
390 Arc::new(move || mt.now()) in test_receiver_interceptor_packet_loss()
501 Arc::new(move || mt.now()) in test_receiver_interceptor_overflow_and_packet_loss()
571 Arc::new(move || mt.now()) in test_receiver_interceptor_reordered_packets()
633 Arc::new(move || mt.now()) in test_receiver_interceptor_jitter()
[all …]
/webrtc/interceptor/src/report/
H A Dmod.rs22 now: Option<FnTimeGen>, field
33 pub fn with_now_fn(mut self, now: FnTimeGen) -> ReportBuilder { in with_now_fn()
34 self.now = Some(now); in with_now_fn()
47 now: self.now.clone(), in build_rr()
66 now: self.now.clone(), in build_sr()
/webrtc/sctp/examples/
H A Dthroughput.rs20 chrono::Local::now().format("%H:%M:%S.%6f"), in main()
83 let mut now = tokio::time::Instant::now(); in main() localVariable
90 if now.elapsed().as_secs() == 1 { in main()
92 now = tokio::time::Instant::now(); in main()
130 let mut now = tokio::time::Instant::now(); in main() localVariable
134 if now.elapsed().as_secs() == 1 { in main()
136 now = tokio::time::Instant::now(); in main()
/webrtc/ice/src/agent/
H A Dagent_stats.rs118 timestamp: Instant::now(), in default()
127 last_packet_sent_timestamp: Instant::now(), in default()
128 last_packet_received_timestamp: Instant::now(), in default()
129 first_request_timestamp: Instant::now(), in default()
130 last_request_timestamp: Instant::now(), in default()
131 last_response_timestamp: Instant::now(), in default()
144 consent_expired_timestamp: Instant::now(), in default()
200 timestamp: Instant::now(), in default()
221 timestamp: Instant::now(), in get_candidate_pairs_stats()
240 timestamp: Instant::now(), in get_local_candidates_stats()
[all …]
H A Dagent_internal.rs117 start_time: SyncMutex::new(Instant::now()), in new()
219 *checking_duration = Instant::now(); in contact()
223 if Instant::now() in contact()
242 let mut checking_duration = Instant::now(); in connectivity_checks()
444 let disconnected_time = SystemTime::now() in validate_selected_pair()
494 let last_sent = SystemTime::now() in check_keepalive()
498 let last_received = SystemTime::now() in check_keepalive()
720 self.invalidate_pending_binding_requests(Instant::now()) in send_binding_request()
725 timestamp: Instant::now(), in send_binding_request()
809 self.invalidate_pending_binding_requests(Instant::now()) in handle_inbound_binding_success()
/webrtc/interceptor/src/mock/
H A Dmock_time.rs20 pub fn set_now(&self, now: SystemTime) { in set_now()
22 *cur_now = now; in set_now()
26 pub fn now(&self) -> SystemTime { in now() method
/webrtc/webrtc/src/stats/
H A Dserialize.rs16 let system_now = SystemTime::now(); in serialize()
17 let instant_now = Instant::now(); in serialize()
H A Dmod.rs280 timestamp: Instant::now(), in new()
310 timestamp: Instant::now(), in new()
344 timestamp: Instant::now(), in from()
399 timestamp: Instant::now(), in from()
432 timestamp: Instant::now(), in new()
/webrtc/ice/src/candidate/
H A Dcandidate_test.rs118 let now = SystemTime::now(); in test_candidate_last_sent() localVariable
119 let d = now.duration_since(UNIX_EPOCH)?; in test_candidate_last_sent()
121 assert_eq!(candidate.last_sent(), now); in test_candidate_last_sent()
131 let now = SystemTime::now(); in test_candidate_last_received() localVariable
132 let d = now.duration_since(UNIX_EPOCH)?; in test_candidate_last_received()
134 assert_eq!(candidate.last_received(), now); in test_candidate_last_received()
/webrtc/util/src/vnet/
H A Dnat.rs86 expires: Arc::new(Mutex::new(SystemTime::now())), // time to expire in default()
231 SystemTime::now().add(self.nat_type.mapping_life_time), in translate_outbound()
371 let now = SystemTime::now(); in find_outbound_mapping() localVariable
376 if now.duration_since(*expires).is_ok() { in find_outbound_mapping()
379 *expires = now.add(mapping_life_time); in find_outbound_mapping()
412 let now = SystemTime::now(); in find_inbound_mapping() localVariable
417 if now.duration_since(*expires).is_ok() { in find_inbound_mapping()
/webrtc/interceptor/src/stats/
H A Dmod.rs61 last_update: Instant::now(), in default()
78 self.last_update = Instant::now(); in mark_updated()
258 last_update: Instant::now(), in default()
277 self.last_update = Instant::now(); in mark_updated()
505 fn update(&mut self, header_bytes: u64, payload_bytes: u64, packets: u64, now: SystemTime) { in update()
509 self.last_packet_timestamp = Some(now); in update()
582 stats.update(24, 960, 1, SystemTime::now()); in test_rtp_stats()
H A Dinterceptor.rs108 now_gen: Arc::new(SystemTime::now), in new()
358 let now = self.now_gen.clone(); in bind_rtcp_writer() localVariable
363 now_gen: move || now(), in bind_rtcp_writer()
373 let now = self.now_gen.clone(); in bind_rtcp_reader() localVariable
378 now_gen: move || now(), in bind_rtcp_reader()
401 let now = (unix2ntp((self.now_gen)()) >> 16) as u32; in read() localVariable
584 calculate_rtt_ms(now, delay_rr, last_rr) in read()
739 last_packet_timestamp: SystemTime::now(), in read()
779 last_packet_timestamp: SystemTime::now(), in write()
796 fn calculate_rtt_ms(now: u32, delay: u32, last_report: u32) -> Option<f64> { in calculate_rtt_ms()
[all …]
/webrtc/webrtc/src/peer_connection/
H A Dcertificate.rs81 SystemTime::now().add(Duration::from_secs(172800)) //60*60*48 or 2 days in from_params()
220 SystemTime::now() in gen_stats_id()
273 let now = SystemTime::now(); in test_generate_certificate_expires_and_stats_id() localVariable
274 assert!(cert.expires.duration_since(now).is_ok()); in test_generate_certificate_expires_and_stats_id()
/webrtc/turn/src/auth/
H A Dmod.rs21 let t = SystemTime::now().duration_since(UNIX_EPOCH)? + duration; in generate_long_term_credentials()
59 if t < SystemTime::now().duration_since(UNIX_EPOCH)? { in auth_handle()
/webrtc/webrtc/src/api/
H A Dmod.rs87 let now = SystemTime::now(); in new_dtls_transport() localVariable
90 .duration_since(now) in new_dtls_transport()
/webrtc/stun/src/agent/
H A Dagent_test.rs13 a.start(m.transaction_id, Instant::now())?; in test_agent_process_in_transaction()
75 let deadline = Instant::now().add(Duration::from_secs(3600)); in test_agent_start()
141 let deadline = Instant::now().add(Duration::from_millis(200)); in test_agent_stop()
/webrtc/stun/src/
H A Dclient.rs56 … if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() { in start()
102 pub(crate) fn next_timeout(&self, now: Instant) -> Instant { in next_timeout()
103 now.add((self.attempt + 1) * self.rto) in next_timeout()
322 let timeout = ct.next_timeout(Instant::now()); in start()
442 start: Instant::now(), in send()
/webrtc/media/src/
H A Dlib.rs75 timestamp: SystemTime::now(), in default()
/webrtc/dtls/src/handshake/
H A Dhandshake_random.rs64 self.gmt_unix_time = SystemTime::now(); in populate()
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs47 arrival_time: (tokio::time::Instant::now() - self.start_time).as_micros() in read()

1234