Lines Matching refs:now
108 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
454 calculate_rtt_ms(now, recp.delay, recp.last_sender_report) in read()
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()
815 let rtt = now.checked_sub(delay)?.checked_sub(last_report)?; in calculate_rtt_ms()