Searched refs:TimerAsync (Results 1 – 11 of 11) sorted by relevance
| /external/crosvm/cros_async/src/ |
| D | timer.rs | 18 pub struct TimerAsync<T: TimerTrait + IntoAsync> { struct
22 impl<T: TimerTrait + IntoAsync> TimerAsync<T> { implementation
23 pub fn new(timer: T, ex: &Executor) -> AsyncResult<TimerAsync<T>> { in new()
25 .map(|io_source| TimerAsync { io_source }) in new()
52 impl TimerAsync<Timer> { implementation
60 let t = TimerAsync::new(tfd, ex).map_err(Error::TimerAsync)?; in sleep()
61 t.wait().await.map_err(Error::TimerAsync)?; in sleep()
|
| D | audio_streams_async.rs | 38 use crate::TimerAsync;
103 TimerAsync::sleep(self, dur).await.map_err(Into::into) in delay()
|
| D | lib.rs | 111 pub use timer::TimerAsync;
134 TimerAsync(AsyncError), enumerator
|
| /external/crosvm/cros_async/src/sys/linux/ |
| D | timer.rs | 10 use crate::TimerAsync;
12 impl<T: TimerTrait + IntoAsync> TimerAsync<T> { impl
41 impl TimerAsync<Timer> { implementation
45 ) -> AsyncResult<TimerAsync<Timer>> { in new_poll()
47 .map(|io_source| TimerAsync { io_source }) in new_poll()
53 ) -> AsyncResult<TimerAsync<Timer>> { in new_uring()
55 .map(|io_source| TimerAsync { io_source }) in new_uring()
64 TimerAsync::sleep(ex, dur).await.expect("unable to sleep"); in timer()
85 let t = TimerAsync::new_uring(tfd, ex).unwrap(); in one_shot()
104 let t = TimerAsync::new_poll(tfd, ex).unwrap(); in one_shot_fd()
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | timer.rs | 9 use crate::TimerAsync;
11 impl<T: TimerTrait + IntoAsync> TimerAsync<T> { impl
35 TimerAsync::sleep(ex, dur).await.expect("unable to sleep"); in timer()
|
| /external/crosvm/cros_async/src/sys/ |
| D | windows.rs | 34 TimerAsync(e) => e.into(), in from()
|
| D | linux.rs | 36 TimerAsync(e) => e.into(), in from()
|
| /external/crosvm/devices/src/virtio/block/ |
| D | asynchronous.rs | 40 use cros_async::TimerAsync;
234 flush_timer: &RefCell<TimerAsync<Timer>>, in process_one_request()
279 flush_timer: &RefCell<TimerAsync<Timer>>, in process_one_chain()
304 flush_timer: Rc<RefCell<TimerAsync<Timer>>>, in handle_queue()
421 timer: TimerAsync<Timer>, in flush_disk()
487 TimerAsync::new( in run_worker()
496 let flush_timer2 = TimerAsync::new(timer, ex).expect("Failed to create an async timer"); in run_worker()
763 flush_timer: &RefCell<TimerAsync<Timer>>, in execute_request()
1371 TimerAsync::new(timer, &ex).expect("Failed to create an async timer"), in read_last_sector()
1440 TimerAsync::new(timer, &ex).expect("Failed to create an async timer"), in read_beyond_last_sector()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | pmem.rs | 28 use cros_async::TimerAsync;
123 TimerAsync::new(timer, ex).expect("Failed to create an async pageout timer"); in pageout()
|
| /external/crosvm/src/sys/windows/ |
| D | run_vcpu.rs | 49 use cros_async::TimerAsync;
435 let mut timer = TimerAsync::new(Timer::new()?, &ex)?; in run()
|
| /external/crosvm/devices/src/virtio/snd/common_backend/ |
| D | async_funcs.rs | 26 use cros_async::TimerAsync;
373 if let Err(e) = TimerAsync::sleep(&ex, period_dur * 2).await { in pcm_worker_loop()
|