_require_full.rs |
|
475 |
async_send_sync.rs |
|
43248 |
buffered.rs |
|
1359 |
coop_budget.rs |
|
2684 |
dump.rs |
|
4872 |
duplex_stream.rs |
|
1249 |
fs.rs |
|
491 |
fs_canonicalize_dir.rs |
|
620 |
fs_copy.rs |
|
1169 |
fs_dir.rs |
|
3254 |
fs_file.rs |
|
6698 |
fs_link.rs |
|
1496 |
fs_open_options.rs |
|
2616 |
fs_open_options_windows.rs |
|
1490 |
fs_remove_dir_all.rs |
|
935 |
fs_remove_file.rs |
|
660 |
fs_rename.rs |
|
796 |
fs_symlink_dir_windows.rs |
|
818 |
fs_symlink_file_windows.rs |
|
682 |
fs_try_exists.rs |
|
1595 |
io_async_fd.rs |
|
23018 |
io_async_read.rs |
|
174 |
io_buf_reader.rs |
|
12063 |
io_buf_writer.rs |
|
16198 |
io_chain.rs |
|
359 |
io_copy.rs |
|
2616 |
io_copy_bidirectional.rs |
|
4670 |
io_driver.rs |
|
2821 |
io_driver_drop.rs |
|
1197 |
io_fill_buf.rs |
|
859 |
io_join.rs |
|
1879 |
io_lines.rs |
|
533 |
io_mem_stream.rs |
|
2851 |
io_panic.rs |
|
5647 |
io_poll_aio.rs |
|
11511 |
io_read.rs |
|
1720 |
io_read_buf.rs |
|
2526 |
io_read_exact.rs |
|
352 |
io_read_line.rs |
|
3164 |
io_read_to_end.rs |
.. do nothing .. |
3549 |
io_read_to_string.rs |
|
1628 |
io_read_until.rs |
|
2101 |
io_repeat.rs |
|
423 |
io_sink.rs |
|
967 |
io_split.rs |
|
2549 |
io_take.rs |
|
1689 |
io_util_empty.rs |
|
1823 |
io_write.rs |
|
1342 |
io_write_all.rs |
|
1184 |
io_write_all_buf.rs |
|
2475 |
io_write_buf.rs |
|
1313 |
io_write_int.rs |
|
942 |
join_handle_panic.rs |
|
621 |
macros_join.rs |
|
4460 |
macros_pin.rs |
|
454 |
macros_rename_test.rs |
|
672 |
macros_select.rs |
|
16481 |
macros_test.rs |
|
2972 |
macros_try_join.rs |
|
4686 |
net_bind_resource.rs |
|
389 |
net_lookup_host.rs |
|
1110 |
net_named_pipe.rs |
|
13127 |
net_panic.rs |
|
5304 |
net_unix_pipe.rs |
|
15985 |
no_rt.rs |
|
1189 |
process_arg0.rs |
|
318 |
process_change_of_runtime.rs |
|
1044 |
process_issue_42.rs |
|
1272 |
process_issue_2174.rs |
|
1404 |
process_kill_on_drop.rs |
|
1063 |
process_raw_handle.rs |
|
591 |
process_smoke.rs |
|
865 |
rt_basic.rs |
|
11594 |
rt_common.rs |
|
39851 |
rt_handle.rs |
|
1728 |
rt_handle_block_on.rs |
|
14428 |
rt_metrics.rs |
|
1639 |
rt_panic.rs |
|
2290 |
rt_threaded.rs |
|
21582 |
rt_threaded_alt.rs |
|
18968 |
rt_time_start_paused.rs |
|
357 |
rt_unstable_metrics.rs |
|
23286 |
signal_ctrl_c.rs |
|
640 |
signal_drop_recv.rs |
|
504 |
signal_drop_rt.rs |
|
1005 |
signal_drop_signal.rs |
|
770 |
signal_multi_rt.rs |
|
1464 |
signal_no_rt.rs |
|
307 |
signal_notify_both.rs |
|
502 |
signal_panic.rs |
|
690 |
signal_twice.rs |
|
439 |
signal_usr1.rs |
|
434 |
support |
|
|
sync_barrier.rs |
|
2218 |
sync_broadcast.rs |
|
14348 |
sync_errors.rs |
|
635 |
sync_mpsc.rs |
|
38040 |
sync_mpsc_weak.rs |
|
18853 |
sync_mutex.rs |
#[test]
#[ignore]
fn lock() {
let mut lock = Mutex::new(false);
let mut lock2 = lock.clone();
std::thread::spawn(move || {
let l = lock2.lock();
pin_mut!(l);
let mut task = MockTask::new();
let mut g = assert_ready!(task.poll(&mut l));
std::thread::sleep(std::time::Duration::from_millis(500));
g = true;
drop(g);
});
std::thread::sleep(std::time::Duration::from_millis(50));
let mut task = MockTask::new();
let l = lock.lock();
pin_mut!(l);
assert_pending!(task.poll(&mut l));
std::thread::sleep(std::time::Duration::from_millis(500));
assert!(task.is_woken());
let result = assert_ready!(task.poll(&mut l));
assert!(*result);
}
|
4653 |
sync_mutex_owned.rs |
|
3725 |
sync_notify.rs |
|
7534 |
sync_once_cell.rs |
|
6376 |
sync_oneshot.rs |
|
6692 |
sync_panic.rs |
|
5282 |
sync_rwlock.rs |
|
9389 |
sync_semaphore.rs |
|
4737 |
sync_semaphore_owned.rs |
|
4847 |
sync_watch.rs |
|
8154 |
task_abort.rs |
|
6885 |
task_blocking.rs |
|
8523 |
task_builder.rs |
|
1810 |
task_id.rs |
|
8070 |
task_join_set.rs |
|
7304 |
task_local.rs |
|
3551 |
task_local_set.rs |
|
21030 |
task_panic.rs |
|
2905 |
task_yield_now.rs |
|
424 |
tcp_accept.rs |
|
4612 |
tcp_connect.rs |
|
5868 |
tcp_echo.rs |
|
1179 |
tcp_into_split.rs |
|
3771 |
tcp_into_std.rs |
|
1441 |
tcp_peek.rs |
|
873 |
tcp_shutdown.rs |
|
858 |
tcp_socket.rs |
|
2017 |
tcp_split.rs |
|
1289 |
tcp_stream.rs |
|
10952 |
test_clock.rs |
|
1392 |
time_interval.rs |
|
16660 |
time_panic.rs |
|
2364 |
time_pause.rs |
|
8387 |
time_rt.rs |
|
2067 |
time_sleep.rs |
|
8380 |
time_timeout.rs |
|
3462 |
udp.rs |
|
19819 |
uds_cred.rs |
|
651 |
uds_datagram.rs |
|
11866 |
uds_socket.rs |
|
3159 |
uds_split.rs |
|
1268 |
uds_stream.rs |
|
10976 |
unwindsafe.rs |
|
1118 |