| /external/rust/crates/tokio/src/time/ |
| D | instant.rs | 34 pub struct Instant { struct
35 std: std::time::Instant, argument
38 impl Instant { implementation
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 | 100 pub fn interval_at(start: Instant, period: Duration) -> Interval { in interval_at()
149 pub async fn tick(&mut self) -> Instant { in tick()
164 pub fn poll_tick(&mut self, cx: &mut Context<'_>) -> Poll<Instant> { in poll_tick()
|
| D | timeout.rs | 94 pub fn timeout_at<T>(deadline: Instant, future: T) -> Timeout<T> in timeout_at()
|
| /external/rust/crates/instant/src/ |
| D | wasm.rs | 5 pub struct Instant(Duration); struct
7 impl Ord for Instant { implementation
13 impl Eq for Instant {} implementation
15 impl Instant { impl
39 pub fn checked_add(&self, duration: Duration) -> Option<Instant> { in checked_add()
47 pub fn checked_sub(&self, duration: Duration) -> Option<Instant> { in checked_sub()
52 impl Add<Duration> for Instant { implementation
61 impl AddAssign<Duration> for Instant { implementation
68 impl Sub<Duration> for Instant { implementation
77 impl Sub<Instant> for Instant { implementation
[all …]
|
| D | native.rs | 1 pub type Instant = std::time::Instant; typedef
|
| /external/rust/crates/quiche/src/recovery/ |
| D | reno.rs | 48 pub fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, _now: Instant) { in on_packet_sent()
53 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
102 r: &mut Recovery, time_sent: Instant, epoch: packet::Epoch, now: Instant, in congestion_event()
|
| D | mod.rs | 198 handshake_status: HandshakeStatus, now: Instant, trace_id: &str, in on_packet_sent()
238 fn on_packet_sent_cc(&mut self, sent_bytes: usize, now: Instant) { in on_packet_sent_cc()
244 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
356 &mut self, handshake_status: HandshakeStatus, now: Instant, in on_loss_detection_timeout()
420 now: Instant, in on_pkt_num_space_discarded()
443 pub fn loss_detection_timer(&self) -> Option<Instant> { in loss_detection_timer()
473 &mut self, latest_rtt: Duration, ack_delay: Duration, now: Instant, in update_rtt()
510 fn loss_time_and_space(&self) -> (Option<Instant>, packet::Epoch) { in loss_time_and_space()
529 &self, handshake_status: HandshakeStatus, now: Instant, in pto_time_and_space()
530 ) -> (Option<Instant>, packet::Epoch) { in pto_time_and_space()
[all …]
|
| D | cubic.rs | 128 fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, now: Instant) { in on_packet_sent()
154 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
256 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 | hystart.rs | 90 pub fn lss_start_time(&self) -> Option<Instant> { in lss_start_time()
115 ssthresh: usize, now: Instant, in on_packet_acked()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | tick.rs | 38 pub fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv()
59 pub fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv()
88 pub unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()> { in read()
138 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | at.rs | 43 pub fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv()
67 pub fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv()
106 pub unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()> { in read()
168 fn deadline(&self) -> Option<Instant> { in deadline()
|
| /external/rust/crates/tokio/src/time/driver/ |
| D | sleep.rs | 181 pub fn deadline(&self) -> Instant { in deadline()
219 pub fn reset(self: Pin<&mut Self>, deadline: Instant) { in reset()
|
| /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/tokio/tests/ |
| D | time_interval.rs | 47 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next()
|
| /external/rust/crates/parking_lot/src/ |
| D | util.rs | 37 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/crossbeam-utils/src/sync/ |
| D | parker.rs | 141 pub fn park_deadline(&self, deadline: Instant) { in park_deadline()
315 fn park(&self, deadline: Option<Instant>) { in park()
|
| /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/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()
321 pub fn tick(duration: Duration) -> Receiver<Instant> { in tick()
1344 fn deadline(&self) -> Option<Instant> { in deadline()
1409 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | select.rs | 101 fn deadline(&self) -> Option<Instant>; in deadline()
127 fn deadline(&self) -> Option<Instant> { in deadline()
491 deadline: Instant, in select_deadline()
905 deadline: Instant, in select_deadline()
|
| D | utils.rs | 49 pub fn sleep_until(deadline: Option<Instant>) { in sleep_until()
|
| /external/tensorflow/tensorflow/core/profiler/utils/ |
| D | timespan.h | 48 bool Instant() const { return duration_ps() == 0; } in Instant() function
|
| /external/pigweed/pw_trace/ |
| D | trace_backend_compile_test.cc | 30 TEST(BasicTrace, Instant) { PW_TRACE_INSTANT("Test"); } in TEST() argument
|