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