| /external/crosvm/cros_async/src/ |
| D | io_ext.rs | 195 let handle = thread::spawn(move || uring_ex.run_until(quit)); in await_uring_from_poll()
198 poll_ex.run_until(go(source)).unwrap(); in await_uring_from_poll()
226 let handle = thread::spawn(move || poll_ex.run_until(quit)); in await_poll_from_uring()
229 uring_ex.run_until(go(source)).unwrap(); in await_poll_from_uring()
250 uring_ex.run_until(go(uring_source)).unwrap(); in readvec()
255 poll_ex.run_until(go(poll_source)).unwrap(); in readvec()
272 ex.run_until(go(uring_source)).unwrap(); in writevec()
277 poll_ex.run_until(go(poll_source)).unwrap(); in writevec()
312 ex.run_until(go(uring_source)).unwrap(); in readmem()
317 poll_ex.run_until(go(poll_source)).unwrap(); in readmem()
[all …]
|
| D | uring_source.rs | 268 assert_eq!(8192, ex.run_until(fut).unwrap().unwrap()); in read_to_mem()
291 ex.run_until(go(&ex)).unwrap(); in readvec()
309 ex.run_until(go(&ex)).unwrap(); in readmulti()
328 assert_eq!(0u64, ex.run_until(read_u64(&source)).unwrap()); in u64_from_file()
364 ex.run_until(futures::future::join(read_task, write_task)) in event()
391 ex.run_until(do_test(&ex)).unwrap(); in pend_on_pipe()
441 ex.run_until(go(&ex)).unwrap(); in readmem()
465 ex.run_until(go(&ex)).unwrap(); in range_error()
498 ex.run_until(go(&ex)).unwrap(); in fallocate()
510 ex.run_until(go(&ex)).unwrap(); in fsync()
[all …]
|
| D | event.rs | 55 let val = ex.run_until(go(eventfd, &ex)).unwrap(); in next_val_reads_value()
69 .run_until(go(EventAsync::new_uring(eventfd, &uring_ex).unwrap())) in next_val_reads_value_poll_and_ring()
77 .run_until(go(EventAsync::new_poll(eventfd, &poll_ex).unwrap())) in next_val_reads_value_poll_and_ring()
|
| D | executor.rs | 299 pub fn run_until<F: Future>(&self, f: F) -> AsyncResult<F::Output> { in run_until() method
301 Executor::Uring(ex) => Ok(ex.run_until(f)?), in run_until()
302 Executor::Fd(ex) => Ok(ex.run_until(f).map_err(PollError::Executor)?), in run_until()
|
| D | timer.rs | 74 ex.run_until(this_test(&ex)).unwrap(); in one_shot()
97 ex.run_until(this_test(&ex)).unwrap(); in one_shot_fd()
|
| D | poll_source.rs | 324 ex.run_until(go(&ex)).unwrap(); in readvec()
341 ex.run_until(go(&ex)).unwrap(); in writevec()
364 ex.run_until(go(&ex)).unwrap(); in fallocate()
|
| D | lib.rs | 156 .and_then(|ex| ex.run_until(fut)) in run_one_uring()
172 .and_then(|ex| ex.run_until(fut)) in run_one_poll()
|
| D | uring_executor.rs | 745 pub fn run_until<F: Future>(&self, f: F) -> Result<F::Output> { in run_until() method
898 ex.run_until(UringQueueEmpty { ex: &ex }) in dont_drop_backing_mem_read()
939 ex.run_until(UringQueueEmpty { ex: &ex }) in dont_drop_backing_mem_write()
978 ex.run_until(check_result(write_task, 8)) in canceled_before_completion()
1032 let t = thread::spawn(move || ex2.run_until(async {})); in drop_on_different_thread()
|
| D | fd_executor.rs | 489 pub fn run_until<F: Future>(&self, f: F) -> Result<F::Output> { in run_until() method
540 ex.run_until(do_test(&ex)).unwrap(); in test_it()
|
| /external/rust/crates/tokio/tests/ |
| D | task_local_set.rs | 22 .run_until(async { in local_basic_scheduler()
37 .run_until(async { in local_threadpool()
118 .run_until(async { in local_threadpool_timer()
165 .run_until(async { in local_threadpool_blocking_run()
194 .run_until(async { in all_spawns_are_local()
219 .run_until(async { in nested_spawn_is_local()
399 rt.block_on(set.run_until(join_all(handles))); in local_tasks_wake_join_all()
416 .run_until(async { in local_tasks_are_polled_after_tick()
485 .run_until(async { in acquire_mutex_in_drop()
498 _ = local.run_until(pending::<()>()).fuse() => unreachable!(), in spawn_wakes_localset()
|
| D | async_send_sync.rs | 302 async_assert_fn!(tokio::task::LocalSet::run_until(_, BoxFutureSync<()>): !Send & !Sync);
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 459 rt.block_on(self.run_until(future)) in block_on()
490 pub async fn run_until<F>(&self, future: F) -> F::Output in run_until() method
494 let run_until = RunUntil { in run_until() localVariable
498 run_until.await in run_until()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 171 pub fn run_until<F: Future>(&mut self, future: F) -> F::Output { in run_until() method
358 LocalPool::new().run_until(self.stream.next()) in next()
|
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 36 pool.run_until(fut); in run_until_single_future()
47 pool.run_until(lazy(|_| ())); in run_until_ignores_spawned()
58 pool.run_until(rx).unwrap(); in run_until_executes_spawned()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_events.py | 394 test_utils.run_until(self.loop, lambda: len(bytes_read) >= 3)
396 test_utils.run_until(self.loop, lambda: len(bytes_read) >= 6)
457 test_utils.run_until(self.loop, lambda: caught)
788 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
856 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
918 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
952 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
1242 test_utils.run_until(self.loop, lambda: server.nbytes)
1244 test_utils.run_until(self.loop, lambda: client.nbytes)
1322 test_utils.run_until(self.loop, lambda: proto.nbytes >= 1)
[all …]
|
| D | utils.py | 110 def run_until(loop, pred, timeout=support.SHORT_TIMEOUT): function
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | worker.rs | 72 match ex.run_until(select2(resample, kill)) { in run()
|
| /external/autotest/client/cros/netprotos/ |
| D | interface_host.py | 53 def run_until(self, predicate, timeout_seconds): member in InterfaceHost
|
| /external/crosvm/devices/src/virtio/ |
| D | block_async.rs | 546 match ex.run_until(select5(queue_handlers, disk_flush, control, resample, kill)) { in run_worker()
1127 ex.run_until(fut) in read_last_sector()
1196 ex.run_until(fut) in read_beyond_last_sector()
1267 ex.run_until(fut) in get_id()
|
| D | balloon.rs | 378 if let Err(e) = ex.run_until(select6(inflate, deflate, stats, command, resample, kill)) { in run_worker()
|
| D | descriptor_utils.rs | 1467 ex.run_until(region_reader_failing_io_async(&ex)).unwrap(); in region_reader_failing_io()
1503 ex.run_until(region_writer_failing_io_async(&ex)).unwrap() in region_writer_failing_io()
|
| /external/crosvm/disk/src/ |
| D | disk.rs | 520 ex.run_until(read_zeros_async(&ex)).unwrap(); in read_async()
540 ex.run_until(write_zeros_async(&ex)).unwrap(); in write_async()
|