| /external/rust/crates/tokio/src/time/ |
| D | instant.rs | 34 pub struct Instant { struct
35 std: std::time::Instant, argument
38 impl Instant { impl
53 pub fn from_std(std: std::time::Instant) -> Instant { in from_std()
66 pub fn into_std(self) -> std::time::Instant { in into_std()
149 pub fn checked_add(&self, duration: Duration) -> Option<Instant> { in checked_add()
156 pub fn checked_sub(&self, duration: Duration) -> Option<Instant> { in checked_sub()
161 impl From<std::time::Instant> for Instant { implementation
162 fn from(time: std::time::Instant) -> Instant { in from()
167 impl From<Instant> for std::time::Instant { implementation
[all …]
|
| D | interval.rs | 106 pub fn interval_at(start: Instant, period: Duration) -> Interval { in interval_at()
305 fn next_timeout(&self, timeout: Instant, now: Instant, period: Duration) -> Instant { in next_timeout()
393 pub async fn tick(&mut self) -> Instant { in tick()
409 pub fn poll_tick(&mut self, cx: &mut Context<'_>) -> Poll<Instant> { in poll_tick()
|
| D | timeout.rs | 100 pub fn timeout_at<T>(deadline: Instant, future: T) -> Timeout<T> in timeout_at()
|
| /external/rust/crates/instant/src/ |
| D | wasm.rs | 6 pub struct Instant(Duration); struct
8 impl Ord for Instant { implementation
14 impl Eq for Instant {} implementation
16 impl Instant { implementation
40 pub fn checked_add(&self, duration: Duration) -> Option<Instant> { in checked_add()
48 pub fn checked_sub(&self, duration: Duration) -> Option<Instant> { in checked_sub()
71 impl Add<Duration> for Instant { implementation
80 impl AddAssign<Duration> for Instant { implementation
87 impl Sub<Duration> for Instant { implementation
96 impl Sub<Instant> for Instant { implementation
[all …]
|
| D | native.rs | 1 pub type Instant = std::time::Instant; typedef
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | sleep.rs | 223 deadline: Instant, in new_timeout()
282 pub fn deadline(&self) -> Instant { in deadline()
322 pub fn reset(self: Pin<&mut Self>, deadline: Instant) { in reset()
326 fn reset_inner(self: Pin<&mut Self>, deadline: Instant) { in reset_inner()
|
| /external/rust/crates/quiche/src/recovery/ |
| D | mod.rs | 216 handshake_status: HandshakeStatus, now: Instant, trace_id: &str, in on_packet_sent()
268 fn on_packet_sent_cc(&mut self, sent_bytes: usize, now: Instant) { in on_packet_sent_cc()
278 pub fn get_packet_send_time(&self) -> Option<Instant> { in get_packet_send_time()
283 &mut self, epoch: packet::Epoch, now: Instant, packet_size: usize, in schedule_next_packet()
313 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
423 &mut self, handshake_status: HandshakeStatus, now: Instant, in on_loss_detection_timeout()
487 now: Instant, in on_pkt_num_space_discarded()
510 pub fn loss_detection_timer(&self) -> Option<Instant> { in loss_detection_timer()
558 &mut self, latest_rtt: Duration, ack_delay: Duration, now: Instant, in update_rtt()
595 fn loss_time_and_space(&self) -> (Option<Instant>, packet::Epoch) { in loss_time_and_space()
[all …]
|
| D | reno.rs | 51 pub fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, _now: Instant) { in on_packet_sent()
56 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
119 r: &mut Recovery, time_sent: Instant, epoch: packet::Epoch, now: Instant, in congestion_event()
|
| D | delivery_rate.rs | 53 pub fn on_packet_sent(&mut self, pkt: &mut Sent, now: Instant) { in on_packet_sent()
71 pub fn on_packet_acked(&mut self, pkt: &Sent, now: Instant) { in on_packet_acked()
|
| D | cubic.rs | 164 fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, now: Instant) { in on_packet_sent()
190 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
334 r: &mut Recovery, time_sent: Instant, epoch: packet::Epoch, now: Instant, in congestion_event()
|
| D | hystart.rs | 91 pub fn lss_start_time(&self) -> Option<Instant> { in lss_start_time()
122 now: Instant, max_datagram_size: usize, in try_enter_lss()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | tick.rs | 38 pub(crate) fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv()
59 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv()
88 pub(crate) unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()> { in read()
139 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | at.rs | 43 pub(crate) fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv()
67 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv()
106 pub(crate) unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()> { in read()
169 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | zero.rs | 222 deadline: Option<Instant>, in send()
393 fn deadline(&self) -> Option<Instant> { in deadline()
443 fn deadline(&self) -> Option<Instant> { in deadline()
|
| /external/rust/crates/quiche/src/ |
| D | minmax.rs | 79 pub fn reset(&mut self, time: Instant, meas: T) -> T { in reset()
90 pub fn running_min(&mut self, win: Duration, time: Instant, meas: T) -> T { in running_min()
111 pub fn _running_max(&mut self, win: Duration, time: Instant, meas: T) -> T { in _running_max()
132 fn subwin_update(&mut self, win: Duration, time: Instant, meas: T) -> T { in subwin_update()
|
| /external/rust/crates/parking_lot/src/ |
| D | util.rs | 36 pub fn to_deadline(timeout: Duration) -> Option<Instant> { in to_deadline()
|
| D | raw_fair_mutex.rs | 54 type Instant = <RawMutex as lock_api::RawMutexTimed>::Instant; typedef
|
| /external/rust/crates/instant/ |
| D | README.md | 1 # Instant chapter
|
| /external/rust/crates/tokio/tests/ |
| D | time_interval.rs | 169 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next()
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 141 pub fn park_deadline(&self, deadline: Instant) { in park_deadline()
317 fn park(&self, deadline: Option<Instant>) { in park()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | channel.rs | 173 pub fn after(duration: Duration) -> Receiver<Instant> { in after()
221 pub fn at(when: Instant) -> Receiver<Instant> { in at()
319 pub fn tick(duration: Duration) -> Receiver<Instant> { in tick()
1342 fn deadline(&self) -> Option<Instant> { in deadline()
1407 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | select.rs | 103 fn deadline(&self) -> Option<Instant>; in deadline()
129 fn deadline(&self) -> Option<Instant> { in deadline()
496 deadline: Instant, in select_deadline()
907 deadline: Instant, in select_deadline()
|
| /external/crosvm/common/cros_asyncv2/src/ |
| D | timer.rs | 62 pub fn deadline(&self) -> Instant { in deadline()
156 pub async fn with_deadline<F: Future>(deadline: Instant, f: F) -> Result<F::Output, TimedOut> { in with_deadline()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | interval.rs | 31 fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Instant>> { in poll_next()
|
| /external/tensorflow/tensorflow/core/profiler/utils/ |
| D | timespan.h | 48 bool Instant() const { return duration_ps() == 0; } in Instant() function
|