| /external/rust/crates/tokio/tests/ |
| D | tcp_connect.rs | 6 use tokio_test::assert_ok;
12 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_v4()
13 let addr = assert_ok!(srv.local_addr()); in connect_v4()
19 let (socket, addr) = assert_ok!(srv.accept().await); in connect_v4()
20 assert_eq!(addr, assert_ok!(socket.peer_addr())); in connect_v4()
21 assert_ok!(tx.send(socket)); in connect_v4()
24 let mine = assert_ok!(TcpStream::connect(&addr).await); in connect_v4()
25 let theirs = assert_ok!(rx.await); in connect_v4()
28 assert_ok!(mine.local_addr()), in connect_v4()
29 assert_ok!(theirs.peer_addr()) in connect_v4()
[all …]
|
| D | tcp_socket.rs | 5 use tokio_test::assert_ok;
10 let addr = assert_ok!("127.0.0.1:0".parse()); in basic_usage_v4()
11 let srv = assert_ok!(TcpSocket::new_v4()); in basic_usage_v4()
12 assert_ok!(srv.bind(addr)); in basic_usage_v4()
14 let srv = assert_ok!(srv.listen(128)); in basic_usage_v4()
18 let cli = assert_ok!(TcpSocket::new_v4()); in basic_usage_v4()
19 let _cli = assert_ok!(cli.connect(addr).await); in basic_usage_v4()
22 let _ = assert_ok!(srv.accept().await); in basic_usage_v4()
28 let addr = assert_ok!("[::1]:0".parse()); in basic_usage_v6()
29 let srv = assert_ok!(TcpSocket::new_v6()); in basic_usage_v6()
[all …]
|
| D | sync_broadcast.rs | 8 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
62 let n = assert_ok!(tx.send("hello")); in send_try_recv_bounded()
79 let n = assert_ok!(tx.send("hello")); in send_two_recv()
100 assert_ok!(tx.send("hello")); in send_recv_bounded()
118 assert_ok!(tx.send("hello")); in send_two_recv_bounded()
135 assert_ok!(tx.send("world")); in send_two_recv_bounded()
177 assert_ok!(tx.send("one")); in send_slow_rx()
182 assert_ok!(tx.send("two")); in send_slow_rx()
195 assert_ok!(tx.send("three")); in send_slow_rx()
218 assert_ok!(tx.send("one")); in drop_rx_while_values_remain()
[all …]
|
| D | tcp_echo.rs | 7 use tokio_test::assert_ok;
15 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in echo_server()
16 let addr = assert_ok!(srv.local_addr()); in echo_server()
20 let mut stream = assert_ok!(TcpStream::connect(&addr).await); in echo_server()
24 assert_ok!(stream.write_all(msg.as_bytes()).await); in echo_server()
28 assert_ok!(stream.read_exact(&mut buf).await); in echo_server()
32 assert_ok!(tx.send(())); in echo_server()
35 let (mut stream, _) = assert_ok!(srv.accept().await); in echo_server()
38 let n = assert_ok!(io::copy(&mut rd, &mut wr).await); in echo_server()
41 assert_ok!(rx.await); in echo_server()
|
| D | rt_common.rs | 63 use tokio_test::{assert_err, assert_ok};
98 assert_ok!(rx.await)
115 assert_ok!(rx.await)
133 let msg = assert_ok!(rx.await);
135 let out = assert_ok!(handle.await);
153 assert_ok!(tx1.send("ZOMG"));
157 let msg = assert_ok!(rx1.await);
158 assert_ok!(tx2.send(msg));
161 assert_ok!(rx2.await)
184 let msg = assert_ok!(rx.await);
[all …]
|
| D | buffered.rs | 5 use tokio_test::assert_ok;
15 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in echo_server()
16 let addr = assert_ok!(srv.local_addr()); in echo_server()
21 let mut s = assert_ok!(TcpStream::connect(&addr)); in echo_server()
24 let mut s = assert_ok!(TcpStream::connect(&addr)); in echo_server()
26 assert_ok!(s.read_exact(&mut b)); in echo_server()
33 let res = assert_ok!(s.write(msg.as_bytes())); in echo_server()
40 let (mut a, _) = assert_ok!(srv.accept().await); in echo_server()
41 let (mut b, _) = assert_ok!(srv.accept().await); in echo_server()
43 let n = assert_ok!(tokio::io::copy(&mut a, &mut b).await); in echo_server()
|
| D | tcp_shutdown.rs | 6 use tokio_test::assert_ok;
10 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in shutdown()
11 let addr = assert_ok!(srv.local_addr()); in shutdown()
14 let mut stream = assert_ok!(TcpStream::connect(&addr).await); in shutdown()
16 assert_ok!(AsyncWriteExt::shutdown(&mut stream).await); in shutdown()
19 let n = assert_ok!(stream.read(&mut buf).await); in shutdown()
23 let (mut stream, _) = assert_ok!(srv.accept().await); in shutdown()
26 let n = assert_ok!(io::copy(&mut rd, &mut wr).await); in shutdown()
|
| D | tcp_accept.rs | 6 use tokio_test::assert_ok;
16 let listener = assert_ok!(TcpListener::bind($target).await);
22 let (socket, _) = assert_ok!(listener.accept().await);
23 assert_ok!(tx.send(socket));
26 let cli = assert_ok!(TcpStream::connect(&addr).await);
27 let srv = assert_ok!(rx.await);
67 let mut listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in no_extra_poll()
78 assert_ok!(tx.send(Arc::clone(&incoming.npolls))); in no_extra_poll()
84 let npolls = assert_ok!(rx.await); in no_extra_poll()
90 let _ = assert_ok!(TcpStream::connect(&addr).await); in no_extra_poll()
[all …]
|
| D | sync_mpsc.rs | 11 assert_err, assert_ok, assert_pending, assert_ready, assert_ready_err, assert_ready_ok,
57 let permit1 = assert_ok!(tx1.reserve().await); in reserve_disarm()
58 let permit2 = assert_ok!(tx2.reserve().await); in reserve_disarm()
93 assert_ok!(tx.send(1).await); in send_recv_stream_with_buffer()
94 assert_ok!(tx.send(2).await); in send_recv_stream_with_buffer()
107 assert_ok!(tx.send(1).await); in async_send_recv_with_buffer()
108 assert_ok!(tx.send(2).await); in async_send_recv_with_buffer()
125 assert_ok!(tx1.try_send(())); in start_send_past_cap()
159 assert_ok!(tx.send(1)); in send_recv_unbounded()
160 assert_ok!(tx.send(2)); in send_recv_unbounded()
[all …]
|
| D | io_lines.rs | 5 use tokio_test::assert_ok;
12 let b = assert_ok!(st.next_line().await).unwrap(); in lines_inherent()
14 let b = assert_ok!(st.next_line().await).unwrap(); in lines_inherent()
16 let b = assert_ok!(st.next_line().await).unwrap(); in lines_inherent()
18 assert!(assert_ok!(st.next_line().await).is_none()); in lines_inherent()
|
| D | macros_select.rs | 4 use tokio_test::{assert_ok, assert_pending, assert_ready};
112 assert_ok!(res) in one_ready()
126 assert_ok!(tx2.send(1)); in select_streams()
129 assert_ok!(tx1.send(2)); in select_streams()
132 assert_ok!(tx2.send(3)); in select_streams()
171 assert_eq!(1, assert_ok!(res)); in move_uncompleted_futures()
172 assert_eq!(2, assert_ok!(rx2.await)); in move_uncompleted_futures()
176 assert_eq!(2, assert_ok!(res)); in move_uncompleted_futures()
177 assert_eq!(1, assert_ok!(rx1.await)); in move_uncompleted_futures()
295 assert_ok!(tx.send(1)); in future_panics_after_poll()
[all …]
|
| D | fs_dir.rs | 5 use tokio_test::{assert_err, assert_ok};
16 assert_ok!(fs::create_dir(new_dir).await); in create_dir()
27 assert_ok!(fs::create_dir_all(new_dir).await); in create_all()
37 assert_ok!(fs::DirBuilder::new().recursive(true).create(new_dir).await); in build_dir()
56 assert_ok!(fs::remove_dir(new_dir).await); in remove()
76 while let Some(e) = assert_ok!(entries.next_entry().await) { in read_inherent()
|
| D | tcp_stream.rs | 8 use tokio_test::{assert_ok, assert_pending, assert_ready_ok};
24 assert_ok!(stream.set_linger(Some(Duration::from_secs(1)))); in set_linger()
27 assert_ok!(stream.set_linger(None)); in set_linger()
136 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);
152 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);
174 assert_ok!(client.write_all(b"ping").await); in poll_read_ready()
179 assert_ok!(server.read_exact(&mut buf).await); in poll_read_ready()
206 let listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in create_pair()
207 let addr = assert_ok!(listener.local_addr()); in create_pair()
208 let (client, (server, _)) = assert_ok!(try_join!(TcpStream::connect(&addr), listener.accept())); in create_pair()
|
| D | tcp_peek.rs | 7 use tokio_test::assert_ok;
16 let t = thread::spawn(move || assert_ok!(listener.accept()).0); in peek()
24 let n = assert_ok!(left.peek(&mut buf).await); in peek()
27 let n = assert_ok!(left.read(&mut buf).await); in peek()
|
| D | fs.rs | 5 use tokio_test::assert_ok;
12 assert_ok!(fs::write(dir.join("bar"), b"bytes").await); in path_read_write()
13 let out = assert_ok!(fs::read(dir.join("bar")).await); in path_read_write()
|
| D | task_blocking.rs | 5 use tokio_test::assert_ok;
18 let out = assert_ok!( in basic_blocking()
20 assert_ok!( in basic_blocking()
39 let out = assert_ok!( in block_in_blocking()
41 assert_ok!( in block_in_blocking()
62 let out = assert_ok!( in block_in_block()
|
| D | io_read_until.rs | 6 use tokio_test::{assert_ok, io::Builder};
13 let n = assert_ok!(rd.read_until(b' ', &mut buf).await); in read_until()
17 let n = assert_ok!(rd.read_until(b' ', &mut buf).await); in read_until()
21 let n = assert_ok!(rd.read_until(b' ', &mut buf).await); in read_until()
|
| D | io_read_line.rs | 6 use tokio_test::{assert_ok, io::Builder};
15 let n = assert_ok!(rd.read_line(&mut buf).await); in read_line()
19 let n = assert_ok!(rd.read_line(&mut buf).await); in read_line()
23 let n = assert_ok!(rd.read_line(&mut buf).await); in read_line()
27 let n = assert_ok!(rd.read_line(&mut buf).await); in read_line()
|
| D | uds_stream.rs | 10 use tokio_test::{assert_ok, assert_pending, assert_ready_ok, task};
147 let dir = assert_ok!(tempfile::tempdir()); in create_pair()
150 let listener = assert_ok!(UnixListener::bind(&bind_path)); in create_pair()
154 let ((server, _), client) = assert_ok!(try_join(accept, connect).await); in create_pair()
161 assert_ok!(poll_fn(|cx| $stream.poll_read_ready(cx)).await);
177 assert_ok!(poll_fn(|cx| $stream.poll_write_ready(cx)).await);
199 assert_ok!(client.write_all(b"ping").await); in poll_read_ready()
204 assert_ok!(server.read_exact(&mut buf).await); in poll_read_ready()
|
| D | process_smoke.rs | 5 use tokio_test::assert_ok;
24 let status = assert_ok!(child.wait().await); in simple()
28 let status = assert_ok!(child.wait().await); in simple()
|
| D | net_lookup_host.rs | 2 use tokio_test::assert_ok;
11 let actual = assert_ok!(net::lookup_host(addr).await).collect::<Vec<_>>(); in lookup_socket_addr()
19 let actual = assert_ok!(net::lookup_host("127.0.0.1:8000").await).collect::<Vec<_>>(); in lookup_str_socket_addr()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_broadcast.rs | 7 use tokio_test::{assert_err, assert_ok};
18 assert_ok!(tx1.send("one")); in broadcast_send()
19 assert_ok!(tx1.send("two")); in broadcast_send()
20 assert_ok!(tx1.send("three")); in broadcast_send()
26 assert_ok!(tx2.send("eins")); in broadcast_send()
27 assert_ok!(tx2.send("zwei")); in broadcast_send()
28 assert_ok!(tx2.send("drei")); in broadcast_send()
44 assert_ok!(th1.join()); in broadcast_send()
45 assert_ok!(th2.join()); in broadcast_send()
58 let v = assert_ok!(rx1.recv().await); in broadcast_two()
[all …]
|
| D | semaphore_batch.rs | 32 assert_ok!(s.try_acquire(1)); in try_acquire_one_available()
35 assert_ok!(s.try_acquire(1)); in try_acquire_one_available()
44 assert_ok!(s.try_acquire(5)); in try_acquire_many_available()
47 assert_ok!(s.try_acquire(5)); in try_acquire_many_available()
117 assert_ok!(s.try_acquire(1)); in try_acquire_one_unavailable()
125 assert_ok!(s.try_acquire(1)); in try_acquire_one_unavailable()
136 assert_ok!(s.try_acquire(1)); in try_acquire_many_unavailable()
144 assert_ok!(s.try_acquire(5)); in try_acquire_many_unavailable()
249 assert_ok!(s.try_acquire(6)); in cancel_acquire_releases_permits()
|
| D | loom_mpsc.rs | 7 use tokio_test::assert_ok;
80 assert_ok!(th1.join()); in closing_and_sending()
81 assert_ok!(th2.join()); in closing_and_sending()
82 assert_ok!(th3.join()); in closing_and_sending()
|
| /external/rust/crates/tokio-test/src/ |
| D | macros.rs | 64 use tokio_test::{assert_ready, assert_ok};
66 assert_ok!(val)
69 use tokio_test::{assert_ready, assert_ok};
71 assert_ok!(val, $($msg)*)
200 macro_rules! assert_ok { macro
202 assert_ok!($e,)
|