• Home
  • Raw
  • Download

Lines Matching full:sleep

28     let sleep = time::sleep(Duration::from_millis(10));  in is_elapsed()  localVariable
30 tokio::pin!(sleep); in is_elapsed()
32 assert!(!sleep.is_elapsed()); in is_elapsed()
34 assert!(futures::poll!(sleep.as_mut()).is_pending()); in is_elapsed()
36 assert!(!sleep.is_elapsed()); in is_elapsed()
38 sleep.as_mut().await; in is_elapsed()
40 assert!(sleep.is_elapsed()); in is_elapsed()
75 time::sleep(ms(5)).await; in delayed_sleep_wrapping_level_0()
89 let mut sleep = task::spawn(Box::pin(time::sleep_until(now + ms(100)))); in reset_future_sleep_before_fire() localVariable
90 assert_pending!(sleep.poll()); in reset_future_sleep_before_fire()
92 let mut sleep = sleep.into_inner(); in reset_future_sleep_before_fire() localVariable
94 sleep.as_mut().reset(Instant::now() + ms(200)); in reset_future_sleep_before_fire()
95 sleep.await; in reset_future_sleep_before_fire()
106 let mut sleep = task::spawn(Box::pin(time::sleep_until(now + ms(100)))); in reset_past_sleep_before_turn() localVariable
107 assert_pending!(sleep.poll()); in reset_past_sleep_before_turn()
109 let mut sleep = sleep.into_inner(); in reset_past_sleep_before_turn() localVariable
111 sleep.as_mut().reset(now + ms(80)); in reset_past_sleep_before_turn()
112 sleep.await; in reset_past_sleep_before_turn()
123 let mut sleep = task::spawn(Box::pin(time::sleep_until(now + ms(100)))); in reset_past_sleep_before_fire() localVariable
124 assert_pending!(sleep.poll()); in reset_past_sleep_before_fire()
126 let mut sleep = sleep.into_inner(); in reset_past_sleep_before_fire() localVariable
128 time::sleep(ms(10)).await; in reset_past_sleep_before_fire()
130 sleep.as_mut().reset(now + ms(80)); in reset_past_sleep_before_fire()
131 sleep.await; in reset_past_sleep_before_fire()
141 let mut sleep = Box::pin(time::sleep_until(now + ms(100))); in reset_future_sleep_after_fire() localVariable
143 sleep.as_mut().await; in reset_future_sleep_after_fire()
146 sleep.as_mut().reset(now + ms(110)); in reset_future_sleep_after_fire()
147 sleep.await; in reset_future_sleep_after_fire()
157 let mut sleep = task::spawn(Box::pin(time::sleep_until(now + ms(100)))); in reset_sleep_to_past() localVariable
158 assert_pending!(sleep.poll()); in reset_sleep_to_past()
160 time::sleep(ms(50)).await; in reset_sleep_to_past()
162 assert!(!sleep.is_woken()); in reset_sleep_to_past()
164 sleep.as_mut().reset(now + ms(40)); in reset_sleep_to_past()
167 //assert!(sleep.is_woken()); in reset_sleep_to_past()
169 assert_ready!(sleep.poll()); in reset_sleep_to_past()
194 tokio::time::sleep(std::time::Duration::from_millis(0)).await; in short_sleeps()
203 tokio::time::sleep(Duration::from_secs( in multi_long_sleeps()
239 let timer = tokio::time::sleep(std::time::Duration::from_millis(1)); in reset_after_firing()
268 time::sleep(ms(MAX_DURATION)).await; in exactly_max()
276 // This is a workaround since awaiting sleep(big) will never finish. in issue_5183()
280 _ = tokio::time::sleep(big) => {} in issue_5183()
281 _ = tokio::time::sleep(std::time::Duration::from_nanos(1)) => {} in issue_5183()
288 time::sleep(ms(MAX_DURATION - 1)).await; in no_out_of_bounds_close_to_max()
303 let mut a = Box::pin(tokio::time::sleep(Duration::from_millis(5))); in drop_after_reschedule_at_new_scheduled_time()
304 let mut b = Box::pin(tokio::time::sleep(Duration::from_millis(5))); in drop_after_reschedule_at_new_scheduled_time()
305 let mut c = Box::pin(tokio::time::sleep(Duration::from_millis(10))); in drop_after_reschedule_at_new_scheduled_time()
326 let list: Arc<Mutex<Vec<Pin<Box<tokio::time::Sleep>>>>> = Arc::new(Mutex::new(Vec::new())); in drop_from_wake()
337 let mut timer = Box::pin(tokio::time::sleep(Duration::from_millis(10))); in drop_from_wake()
345 tokio::time::sleep(Duration::from_millis(11)).await; in drop_from_wake()
355 Arc<Mutex<Vec<Pin<Box<tokio::time::Sleep>>>>>, in drop_from_wake()