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
425 466 StreamMap::iter call site: 00466 Steal::steal_into
328 33 from_raw call site: 00033 Steal::steal_into
81 384 StreamMap::values call site: 00384 Steal::steal_into
51 894 to_raw call site: 00894 read_to_string
17 946 ThreadWaker::new call site: 00946 StreamMap::insert
16 16 ThreadWaker::new call site: 00016 test_panic
12 0 EP call site: 00000 Alternate::poll_next
12 362 StreamMap::insert call site: 00362 StreamMap::insert
6 375 StreamMap::insert call site: 00375 Inject::push
1 13 MockTask::new call site: 00013
1 892 to_raw call site: 00892

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 StreamNotifyClose::new [function] [call site] 00300
24 Some [function] [call site] 00301
23 io::Result::to_string [function] [call site] 00302
24 UnboundedReceiverStream::as_ref [function] [call site] 00303
24 &UnboundedReceiver::to_owned [function] [call site] 00304
24 fs::asyncify [function] [call site] 00305
25 mocks::spawn_blocking [function] [call site] 00306
26 task::spawn_blocking [function] [call site] 00307
27 task::spawn_blocking [function] [call site] 00308
27 unwrap [function] [call site] 00309
26 unwrap [function] [call site] 00310
25 Err [function] [call site] 00311
25 io::Error::new [function] [call site] 00312
26 Some [function] [call site] 00313
24 std::fs::read_to_string [function] [call site] 00314
25 UnboundedReceiverStream::as_ref [function] [call site] 00315
25 &UnboundedReceiver::to_owned [function] [call site] 00316
25 fs::asyncify [function] [call site] 00317
25 std::fs::read_to_string [function] [call site] 00318
23 iter [function] [call site] 00319
24 into_iter [function] [call site] 00320
23 send [function] [call site] 00321
23 io::Result::clone [function] [call site] 00322
24 tempfile [function] [call site] 00323
24 File::create [function] [call site] 00324
24 NamedTempFile::path [function] [call site] 00325
24 unwrap [function] [call site] 00326
24 File::try_clone [function] [call site] 00327
25 try_lock [function] [call site] 00328
25 Inner::complete_inflight [function] [call site] 00329
26 poll_fn [function] [call site] 00330
26 Inner::poll_complete_inflight [function] [call site] 00331
27 Inner::poll_flush [function] [call site] 00332
28 take [function] [call site] 00333
28 Poll::Ready [function] [call site] 00334
28 Err [function] [call site] 00335
28 Steal::steal_into [function] [call site] 00336
29 AtomicU16::unsync_load [function] [call site] 00337
30 core::ptr::read [function] [call site] 00338
31 tempfile [function] [call site] 00339
31 NamedTempFile::write_all [function] [call site] 00340
31 WriteAll::unwrap [function] [call site] 00341
31 File::open [function] [call site] 00342
31 NamedTempFile::path [function] [call site] 00343
31 unwrap [function] [call site] 00344
31 NamedTempFile::read [function] [call site] 00345
31 unwrap [function] [call site] 00346
30 fuzz_target [function] [call site] 00347
31 StreamNotifyClose::new [function] [call site] 00348
31 Alternate::poll_next [function] [call site] 00349
31 StreamMap::len [function] [call site] 00350
31 my_custom_runtime::spawn [function] [call site] 00351
31 StreamMap::new [function] [call site] 00352
31 iter [function] [call site] 00353
31 copied [function] [call site] 00354
31 enumerate [function] [call site] 00355
31 pin_box [function] [call site] 00356
32 Box::pin [function] [call site] 00357
31 stream::empty::<()> [function] [call site] 00358
31 pin_box [function] [call site] 00359
31 stream::pending::<()> [function] [call site] 00360
31 StreamMap::insert [function] [call site] 00361
32 StreamMap::remove [function] [call site] 00362
33 len [function] [call site] 00363
33 contains_key_borrow [function] [call site] 00364
34 StreamMap::new [function] [call site] 00365
34 StreamMap::insert [function] [call site] 00366
34 &str::to_string [function] [call site] 00367
35 UnboundedReceiverStream::as_ref [function] [call site] 00368
35 &UnboundedReceiver::to_owned [function] [call site] 00369
35 fs::asyncify [function] [call site] 00370
35 std::fs::read_to_string [function] [call site] 00371
34 pending::<()> [function] [call site] 00372
33 Some [function] [call site] 00373
33 swap_remove [function] [call site] 00374
32 Inject::push [function] [call site] 00375
33 try_lock [function] [call site] 00376
33 Inject::push [function] [call site] 00377
31 assert_ready_none [function] [call site] 00378
32 tokio_test::assert_ready [function] [call site] 00379
31 tokio_test::assert_pending [function] [call site] 00380
31 StreamMap::values [function] [call site] 00381
32 StreamMap::iter [function] [call site] 00382
33 iter [function] [call site] 00383
32 StreamExt::map [function] [call site] 00384
33 Map::new [function] [call site] 00385
29 unpack [function] [call site] 00386
29 group_b::complete_block_on_under_load [function] [call site] 00387
30 loom::model [function] [call site] 00388
31 loom::model [function] [call site] 00389
30 mk_pool [function] [call site] 00390
31 runtime::Builder::new_multi_thread [function] [call site] 00391
32 Builder::new [function] [call site] 00392
31 Builder::worker_threads [function] [call site] 00393
31 Builder::event_interval [function] [call site] 00394
31 Configuration::build [function] [call site] 00395
31 Result::unwrap [function] [call site] 00396
30 block_on [function] [call site] 00397
31 runtime::Builder::new_current_thread [function] [call site] 00398
32 Builder::new [function] [call site] 00399
31 Builder::enable_all [function] [call site] 00400
31 Configuration::build [function] [call site] 00401
31 Result::unwrap [function] [call site] 00402
31 tokio::runtime::Runtime::block_on [function] [call site] 00403
32 mem::size_of::<F> [function] [call site] 00404
32 Runtime::block_on_inner [function] [call site] 00405
33 super::task::trace::Trace::root [function] [call site] 00406
33 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] 00407
34 std::thread::sleep [function] [call site] 00408
35 tokio::time::sleep [function] [call site] 00409
36 tokio::time::sleep [function] [call site] 00410
36 ms [function] [call site] 00411
37 subsec_nanos [function] [call site] 00412
37 subsec_millis [function] [call site] 00413
37 as_secs [function] [call site] 00414
37 saturating_mul [function] [call site] 00415
37 saturating_add [function] [call site] 00416
37 std::io::Error::from [function] [call site] 00417
38 Steal::steal_into [function] [call site] 00418
35 ms [function] [call site] 00419
34 std::time::Duration::from_micros [function] [call site] 00420
33 crate::runtime::task::Id::next [function] [call site] 00421
34 group_b::complete_block_on_under_load [function] [call site] 00422
34 Instant::checked_add [function] [call site] 00423
35 Instant::checked_add [function] [call site] 00424
35 StreamExt::map [function] [call site] 00425
36 Map::new [function] [call site] 00426
34 exhausted [function] [call site] 00427
34 StaticAtomicU64::compare_exchange_weak [function] [call site] 00428
35 StaticAtomicU64::inner [function] [call site] 00429
36 get_or_init [function] [call site] 00430
37 runtime::Builder::new_current_thread [function] [call site] 00431
37 Builder::enable_time [function] [call site] 00432
37 Configuration::set_start_paused [function] [call site] 00433
38 is_some [function] [call site] 00434
38 Err [function] [call site] 00435
38 syn::Error::new [function] [call site] 00436
38 parse_bool [function] [call site] 00437
39 Ok [function] [call site] 00438
39 Err [function] [call site] 00439
39 syn::Error::new [function] [call site] 00440
38 Some [function] [call site] 00441
38 Ok [function] [call site] 00442
37 Configuration::build [function] [call site] 00443
37 unwrap [function] [call site] 00444
37 tokio::runtime::Runtime::block_on [function] [call site] 00445
37 tokio::runtime::Runtime::spawn [function] [call site] 00446
37 get_or_init [function] [call site] 00447
37 tokio::runtime::Runtime::spawn [function] [call site] 00448
37 get_or_init [function] [call site] 00449
37 time::advance [function] [call site] 00450
38 Instant::now [function] [call site] 00451
39 variant::now [function] [call site] 00452
40 crate::time::clock::now [function] [call site] 00453
41 Now [function] [call site] 00454
38 time::advance [function] [call site] 00455
38 Duration::from_millis [function] [call site] 00456
38 my_custom_runtime::spawn [function] [call site] 00457
38 time::sleep_until [function] [call site] 00458
39 Sleep::new_timeout [function] [call site] 00459
40 scheduler::Handle::current [function] [call site] 00460
40 Timer::new [function] [call site] 00461
41 Handle::driver [function] [call site] 00462
41 &driver::Handle::time [function] [call site] 00463
42 into_iter [function] [call site] 00464
42 StreamMap::iter [function] [call site] 00465
43 iter [function] [call site] 00466
42 into_iter [function] [call site] 00467
42 StreamMap::iter [function] [call site] 00468
42 StreamExt::then [function] [call site] 00469
43 Then::new [function] [call site] 00470
42 time::sleep [function] [call site] 00471
43 tokio::time::sleep [function] [call site] 00472
43 ms [function] [call site] 00473
42 Duration::from_secs [function] [call site] 00474
42 StreamExt::map [function] [call site] 00475
43 Map::new [function] [call site] 00476
42 StreamExt::chain [function] [call site] 00477
43 Chain::new [function] [call site] 00478
44 Fuse::new [function] [call site] 00479
45 Some [function] [call site] 00480
42 StreamExt::chunks_timeout [function] [call site] 00481
43 ChunksTimeout::new [function] [call site] 00482
44 Fuse::new [function] [call site] 00483
44 Vec::with_capacity [function] [call site] 00484
45 StreamMap::<&str, [call site] 00485
42 Duration::from_secs [function] [call site] 00486
42 my_custom_runtime::spawn [function] [call site] 00487
40 scheduler::Handle::current [function] [call site] 00488
40 Handle::driver [function] [call site] 00489
40 &driver::Handle::clock [function] [call site] 00490
41 Handle::driver [function] [call site] 00491
41 Timer::clock [function] [call site] 00492
42 Handle::driver [function] [call site] 00493
42 Timer::clock [function] [call site] 00494
40 Handle::driver [function] [call site] 00495
40 &driver::Handle::time [function] [call site] 00496
40 Handle::time_source [function] [call site] 00497
40 &TimeSource::deadline_to_tick [function] [call site] 00498
41 Handle::driver [function] [call site] 00499
41 &driver::Handle::time [function] [call site] 00500
41 Handle::time_source [function] [call site] 00501
41 &TimeSource::deadline_to_tick [function] [call site] 00502
40 u64::saturating_sub [function] [call site] 00503
40 date::now [function] [call site] 00504
41 Now [function] [call site] 00505
40 &'static [call site] 00506
40 in_scope [function] [call site] 00507
40 in_scope [function] [call site] 00508
39 trace::caller_location [function] [call site] 00509
38 Duration::from_secs [function] [call site] 00510
38 tokio_test::assert_pending [function] [call site] 00511
38 Instant::now [function] [call site] 00512
38 Duration::from_micros [function] [call site] 00513
38 time::advance [function] [call site] 00514
38 tokio_test::assert_pending [function] [call site] 00515
37 Duration::from_millis [function] [call site] 00516
37 time::resume [function] [call site] 00517
38 Instant::now [function] [call site] 00518
38 time::pause [function] [call site] 00519
38 time::advance [function] [call site] 00520
38 Duration::from_secs [function] [call site] 00521
38 time::resume [function] [call site] 00522
38 time::pause [function] [call site] 00523
38 time::advance [function] [call site] 00524
38 Duration::from_secs [function] [call site] 00525
37 unwrap [function] [call site] 00526
37 unwrap [function] [call site] 00527
36 Mutex::new [function] [call site] 00528
35 &Mutex::lock [function] [call site] 00529
36 Mutex::new [function] [call site] 00530
36 try_lock [function] [call site] 00531
36 try_lock [function] [call site] 00532
36 try_lock [function] [call site] 00533
35 Ok [function] [call site] 00534
35 Err [function] [call site] 00535
34 ThreadId [function] [call site] 00536
34 StreamNotifyClose::new [function] [call site] 00537
35 Some [function] [call site] 00538
34 Self::unwrap [function] [call site] 00539
33 Id::as_u64 [function] [call site] 00540
34 fuzz_target [function] [call site] 00541
33 Runtime::enter [function] [call site] 00542
34 basic_enter [function] [call site] 00543
33 &mut [call site] 00544
34 oneshot::channel [function] [call site] 00545
34 rt [function] [call site] 00546
34 tokio::runtime::Runtime::spawn [function] [call site] 00547
34 tokio_test::assert_ok [function] [call site] 00548
34 thread::sleep [function] [call site] 00549
35 tokio::time::sleep [function] [call site] 00550
35 ms [function] [call site] 00551
34 Duration::from_millis [function] [call site] 00552
34 tokio_test::assert_err [function] [call site] 00553
34 tokio::runtime::Runtime::block_on [function] [call site] 00554
34 tokio_test::assert_ok [function] [call site] 00555
33 &mut [call site] 00556
32 Box::pin [function] [call site] 00557
32 SpawnMeta::new_unnamed [function] [call site] 00558
32 Runtime::block_on_inner [function] [call site] 00559
32 SpawnMeta::new_unnamed [function] [call site] 00560
30 my_custom_runtime::spawn [function] [call site] 00561
31 spawn [function] [call site] 00562
30 track [function] [call site] 00563
31 StreamNotifyClose::new [function] [call site] 00564
30 task::yield_now [function] [call site] 00565
30 gated2 [function] [call site] 00566
31 StreamNotifyClose::new [function] [call site] 00567
31 StreamNotifyClose::new [function] [call site] 00568
32 Some [function] [call site] 00569
31 std::future::poll_fn [function] [call site] 00570
31 clone [function] [call site] 00571
31 CachedParkThread::waker [function] [call site] 00572
32 CachedParkThread::unpark [function] [call site] 00573
33 CachedParkThread::with_current [function] [call site] 00574
34 LocalKey::try_with [function] [call site] 00575
35 LocalKey::try_with [function] [call site] 00576
35 Result::borrow [function] [call site] 00577
36 StreamMap::new [function] [call site] 00578
36 StreamMap::insert [function] [call site] 00579
36 &str::to_string [function] [call site] 00580
36 pending::<()> [function] [call site] 00581
35 UnboundedReceiverStream::as_ref [function] [call site] 00582
35 StreamExt::map [function] [call site] 00583
36 Map::new [function] [call site] 00584
35 Ok [function] [call site] 00585
35 Err [function] [call site] 00586
34 Throttle::get_ref [function] [call site] 00587
32 StreamExt::map [function] [call site] 00588
31 clone [function] [call site] 00589
31 my_custom_runtime::spawn [function] [call site] 00590
32 spawn [function] [call site] 00591
31 AtomicU64::store [function] [call site] 00592
32 try_lock [function] [call site] 00593
31 TestWakerInner::wake_by_ref [function] [call site] 00594
32 AtomicU64::store [function] [call site] 00595
31 spawn [function] [call site] 00596
31 track [function] [call site] 00597
31 AtomicU64::store [function] [call site] 00598
31 TestWakerInner::wake_by_ref [function] [call site] 00599
31 group_b::complete_block_on_under_load [function] [call site] 00600
31 Poll::Ready [function] [call site] 00601
29 wrapping_sub [function] [call site] 00602
29 Steal::steal_into2 [function] [call site] 00603
30 group_b::complete_block_on_under_load [function] [call site] 00604
30 unpack [function] [call site] 00605
30 group_b::complete_block_on_under_load [function] [call site] 00606
30 wrapping_sub [function] [call site] 00607
30 wrapping_add [function] [call site] 00608
30 pack [function] [call site] 00609
31 mem::size_of::<UnsignedShort> [function] [call site] 00610
30 AtomicU64::compare_exchange [function] [call site] 00611
31 try_lock [function] [call site] 00612
31 Ok [function] [call site] 00613
31 Err [function] [call site] 00614
30 unpack [function] [call site] 00615
30 wrapping_add [function] [call site] 00616
30 UnsignedShort::wrapping_add [function] [call site] 00617
30 with [function] [call site] 00618
31 Runtime [function] [call site] 00619
31 StreamNotifyClose::new [function] [call site] 00620
31 OwnedTasks::new [function] [call site] 00621
32 OwnedTasks::gen_shared_list_size [function] [call site] 00622
33 usize::min [function] [call site] 00623
33 usize::next_power_of_two [function] [call site] 00624
32 WakeList::new [function] [call site] 00625
32 StreamNotifyClose::new [function] [call site] 00626
32 get_next_id [function] [call site] 00627
31 Mutex::new [function] [call site] 00628
31 StreamNotifyClose::new [function] [call site] 00629
32 Some [function] [call site] 00630
31 try_lock [function] [call site] 00631
31 unwrap [function] [call site] 00632
31 Some [function] [call site] 00633
31 tokio::runtime::Runtime::clone [function] [call site] 00634
32 tempfile [function] [call site] 00635
32 File::create [function] [call site] 00636
32 NamedTempFile::path [function] [call site] 00637
32 unwrap [function] [call site] 00638
32 File::try_clone [function] [call site] 00639
32 unwrap [function] [call site] 00640
32 RawWaker::write_all [function] [call site] 00641
32 unwrap [function] [call site] 00642
32 RW::poll_flush [function] [call site] 00643
33 Poll::Ready [function] [call site] 00644
33 Ok [function] [call site] 00645
32 unwrap [function] [call site] 00646
32 std::fs::read [function] [call site] 00647
32 NamedTempFile::path [function] [call site] 00648
32 unwrap [function] [call site] 00649
30 ptr::read [function] [call site] 00650
31 tempfile [function] [call site] 00651
31 NamedTempFile::write_all [function] [call site] 00652
31 WriteAll::unwrap [function] [call site] 00653
31 File::open [function] [call site] 00654
31 NamedTempFile::path [function] [call site] 00655
31 unwrap [function] [call site] 00656
31 NamedTempFile::read [function] [call site] 00657
31 unwrap [function] [call site] 00658
30 as_ptr [function] [call site] 00659
30 CoreStage::with_mut [function] [call site] 00660
31 CoreStage::with_mut [function] [call site] 00661
30 ptr::write [function] [call site] 00662
31 tempfile [function] [call site] 00663
31 File::create [function] [call site] 00664
31 NamedTempFile::path [function] [call site] 00665
31 unwrap [function] [call site] 00666
31 NamedTempFile::write_all [function] [call site] 00667
31 unwrap [function] [call site] 00668
31 RW::poll_flush [function] [call site] 00669
31 unwrap [function] [call site] 00670
31 std::fs::read [function] [call site] 00671
31 NamedTempFile::path [function] [call site] 00672
31 unwrap [function] [call site] 00673
30 as_mut_ptr [function] [call site] 00674
30 unpack [function] [call site] 00675
30 pack [function] [call site] 00676
30 AtomicU64::compare_exchange [function] [call site] 00677
30 unpack [function] [call site] 00678
29 Stats::incr_steal_count [function] [call site] 00679
30 Stats::incr_steal_count [function] [call site] 00680
31 Stats::incr_steal_count [function] [call site] 00681
29 Stats::incr_steal_operations [function] [call site] 00682
30 Stats::incr_steal_operations [function] [call site] 00683
31 Stats::incr_steal_operations [function] [call site] 00684
29 wrapping_add [function] [call site] 00685
29 with [function] [call site] 00686
29 ptr::read [function] [call site] 00687
29 as_ptr [function] [call site] 00688
29 Some [function] [call site] 00689
29 AtomicU64::store [function] [call site] 00690
29 wrapping_add [function] [call site] 00691
29 Some [function] [call site] 00692
28 Poll::Ready [function] [call site] 00693
28 Ok [function] [call site] 00694
28 State::Idle [function] [call site] 00695
28 Some [function] [call site] 00696
28 Poll::Ready [function] [call site] 00697
28 Ok [function] [call site] 00698
28 Poll::Ready [function] [call site] 00699
28 Poll::Ready [function] [call site] 00700
28 Ok [function] [call site] 00701
27 Some [function] [call site] 00702
27 kind [function] [call site] 00703
27 Poll::Ready [function] [call site] 00704
27 Poll::Ready [function] [call site] 00705
25 clone [function] [call site] 00706
25 fs::asyncify [function] [call site] 00707
25 File::try_clone [function] [call site] 00708
26 try_lock [function] [call site] 00709
26 Inner::complete_inflight [function] [call site] 00710
26 clone [function] [call site] 00711
26 fs::asyncify [function] [call site] 00712
26 File::try_clone [function] [call site] 00713
26 File::from_std [function] [call site] 00714
27 StreamNotifyClose::new [function] [call site] 00715
27 Mutex::new [function] [call site] 00716
27 State::Idle [function] [call site] 00717
27 Some [function] [call site] 00718
27 Buf::with_capacity [function] [call site] 00719
28 Vec::with_capacity [function] [call site] 00720
26 File::set_max_buf_size [function] [call site] 00721
26 Ok [function] [call site] 00722
25 File::from_std [function] [call site] 00723
25 File::set_max_buf_size [function] [call site] 00724
25 Ok [function] [call site] 00725
24 unwrap [function] [call site] 00726
24 RawWaker::write_all [function] [call site] 00727
24 unwrap [function] [call site] 00728
24 RW::poll_flush [function] [call site] 00729
24 unwrap [function] [call site] 00730
24 std::fs::read [function] [call site] 00731
24 NamedTempFile::path [function] [call site] 00732
24 unwrap [function] [call site] 00733
23 Result::is_err [function] [call site] 00734
23 Inject::push [function] [call site] 00735
24 try_lock [function] [call site] 00736
24 Inject::push [function] [call site] 00737
23 remove [function] [call site] 00738
24 tempfile::tempdir [function] [call site] 00739
25 tempfile::tempdir [function] [call site] 00740
25 tempfile::TempDir::unwrap [function] [call site] 00741
24 tempfile::TempDir::unwrap [function] [call site] 00742
24 parse_path [function] [call site] 00743
25 syn::Error::new [function] [call site] 00744
25 parse::<syn::Path> [function] [call site] 00745
25 map_err [function] [call site] 00746
25 clone [function] [call site] 00747
25 Err [function] [call site] 00748
25 syn::Error::new [function] [call site] 00749
24 join [function] [call site] 00750
24 clone [function] [call site] 00751
24 std::fs::create_dir [function] [call site] 00752
25 UnboundedReceiverStream::as_ref [function] [call site] 00753
25 &UnboundedReceiver::to_owned [function] [call site] 00754
25 fs::asyncify [function] [call site] 00755
25 std::fs::create_dir [function] [call site] 00756
24 clone [function] [call site] 00757
24 io::Result::unwrap [function] [call site] 00758
24 tokio_test::assert_ok [function] [call site] 00759
21 OwnedTasks::bind_inner [function] [call site] 00760
22 Harness::header [function] [call site] 00761
23 Harness::header_ptr [function] [call site] 00762
24 Shared::broadcast [function] [call site] 00763
23 NonNull::as_ptr [function] [call site] 00764
22 Header::set_owner_id [function] [call site] 00765
23 CoreStage::with_mut [function] [call site] 00766
23 Some [function] [call site] 00767
22 ShardedList::lock_shard [function] [call site] 00768
23 Task::get_shard_id [function] [call site] 00769
24 Header::get_id [function] [call site] 00770
25 Header::get_id_ptr [function] [call site] 00771
26 UnboundedReceiverStream::as_ref [function] [call site] 00772
26 as_ptr [function] [call site] 00773
26 as_ptr().cast::<u8> [function] [call site] 00774
26 Interest::add [function] [call site] 00775
27 Self [function] [call site] 00776
26 as_ptr().cast::<u8>().add(offset).cast::<Id> [function] [call site] 00777
26 NonNull::new_unchecked [function] [call site] 00778
25 NonNull::as_ptr [function] [call site] 00779
24 fuzz_target [function] [call site] 00780
23 Waiter::as_raw [function] [call site] 00781
23 ShardedList::shard_inner [function] [call site] 00782
24 SetOnce::get_unchecked [function] [call site] 00783
25 with [function] [call site] 00784
25 as_ptr [function] [call site] 00785
24 try_lock [function] [call site] 00786
22 group_b::complete_block_on_under_load [function] [call site] 00787
22 size_hint_stream_closed_permits_drop [function] [call site] 00788
22 shutdown [function] [call site] 00789
22 ShardGuard::push [function] [call site] 00790
23 Task::get_shard_id [function] [call site] 00791
23 Waiter::as_raw [function] [call site] 00792
23 WakeQueue::push_front [function] [call site] 00793
24 WakeQueue::push_front [function] [call site] 00794
23 Interest::add [function] [call site] 00795
23 MetricAtomicUsize::increment [function] [call site] 00796
24 StaticAtomicU64::fetch_add [function] [call site] 00797
25 StaticAtomicU64::inner [function] [call site] 00798
25 &Mutex::lock [function] [call site] 00799
22 Some [function] [call site] 00800
20 Runtime::clone [function] [call site] 00801
21 tempfile [function] [call site] 00802
21 File::create [function] [call site] 00803
21 NamedTempFile::path [function] [call site] 00804
21 unwrap [function] [call site] 00805
21 File::try_clone [function] [call site] 00806
21 unwrap [function] [call site] 00807
21 RawWaker::write_all [function] [call site] 00808
21 unwrap [function] [call site] 00809
21 RW::poll_flush [function] [call site] 00810
21 unwrap [function] [call site] 00811
21 std::fs::read [function] [call site] 00812
21 NamedTempFile::path [function] [call site] 00813
21 unwrap [function] [call site] 00814
20 Id::next [function] [call site] 00815
21 StaticAtomicU64::fetch_add [function] [call site] 00816
21 StreamNotifyClose::new [function] [call site] 00817
21 Self [function] [call site] 00818
20 SpawnLocation::capture [function] [call site] 00819
21 std::io::Error::from [function] [call site] 00820
22 Steal::steal_into [function] [call site] 00821
21 Location::caller [function] [call site] 00822
22 test_panic [function] [call site] 00823
22 into_iter [function] [call site] 00824
22 StreamMap::iter [function] [call site] 00825
22 StreamExt::chunks_timeout [function] [call site] 00826
23 ChunksTimeout::new [function] [call site] 00827
22 Duration::from_secs [function] [call site] 00828
22 Ok [function] [call site] 00829
20 Runtime::schedule [function] [call site] 00830
21 try_lock [function] [call site] 00831
21 unwrap [function] [call site] 00832
21 LocalState::task_push_back [function] [call site] 00833
22 LocalState::assert_called_from_owner_thread [function] [call site] 00834
22 CoreStage::with_mut [function] [call site] 00835
22 LocalState::task_push_back [function] [call site] 00836
19 tokio_test::assert_ok [function] [call site] 00837
19 thread::sleep [function] [call site] 00838
19 Duration::from_millis [function] [call site] 00839
19 tokio_test::assert_err [function] [call site] 00840
19 tokio::runtime::Runtime::block_on [function] [call site] 00841
19 tokio_test::assert_ok [function] [call site] 00842
18 send [function] [call site] 00843
18 unwrap [function] [call site] 00844
18 Handle::current [function] [call site] 00845
18 Self::block_on [function] [call site] 00846
18 recv [function] [call site] 00847
18 unwrap [function] [call site] 00848
17 send [function] [call site] 00849
17 unwrap [function] [call site] 00850
17 send [function] [call site] 00851
17 unwrap [function] [call site] 00852
17 ReceiverStream::new [function] [call site] 00853
17 Alternate::poll_next [function] [call site] 00854
17 Alternate::poll_next [function] [call site] 00855
15 NamedTempFile::path [function] [call site] 00856
15 unwrap [function] [call site] 00857
15 NamedTempFile::read [function] [call site] 00858
15 unwrap [function] [call site] 00859
14 NamedTempFile::path [function] [call site] 00860
14 unwrap [function] [call site] 00861
13 write [function] [call site] 00862
13 Configuration::build [function] [call site] 00863
13 write_all [function] [call site] 00864
13 expect [function] [call site] 00865
13 write_all [function] [call site] 00866
13 expect [function] [call site] 00867
12 write [function] [call site] 00868
11 &mut [call site] 00869
11 open_options_truncate [function] [call site] 00870
11 size_hint_stream_open [function] [call site] 00871
12 mpsc::channel [function] [call site] 00872
12 send [function] [call site] 00873
12 unwrap [function] [call site] 00874
12 send [function] [call site] 00875
12 unwrap [function] [call site] 00876
12 ReceiverStream::new [function] [call site] 00877
12 Alternate::poll_next [function] [call site] 00878
12 Alternate::poll_next [function] [call site] 00879
10 NamedTempFile::path [function] [call site] 00880
10 unwrap [function] [call site] 00881
10 File::try_clone [function] [call site] 00882
10 unwrap [function] [call site] 00883
10 RawWaker::write_all [function] [call site] 00884
10 unwrap [function] [call site] 00885
10 RW::poll_flush [function] [call site] 00886
10 unwrap [function] [call site] 00887
10 std::fs::read [function] [call site] 00888
10 NamedTempFile::path [function] [call site] 00889
10 unwrap [function] [call site] 00890
9 to_raw [function] [call site] 00891
10 StreamNotifyClose::new [function] [call site] 00892
11 Some [function] [call site] 00893
10 Inner::into_raw [function] [call site] 00894
11 Inner::into_raw [function] [call site] 00895
8 panic::set_hook [function] [call site] 00896
8 StreamNotifyClose::new [function] [call site] 00897
9 Some [function] [call site] 00898
8 Header::get_spawn_location [function] [call site] 00899
9 Header::get_spawn_location_ptr [function] [call site] 00900
10 UnboundedReceiverStream::as_ref [function] [call site] 00901
10 as_ptr [function] [call site] 00902
10 as_ptr() [call site] 00903
6 .cast::<u8> [function] [call site] 00904
10 Interest::add [function] [call site] 00905
10 as_ptr() [call site] 00906
6 .cast::<u8>() [call site] 00907
6 .add(offset) [call site] 00908
6 .cast::<&'static [call site] 00909
10 NonNull::new_unchecked [function] [call site] 00910
9 NonNull::as_ptr [function] [call site] 00911
8 unwrap [function] [call site] 00912
8 try_lock [function] [call site] 00913
8 clone_from [function] [call site] 00914
8 Some [function] [call site] 00915
8 tempfile [function] [call site] 00916
9 StreamNotifyClose::new [function] [call site] 00917
9 Self::unwrap [function] [call site] 00918
8 read_to_string [function] [call site] 00919
9 UnboundedReceiverStream::as_ref [function] [call site] 00920
9 &UnboundedReceiver::to_owned [function] [call site] 00921
9 fs::asyncify [function] [call site] 00922
9 std::fs::read_to_string [function] [call site] 00923
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] 00924
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] 00925
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] 00926
10 std::panic::AssertUnwindSafe [function] [call site] 00927
9 std::panic::AssertUnwindSafe [function] [call site] 00928
8 panic::set_hook [function] [call site] 00929
8 is_err [function] [call site] 00930
8 try_lock [function] [call site] 00931
8 clone [function] [call site] 00932
7 into_iter [function] [call site] 00933
7 StreamMap::iter [function] [call site] 00934
7 StreamExt::chunks_timeout [function] [call site] 00935
7 Duration::from_secs [function] [call site] 00936
7 Ok [function] [call site] 00937
6 in_scope [function] [call site] 00938
6 semaphore::Semaphore::new [function] [call site] 00939
7 in_scope [function] [call site] 00940
7 AtomicUsize::new [function] [call site] 00941
7 Mutex::new [function] [call site] 00942
7 LinkedList::new [function] [call site] 00943
6 semaphore::Semaphore::new [function] [call site] 00944
6 UnsafeCell::new [function] [call site] 00945
5 Condvar::new [function] [call site] 00946
6 Condvar [function] [call site] 00947
6 parking_lot::Condvar::new [function] [call site] 00948
7 Condvar [function] [call site] 00949
7 parking_lot::Condvar::new [function] [call site] 00950
3 Box::pin [function] [call site] 00951
1 StreamMap::new [function] [call site] 00952
1 iter [function] [call site] 00953
1 copied [function] [call site] 00954
1 enumerate [function] [call site] 00955
1 pin_box [function] [call site] 00956
1 stream::empty::<()> [function] [call site] 00957
1 pin_box [function] [call site] 00958
1 stream::pending::<()> [function] [call site] 00959
1 StreamMap::insert [function] [call site] 00960
1 assert_ready_none [function] [call site] 00961
1 tokio_test::assert_pending [function] [call site] 00962
1 StreamMap::values [function] [call site] 00963