Fuzz introspector: fuzz_stream_map
For issues and ideas: https://github.com/ossf/fuzz-introspector/issues

Fuzz blockers

The following nodes represent call sites where fuzz blockers occur.

Amount of callsites blocked Calltree index Parent function Callsite Largest blocked function
321 585 StreamMap::iter call site: 00585 Steal::steal_into
296 33 from_raw call site: 00033 size_hint_stream_closed_permits_drop
220 364 StreamMap::values call site: 00364 Steal::steal_into
51 909 to_raw call site: 00909 read_to_string
24 330 StreamMap::insert call site: 00330 StreamMap::insert
17 961 ThreadWaker::new call site: 00961 StreamMap::insert
16 16 ThreadWaker::new call site: 00016 test_panic
12 0 EP call site: 00000 Alternate::poll_next
6 355 StreamMap::insert call site: 00355 Inject::push
1 13 MockTask::new call site: 00013
1 907 to_raw call site: 00907

Fuzzer calltree

0 fuzz_target [function] [call site] 00000
1 StreamNotifyClose::new [function] [call site] 00001
2 Some [function] [call site] 00002
1 Alternate::poll_next [function] [call site] 00003
2 Poll::Ready [function] [call site] 00004
2 Some [function] [call site] 00005
2 Poll::Ready [function] [call site] 00006
1 StreamMap::len [function] [call site] 00007
2 len [function] [call site] 00008
3 wrapping_sub [function] [call site] 00009
1 my_custom_runtime::spawn [function] [call site] 00010
2 spawn [function] [call site] 00011
3 MockTask::new [function] [call site] 00012
4 StreamNotifyClose::new [function] [call site] 00013
5 Some [function] [call site] 00014
4 ThreadWaker::new [function] [call site] 00015
5 Mutex::new [function] [call site] 00016
6 std::panic::Location::caller [function] [call site] 00017
7 test_panic [function] [call site] 00018
8 try_lock [function] [call site] 00019
9 Mutex::new [function] [call site] 00020
9 try_lock [function] [call site] 00021
10 Mutex::new [function] [call site] 00022
10 try_lock [function] [call site] 00023
10 try_lock [function] [call site] 00024
10 try_lock [function] [call site] 00025
9 try_lock [function] [call site] 00026
9 try_lock [function] [call site] 00027
8 StreamNotifyClose::new [function] [call site] 00028
8 Mutex::new [function] [call site] 00029
8 panic::take_hook [function] [call site] 00030
8 clone [function] [call site] 00031
9 from_raw [function] [call site] 00032
10 Arc::from_raw [function] [call site] 00033
11 Arc::from_raw [function] [call site] 00034
11 NonNull::as_ptr [function] [call site] 00035
9 mem::forget [function] [call site] 00036
10 StreamNotifyClose::new [function] [call site] 00037
10 Semaphore::new [function] [call site] 00038
11 in_scope [function] [call site] 00039
11 AtomicUsize::new [function] [call site] 00040
12 UnsafeCell::new [function] [call site] 00041
13 UnsafeCell [function] [call site] 00042
13 std::cell::UnsafeCell::new [function] [call site] 00043
14 UnsafeCell [function] [call site] 00044
14 std::cell::UnsafeCell::new [function] [call site] 00045
12 std::sync::atomic::AtomicUsize::new [function] [call site] 00046
13 UnsafeCell::new [function] [call site] 00047
13 std::sync::atomic::AtomicUsize::new [function] [call site] 00048
11 Mutex::new [function] [call site] 00049
11 LinkedList::new [function] [call site] 00050
10 Self::try_acquire [function] [call site] 00051
11 Semaphore::new [function] [call site] 00052
11 Self::try_acquire [function] [call site] 00053
11 Self::try_acquire [function] [call site] 00054
11 Self::try_acquire [function] [call site] 00055
10 unwrap [function] [call site] 00056
10 i32::forget [function] [call site] 00057
11 StreamNotifyClose::new [function] [call site] 00058
11 Semaphore::new [function] [call site] 00059
11 Self::try_acquire [function] [call site] 00060
11 unwrap [function] [call site] 00061
11 i32::forget [function] [call site] 00062
9 Result::clone [function] [call site] 00063
10 tempfile [function] [call site] 00064
11 StreamNotifyClose::new [function] [call site] 00065
12 Some [function] [call site] 00066
11 Self::unwrap [function] [call site] 00067
10 File::create [function] [call site] 00068
11 File::options [function] [call site] 00069
12 OpenOptions::new [function] [call site] 00070
13 Kind::Uring [function] [call site] 00071
13 UringOpenOptions::new [function] [call site] 00072
13 Kind::Std [function] [call site] 00073
13 StreamNotifyClose::new [function] [call site] 00074
14 Some [function] [call site] 00075
11 OpenOptions::write [function] [call site] 00076
12 write [function] [call site] 00077
13 Builder::new [function] [call site] 00078
14 StreamMap::default [function] [call site] 00079
15 StreamNotifyClose::new [function] [call site] 00080
16 Some [function] [call site] 00081
13 Self::write [function] [call site] 00082
14 tempfile [function] [call site] 00083
14 File::create [function] [call site] 00084
14 NamedTempFile::path [function] [call site] 00085
15 syn::Error::new [function] [call site] 00086
16 Some [function] [call site] 00087
15 parse::<syn::Path> [function] [call site] 00088
15 map_err [function] [call site] 00089
15 clone [function] [call site] 00090
15 Err [function] [call site] 00091
15 syn::Error::new [function] [call site] 00092
14 unwrap [function] [call site] 00093
14 NamedTempFile::write_all [function] [call site] 00094
14 unwrap [function] [call site] 00095
14 RW::poll_flush [function] [call site] 00096
15 Poll::Ready [function] [call site] 00097
15 Ok [function] [call site] 00098
14 unwrap [function] [call site] 00099
14 std::fs::read [function] [call site] 00100
15 tempfile [function] [call site] 00101
15 NamedTempFile::write_all [function] [call site] 00102
15 WriteAll::unwrap [function] [call site] 00103
15 File::open [function] [call site] 00104
16 File::options [function] [call site] 00105
16 OpenOptions::read [function] [call site] 00106
17 read [function] [call site] 00107
18 Builder::new [function] [call site] 00108
18 Self::read [function] [call site] 00109
19 tempfile [function] [call site] 00110
19 NamedTempFile::write_all [function] [call site] 00111
19 WriteAll::unwrap [function] [call site] 00112
19 File::open [function] [call site] 00113
19 NamedTempFile::path [function] [call site] 00114
19 unwrap [function] [call site] 00115
19 NamedTempFile::read [function] [call site] 00116
20 tempfile [function] [call site] 00117
20 NamedTempFile::write_all [function] [call site] 00118
20 WriteAll::unwrap [function] [call site] 00119
20 File::open [function] [call site] 00120
20 NamedTempFile::path [function] [call site] 00121
20 unwrap [function] [call site] 00122
20 NamedTempFile::read [function] [call site] 00123
20 unwrap [function] [call site] 00124
19 unwrap [function] [call site] 00125
18 read [function] [call site] 00126
18 Configuration::build [function] [call site] 00127
19 unwrap_or [function] [call site] 00128
19 Err [function] [call site] 00129
19 syn::Error::new [function] [call site] 00130
19 StreamExt::map [function] [call site] 00131
20 Map::new [function] [call site] 00132
19 is_none [function] [call site] 00133
19 Err [function] [call site] 00134
19 syn::Error::new [function] [call site] 00135
19 Span::call_site [function] [call site] 00136
19 Err [function] [call site] 00137
19 syn::Error::new [function] [call site] 00138
19 Some [function] [call site] 00139
19 Err [function] [call site] 00140
19 syn::Error::new [function] [call site] 00141
19 Some [function] [call site] 00142
19 Ok [function] [call site] 00143
19 clone [function] [call site] 00144
18 read [function] [call site] 00145
18 expect [function] [call site] 00146
18 read [function] [call site] 00147
18 expect [function] [call site] 00148
17 read [function] [call site] 00149
16 &mut [call site] 00150
17 mpsc::channel [function] [call site] 00151
18 test_with_runtimes [function] [call site] 00152
19 new_current_thread [function] [call site] 00153
20 tokio::runtime::Builder::new_current_thread [function] [call site] 00154
21 Builder::new [function] [call site] 00155
20 Builder::enable_all [function] [call site] 00156
21 Builder::enable_io [function] [call site] 00157
21 Builder::enable_io_uring [function] [call site] 00158
21 Builder::enable_time [function] [call site] 00159
20 Configuration::build [function] [call site] 00160
21 unwrap_or [function] [call site] 00161
21 Err [function] [call site] 00162
21 syn::Error::new [function] [call site] 00163
21 StreamExt::map [function] [call site] 00164
21 is_none [function] [call site] 00165
21 Err [function] [call site] 00166
21 syn::Error::new [function] [call site] 00167
21 Span::call_site [function] [call site] 00168
21 Err [function] [call site] 00169
21 syn::Error::new [function] [call site] 00170
21 Some [function] [call site] 00171
21 Err [function] [call site] 00172
21 syn::Error::new [function] [call site] 00173
21 Some [function] [call site] 00174
21 Ok [function] [call site] 00175
21 clone [function] [call site] 00176
20 Result::unwrap [function] [call site] 00177
19 tokio::runtime::Runtime::enter [function] [call site] 00178
20 basic_enter [function] [call site] 00179
21 rt [function] [call site] 00180
22 tokio::runtime::Builder::new_multi_thread [function] [call site] 00181
23 Builder::new [function] [call site] 00182
22 Builder::worker_threads [function] [call site] 00183
23 Some [function] [call site] 00184
22 Configuration::build [function] [call site] 00185
22 Result::unwrap [function] [call site] 00186
21 rt [function] [call site] 00187
21 tokio::runtime::Runtime::enter [function] [call site] 00188
21 tokio::runtime::Runtime::enter [function] [call site] 00189
21 size_hint_stream_closed_permits_drop [function] [call site] 00190
22 mpsc::channel [function] [call site] 00191
22 send [function] [call site] 00192
23 Alternate::poll_next [function] [call site] 00193
24 Poll::Ready [function] [call site] 00194
24 Some [function] [call site] 00195
24 Poll::Ready [function] [call site] 00196
23 send [function] [call site] 00197
23 Ok [function] [call site] 00198
22 unwrap [function] [call site] 00199
22 VecWithInitialized::reserve [function] [call site] 00200
23 UnboundedReceiverStream::as_mut [function] [call site] 00201
23 with_capacity [function] [call site] 00202
24 StreamMap::<&str, [call site] 00203
25 StreamMap::<&str, [call site] 00204
23 len [function] [call site] 00205
23 len [function] [call site] 00206
23 VecWithInitialized::reserve [function] [call site] 00207
22 unwrap [function] [call site] 00208
22 VecWithInitialized::reserve [function] [call site] 00209
22 unwrap [function] [call site] 00210
22 ReceiverStream::new [function] [call site] 00211
22 UnboundedReceiverStream::close [function] [call site] 00212
23 UnboundedReceiverStream::close [function] [call site] 00213
24 UnboundedReceiverStream::close [function] [call site] 00214
22 size_hint_stream_closed_permits_drop [function] [call site] 00215
22 Alternate::poll_next [function] [call site] 00216
23 Poll::Ready [function] [call site] 00217
23 Some [function] [call site] 00218
23 Poll::Ready [function] [call site] 00219
22 size_hint_stream_closed_permits_drop [function] [call site] 00220
21 size_hint_stream_closed_permits_drop [function] [call site] 00221
19 Throttle::get_ref [function] [call site] 00222
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00223
20 shutdown [function] [call site] 00224
21 Harness::<T, [call site] 00225
22 Self [function] [call site] 00226
21 Self::shutdown [function] [call site] 00227
22 tempfile [function] [call site] 00228
22 File::create [function] [call site] 00229
22 NamedTempFile::path [function] [call site] 00230
22 unwrap [function] [call site] 00231
22 NamedTempFile::write_all [function] [call site] 00232
22 unwrap [function] [call site] 00233
22 NamedTempFile::shutdown [function] [call site] 00234
23 tempfile [function] [call site] 00235
23 File::create [function] [call site] 00236
23 NamedTempFile::path [function] [call site] 00237
23 unwrap [function] [call site] 00238
23 NamedTempFile::write_all [function] [call site] 00239
23 unwrap [function] [call site] 00240
23 NamedTempFile::shutdown [function] [call site] 00241
23 unwrap [function] [call site] 00242
23 std::fs::read [function] [call site] 00243
23 NamedTempFile::path [function] [call site] 00244
23 unwrap [function] [call site] 00245
22 unwrap [function] [call site] 00246
22 std::fs::read [function] [call site] 00247
22 NamedTempFile::path [function] [call site] 00248
22 unwrap [function] [call site] 00249
20 shutdown [function] [call site] 00250
20 Some [function] [call site] 00251
19 Duration::from_secs [function] [call site] 00252
19 Throttle::get_ref [function] [call site] 00253
19 new_multi_thread [function] [call site] 00254
20 tokio::runtime::Builder::new_multi_thread [function] [call site] 00255
20 Builder::worker_threads [function] [call site] 00256
20 Builder::enable_all [function] [call site] 00257
21 Builder::enable_io [function] [call site] 00258
21 Builder::enable_io_uring [function] [call site] 00259
21 Builder::enable_time [function] [call site] 00260
20 Configuration::build [function] [call site] 00261
20 Result::unwrap [function] [call site] 00262
19 tokio::runtime::Runtime::enter [function] [call site] 00263
19 Throttle::get_ref [function] [call site] 00264
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00265
19 Duration::from_secs [function] [call site] 00266
19 Throttle::get_ref [function] [call site] 00267
19 new_multi_thread [function] [call site] 00268
19 tokio::runtime::Runtime::enter [function] [call site] 00269
19 Throttle::get_ref [function] [call site] 00270
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00271
19 Duration::from_secs [function] [call site] 00272
19 Throttle::get_ref [function] [call site] 00273
18 mpsc::channel [function] [call site] 00274
18 Handle::current [function] [call site] 00275
19 scheduler::Handle::current [function] [call site] 00276
20 scheduler::Handle::current [function] [call site] 00277
18 Self::block_on [function] [call site] 00278
19 oneshot::channel [function] [call site] 00279
20 test_with_runtimes [function] [call site] 00280
20 mpsc::channel [function] [call site] 00281
20 Handle::current [function] [call site] 00282
20 Self::block_on [function] [call site] 00283
20 send [function] [call site] 00284
20 unwrap [function] [call site] 00285
20 Handle::current [function] [call site] 00286
20 Self::block_on [function] [call site] 00287
20 recv [function] [call site] 00288
21 recv [function] [call site] 00289
21 &mut [call site] 00290
21 Bytes::copy_from_slice [function] [call site] 00291
20 unwrap [function] [call site] 00292
19 rt [function] [call site] 00293
19 tokio::runtime::Runtime::spawn [function] [call site] 00294
20 OwnedTasks::bind [function] [call site] 00295
21 Harness::get_new_task [function] [call site] 00296
22 Task::from_raw [function] [call site] 00297
23 Task::from_raw [function] [call site] 00298
22 Shared::broadcast [function] [call site] 00299
23 StreamMap::iter_mut [function] [call site] 00300
24 StreamMap::iter_mut [function] [call site] 00301
23 send [function] [call site] 00302
23 io::Result::into [function] [call site] 00303
24 AtomicU16::unsync_load [function] [call site] 00304
25 core::ptr::read [function] [call site] 00305
26 tempfile [function] [call site] 00306
26 NamedTempFile::write_all [function] [call site] 00307
26 WriteAll::unwrap [function] [call site] 00308
26 File::open [function] [call site] 00309
26 NamedTempFile::path [function] [call site] 00310
26 unwrap [function] [call site] 00311
26 NamedTempFile::read [function] [call site] 00312
26 unwrap [function] [call site] 00313
25 fuzz_target [function] [call site] 00314
26 StreamNotifyClose::new [function] [call site] 00315
26 Alternate::poll_next [function] [call site] 00316
26 StreamMap::len [function] [call site] 00317
26 my_custom_runtime::spawn [function] [call site] 00318
26 StreamMap::new [function] [call site] 00319
26 iter [function] [call site] 00320
27 into_iter [function] [call site] 00321
26 copied [function] [call site] 00322
26 enumerate [function] [call site] 00323
26 pin_box [function] [call site] 00324
27 Box::pin [function] [call site] 00325
26 stream::empty::<()> [function] [call site] 00326
26 pin_box [function] [call site] 00327
26 stream::pending::<()> [function] [call site] 00328
26 StreamMap::insert [function] [call site] 00329
27 StreamMap::remove [function] [call site] 00330
28 len [function] [call site] 00331
28 contains_key_borrow [function] [call site] 00332
29 StreamMap::new [function] [call site] 00333
29 StreamMap::insert [function] [call site] 00334
29 &str::to_string [function] [call site] 00335
30 UnboundedReceiverStream::as_ref [function] [call site] 00336
30 &UnboundedReceiver::to_owned [function] [call site] 00337
30 fs::asyncify [function] [call site] 00338
31 mocks::spawn_blocking [function] [call site] 00339
32 task::spawn_blocking [function] [call site] 00340
33 task::spawn_blocking [function] [call site] 00341
33 unwrap [function] [call site] 00342
32 unwrap [function] [call site] 00343
31 Err [function] [call site] 00344
31 io::Error::new [function] [call site] 00345
32 Some [function] [call site] 00346
30 std::fs::read_to_string [function] [call site] 00347
31 UnboundedReceiverStream::as_ref [function] [call site] 00348
31 &UnboundedReceiver::to_owned [function] [call site] 00349
31 fs::asyncify [function] [call site] 00350
31 std::fs::read_to_string [function] [call site] 00351
29 pending::<()> [function] [call site] 00352
28 Some [function] [call site] 00353
28 swap_remove [function] [call site] 00354
27 Inject::push [function] [call site] 00355
28 try_lock [function] [call site] 00356
28 Inject::push [function] [call site] 00357
26 assert_ready_none [function] [call site] 00358
27 tokio_test::assert_ready [function] [call site] 00359
26 tokio_test::assert_pending [function] [call site] 00360
26 StreamMap::values [function] [call site] 00361
27 StreamMap::iter [function] [call site] 00362
28 iter [function] [call site] 00363
27 StreamExt::map [function] [call site] 00364
28 Map::new [function] [call site] 00365
24 unpack [function] [call site] 00366
24 group_b::complete_block_on_under_load [function] [call site] 00367
25 loom::model [function] [call site] 00368
26 loom::model [function] [call site] 00369
25 mk_pool [function] [call site] 00370
26 runtime::Builder::new_multi_thread [function] [call site] 00371
27 Builder::new [function] [call site] 00372
26 Builder::worker_threads [function] [call site] 00373
26 Builder::event_interval [function] [call site] 00374
26 Configuration::build [function] [call site] 00375
26 Result::unwrap [function] [call site] 00376
25 block_on [function] [call site] 00377
26 runtime::Builder::new_current_thread [function] [call site] 00378
27 Builder::new [function] [call site] 00379
26 Builder::enable_all [function] [call site] 00380
26 Configuration::build [function] [call site] 00381
26 Result::unwrap [function] [call site] 00382
26 tokio::runtime::Runtime::block_on [function] [call site] 00383
27 mem::size_of::<F> [function] [call site] 00384
27 Runtime::block_on_inner [function] [call site] 00385
28 super::task::trace::Trace::root [function] [call site] 00386
28 w::o::r::k::e::r::_::p::o::l::l::_::c::o::u::n::t::_::a::n::d::_::t::i::m::e::task [function] [call site] 00387
29 std::thread::sleep [function] [call site] 00388
30 tokio::time::sleep [function] [call site] 00389
31 tokio::time::sleep [function] [call site] 00390
31 ms [function] [call site] 00391
32 subsec_nanos [function] [call site] 00392
32 subsec_millis [function] [call site] 00393
32 as_secs [function] [call site] 00394
32 saturating_mul [function] [call site] 00395
32 saturating_add [function] [call site] 00396
32 std::io::Error::from [function] [call site] 00397
33 Steal::steal_into [function] [call site] 00398
34 AtomicU16::unsync_load [function] [call site] 00399
34 unpack [function] [call site] 00400
34 group_b::complete_block_on_under_load [function] [call site] 00401
34 wrapping_sub [function] [call site] 00402
34 Steal::steal_into2 [function] [call site] 00403
35 group_b::complete_block_on_under_load [function] [call site] 00404
35 unpack [function] [call site] 00405
35 group_b::complete_block_on_under_load [function] [call site] 00406
35 wrapping_sub [function] [call site] 00407
35 wrapping_add [function] [call site] 00408
35 pack [function] [call site] 00409
36 mem::size_of::<UnsignedShort> [function] [call site] 00410
35 AtomicU64::compare_exchange [function] [call site] 00411
36 try_lock [function] [call site] 00412
36 Ok [function] [call site] 00413
36 Err [function] [call site] 00414
35 unpack [function] [call site] 00415
35 wrapping_add [function] [call site] 00416
35 UnsignedShort::wrapping_add [function] [call site] 00417
35 with [function] [call site] 00418
36 Runtime [function] [call site] 00419
36 StreamNotifyClose::new [function] [call site] 00420
36 OwnedTasks::new [function] [call site] 00421
37 OwnedTasks::gen_shared_list_size [function] [call site] 00422
38 usize::min [function] [call site] 00423
38 usize::next_power_of_two [function] [call site] 00424
37 WakeList::new [function] [call site] 00425
37 StreamNotifyClose::new [function] [call site] 00426
38 Some [function] [call site] 00427
37 get_next_id [function] [call site] 00428
36 Mutex::new [function] [call site] 00429
36 StreamNotifyClose::new [function] [call site] 00430
37 Some [function] [call site] 00431
36 try_lock [function] [call site] 00432
36 unwrap [function] [call site] 00433
36 Some [function] [call site] 00434
36 tokio::runtime::Runtime::clone [function] [call site] 00435
37 tempfile [function] [call site] 00436
37 File::create [function] [call site] 00437
37 NamedTempFile::path [function] [call site] 00438
37 unwrap [function] [call site] 00439
37 File::try_clone [function] [call site] 00440
38 try_lock [function] [call site] 00441
38 Inner::complete_inflight [function] [call site] 00442
39 poll_fn [function] [call site] 00443
39 Inner::poll_complete_inflight [function] [call site] 00444
40 Inner::poll_flush [function] [call site] 00445
41 take [function] [call site] 00446
41 Poll::Ready [function] [call site] 00447
41 Err [function] [call site] 00448
41 Steal::steal_into [function] [call site] 00449
41 Poll::Ready [function] [call site] 00450
41 Ok [function] [call site] 00451
41 State::Idle [function] [call site] 00452
41 Some [function] [call site] 00453
41 Poll::Ready [function] [call site] 00454
41 Ok [function] [call site] 00455
41 Poll::Ready [function] [call site] 00456
41 Poll::Ready [function] [call site] 00457
41 Ok [function] [call site] 00458
40 Some [function] [call site] 00459
40 kind [function] [call site] 00460
40 Poll::Ready [function] [call site] 00461
40 Poll::Ready [function] [call site] 00462
38 clone [function] [call site] 00463
38 fs::asyncify [function] [call site] 00464
38 File::try_clone [function] [call site] 00465
39 try_lock [function] [call site] 00466
39 Inner::complete_inflight [function] [call site] 00467
39 clone [function] [call site] 00468
39 fs::asyncify [function] [call site] 00469
39 File::try_clone [function] [call site] 00470
39 File::from_std [function] [call site] 00471
40 StreamNotifyClose::new [function] [call site] 00472
40 Mutex::new [function] [call site] 00473
40 State::Idle [function] [call site] 00474
40 Some [function] [call site] 00475
40 Buf::with_capacity [function] [call site] 00476
41 Vec::with_capacity [function] [call site] 00477
42 StreamMap::<&str, [call site] 00478
39 File::set_max_buf_size [function] [call site] 00479
39 Ok [function] [call site] 00480
38 File::from_std [function] [call site] 00481
38 File::set_max_buf_size [function] [call site] 00482
38 Ok [function] [call site] 00483
37 unwrap [function] [call site] 00484
37 RawWaker::write_all [function] [call site] 00485
37 unwrap [function] [call site] 00486
37 RW::poll_flush [function] [call site] 00487
38 Poll::Ready [function] [call site] 00488
38 Ok [function] [call site] 00489
37 unwrap [function] [call site] 00490
37 std::fs::read [function] [call site] 00491
37 NamedTempFile::path [function] [call site] 00492
37 unwrap [function] [call site] 00493
35 ptr::read [function] [call site] 00494
36 tempfile [function] [call site] 00495
36 NamedTempFile::write_all [function] [call site] 00496
36 WriteAll::unwrap [function] [call site] 00497
36 File::open [function] [call site] 00498
36 NamedTempFile::path [function] [call site] 00499
36 unwrap [function] [call site] 00500
36 NamedTempFile::read [function] [call site] 00501
36 unwrap [function] [call site] 00502
35 as_ptr [function] [call site] 00503
35 CoreStage::with_mut [function] [call site] 00504
36 CoreStage::with_mut [function] [call site] 00505
35 ptr::write [function] [call site] 00506
36 tempfile [function] [call site] 00507
36 File::create [function] [call site] 00508
36 NamedTempFile::path [function] [call site] 00509
36 unwrap [function] [call site] 00510
36 NamedTempFile::write_all [function] [call site] 00511
36 unwrap [function] [call site] 00512
36 RW::poll_flush [function] [call site] 00513
36 unwrap [function] [call site] 00514
36 std::fs::read [function] [call site] 00515
36 NamedTempFile::path [function] [call site] 00516
36 unwrap [function] [call site] 00517
35 as_mut_ptr [function] [call site] 00518
35 unpack [function] [call site] 00519
35 pack [function] [call site] 00520
35 AtomicU64::compare_exchange [function] [call site] 00521
35 unpack [function] [call site] 00522
34 Stats::incr_steal_count [function] [call site] 00523
35 Stats::incr_steal_count [function] [call site] 00524
36 Stats::incr_steal_count [function] [call site] 00525
34 Stats::incr_steal_operations [function] [call site] 00526
35 Stats::incr_steal_operations [function] [call site] 00527
36 Stats::incr_steal_operations [function] [call site] 00528
34 wrapping_add [function] [call site] 00529
34 with [function] [call site] 00530
34 ptr::read [function] [call site] 00531
34 as_ptr [function] [call site] 00532
34 Some [function] [call site] 00533
34 AtomicU64::store [function] [call site] 00534
35 try_lock [function] [call site] 00535
34 wrapping_add [function] [call site] 00536
34 Some [function] [call site] 00537
30 ms [function] [call site] 00538
29 std::time::Duration::from_micros [function] [call site] 00539
28 crate::runtime::task::Id::next [function] [call site] 00540
29 group_b::complete_block_on_under_load [function] [call site] 00541
29 Instant::checked_add [function] [call site] 00542
30 Instant::checked_add [function] [call site] 00543
30 StreamExt::map [function] [call site] 00544
31 Map::new [function] [call site] 00545
29 exhausted [function] [call site] 00546
29 StaticAtomicU64::compare_exchange_weak [function] [call site] 00547
30 StaticAtomicU64::inner [function] [call site] 00548
31 get_or_init [function] [call site] 00549
32 runtime::Builder::new_current_thread [function] [call site] 00550
32 Builder::enable_time [function] [call site] 00551
32 Configuration::set_start_paused [function] [call site] 00552
33 is_some [function] [call site] 00553
33 Err [function] [call site] 00554
33 syn::Error::new [function] [call site] 00555
33 parse_bool [function] [call site] 00556
34 Ok [function] [call site] 00557
34 Err [function] [call site] 00558
34 syn::Error::new [function] [call site] 00559
33 Some [function] [call site] 00560
33 Ok [function] [call site] 00561
32 Configuration::build [function] [call site] 00562
32 unwrap [function] [call site] 00563
32 tokio::runtime::Runtime::block_on [function] [call site] 00564
32 tokio::runtime::Runtime::spawn [function] [call site] 00565
32 get_or_init [function] [call site] 00566
32 tokio::runtime::Runtime::spawn [function] [call site] 00567
32 get_or_init [function] [call site] 00568
32 time::advance [function] [call site] 00569
33 Instant::now [function] [call site] 00570
34 variant::now [function] [call site] 00571
35 crate::time::clock::now [function] [call site] 00572
36 Now [function] [call site] 00573
33 time::advance [function] [call site] 00574
33 Duration::from_millis [function] [call site] 00575
33 my_custom_runtime::spawn [function] [call site] 00576
33 time::sleep_until [function] [call site] 00577
34 Sleep::new_timeout [function] [call site] 00578
35 scheduler::Handle::current [function] [call site] 00579
35 TimerEntry::new [function] [call site] 00580
36 Handle::driver [function] [call site] 00581
36 &driver::Handle::time [function] [call site] 00582
37 into_iter [function] [call site] 00583
37 StreamMap::iter [function] [call site] 00584
38 iter [function] [call site] 00585
37 into_iter [function] [call site] 00586
37 StreamMap::iter [function] [call site] 00587
37 StreamExt::then [function] [call site] 00588
38 Then::new [function] [call site] 00589
37 time::sleep [function] [call site] 00590
38 tokio::time::sleep [function] [call site] 00591
38 ms [function] [call site] 00592
37 Duration::from_secs [function] [call site] 00593
37 StreamExt::map [function] [call site] 00594
38 Map::new [function] [call site] 00595
37 StreamExt::chain [function] [call site] 00596
38 Chain::new [function] [call site] 00597
39 Fuse::new [function] [call site] 00598
40 Some [function] [call site] 00599
37 StreamExt::chunks_timeout [function] [call site] 00600
38 ChunksTimeout::new [function] [call site] 00601
39 Fuse::new [function] [call site] 00602
39 Vec::with_capacity [function] [call site] 00603
37 Duration::from_secs [function] [call site] 00604
37 my_custom_runtime::spawn [function] [call site] 00605
35 scheduler::Handle::current [function] [call site] 00606
35 Handle::driver [function] [call site] 00607
35 &driver::Handle::clock [function] [call site] 00608
36 Handle::driver [function] [call site] 00609
36 TimerEntry::clock [function] [call site] 00610
37 Handle::driver [function] [call site] 00611
37 TimerEntry::clock [function] [call site] 00612
35 Handle::driver [function] [call site] 00613
35 &driver::Handle::time [function] [call site] 00614
35 Handle::time_source [function] [call site] 00615
35 TimeSource::deadline_to_tick [function] [call site] 00616
36 TimeSource::instant_to_tick [function] [call site] 00617
37 Instant::saturating_duration_since [function] [call site] 00618
38 Instant::saturating_duration_since [function] [call site] 00619
37 Duration::as_millis [function] [call site] 00620
37 ChildStdin::try_into [function] [call site] 00621
38 imp::convert_to_stdio [function] [call site] 00622
39 convert_to_blocking_file [function] [call site] 00623
40 into_inner [function] [call site] 00624
41 RwLock::new [function] [call site] 00625
42 std::panic::Location::caller [function] [call site] 00626
42 in_scope [function] [call site] 00627
42 in_scope [function] [call site] 00628
42 Semaphore::new [function] [call site] 00629
42 Semaphore::new [function] [call site] 00630
42 UnsafeCell::new [function] [call site] 00631
40 set_nonblocking [function] [call site] 00632
41 FileDescriptor::as_raw_fd [function] [call site] 00633
42 FileDescriptor::as_raw_fd [function] [call site] 00634
41 libc::fcntl [function] [call site] 00635
41 Err [function] [call site] 00636
41 io::Error::last_os_error [function] [call site] 00637
41 libc::fcntl [function] [call site] 00638
41 Err [function] [call site] 00639
41 io::Error::last_os_error [function] [call site] 00640
41 Ok [function] [call site] 00641
40 Ok [function] [call site] 00642
39 io::Result::map [function] [call site] 00643
40 Map::new [function] [call site] 00644
37 unwrap_or [function] [call site] 00645
37 u64::min [function] [call site] 00646
36 Duration::from_nanos [function] [call site] 00647
35 u64::saturating_sub [function] [call site] 00648
35 date::now [function] [call site] 00649
36 Now [function] [call site] 00650
35 &'static [call site] 00651
35 in_scope [function] [call site] 00652
35 in_scope [function] [call site] 00653
34 trace::caller_location [function] [call site] 00654
33 Duration::from_secs [function] [call site] 00655
33 tokio_test::assert_pending [function] [call site] 00656
33 Instant::now [function] [call site] 00657
33 Duration::from_micros [function] [call site] 00658
33 time::advance [function] [call site] 00659
33 tokio_test::assert_pending [function] [call site] 00660
32 Duration::from_millis [function] [call site] 00661
32 time::resume [function] [call site] 00662
33 Instant::now [function] [call site] 00663
33 time::pause [function] [call site] 00664
33 time::advance [function] [call site] 00665
33 Duration::from_secs [function] [call site] 00666
33 time::resume [function] [call site] 00667
33 time::pause [function] [call site] 00668
33 time::advance [function] [call site] 00669
33 Duration::from_secs [function] [call site] 00670
32 unwrap [function] [call site] 00671
32 unwrap [function] [call site] 00672
31 Mutex::new [function] [call site] 00673
30 &Mutex::lock [function] [call site] 00674
31 Mutex::new [function] [call site] 00675
31 try_lock [function] [call site] 00676
31 try_lock [function] [call site] 00677
31 try_lock [function] [call site] 00678
30 Ok [function] [call site] 00679
30 Err [function] [call site] 00680
29 ThreadId [function] [call site] 00681
29 StreamNotifyClose::new [function] [call site] 00682
30 Some [function] [call site] 00683
29 Self::unwrap [function] [call site] 00684
28 Id::as_u64 [function] [call site] 00685
29 fuzz_target [function] [call site] 00686
28 Runtime::enter [function] [call site] 00687
29 basic_enter [function] [call site] 00688
28 &mut [call site] 00689
29 oneshot::channel [function] [call site] 00690
29 rt [function] [call site] 00691
29 tokio::runtime::Runtime::spawn [function] [call site] 00692
29 tokio_test::assert_ok [function] [call site] 00693
29 thread::sleep [function] [call site] 00694
30 tokio::time::sleep [function] [call site] 00695
30 ms [function] [call site] 00696
29 Duration::from_millis [function] [call site] 00697
29 tokio_test::assert_err [function] [call site] 00698
29 tokio::runtime::Runtime::block_on [function] [call site] 00699
29 tokio_test::assert_ok [function] [call site] 00700
28 &mut [call site] 00701
27 Box::pin [function] [call site] 00702
27 SpawnMeta::new_unnamed [function] [call site] 00703
27 Runtime::block_on_inner [function] [call site] 00704
27 SpawnMeta::new_unnamed [function] [call site] 00705
25 my_custom_runtime::spawn [function] [call site] 00706
26 spawn [function] [call site] 00707
25 track [function] [call site] 00708
26 StreamNotifyClose::new [function] [call site] 00709
25 task::yield_now [function] [call site] 00710
25 gated2 [function] [call site] 00711
26 StreamNotifyClose::new [function] [call site] 00712
26 StreamNotifyClose::new [function] [call site] 00713
26 std::future::poll_fn [function] [call site] 00714
26 clone [function] [call site] 00715
26 CachedParkThread::waker [function] [call site] 00716
27 CachedParkThread::unpark [function] [call site] 00717
28 CachedParkThread::with_current [function] [call site] 00718
29 LocalKey::try_with [function] [call site] 00719
30 LocalKey::try_with [function] [call site] 00720
30 Result::borrow [function] [call site] 00721
31 StreamMap::new [function] [call site] 00722
31 StreamMap::insert [function] [call site] 00723
31 &str::to_string [function] [call site] 00724
31 pending::<()> [function] [call site] 00725
30 UnboundedReceiverStream::as_ref [function] [call site] 00726
30 StreamExt::map [function] [call site] 00727
31 Map::new [function] [call site] 00728
30 Ok [function] [call site] 00729
30 Err [function] [call site] 00730
29 Throttle::get_ref [function] [call site] 00731
27 StreamExt::map [function] [call site] 00732
26 clone [function] [call site] 00733
26 my_custom_runtime::spawn [function] [call site] 00734
27 spawn [function] [call site] 00735
26 AtomicU64::store [function] [call site] 00736
26 TestWakerInner::wake_by_ref [function] [call site] 00737
27 AtomicU64::store [function] [call site] 00738
26 spawn [function] [call site] 00739
26 track [function] [call site] 00740
26 AtomicU64::store [function] [call site] 00741
26 TestWakerInner::wake_by_ref [function] [call site] 00742
26 group_b::complete_block_on_under_load [function] [call site] 00743
26 Poll::Ready [function] [call site] 00744
24 wrapping_sub [function] [call site] 00745
24 Steal::steal_into2 [function] [call site] 00746
24 Stats::incr_steal_count [function] [call site] 00747
24 Stats::incr_steal_operations [function] [call site] 00748
24 wrapping_add [function] [call site] 00749
24 with [function] [call site] 00750
24 ptr::read [function] [call site] 00751
24 as_ptr [function] [call site] 00752
24 Some [function] [call site] 00753
24 AtomicU64::store [function] [call site] 00754
24 wrapping_add [function] [call site] 00755
24 Some [function] [call site] 00756
21 OwnedTasks::bind_inner [function] [call site] 00757
22 Harness::header [function] [call site] 00758
23 Harness::header_ptr [function] [call site] 00759
24 Shared::broadcast [function] [call site] 00760
23 NonNull::as_ptr [function] [call site] 00761
22 Header::set_owner_id [function] [call site] 00762
23 CoreStage::with_mut [function] [call site] 00763
23 Some [function] [call site] 00764
22 ShardedList::lock_shard [function] [call site] 00765
23 Task::get_shard_id [function] [call site] 00766
24 Header::get_id [function] [call site] 00767
25 Header::get_id_ptr [function] [call site] 00768
26 UnboundedReceiverStream::as_ref [function] [call site] 00769
26 as_ptr [function] [call site] 00770
26 as_ptr().cast::<u8> [function] [call site] 00771
26 Interest::add [function] [call site] 00772
27 Self [function] [call site] 00773
26 as_ptr().cast::<u8>().add(offset).cast::<Id> [function] [call site] 00774
26 NonNull::new_unchecked [function] [call site] 00775
25 NonNull::as_ptr [function] [call site] 00776
24 fuzz_target [function] [call site] 00777
23 Waiter::as_raw [function] [call site] 00778
23 ShardedList::shard_inner [function] [call site] 00779
24 SetOnce::get_unchecked [function] [call site] 00780
25 with [function] [call site] 00781
25 as_ptr [function] [call site] 00782
24 try_lock [function] [call site] 00783
22 group_b::complete_block_on_under_load [function] [call site] 00784
22 size_hint_stream_closed_permits_drop [function] [call site] 00785
22 shutdown [function] [call site] 00786
22 ShardGuard::push [function] [call site] 00787
23 Task::get_shard_id [function] [call site] 00788
23 Waiter::as_raw [function] [call site] 00789
23 LinkedList::push_front [function] [call site] 00790
24 StreamNotifyClose::new [function] [call site] 00791
25 Some [function] [call site] 00792
24 Waiter::as_raw [function] [call site] 00793
24 Waiter::pointers [function] [call site] 00794
25 Waiter::addr_of_pointers [function] [call site] 00795
24 UnboundedReceiverStream::as_mut [function] [call site] 00796
24 Header::set_next [function] [call site] 00797
25 CoreStage::with_mut [function] [call site] 00798
24 Waiter::pointers [function] [call site] 00799
24 UnboundedReceiverStream::as_mut [function] [call site] 00800
24 Pointers::set_prev [function] [call site] 00801
25 write [function] [call site] 00802
24 Waiter::pointers [function] [call site] 00803
24 UnboundedReceiverStream::as_mut [function] [call site] 00804
24 Pointers::set_prev [function] [call site] 00805
24 Some [function] [call site] 00806
24 Some [function] [call site] 00807
24 is_none [function] [call site] 00808
24 Some [function] [call site] 00809
23 Interest::add [function] [call site] 00810
23 MetricAtomicUsize::increment [function] [call site] 00811
24 StaticAtomicU64::fetch_add [function] [call site] 00812
25 StaticAtomicU64::inner [function] [call site] 00813
25 &Mutex::lock [function] [call site] 00814
22 Some [function] [call site] 00815
20 Runtime::clone [function] [call site] 00816
21 tempfile [function] [call site] 00817
21 File::create [function] [call site] 00818
21 NamedTempFile::path [function] [call site] 00819
21 unwrap [function] [call site] 00820
21 File::try_clone [function] [call site] 00821
21 unwrap [function] [call site] 00822
21 RawWaker::write_all [function] [call site] 00823
21 unwrap [function] [call site] 00824
21 RW::poll_flush [function] [call site] 00825
21 unwrap [function] [call site] 00826
21 std::fs::read [function] [call site] 00827
21 NamedTempFile::path [function] [call site] 00828
21 unwrap [function] [call site] 00829
20 Id::next [function] [call site] 00830
21 StaticAtomicU64::fetch_add [function] [call site] 00831
21 StreamNotifyClose::new [function] [call site] 00832
21 Self [function] [call site] 00833
20 SpawnLocation::capture [function] [call site] 00834
21 std::io::Error::from [function] [call site] 00835
22 Steal::steal_into [function] [call site] 00836
21 Location::caller [function] [call site] 00837
22 test_panic [function] [call site] 00838
22 into_iter [function] [call site] 00839
22 StreamMap::iter [function] [call site] 00840
22 StreamExt::chunks_timeout [function] [call site] 00841
23 ChunksTimeout::new [function] [call site] 00842
22 Duration::from_secs [function] [call site] 00843
22 Ok [function] [call site] 00844
20 Runtime::schedule [function] [call site] 00845
21 try_lock [function] [call site] 00846
21 unwrap [function] [call site] 00847
21 LocalState::task_push_back [function] [call site] 00848
22 LocalState::assert_called_from_owner_thread [function] [call site] 00849
22 CoreStage::with_mut [function] [call site] 00850
22 LocalState::task_push_back [function] [call site] 00851
19 tokio_test::assert_ok [function] [call site] 00852
19 thread::sleep [function] [call site] 00853
19 Duration::from_millis [function] [call site] 00854
19 tokio_test::assert_err [function] [call site] 00855
19 tokio::runtime::Runtime::block_on [function] [call site] 00856
19 tokio_test::assert_ok [function] [call site] 00857
18 send [function] [call site] 00858
18 unwrap [function] [call site] 00859
18 Handle::current [function] [call site] 00860
18 Self::block_on [function] [call site] 00861
18 recv [function] [call site] 00862
18 unwrap [function] [call site] 00863
17 send [function] [call site] 00864
17 unwrap [function] [call site] 00865
17 send [function] [call site] 00866
17 unwrap [function] [call site] 00867
17 ReceiverStream::new [function] [call site] 00868
17 Alternate::poll_next [function] [call site] 00869
17 Alternate::poll_next [function] [call site] 00870
15 NamedTempFile::path [function] [call site] 00871
15 unwrap [function] [call site] 00872
15 NamedTempFile::read [function] [call site] 00873
15 unwrap [function] [call site] 00874
14 NamedTempFile::path [function] [call site] 00875
14 unwrap [function] [call site] 00876
13 write [function] [call site] 00877
13 Configuration::build [function] [call site] 00878
13 write_all [function] [call site] 00879
13 expect [function] [call site] 00880
13 write_all [function] [call site] 00881
13 expect [function] [call site] 00882
12 write [function] [call site] 00883
11 &mut [call site] 00884
11 open_options_truncate [function] [call site] 00885
11 size_hint_stream_open [function] [call site] 00886
12 mpsc::channel [function] [call site] 00887
12 send [function] [call site] 00888
12 unwrap [function] [call site] 00889
12 send [function] [call site] 00890
12 unwrap [function] [call site] 00891
12 ReceiverStream::new [function] [call site] 00892
12 Alternate::poll_next [function] [call site] 00893
12 Alternate::poll_next [function] [call site] 00894
10 NamedTempFile::path [function] [call site] 00895
10 unwrap [function] [call site] 00896
10 File::try_clone [function] [call site] 00897
10 unwrap [function] [call site] 00898
10 RawWaker::write_all [function] [call site] 00899
10 unwrap [function] [call site] 00900
10 RW::poll_flush [function] [call site] 00901
10 unwrap [function] [call site] 00902
10 std::fs::read [function] [call site] 00903
10 NamedTempFile::path [function] [call site] 00904
10 unwrap [function] [call site] 00905
9 to_raw [function] [call site] 00906
10 StreamNotifyClose::new [function] [call site] 00907
11 Some [function] [call site] 00908
10 Inner::into_raw [function] [call site] 00909
11 Inner::into_raw [function] [call site] 00910
8 panic::set_hook [function] [call site] 00911
8 StreamNotifyClose::new [function] [call site] 00912
9 Some [function] [call site] 00913
8 Header::get_spawn_location [function] [call site] 00914
9 Header::get_spawn_location_ptr [function] [call site] 00915
10 UnboundedReceiverStream::as_ref [function] [call site] 00916
10 as_ptr [function] [call site] 00917
10 as_ptr() [call site] 00918
6 .cast::<u8> [function] [call site] 00919
10 Interest::add [function] [call site] 00920
10 as_ptr() [call site] 00921
6 .cast::<u8>() [call site] 00922
6 .add(offset) [call site] 00923
6 .cast::<&'static [call site] 00924
10 NonNull::new_unchecked [function] [call site] 00925
9 NonNull::as_ptr [function] [call site] 00926
8 unwrap [function] [call site] 00927
8 try_lock [function] [call site] 00928
8 clone_from [function] [call site] 00929
8 Some [function] [call site] 00930
8 tempfile [function] [call site] 00931
9 StreamNotifyClose::new [function] [call site] 00932
9 Self::unwrap [function] [call site] 00933
8 read_to_string [function] [call site] 00934
9 UnboundedReceiverStream::as_ref [function] [call site] 00935
9 &UnboundedReceiver::to_owned [function] [call site] 00936
9 fs::asyncify [function] [call site] 00937
9 std::fs::read_to_string [function] [call site] 00938
8 A::t::o::m::i::c::W::a::k::e::r::::::::d::o::_::r::e::g::i::s::t::e::r::catch_unwind [function] [call site] 00939
9 A::t::o::m::i::c::W::a::k::e::r::::::::d::o::_::r::e::g::i::s::t::e::r::catch_unwind [function] [call site] 00940
10 A::t::o::m::i::c::W::a::k::e::r::::::::d::o::_::r::e::g::i::s::t::e::r::catch_unwind [function] [call site] 00941
10 std::panic::AssertUnwindSafe [function] [call site] 00942
9 std::panic::AssertUnwindSafe [function] [call site] 00943
8 panic::set_hook [function] [call site] 00944
8 is_err [function] [call site] 00945
8 try_lock [function] [call site] 00946
8 clone [function] [call site] 00947
7 into_iter [function] [call site] 00948
7 StreamMap::iter [function] [call site] 00949
7 StreamExt::chunks_timeout [function] [call site] 00950
7 Duration::from_secs [function] [call site] 00951
7 Ok [function] [call site] 00952
6 in_scope [function] [call site] 00953
6 semaphore::Semaphore::new [function] [call site] 00954
7 in_scope [function] [call site] 00955
7 AtomicUsize::new [function] [call site] 00956
7 Mutex::new [function] [call site] 00957
7 LinkedList::new [function] [call site] 00958
6 semaphore::Semaphore::new [function] [call site] 00959
6 UnsafeCell::new [function] [call site] 00960
5 Condvar::new [function] [call site] 00961
6 Condvar [function] [call site] 00962
6 parking_lot::Condvar::new [function] [call site] 00963
7 Condvar [function] [call site] 00964
7 parking_lot::Condvar::new [function] [call site] 00965
3 Box::pin [function] [call site] 00966
1 StreamMap::new [function] [call site] 00967
1 iter [function] [call site] 00968
1 copied [function] [call site] 00969
1 enumerate [function] [call site] 00970
1 pin_box [function] [call site] 00971
1 stream::empty::<()> [function] [call site] 00972
1 pin_box [function] [call site] 00973
1 stream::pending::<()> [function] [call site] 00974
1 StreamMap::insert [function] [call site] 00975
1 assert_ready_none [function] [call site] 00976
1 tokio_test::assert_pending [function] [call site] 00977
1 StreamMap::values [function] [call site] 00978