| /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()
141 pub fn checked_add(&self, duration: Duration) -> Option<Instant> { in checked_add()
148 pub fn checked_sub(&self, duration: Duration) -> Option<Instant> { in checked_sub()
153 impl From<std::time::Instant> for Instant { implementation
154 fn from(time: std::time::Instant) -> Instant { in from()
159 impl From<Instant> for std::time::Instant { implementation
[all …]
|
| D | interval.rs | 109 pub fn interval_at(start: Instant, period: Duration) -> Interval { in interval_at()
116 start: Instant, in internal_interval_at()
341 fn next_timeout(&self, timeout: Instant, now: Instant, period: Duration) -> Instant { in next_timeout()
433 pub async fn tick(&mut self) -> Instant { in tick()
462 pub fn poll_tick(&mut self, cx: &mut Context<'_>) -> Poll<Instant> { in poll_tick()
|
| D | sleep.rs | 254 deadline: Instant, in new_timeout()
313 pub fn deadline(&self) -> Instant { in deadline()
353 pub fn reset(self: Pin<&mut Self>, deadline: Instant) { in reset()
357 fn reset_inner(self: Pin<&mut Self>, deadline: Instant) { in reset_inner()
|
| /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/quiche/src/recovery/bbr/ |
| D | per_ack.rs | 49 r: &mut Recovery, packet: &Acked, now: Instant, in bbr_update_model_and_state()
59 pub fn bbr_update_control_parameters(r: &mut Recovery, now: Instant) { in bbr_update_control_parameters()
105 fn bbr_update_rtprop(r: &mut Recovery, now: Instant) { in bbr_update_rtprop()
254 fn bbr_check_drain(r: &mut Recovery, now: Instant) { in bbr_check_drain()
268 fn bbr_enter_probe_bw(r: &mut Recovery, now: Instant) { in bbr_enter_probe_bw()
287 fn bbr_check_cycle_phase(r: &mut Recovery, now: Instant) { in bbr_check_cycle_phase()
295 fn bbr_advance_cycle_phase(r: &mut Recovery, now: Instant) { in bbr_advance_cycle_phase()
326 fn bbr_check_probe_rtt(r: &mut Recovery, now: Instant) { in bbr_check_probe_rtt()
352 fn bbr_handle_probe_rtt(r: &mut Recovery, now: Instant) { in bbr_handle_probe_rtt()
374 fn bbr_exit_probe_rtt(r: &mut Recovery, now: Instant) { in bbr_exit_probe_rtt()
|
| D | mod.rs | 255 fn bbr_enter_recovery(r: &mut Recovery, now: Instant) { in bbr_enter_recovery()
291 fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, _now: Instant) { in on_packet_sent()
298 r: &mut Recovery, packets: &[Acked], _epoch: packet::Epoch, now: Instant, in on_packets_acked()
323 r: &mut Recovery, lost_bytes: usize, time_sent: Instant, in congestion_event()
324 _epoch: packet::Epoch, now: Instant, in congestion_event()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | tick.rs | 29 pub(crate) fn new(delivery_time: Instant, dur: Duration) -> Self { in new()
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()
138 fn deadline(&self) -> Option<Instant> { in deadline()
|
| D | at.rs | 38 pub(crate) fn try_recv(&self) -> Result<Instant, TryRecvError> { in try_recv()
62 pub(crate) fn recv(&self, deadline: Option<Instant>) -> Result<Instant, RecvTimeoutError> { in recv()
101 pub(crate) unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()> { in read()
163 fn deadline(&self) -> Option<Instant> { in deadline()
|
| /external/rust/crates/quiche/src/recovery/ |
| D | reno.rs | 58 pub fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, _now: Instant) { in on_packet_sent()
63 r: &mut Recovery, packets: &[Acked], epoch: packet::Epoch, now: Instant, in on_packets_acked()
71 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
110 r: &mut Recovery, _lost_bytes: usize, time_sent: Instant, in congestion_event()
111 epoch: packet::Epoch, now: Instant, in congestion_event()
|
| D | pacer.rs | 113 pub fn update(&mut self, capacity: usize, rate: u64, now: Instant) { in update()
126 pub fn reset(&mut self, now: Instant) { in reset()
139 pub fn send(&mut self, packet_size: usize, now: Instant) { in send()
185 pub fn next_time(&self) -> Instant { in next_time()
|
| D | mod.rs | 320 handshake_status: HandshakeStatus, now: Instant, trace_id: &str, in on_packet_sent()
385 fn on_packet_sent_cc(&mut self, sent_bytes: usize, now: Instant) { in on_packet_sent_cc()
389 pub fn set_pacing_rate(&mut self, rate: u64, now: Instant) { in set_pacing_rate()
393 pub fn get_packet_send_time(&self) -> Instant { in get_packet_send_time()
398 &mut self, epoch: packet::Epoch, now: Instant, packet_size: usize, in schedule_next_packet()
421 epoch: packet::Epoch, handshake_status: HandshakeStatus, now: Instant, in on_ack_received()
578 &mut self, handshake_status: HandshakeStatus, now: Instant, in on_loss_detection_timeout()
645 now: Instant, in on_pkt_num_space_discarded()
668 pub fn loss_detection_timer(&self) -> Option<Instant> { in loss_detection_timer()
737 &mut self, latest_rtt: Duration, ack_delay: Duration, now: Instant, in update_rtt()
[all …]
|
| D | cubic.rs | 174 fn on_packet_sent(r: &mut Recovery, sent_bytes: usize, now: Instant) { in on_packet_sent()
200 r: &mut Recovery, packets: &[Acked], epoch: packet::Epoch, now: Instant, in on_packets_acked()
208 r: &mut Recovery, packet: &Acked, epoch: packet::Epoch, now: Instant, in on_packet_acked()
350 r: &mut Recovery, _lost_bytes: usize, time_sent: Instant, in congestion_event()
351 epoch: packet::Epoch, now: Instant, in congestion_event()
|
| D | hystart.rs | 107 pub fn css_start_time(&self) -> Option<Instant> { in css_start_time()
132 now: Instant, in on_packet_acked()
|
| /external/crosvm/base/src/ |
| D | clock.rs | 21 pub fn now(&self) -> Instant { in now()
45 pub fn now(&self) -> Instant { in now()
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/time/ |
| D | DurationUtils.java | 118 …public static <E extends Throwable> Duration of(final FailableConsumer<Instant, E> consumer) throw… in of()
135 …private static <E extends Throwable> Instant now(final FailableConsumer<Instant, E> nowConsumer) t… in now()
|
| /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()
|
| D | flowcontrol.rs | 101 pub fn update_max_data(&mut self, now: Instant) { in update_max_data()
109 pub fn autotune_window(&mut self, now: Instant, rtt: Duration) { in autotune_window()
|
| /external/crosvm/devices/src/ |
| D | bus_stats.rs | 69 fn increment(&mut self, stat: BusOperation, start: Instant) { in increment()
147 pub(crate) fn start_stat(&self) -> Option<Instant> { in start_stat()
162 start: Option<Instant>, in end_stat()
|
| /external/rust/crates/parking_lot/src/ |
| D | util.rs | 36 pub fn to_deadline(timeout: Duration) -> Option<Instant> { in to_deadline()
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | utils.rs | 45 pub(crate) fn sleep_until(deadline: Option<Instant>) { in sleep_until()
|
| /external/rust/crates/instant/ |
| D | README.md | 1 # Instant chapter
|
| /external/crosvm/src/crosvm/sys/windows/ |
| D | stats.rs | 50 pub fn start_stat(&self) -> Option<Instant> { in start_stat()
62 pub fn end_stat(&mut self, exit: &base::Result<VcpuExit>, start: Option<Instant>) { in end_stat()
|
| /external/pigweed/pw_trace/ |
| D | trace_facade_test.cc | 53 TEST(BasicTrace, Instant) { in TEST() argument
403 TEST(DisableTrace, Instant) { in TEST() argument
|
| /external/rust/crates/tokio/tests/ |
| D | time_interval.rs | 205 fn poll_next(interval: &mut task::Spawn<time::Interval>) -> Poll<Instant> { in poll_next()
|