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