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
617 315 StreamMap::values call site: 00315 Steal::steal_into
247 33 from_raw call site: 00033 Steal::steal_into
47 935 to_raw call site: 00935 read_to_string
24 281 StreamMap::insert call site: 00281 StreamMap::insert
17 983 ThreadWaker::new call site: 00983 StreamMap::insert
16 16 ThreadWaker::new call site: 00016 test_panic
12 0 EP call site: 00000 Alternate::poll_next
6 306 StreamMap::insert call site: 00306 Inject::push
1 13 MockTask::new call site: 00013
1 933 to_raw call site: 00933

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