Home
last modified time | relevance | path

Searched refs:Instant (Results 1 – 25 of 27) sorted by relevance

12

/webrtc/ice/src/agent/
H A Dagent_stats.rs6 use tokio::time::Instant;
11 pub timestamp: Instant,
42 pub last_packet_sent_timestamp: Instant,
49 pub first_request_timestamp: Instant,
54 pub last_request_timestamp: Instant,
57 pub last_response_timestamp: Instant,
112 pub consent_expired_timestamp: Instant,
118 timestamp: Instant::now(), in default()
153 pub timestamp: Instant,
200 timestamp: Instant::now(), in default()
[all …]
H A Dagent_selector.rs13 use tokio::time::{Duration, Instant};
68 Instant::now() in is_nominatable()
75 Instant::now() in is_nominatable()
82 Instant::now() in is_nominatable()
89 Instant::now() in is_nominatable()
220 *self.start_time.lock() = Instant::now(); in start()
H A Dagent_internal.rs46 pub(crate) start_time: SyncMutex<Instant>,
117 start_time: SyncMutex::new(Instant::now()), in new()
208 checking_duration: &mut Instant, in contact() argument
219 *checking_duration = Instant::now(); in contact()
223 if Instant::now() in contact()
242 let mut checking_duration = Instant::now(); in connectivity_checks()
720 self.invalidate_pending_binding_requests(Instant::now()) in send_binding_request()
725 timestamp: Instant::now(), in send_binding_request()
777 pub(crate) async fn invalidate_pending_binding_requests(&self, filter_time: Instant) { in invalidate_pending_binding_requests() argument
809 self.invalidate_pending_binding_requests(Instant::now()) in handle_inbound_binding_success()
H A Dmod.rs45 use tokio::time::{Duration, Instant};
49 pub(crate) timestamp: Instant,
58 timestamp: Instant::now(), in default()
/webrtc/ice/src/stats/
H A Dmod.rs4 use tokio::time::Instant;
10 pub timestamp: Instant,
42 pub last_packet_sent_timestamp: Instant,
46 pub last_packet_received_timestamp: Instant,
50 pub first_request_timestamp: Instant,
56 pub last_request_timestamp: Instant,
60 pub last_response_timestamp: Instant,
125 pub consent_expired_timestamp: Instant,
132 pub timestamp: Instant,
/webrtc/webrtc/src/stats/
H A Dmod.rs19 use tokio::time::Instant;
143 pub timestamp: Instant,
224 pub timestamp: Instant,
263 pub timestamp: Instant,
290 pub timestamp: Instant,
320 pub timestamp: Instant,
354 pub timestamp: Instant,
409 pub timestamp: Instant,
442 pub timestamp: Instant,
489 pub timestamp: Instant,
[all …]
H A Dserialize.rs10 use tokio::time::Instant;
12 pub fn serialize<S>(instant: &Instant, serializer: S) -> Result<S::Ok, S::Error> in serialize() argument
17 let instant_now = Instant::now(); in serialize()
/webrtc/turn/src/client/
H A Dbinding.rs7 use tokio::time::Instant;
29 pub(crate) refreshed_at: Instant,
43 pub(crate) fn set_refreshed_at(&mut self, at: Instant) { in set_refreshed_at() argument
47 pub(crate) fn refreshed_at(&self) -> Instant { in refreshed_at() argument
83 refreshed_at: Instant::now(), in create()
H A Drelay_conn.rs26 use tokio::time::{Duration, Instant};
313 && Instant::now() in send_to()
345 b.set_refreshed_at(Instant::now()); in send_to()
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs9 start_time: tokio::time::Instant,
18 start_time: tokio::time::Instant, in new() argument
47 arrival_time: (tokio::time::Instant::now() - self.start_time).as_micros() in read()
H A Dmod.rs47 start_time: tokio::time::Instant::now(), in build()
76 start_time: tokio::time::Instant,
/webrtc/stun/src/
H A Dagent.rs12 use tokio::time::Instant;
76 deadline: Instant,
109 Collect(Instant),
110 Start(TransactionId, Instant),
193 pub fn start(&mut self, id: TransactionId, deadline: Instant) -> Result<()> { in start()
218 pub fn collect(&mut self, deadline: Instant) -> Result<()> { in collect()
H A Dclient.rs16 use tokio::time::{self, Duration, Instant};
56 … if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() { in start()
86 start: Instant,
102 pub(crate) fn next_timeout(&self, now: Instant) -> Instant { in next_timeout() argument
322 let timeout = ct.next_timeout(Instant::now()); in start()
442 start: Instant::now(), in send()
/webrtc/sctp/examples/
H A Dthroughput.rs83 let mut now = tokio::time::Instant::now(); in main()
92 now = tokio::time::Instant::now(); in main()
130 let mut now = tokio::time::Instant::now(); in main()
136 now = tokio::time::Instant::now(); in main()
/webrtc/interceptor/src/stats/
H A Dmod.rs19 use tokio::time::{Duration, Instant};
34 last_update: Instant,
61 last_update: Instant::now(), in default()
78 self.last_update = Instant::now(); in mark_updated()
207 use tokio::time::{Duration, Instant};
222 last_update: Instant,
258 last_update: Instant::now(), in default()
277 self.last_update = Instant::now(); in mark_updated()
/webrtc/turn/src/allocation/
H A Dpermission.rs5 use tokio::time::{Duration, Instant};
54 timer.as_mut().reset(Instant::now() + d); in start()
H A Dchannel_bind.rs9 use tokio::time::{Duration, Instant};
60 timer.as_mut().reset(Instant::now() + d); in start()
H A Dmod.rs32 time::{Duration, Instant},
292 timer.as_mut().reset(Instant::now() + d); in start()
/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/turn/src/server/request/
H A Drequest_test.rs7 time::{Duration, Instant},
79 nonces.insert(STATIC_KEY.to_owned(), Instant::now()); in test_allocation_lifetime_deletion_zero_lifetime()
/webrtc/turn/src/server/
H A Dmod.rs23 time::{Duration, Instant},
34 pub(crate) nonces: Arc<Mutex<HashMap<String, Instant>>>,
146 nonces: Arc<Mutex<HashMap<String, Instant>>>, in read_loop() argument
H A Drequest.rs41 use tokio::time::{Duration, Instant};
57 pub nonces: Arc<Mutex<HashMap<String, Instant>>>,
174 Instant::now() in authenticate_request()
244 nonces.insert(nonce.clone(), Instant::now()); in respond_with_nonce()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_internal.rs2 use tokio::time::Instant;
1273 timestamp: Instant::now(), in collect_inbound_stats()
1300 timestamp: Instant::now(), in collect_inbound_stats()
1413 timestamp: Instant::now(), in collect_outbound_stats()
1441 timestamp: Instant::now(), in collect_outbound_stats()
/webrtc/stun/benches/
H A Dbench.rs24 use tokio::time::Instant;
57 let deadline = Instant::now().add(Duration::from_secs(60 * 60 * 24)); in benchmark_agent()
/webrtc/examples/examples/ice-restart/
H A Dice-restart.rs126 .send_text(format!("{:?}", tokio::time::Instant::now())) in do_signaling()

12