Searched refs:assert_err (Results 1 – 14 of 14) sorted by relevance
| /external/rust/crates/tokio-test/src/ |
| D | macros.rs | 97 use tokio_test::{assert_ready, assert_err};
99 assert_err!(val)
102 use tokio_test::{assert_ready, assert_err};
104 assert_err!(val, $($msg)*)
243 macro_rules! assert_err { macro
245 assert_err!($e,);
|
| /external/rust/crates/tokio/tests/ |
| D | io_driver_drop.rs | 6 use tokio_test::{assert_err, assert_pending, assert_ready, task};
21 assert_err!(listener.accept().await); in tcp_doesnt_block()
38 assert_err!(listener.accept().await); in drop_wakes()
|
| D | io_async_fd.rs | 22 use tokio_test::{assert_err, assert_pending};
503 assert_err!(futures::executor::block_on(readable)); in driver_shutdown_wakes_currently_pending()
506 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_currently_pending()
521 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_future_pending()
542 assert_err!(futures::executor::block_on(afd_a.readable())); in driver_shutdown_wakes_pending_race()
572 assert_err!(futures::executor::block_on(readable)); in driver_shutdown_wakes_currently_pending_polls()
573 assert_err!(futures::executor::block_on(writable)); in driver_shutdown_wakes_currently_pending_polls()
588 assert_err!(futures::executor::block_on(poll_readable(&afd_a))); in driver_shutdown_wakes_poll()
589 assert_err!(futures::executor::block_on(poll_writable(&afd_a))); in driver_shutdown_wakes_poll()
609 assert_err!(futures::executor::block_on(poll_readable(&afd_a))); in driver_shutdown_wakes_poll_race()
[all …]
|
| D | process_issue_2174.rs | 17 use tokio_test::assert_err;
44 assert_err!(handle.await); in issue_2174()
|
| D | sync_oneshot.rs | 70 assert_err!(tx.send(1)); in close_rx()
85 assert_err!(tx.into_inner().send(1)); in close_rx()
125 assert_err!(tx.into_inner().send(1)); in explicit_close_poll()
168 assert_err!(rx.try_recv()); in explicit_close_try_recv()
179 assert_err!(rx.try_recv()); in close_try_recv_poll()
|
| D | sync_mpsc.rs | 11 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
255 assert_err!(tx.try_send(1337)); in send_recv_buffer_limited()
272 assert_err!(tx.send(1).await); in recv_close_gets_none_idle()
316 match assert_err!(tx.try_send("fail")) { in try_send_fail()
337 match assert_err!(tx.try_reserve()) { in try_reserve_fails()
379 assert_err!(tx.reserve().await); in dropping_rx_closes_channel()
393 let err = assert_err!(tx.try_send(msg.clone())); in dropping_rx_closes_channel_for_try()
|
| D | time_pause.rs | 7 use tokio_test::assert_err;
35 assert_err!(t.await); in pause_time_in_spawn_threads()
|
| D | sync_broadcast.rs | 8 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
34 match assert_err!($e) {
45 match assert_err!($e) {
264 assert_err!(tx.send("hello")); in send_no_rx()
312 assert_err!(res); in panic_in_clone()
|
| D | fs_dir.rs | 5 use tokio_test::{assert_err, assert_ok};
40 assert_err!( in build_dir()
|
| D | rt_basic.rs | 6 use tokio_test::{assert_err, assert_ok};
27 assert_err!(rx.try_recv()); in spawned_task_does_not_progress_without_block_on()
|
| D | rt_threaded.rs | 8 use tokio_test::{assert_err, assert_ok};
137 assert_err!(rx.try_recv()); in spawn_shutdown()
|
| D | rt_common.rs | 63 use tokio_test::{assert_err, assert_ok};
646 assert_err!(rx.try_recv());
965 assert_err!(rx.try_recv());
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_broadcast.rs | 7 use tokio_test::{assert_err, assert_ok};
64 match assert_err!(rx1.recv().await) { in broadcast_two()
79 match assert_err!(rx2.recv().await) { in broadcast_two()
161 match assert_err!(rx1.recv().await) { in drop_rx()
|
| D | semaphore_batch.rs | 120 assert_err!(s.try_acquire(1)); in try_acquire_one_unavailable()
139 assert_err!(s.try_acquire(5)); in try_acquire_many_unavailable()
|