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
523 410 StreamMap::values call site: 00410 Steal::steal_into
238 16 ThreadWaker::new call site: 00016 Steal::steal_into
128 255 StreamMap::iter call site: 00255 convert_to_blocking_file
17 934 ThreadWaker::new call site: 00934 StreamMap::insert
16 384 StreamMap::insert call site: 00384 StreamMap::insert
12 0 EP call site: 00000 Alternate::poll_next
6 401 StreamMap::insert call site: 00401 Inject::push
1 13 MockTask::new call site: 00013

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