| _require_full.rs |
|
432 |
- |
| async_send_sync.rs |
|
44706 |
- |
| buffered.rs |
|
1409 |
- |
| coop_budget.rs |
|
3070 |
- |
| dump.rs |
|
4836 |
- |
| duplex_stream.rs |
|
1249 |
- |
| fs.rs |
|
899 |
- |
| fs_canonicalize_dir.rs |
|
620 |
- |
| fs_copy.rs |
|
1269 |
- |
| fs_dir.rs |
|
3254 |
- |
| fs_file.rs |
|
7260 |
- |
| fs_link.rs |
|
3323 |
- |
| fs_open_options.rs |
|
2603 |
- |
| 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 |
|
817 |
- |
| fs_symlink_file_windows.rs |
|
682 |
- |
| fs_try_exists.rs |
|
1714 |
- |
| fs_uring.rs |
Uring file operations tests. |
3975 |
- |
| fs_uring_cancel_open.rs |
Uring file operations tests. |
2282 |
- |
| fs_uring_completed_then_dropped_before_repoll.rs |
|
4389 |
- |
| fs_uring_file_read.rs |
Tests for AsyncRead on tokio::fs::File via io-uring. |
13846 |
- |
| fs_uring_read.rs |
Uring file operations tests. |
5034 |
- |
| fs_uring_runtime_shutdown.rs |
Uring file operations tests. |
2540 |
- |
| fs_write.rs |
|
440 |
- |
| io_async_fd.rs |
|
25974 |
- |
| io_async_fd_memory_leak.rs |
Regression test for issue #7563 - Memory leak when fd closed before AsyncFd drop
This test uses a custom global allocator to track actual memory usage,
avoiding false positives from RSS measurements which include freed-but-retained memory. |
6012 |
- |
| io_async_read.rs |
|
174 |
- |
| io_buf_reader.rs |
|
12063 |
- |
| io_buf_writer.rs |
|
16198 |
- |
| io_chain.rs |
|
359 |
- |
| io_copy.rs |
|
2603 |
- |
| io_copy_bidirectional.rs |
|
4820 |
- |
| io_driver.rs |
|
2993 |
- |
| io_driver_drop.rs |
|
1399 |
- |
| io_fill_buf.rs |
|
859 |
- |
| io_join.rs |
|
1836 |
- |
| io_lines.rs |
|
533 |
- |
| io_mem_stream.rs |
|
2851 |
- |
| io_panic.rs |
|
5644 |
- |
| io_poll_aio.rs |
|
11594 |
- |
| 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 .. |
3597 |
- |
| io_read_to_string.rs |
|
1620 |
- |
| io_read_until.rs |
|
2101 |
- |
| io_repeat.rs |
|
439 |
- |
| io_sink.rs |
|
967 |
- |
| io_split.rs |
|
2506 |
- |
| io_take.rs |
|
1685 |
- |
| io_util_empty.rs |
|
1823 |
- |
| io_write.rs |
|
1342 |
- |
| io_write_all.rs |
|
1184 |
- |
| io_write_all_buf.rs |
|
3948 |
- |
| io_write_buf.rs |
|
2708 |
- |
| io_write_int.rs |
|
942 |
- |
| join_handle_panic.rs |
|
621 |
- |
| macros_join.rs |
|
6806 |
- |
| macros_pin.rs |
|
454 |
- |
| macros_rename_test.rs |
|
672 |
- |
| macros_select.rs |
|
17748 |
- |
| macros_test.rs |
|
3154 |
- |
| macros_try_join.rs |
|
7277 |
- |
| net_bind_resource.rs |
|
564 |
- |
| net_lookup_host.rs |
|
1566 |
- |
| net_named_pipe.rs |
|
13127 |
- |
| net_panic.rs |
|
5654 |
- |
| net_quickack.rs |
|
2188 |
- |
| net_unix_pipe.rs |
|
19236 |
- |
| no_rt.rs |
|
1365 |
- |
| process_arg0.rs |
|
329 |
- |
| process_change_of_runtime.rs |
|
1090 |
- |
| process_issue_42.rs |
|
1289 |
- |
| process_issue_2174.rs |
|
1415 |
- |
| process_issue_7144.rs |
|
818 |
- |
| process_kill_after_wait.rs |
|
612 |
- |
| process_kill_on_drop.rs |
|
1074 |
- |
| process_raw_handle.rs |
|
610 |
- |
| process_smoke.rs |
|
881 |
- |
| rt_basic.rs |
|
13205 |
- |
| rt_common.rs |
|
40636 |
- |
| rt_common_before_park.rs |
|
2750 |
- |
| rt_handle.rs |
|
2700 |
- |
| rt_handle_block_on.rs |
|
15395 |
- |
| rt_local.rs |
|
4398 |
- |
| rt_metrics.rs |
|
6269 |
- |
| rt_panic.rs |
|
2935 |
- |
| rt_poll_callbacks.rs |
|
4383 |
- |
| rt_shutdown_err.rs |
|
2414 |
- |
| rt_spawn_blocking.rs |
|
4303 |
- |
| rt_threaded.rs |
|
24710 |
- |
| rt_time_start_paused.rs |
|
357 |
- |
| rt_unstable_eager_driver_handoff.rs |
|
7003 |
- |
| rt_unstable_metrics.rs |
|
24434 |
- |
| rt_worker_index.rs |
|
2319 |
- |
| signal_ctrl_c.rs |
|
403 |
- |
| signal_drop_recv.rs |
|
550 |
- |
| signal_drop_rt.rs |
|
1051 |
- |
| signal_drop_signal.rs |
|
816 |
- |
| signal_info.rs |
|
857 |
- |
| signal_multi_rt.rs |
|
1510 |
- |
| signal_no_rt.rs |
|
353 |
- |
| signal_notify_both.rs |
|
548 |
- |
| signal_panic.rs |
|
736 |
- |
| signal_realtime.rs |
|
3222 |
- |
| signal_twice.rs |
|
485 |
- |
| signal_usr1.rs |
|
480 |
- |
| support |
|
|
- |
| sync_barrier.rs |
|
2218 |
- |
| sync_broadcast.rs |
|
16198 |
- |
| sync_broadcast_weak.rs |
|
4657 |
- |
| sync_errors.rs |
|
635 |
- |
| sync_mpsc.rs |
|
43805 |
- |
| 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);
}
|
4647 |
- |
| sync_mutex_owned.rs |
|
3749 |
- |
| sync_notify.rs |
|
7914 |
- |
| sync_notify_owned.rs |
|
8144 |
- |
| sync_once_cell.rs |
|
6078 |
- |
| sync_oneshot.rs |
|
10396 |
- |
| sync_panic.rs |
|
6221 |
- |
| sync_rwlock.rs |
|
9740 |
- |
| sync_semaphore.rs |
|
6223 |
- |
| sync_semaphore_owned.rs |
|
4847 |
- |
| sync_set_once.rs |
|
3653 |
- |
| sync_watch.rs |
|
11295 |
- |
| task_abort.rs |
|
10294 |
- |
| task_blocking.rs |
|
8524 |
- |
| task_builder.rs |
|
2642 |
- |
| task_hooks.rs |
|
6405 |
- |
| task_id.rs |
|
7924 |
- |
| task_join_set.rs |
|
17796 |
- |
| task_local.rs |
|
4075 |
- |
| task_local_set.rs |
|
24142 |
- |
| task_panic.rs |
|
2905 |
- |
| task_trace_self.rs |
|
8293 |
- |
| task_yield_now.rs |
|
654 |
- |
| tcp_accept.rs |
|
5078 |
- |
| tcp_connect.rs |
|
6537 |
- |
| tcp_echo.rs |
|
1322 |
- |
| tcp_into_split.rs |
|
3888 |
- |
| tcp_into_std.rs |
|
1584 |
- |
| tcp_peek.rs |
|
1066 |
- |
| tcp_shutdown.rs |
|
2646 |
- |
| tcp_socket.rs |
|
5455 |
- |
| tcp_split.rs |
|
1394 |
- |
| tcp_stream.rs |
|
12690 |
- |
| test_clock.rs |
|
1392 |
- |
| time_alt.rs |
|
2959 |
- |
| time_interval.rs |
|
16660 |
- |
| time_panic.rs |
|
3922 |
- |
| time_pause.rs |
|
8430 |
- |
| time_rt.rs |
|
3843 |
- |
| time_sleep.rs |
|
8352 |
- |
| time_timeout.rs |
|
3462 |
- |
| time_wasm.rs |
|
1106 |
- |
| tracing_sync.rs |
Tests for sync instrumentation.
These tests ensure that the instrumentation for tokio
synchronization primitives is correct. |
9675 |
- |
| tracing_task.rs |
Tests for task instrumentation.
These tests ensure that the instrumentation for task spawning and task
lifecycles is correct. |
5371 |
- |
| tracing_time.rs |
Tests for time resource instrumentation.
These tests ensure that the instrumentation for tokio
synchronization primitives is correct. |
2511 |
- |
| udp.rs |
|
25190 |
- |
| uds_cred.rs |
|
690 |
- |
| uds_datagram.rs |
|
12503 |
- |
| uds_socket.rs |
|
3309 |
- |
| uds_split.rs |
|
1311 |
- |
| uds_stream.rs |
|
12302 |
- |
| unwindsafe.rs |
|
1118 |
- |