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
355 582 StreamMap::iter call site: 00582 group_b::complete_block_on_under_load
293 33 from_raw call site: 00033 Steal::steal_into
220 361 StreamMap::values call site: 00361 Steal::steal_into
47 940 to_raw call site: 00940 read_to_string
24 327 StreamMap::insert call site: 00327 StreamMap::insert
17 988 ThreadWaker::new call site: 00988 StreamMap::insert
16 16 ThreadWaker::new call site: 00016 test_panic
12 0 EP call site: 00000 Alternate::poll_next
6 352 StreamMap::insert call site: 00352 Inject::push
1 13 MockTask::new call site: 00013
1 938 to_raw call site: 00938

Fuzzer calltree

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