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
706 465 StreamMap::insert call site: 00465 Steal::steal_into
406 33 from_raw call site: 00033 Steal::steal_into
36 1174 to_raw call site: 01174 read_to_string
24 440 StreamMap::insert call site: 00440 StreamMap::insert
19 1211 ThreadWaker::new call site: 01211 StreamMap::insert
16 16 ThreadWaker::new call site: 00016 test_panic
12 0 EP call site: 00000 Alternate::poll_next
1 13 MockTask::new call site: 00013
1 1172 to_raw call site: 01172
1 1233 StreamMap::values call site: 01233

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
22 size_hint_stream_closed_permits_drop [function] [call site] 00216
22 Alternate::poll_next [function] [call site] 00217
23 Poll::Ready [function] [call site] 00218
23 Some [function] [call site] 00219
23 Poll::Ready [function] [call site] 00220
22 size_hint_stream_closed_permits_drop [function] [call site] 00221
21 size_hint_stream_closed_permits_drop [function] [call site] 00222
19 Throttle::get_ref [function] [call site] 00223
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00224
20 shutdown [function] [call site] 00225
21 Harness::<T, [call site] 00226
22 Self [function] [call site] 00227
21 Self::shutdown [function] [call site] 00228
22 time::timeout [function] [call site] 00229
23 Inner::into_iter [function] [call site] 00230
24 Iter [function] [call site] 00231
23 stream::iter [function] [call site] 00232
24 tokio_stream::iter [function] [call site] 00233
25 tokio_stream::iter [function] [call site] 00234
25 StreamExt::fuse [function] [call site] 00235
26 Fuse::new [function] [call site] 00236
27 Some [function] [call site] 00237
24 StreamExt::fuse [function] [call site] 00238
23 Inner::into_iter [function] [call site] 00239
23 stream::iter [function] [call site] 00240
23 StreamExt::then [function] [call site] 00241
24 Then::new [function] [call site] 00242
23 time::sleep [function] [call site] 00243
24 tokio::time::sleep [function] [call site] 00244
25 tokio::time::sleep [function] [call site] 00245
25 ms [function] [call site] 00246
26 subsec_nanos [function] [call site] 00247
26 subsec_millis [function] [call site] 00248
26 as_secs [function] [call site] 00249
26 saturating_mul [function] [call site] 00250
26 saturating_add [function] [call site] 00251
26 std::io::Error::from [function] [call site] 00252
27 Steal::steal_into [function] [call site] 00253
28 AtomicU16::unsync_load [function] [call site] 00254
29 core::ptr::read [function] [call site] 00255
30 tempfile [function] [call site] 00256
30 NamedTempFile::write_all [function] [call site] 00257
30 WriteAll::unwrap [function] [call site] 00258
30 File::open [function] [call site] 00259
30 NamedTempFile::path [function] [call site] 00260
30 unwrap [function] [call site] 00261
30 NamedTempFile::read [function] [call site] 00262
30 unwrap [function] [call site] 00263
29 test_iter_coop_budget [function] [call site] 00264
30 my_custom_runtime::spawn [function] [call site] 00265
30 stream::iter [function] [call site] 00266
30 iter::repeat [function] [call site] 00267
31 LinesCodec::new_with_max_length [function] [call site] 00268
32 LinesCodec::new [function] [call site] 00269
31 StreamNotifyClose::new [function] [call site] 00270
32 Some [function] [call site] 00271
31 VecWithInitialized::reserve [function] [call site] 00272
31 ReadBuf::put_slice [function] [call site] 00273
32 len [function] [call site] 00274
32 as_mut_ptr [function] [call site] 00275
32 buf[self.filled..end] [call site] 00276
8 .as_mut_ptr() [call site] 00277
8 .cast::<u8> [function] [call site] 00278
32 copy_from_nonoverlapping [function] [call site] 00279
32 as_ptr [function] [call site] 00280
31 ReadBuf::put_slice [function] [call site] 00281
30 poll_next [function] [call site] 00282
31 Interval::enter [function] [call site] 00283
32 rt [function] [call site] 00284
32 rt [function] [call site] 00285
32 tokio::runtime::Runtime::enter [function] [call site] 00286
32 tokio::runtime::Runtime::enter [function] [call site] 00287
32 size_hint_stream_closed_permits_drop [function] [call site] 00288
32 size_hint_stream_closed_permits_drop [function] [call site] 00289
31 Interval::poll_tick [function] [call site] 00290
32 completed_future_past_deadline [function] [call site] 00291
33 my_custom_runtime::spawn [function] [call site] 00292
33 tokio::time::timeout_at [function] [call site] 00293
34 { [call site] 00294
0 task::coop, [call site] 00295
0 time::sleep_until [function] [call site] 00296
35 Sleep::new_timeout [function] [call site] 00297
36 scheduler::Handle::current [function] [call site] 00298
37 scheduler::Handle::current [function] [call site] 00299
36 Handle::driver [function] [call site] 00300
36 &driver::Handle::time [function] [call site] 00301
37 Inner::into_iter [function] [call site] 00302
37 stream::iter [function] [call site] 00303
37 Inner::into_iter [function] [call site] 00304
37 stream::iter [function] [call site] 00305
37 StreamExt::then [function] [call site] 00306
37 time::sleep [function] [call site] 00307
37 Duration::from_secs [function] [call site] 00308
37 StreamExt::map [function] [call site] 00309
38 Map::new [function] [call site] 00310
37 StreamExt::chain [function] [call site] 00311
38 Chain::new [function] [call site] 00312
39 Fuse::new [function] [call site] 00313
37 StreamExt::chunks_timeout [function] [call site] 00314
38 ChunksTimeout::new [function] [call site] 00315
39 Fuse::new [function] [call site] 00316
39 Vec::with_capacity [function] [call site] 00317
40 StreamMap::<&str, [call site] 00318
37 Duration::from_secs [function] [call site] 00319
37 my_custom_runtime::spawn [function] [call site] 00320
36 &'static [call site] 00321
35 trace::caller_location [function] [call site] 00322
34 Timeout::new_with_delay [function] [call site] 00323
34 select_into_future [function] [call site] 00324
33 Instant::now [function] [call site] 00325
34 variant::now [function] [call site] 00326
35 crate::time::clock::now [function] [call site] 00327
36 Now [function] [call site] 00328
33 ms [function] [call site] 00329
33 assert_ready_ok [function] [call site] 00330
34 assert_ready [function] [call site] 00331
34 assert_ok [function] [call site] 00332
32 Instant::now [function] [call site] 00333
32 Duration::from_millis [function] [call site] 00334
32 MissedTickBehavior::next_timeout [function] [call site] 00335
33 Duration::from_nanos [function] [call site] 00336
33 as_nanos [function] [call site] 00337
33 Duration::as_nanos [function] [call site] 00338
33 ChildStdin::try_into [function] [call site] 00339
34 imp::convert_to_stdio [function] [call site] 00340
35 convert_to_blocking_file [function] [call site] 00341
36 into_inner [function] [call site] 00342
37 RwLock::new [function] [call site] 00343
38 std::panic::Location::caller [function] [call site] 00344
38 in_scope [function] [call site] 00345
38 in_scope [function] [call site] 00346
38 Semaphore::new [function] [call site] 00347
38 Semaphore::new [function] [call site] 00348
38 UnsafeCell::new [function] [call site] 00349
36 set_nonblocking [function] [call site] 00350
37 FileDescriptor::as_raw_fd [function] [call site] 00351
38 FileDescriptor::as_raw_fd [function] [call site] 00352
37 libc::fcntl [function] [call site] 00353
37 Err [function] [call site] 00354
37 io::Error::last_os_error [function] [call site] 00355
37 libc::fcntl [function] [call site] 00356
37 Err [function] [call site] 00357
37 io::Error::last_os_error [function] [call site] 00358
37 Ok [function] [call site] 00359
36 Ok [function] [call site] 00360
35 io::Result::map [function] [call site] 00361
36 Map::new [function] [call site] 00362
33 expect [function] [call site] 00363
32 Instant::checked_add [function] [call site] 00364
33 Instant::checked_add [function] [call site] 00365
34 Instant::checked_add [function] [call site] 00366
34 StreamExt::map [function] [call site] 00367
35 Map::new [function] [call site] 00368
33 StreamExt::map [function] [call site] 00369
32 Option::unwrap_or_else [function] [call site] 00370
32 UnboundedReceiverStream::as_mut [function] [call site] 00371
32 Sleep::reset_without_timer [function] [call site] 00372
33 Notified::project [function] [call site] 00373
34 is_unpin::<&Notify> [function] [call site] 00374
34 is_unpin::<State> [function] [call site] 00375
34 is_unpin::<usize> [function] [call site] 00376
34 OnceCell::get_unchecked_mut [function] [call site] 00377
35 CoreStage::with_mut [function] [call site] 00378
36 CoreStage::with_mut [function] [call site] 00379
35 as_mut_ptr [function] [call site] 00380
33 spawn_wakes_localset [function] [call site] 00381
34 LocalSet::new [function] [call site] 00382
35 context::thread_id [function] [call site] 00383
36 runtime::Builder::new_multi_thread [function] [call site] 00384
37 Builder::new [function] [call site] 00385
36 Builder::worker_threads [function] [call site] 00386
36 Builder::enable_all [function] [call site] 00387
37 Builder::enable_io [function] [call site] 00388
37 Builder::enable_io_uring [function] [call site] 00389
37 Builder::enable_time [function] [call site] 00390
36 Configuration::build [function] [call site] 00391
36 Result::unwrap [function] [call site] 00392
36 tokio::runtime::Runtime::metrics [function] [call site] 00393
37 cfg_metrics [function] [call site] 00394
36 tokio::runtime::Runtime::block_on [function] [call site] 00395
37 mem::size_of::<F> [function] [call site] 00396
37 Runtime::block_on_inner [function] [call site] 00397
38 super::task::trace::Trace::root [function] [call site] 00398
38 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] 00399
39 std::thread::sleep [function] [call site] 00400
40 tokio::time::sleep [function] [call site] 00401
40 ms [function] [call site] 00402
39 std::time::Duration::from_micros [function] [call site] 00403
38 crate::runtime::task::Id::next [function] [call site] 00404
39 group_b::complete_block_on_under_load [function] [call site] 00405
40 loom::model [function] [call site] 00406
41 loom::model [function] [call site] 00407
40 mk_pool [function] [call site] 00408
41 runtime::Builder::new_multi_thread [function] [call site] 00409
41 Builder::worker_threads [function] [call site] 00410
41 Builder::event_interval [function] [call site] 00411
41 Configuration::build [function] [call site] 00412
41 Result::unwrap [function] [call site] 00413
40 block_on [function] [call site] 00414
41 runtime::Builder::new_current_thread [function] [call site] 00415
42 Builder::new [function] [call site] 00416
41 Builder::enable_all [function] [call site] 00417
41 Configuration::build [function] [call site] 00418
41 Result::unwrap [function] [call site] 00419
41 tokio::runtime::Runtime::block_on [function] [call site] 00420
40 my_custom_runtime::spawn [function] [call site] 00421
41 spawn [function] [call site] 00422
40 track [function] [call site] 00423
41 StreamNotifyClose::new [function] [call site] 00424
40 task::yield_now [function] [call site] 00425
41 std::future::poll_fn [function] [call site] 00426
41 Poll::Ready [function] [call site] 00427
41 context::defer [function] [call site] 00428
42 Defer [function] [call site] 00429
42 StreamNotifyClose::new [function] [call site] 00430
43 Some [function] [call site] 00431
41 CachedParkThread::waker [function] [call site] 00432
42 CachedParkThread::unpark [function] [call site] 00433
43 CachedParkThread::with_current [function] [call site] 00434
44 LocalKey::try_with [function] [call site] 00435
45 LocalKey::try_with [function] [call site] 00436
45 Result::borrow [function] [call site] 00437
46 StreamMap::new [function] [call site] 00438
46 StreamMap::insert [function] [call site] 00439
47 StreamMap::remove [function] [call site] 00440
48 len [function] [call site] 00441
48 contains_key_borrow [function] [call site] 00442
49 StreamMap::new [function] [call site] 00443
49 StreamMap::insert [function] [call site] 00444
49 &str::to_string [function] [call site] 00445
50 UnboundedReceiverStream::as_ref [function] [call site] 00446
50 &UnboundedReceiver::to_owned [function] [call site] 00447
50 fs::asyncify [function] [call site] 00448
51 mocks::spawn_blocking [function] [call site] 00449
52 task::spawn_blocking [function] [call site] 00450
53 task::spawn_blocking [function] [call site] 00451
53 unwrap [function] [call site] 00452
52 unwrap [function] [call site] 00453
51 Err [function] [call site] 00454
51 io::Error::new [function] [call site] 00455
52 Some [function] [call site] 00456
50 std::fs::read_to_string [function] [call site] 00457
51 UnboundedReceiverStream::as_ref [function] [call site] 00458
51 &UnboundedReceiver::to_owned [function] [call site] 00459
51 fs::asyncify [function] [call site] 00460
51 std::fs::read_to_string [function] [call site] 00461
49 pending::<()> [function] [call site] 00462
48 Some [function] [call site] 00463
48 swap_remove [function] [call site] 00464
47 Inject::push [function] [call site] 00465
48 try_lock [function] [call site] 00466
48 Inject::push [function] [call site] 00467
46 &str::to_string [function] [call site] 00468
46 pending::<()> [function] [call site] 00469
45 UnboundedReceiverStream::as_ref [function] [call site] 00470
45 StreamExt::map [function] [call site] 00471
46 Map::new [function] [call site] 00472
45 Ok [function] [call site] 00473
45 Err [function] [call site] 00474
44 Throttle::get_ref [function] [call site] 00475
42 StreamExt::map [function] [call site] 00476
40 gated2 [function] [call site] 00477
41 StreamNotifyClose::new [function] [call site] 00478
41 StreamNotifyClose::new [function] [call site] 00479
42 Some [function] [call site] 00480
41 std::future::poll_fn [function] [call site] 00481
41 clone [function] [call site] 00482
41 CachedParkThread::waker [function] [call site] 00483
41 clone [function] [call site] 00484
41 my_custom_runtime::spawn [function] [call site] 00485
42 spawn [function] [call site] 00486
41 AtomicU64::store [function] [call site] 00487
42 try_lock [function] [call site] 00488
41 TestWakerInner::wake_by_ref [function] [call site] 00489
42 AtomicU64::store [function] [call site] 00490
41 spawn [function] [call site] 00491
41 track [function] [call site] 00492
41 AtomicU64::store [function] [call site] 00493
41 TestWakerInner::wake_by_ref [function] [call site] 00494
41 group_b::complete_block_on_under_load [function] [call site] 00495
41 Poll::Ready [function] [call site] 00496
39 Instant::checked_add [function] [call site] 00497
39 exhausted [function] [call site] 00498
39 StaticAtomicU64::compare_exchange_weak [function] [call site] 00499
40 StaticAtomicU64::inner [function] [call site] 00500
41 get_or_init [function] [call site] 00501
42 runtime::Builder::new_current_thread [function] [call site] 00502
42 Builder::enable_time [function] [call site] 00503
42 Configuration::set_start_paused [function] [call site] 00504
43 is_some [function] [call site] 00505
43 Err [function] [call site] 00506
43 syn::Error::new [function] [call site] 00507
43 parse_bool [function] [call site] 00508
44 Ok [function] [call site] 00509
44 Err [function] [call site] 00510
44 syn::Error::new [function] [call site] 00511
43 Some [function] [call site] 00512
43 Ok [function] [call site] 00513
42 Configuration::build [function] [call site] 00514
42 unwrap [function] [call site] 00515
42 tokio::runtime::Runtime::block_on [function] [call site] 00516
42 tokio::runtime::Runtime::spawn [function] [call site] 00517
43 OwnedTasks::bind [function] [call site] 00518
44 Harness::get_new_task [function] [call site] 00519
45 Task::from_raw [function] [call site] 00520
46 Task::from_raw [function] [call site] 00521
45 Shared::broadcast [function] [call site] 00522
46 StreamNotifyClose::new [function] [call site] 00523
47 Some [function] [call site] 00524
46 io::Result::to_string [function] [call site] 00525
47 UnboundedReceiverStream::as_ref [function] [call site] 00526
47 &UnboundedReceiver::to_owned [function] [call site] 00527
47 fs::asyncify [function] [call site] 00528
47 std::fs::read_to_string [function] [call site] 00529
46 iter [function] [call site] 00530
47 Inner::into_iter [function] [call site] 00531
46 send [function] [call site] 00532
46 io::Result::clone [function] [call site] 00533
47 tempfile [function] [call site] 00534
47 File::create [function] [call site] 00535
47 NamedTempFile::path [function] [call site] 00536
47 unwrap [function] [call site] 00537
47 File::try_clone [function] [call site] 00538
48 try_lock [function] [call site] 00539
48 Inner::complete_inflight [function] [call site] 00540
49 poll_fn [function] [call site] 00541
49 Inner::poll_complete_inflight [function] [call site] 00542
50 Inner::poll_flush [function] [call site] 00543
51 take [function] [call site] 00544
51 Poll::Ready [function] [call site] 00545
51 Err [function] [call site] 00546
51 Steal::steal_into [function] [call site] 00547
51 Poll::Ready [function] [call site] 00548
51 Ok [function] [call site] 00549
51 State::Idle [function] [call site] 00550
51 Some [function] [call site] 00551
51 Poll::Ready [function] [call site] 00552
51 Ok [function] [call site] 00553
51 Poll::Ready [function] [call site] 00554
51 Poll::Ready [function] [call site] 00555
51 Ok [function] [call site] 00556
50 Some [function] [call site] 00557
50 kind [function] [call site] 00558
50 Poll::Ready [function] [call site] 00559
50 Poll::Ready [function] [call site] 00560
48 clone [function] [call site] 00561
48 fs::asyncify [function] [call site] 00562
48 File::try_clone [function] [call site] 00563
49 try_lock [function] [call site] 00564
49 Inner::complete_inflight [function] [call site] 00565
49 clone [function] [call site] 00566
49 fs::asyncify [function] [call site] 00567
49 File::try_clone [function] [call site] 00568
49 File::from_std [function] [call site] 00569
50 StreamNotifyClose::new [function] [call site] 00570
50 Mutex::new [function] [call site] 00571
50 State::Idle [function] [call site] 00572
50 Some [function] [call site] 00573
50 Buf::with_capacity [function] [call site] 00574
51 Vec::with_capacity [function] [call site] 00575
49 File::set_max_buf_size [function] [call site] 00576
49 Ok [function] [call site] 00577
48 File::from_std [function] [call site] 00578
48 File::set_max_buf_size [function] [call site] 00579
48 Ok [function] [call site] 00580
47 unwrap [function] [call site] 00581
47 RawWaker::write_all [function] [call site] 00582
47 unwrap [function] [call site] 00583
47 RW::poll_flush [function] [call site] 00584
48 Poll::Ready [function] [call site] 00585
48 Ok [function] [call site] 00586
47 unwrap [function] [call site] 00587
47 std::fs::read [function] [call site] 00588
47 NamedTempFile::path [function] [call site] 00589
47 unwrap [function] [call site] 00590
46 Result::is_err [function] [call site] 00591
46 Inject::push [function] [call site] 00592
47 try_lock [function] [call site] 00593
47 Inject::push [function] [call site] 00594
46 remove [function] [call site] 00595
47 tempfile::tempdir [function] [call site] 00596
48 tempfile::tempdir [function] [call site] 00597
48 tempfile::TempDir::unwrap [function] [call site] 00598
47 tempfile::TempDir::unwrap [function] [call site] 00599
47 parse_path [function] [call site] 00600
48 syn::Error::new [function] [call site] 00601
48 parse::<syn::Path> [function] [call site] 00602
48 map_err [function] [call site] 00603
48 clone [function] [call site] 00604
48 Err [function] [call site] 00605
48 syn::Error::new [function] [call site] 00606
47 join [function] [call site] 00607
47 clone [function] [call site] 00608
47 std::fs::create_dir [function] [call site] 00609
48 UnboundedReceiverStream::as_ref [function] [call site] 00610
48 &UnboundedReceiver::to_owned [function] [call site] 00611
48 fs::asyncify [function] [call site] 00612
48 std::fs::create_dir [function] [call site] 00613
47 clone [function] [call site] 00614
47 io::Result::unwrap [function] [call site] 00615
47 tokio_test::assert_ok [function] [call site] 00616
44 OwnedTasks::bind_inner [function] [call site] 00617
45 Harness::header [function] [call site] 00618
46 Harness::header_ptr [function] [call site] 00619
47 Shared::broadcast [function] [call site] 00620
46 NonNull::as_ptr [function] [call site] 00621
45 Header::set_owner_id [function] [call site] 00622
46 CoreStage::with_mut [function] [call site] 00623
46 Some [function] [call site] 00624
45 ShardedList::lock_shard [function] [call site] 00625
46 Task::get_shard_id [function] [call site] 00626
47 Header::get_id [function] [call site] 00627
48 Header::get_id_ptr [function] [call site] 00628
49 UnboundedReceiverStream::as_ref [function] [call site] 00629
49 as_ptr [function] [call site] 00630
49 as_ptr().cast::<u8> [function] [call site] 00631
49 Interest::add [function] [call site] 00632
50 Self [function] [call site] 00633
49 as_ptr().cast::<u8>().add(offset).cast::<Id> [function] [call site] 00634
49 NonNull::new_unchecked [function] [call site] 00635
48 NonNull::as_ptr [function] [call site] 00636
47 test_iter_coop_budget [function] [call site] 00637
46 Waiter::as_raw [function] [call site] 00638
46 ShardedList::shard_inner [function] [call site] 00639
47 SetOnce::get_unchecked [function] [call site] 00640
48 with [function] [call site] 00641
49 Runtime [function] [call site] 00642
49 StreamNotifyClose::new [function] [call site] 00643
49 OwnedTasks::new [function] [call site] 00644
50 OwnedTasks::gen_shared_list_size [function] [call site] 00645
51 usize::min [function] [call site] 00646
51 usize::next_power_of_two [function] [call site] 00647
50 ShardedList::new [function] [call site] 00648
51 std::iter::repeat_with [function] [call site] 00649
51 Mutex::new [function] [call site] 00650
51 LinkedList::new [function] [call site] 00651
51 take [function] [call site] 00652
51 StreamExt::collect [function] [call site] 00653
52 Collect::new [function] [call site] 00654
53 test_iter_size_hint [function] [call site] 00655
54 stream::iter [function] [call site] 00656
53 ()::initialize [function] [call site] 00657
51 StreamNotifyClose::new [function] [call site] 00658
52 Some [function] [call site] 00659
51 MetricAtomicUsize::new [function] [call site] 00660
52 AtomicUsize::new [function] [call site] 00661
50 StreamNotifyClose::new [function] [call site] 00662
50 get_next_id [function] [call site] 00663
49 Mutex::new [function] [call site] 00664
49 StreamNotifyClose::new [function] [call site] 00665
50 Some [function] [call site] 00666
49 try_lock [function] [call site] 00667
49 unwrap [function] [call site] 00668
49 Some [function] [call site] 00669
49 tokio::runtime::Runtime::clone [function] [call site] 00670
50 tempfile [function] [call site] 00671
50 File::create [function] [call site] 00672
50 NamedTempFile::path [function] [call site] 00673
50 unwrap [function] [call site] 00674
50 File::try_clone [function] [call site] 00675
50 unwrap [function] [call site] 00676
50 RawWaker::write_all [function] [call site] 00677
50 unwrap [function] [call site] 00678
50 RW::poll_flush [function] [call site] 00679
50 unwrap [function] [call site] 00680
50 std::fs::read [function] [call site] 00681
50 NamedTempFile::path [function] [call site] 00682
50 unwrap [function] [call site] 00683
48 as_ptr [function] [call site] 00684
47 try_lock [function] [call site] 00685
45 group_b::complete_block_on_under_load [function] [call site] 00686
45 size_hint_stream_closed_permits_drop [function] [call site] 00687
45 shutdown [function] [call site] 00688
45 ShardGuard::push [function] [call site] 00689
46 Task::get_shard_id [function] [call site] 00690
46 Waiter::as_raw [function] [call site] 00691
46 WakeQueue::push_front [function] [call site] 00692
47 WakeQueue::push_front [function] [call site] 00693
46 Interest::add [function] [call site] 00694
46 MetricAtomicUsize::increment [function] [call site] 00695
47 StaticAtomicU64::fetch_add [function] [call site] 00696
48 StaticAtomicU64::inner [function] [call site] 00697
48 &Mutex::lock [function] [call site] 00698
49 Mutex::new [function] [call site] 00699
49 try_lock [function] [call site] 00700
49 try_lock [function] [call site] 00701
49 try_lock [function] [call site] 00702
45 Some [function] [call site] 00703
43 Runtime::clone [function] [call site] 00704
44 tempfile [function] [call site] 00705
44 File::create [function] [call site] 00706
44 NamedTempFile::path [function] [call site] 00707
44 unwrap [function] [call site] 00708
44 File::try_clone [function] [call site] 00709
44 unwrap [function] [call site] 00710
44 RawWaker::write_all [function] [call site] 00711
44 unwrap [function] [call site] 00712
44 RW::poll_flush [function] [call site] 00713
44 unwrap [function] [call site] 00714
44 std::fs::read [function] [call site] 00715
44 NamedTempFile::path [function] [call site] 00716
44 unwrap [function] [call site] 00717
43 Id::next [function] [call site] 00718
44 StaticAtomicU64::fetch_add [function] [call site] 00719
44 StreamNotifyClose::new [function] [call site] 00720
45 Some [function] [call site] 00721
44 Self [function] [call site] 00722
43 SpawnLocation::capture [function] [call site] 00723
44 std::io::Error::from [function] [call site] 00724
45 Steal::steal_into [function] [call site] 00725
44 Location::caller [function] [call site] 00726
45 test_panic [function] [call site] 00727
45 Inner::into_iter [function] [call site] 00728
45 stream::iter [function] [call site] 00729
45 StreamExt::chunks_timeout [function] [call site] 00730
46 ChunksTimeout::new [function] [call site] 00731
45 Duration::from_secs [function] [call site] 00732
45 Ok [function] [call site] 00733
43 Runtime::schedule [function] [call site] 00734
44 try_lock [function] [call site] 00735
44 unwrap [function] [call site] 00736
44 LocalState::task_push_back [function] [call site] 00737
45 LocalState::assert_called_from_owner_thread [function] [call site] 00738
45 CoreStage::with_mut [function] [call site] 00739
45 LocalState::task_push_back [function] [call site] 00740
42 get_or_init [function] [call site] 00741
42 tokio::runtime::Runtime::spawn [function] [call site] 00742
42 get_or_init [function] [call site] 00743
42 time::advance [function] [call site] 00744
43 Instant::now [function] [call site] 00745
43 time::advance [function] [call site] 00746
43 Duration::from_millis [function] [call site] 00747
43 my_custom_runtime::spawn [function] [call site] 00748
43 time::sleep_until [function] [call site] 00749
44 Sleep::new_timeout [function] [call site] 00750
44 trace::caller_location [function] [call site] 00751
43 Duration::from_secs [function] [call site] 00752
43 tokio_test::assert_pending [function] [call site] 00753
43 Instant::now [function] [call site] 00754
43 Duration::from_micros [function] [call site] 00755
43 time::advance [function] [call site] 00756
43 tokio_test::assert_pending [function] [call site] 00757
42 Duration::from_millis [function] [call site] 00758
42 time::resume [function] [call site] 00759
43 Instant::now [function] [call site] 00760
43 time::pause [function] [call site] 00761
43 time::advance [function] [call site] 00762
43 Duration::from_secs [function] [call site] 00763
43 time::resume [function] [call site] 00764
43 time::pause [function] [call site] 00765
43 time::advance [function] [call site] 00766
43 Duration::from_secs [function] [call site] 00767
42 unwrap [function] [call site] 00768
42 unwrap [function] [call site] 00769
41 Mutex::new [function] [call site] 00770
40 &Mutex::lock [function] [call site] 00771
40 Ok [function] [call site] 00772
40 Err [function] [call site] 00773
39 ThreadId [function] [call site] 00774
39 StreamNotifyClose::new [function] [call site] 00775
39 Self::unwrap [function] [call site] 00776
38 Id::as_u64 [function] [call site] 00777
39 test_iter_coop_budget [function] [call site] 00778
38 Runtime::enter [function] [call site] 00779
39 basic_enter [function] [call site] 00780
38 &mut [call site] 00781
39 Builder::new_current_thread [function] [call site] 00782
40 Builder::new [function] [call site] 00783
39 Builder::enable_all [function] [call site] 00784
39 Configuration::build [function] [call site] 00785
39 Result::unwrap [function] [call site] 00786
39 tokio::runtime::Runtime::handle [function] [call site] 00787
39 &Handle::clone [function] [call site] 00788
40 tempfile [function] [call site] 00789
40 File::create [function] [call site] 00790
40 NamedTempFile::path [function] [call site] 00791
40 unwrap [function] [call site] 00792
40 File::try_clone [function] [call site] 00793
40 unwrap [function] [call site] 00794
40 RawWaker::write_all [function] [call site] 00795
40 unwrap [function] [call site] 00796
40 RW::poll_flush [function] [call site] 00797
40 unwrap [function] [call site] 00798
40 std::fs::read [function] [call site] 00799
40 NamedTempFile::path [function] [call site] 00800
40 unwrap [function] [call site] 00801
39 StreamNotifyClose::new [function] [call site] 00802
39 Notify::new [function] [call site] 00803
40 AtomicUsize::new [function] [call site] 00804
40 Mutex::new [function] [call site] 00805
40 LinkedList::new [function] [call site] 00806
39 clone [function] [call site] 00807
39 std::thread::spawn [function] [call site] 00808
40 spawn [function] [call site] 00809
39 std::thread::sleep [function] [call site] 00810
39 std::time::Duration::from_millis [function] [call site] 00811
39 block_on [function] [call site] 00812
39 Condvar::notify_one [function] [call site] 00813
40 notify_one [function] [call site] 00814
41 rt [function] [call site] 00815
41 StreamNotifyClose::new [function] [call site] 00816
41 Notify::new [function] [call site] 00817
41 StreamNotifyClose::new [function] [call site] 00818
41 AtomicUsize::new [function] [call site] 00819
41 tokio::runtime::Runtime::spawn [function] [call site] 00820
41 clone [function] [call site] 00821
41 clone [function] [call site] 00822
41 Snapshot::is_notified [function] [call site] 00823
41 StaticAtomicU64::fetch_add [function] [call site] 00824
41 bench_function [function] [call site] 00825
41 read_to_string [function] [call site] 00826
42 UnboundedReceiverStream::as_ref [function] [call site] 00827
42 &UnboundedReceiver::to_owned [function] [call site] 00828
42 fs::asyncify [function] [call site] 00829
42 std::fs::read_to_string [function] [call site] 00830
41 iter [function] [call site] 00831
41 AtomicU64::store [function] [call site] 00832
41 notify_one [function] [call site] 00833
41 group_b::complete_block_on_under_load [function] [call site] 00834
39 tokio::runtime::Runtime::block_on [function] [call site] 00835
39 Snapshot::is_notified [function] [call site] 00836
39 Result::join [function] [call site] 00837
39 unwrap [function] [call site] 00838
38 &mut [call site] 00839
37 Box::pin [function] [call site] 00840
37 SpawnMeta::new_unnamed [function] [call site] 00841
37 Runtime::block_on_inner [function] [call site] 00842
37 SpawnMeta::new_unnamed [function] [call site] 00843
36 tokio::task::spawn [function] [call site] 00844
37 spawn [function] [call site] 00845
36 Context::worker_index [function] [call site] 00846
36 usize::expect [function] [call site] 00847
36 std::thread::current [function] [call site] 00848
37 StreamExt::map [function] [call site] 00849
37 StreamExt::map [function] [call site] 00850
37 StreamExt::collect [function] [call site] 00851
37 create_temp_file [function] [call site] 00852
38 StreamNotifyClose::new [function] [call site] 00853
38 Self::unwrap [function] [call site] 00854
38 write_all [function] [call site] 00855
38 unwrap [function] [call site] 00856
38 flush [function] [call site] 00857
39 Poll::Ready [function] [call site] 00858
39 Ok [function] [call site] 00859
38 unwrap [function] [call site] 00860
38 parse_path [function] [call site] 00861
38 to_path_buf [function] [call site] 00862
37 StreamExt::collect [function] [call site] 00863
37 TaskTracker::new [function] [call site] 00864
38 StreamNotifyClose::new [function] [call site] 00865
38 TaskTrackerInner::new [function] [call site] 00866
39 AtomicUsize::new [function] [call site] 00867
39 Notify::new [function] [call site] 00868
37 iter [function] [call site] 00869
37 Iter::enumerate [function] [call site] 00870
37 Result::clone [function] [call site] 00871
37 StreamExt::map [function] [call site] 00872
37 StreamExt::collect [function] [call site] 00873
37 my_custom_runtime::spawn [function] [call site] 00874
38 spawn [function] [call site] 00875
37 File::open [function] [call site] 00876
37 unwrap [function] [call site] 00877
37 StreamNotifyClose::new [function] [call site] 00878
37 NamedTempFile::read_to_end [function] [call site] 00879
38 VecWithInitialized::new [function] [call site] 00880
39 UnboundedReceiverStream::as_mut [function] [call site] 00881
39 StreamMap::len [function] [call site] 00882
40 len [function] [call site] 00883
39 UnboundedReceiverStream::as_ref [function] [call site] 00884
39 &UnboundedReceiver::capacity [function] [call site] 00885
40 StreamMap::<&str, [call site] 00886
37 unwrap [function] [call site] 00887
37 UnboundedReceiverStream::close [function] [call site] 00888
38 UnboundedReceiverStream::close [function] [call site] 00889
37 &TaskTracker::wait [function] [call site] 00890
38 oneshot::channel::<i32> [function] [call site] 00891
38 my_custom_runtime::spawn [function] [call site] 00892
38 send [function] [call site] 00893
38 Result::unwrap [function] [call site] 00894
38 UnboundedReceiverStream::close [function] [call site] 00895
36 id [function] [call site] 00896
37 context::current_task_id [function] [call site] 00897
37 expect [function] [call site] 00898
36 worker_index_matches_metrics_worker_thread_id [function] [call site] 00899
37 runtime::Builder::new_multi_thread [function] [call site] 00900
37 Builder::worker_threads [function] [call site] 00901
37 Builder::enable_all [function] [call site] 00902
37 Configuration::build [function] [call site] 00903
37 Result::unwrap [function] [call site] 00904
37 tokio::runtime::Runtime::metrics [function] [call site] 00905
37 tokio::runtime::Runtime::block_on [function] [call site] 00906
37 tokio::task::spawn [function] [call site] 00907
37 Context::worker_index [function] [call site] 00908
37 usize::expect [function] [call site] 00909
37 std::thread::current [function] [call site] 00910
37 id [function] [call site] 00911
37 worker_index_matches_metrics_worker_thread_id [function] [call site] 00912
37 unwrap [function] [call site] 00913
36 unwrap [function] [call site] 00914
35 expect [function] [call site] 00915
35 Cell::new [function] [call site] 00916
36 id [function] [call site] 00917
36 raw::vtable::<T, [call site] 00918
36 StreamNotifyClose::new [function] [call site] 00919
37 Some [function] [call site] 00920
36 Trailer::new [function] [call site] 00921
37 UnsafeCell::new [function] [call site] 00922
37 linked_list::Pointers::new [function] [call site] 00923
38 UnsafeCell::new [function] [call site] 00924
36 Arc::hooks [function] [call site] 00925
37 clone [function] [call site] 00926
36 C::e::l::l::::::::n::e::w::new_header [function] [call site] 00927
37 UnsafeCell::new [function] [call site] 00928
37 UnsafeCell::new [function] [call site] 00929
37 UnsafeCell::new [function] [call site] 00930
37 ScheduleLatencyInstant::new [function] [call site] 00931
38 Self [function] [call site] 00932
38 StreamExt::map [function] [call site] 00933
39 Map::new [function] [call site] 00934
38 StreamNotifyClose::new [function] [call site] 00935
38 Option<Instant>::elapsed [function] [call site] 00936
39 time::pause [function] [call site] 00937
39 time::sleep [function] [call site] 00938
39 Duration::from_millis [function] [call site] 00939
39 UnboundedReceiverStream::as_mut [function] [call site] 00940
38 as_nanos [function] [call site] 00941
38 Self::unwrap_or [function] [call site] 00942
36 UnsafeCell::new [function] [call site] 00943
36 Stage::Running [function] [call site] 00944
36 Header::get_trailer [function] [call site] 00945
37 UnboundedReceiverStream::as_ref [function] [call site] 00946
37 as_ptr [function] [call site] 00947
37 as_ptr().cast::<u8> [function] [call site] 00948
37 Interest::add [function] [call site] 00949
37 as_ptr().cast::<u8>().add(offset).cast::<Trailer> [function] [call site] 00950
37 NonNull::new_unchecked [function] [call site] 00951
36 NonNull::from [function] [call site] 00952
37 NonNull::new_unchecked [function] [call site] 00953
37 Arc::as_ptr [function] [call site] 00954
36 Header::get_scheduler::<S> [function] [call site] 00955
36 NonNull::from [function] [call site] 00956
36 Header::get_id_ptr [function] [call site] 00957
36 NonNull::from [function] [call site] 00958
36 Header::get_spawn_location_ptr [function] [call site] 00959
37 UnboundedReceiverStream::as_ref [function] [call site] 00960
37 as_ptr [function] [call site] 00961
37 as_ptr() [call site] 00962
6 .cast::<u8> [function] [call site] 00963
37 Interest::add [function] [call site] 00964
37 as_ptr() [call site] 00965
6 .cast::<u8>() [call site] 00966
6 .add(offset) [call site] 00967
6 .cast::<&'static [call site] 00968
37 NonNull::new_unchecked [function] [call site] 00969
36 NonNull::from [function] [call site] 00970
36 test::bucket_computation_spot_check [function] [call site] 00971
37 HistogramType::H2 [function] [call site] 00972
35 StreamNotifyClose::new [function] [call site] 00973
36 Some [function] [call site] 00974
35 StreamNotifyClose::new [function] [call site] 00975
35 LocalOwnedTasks::new [function] [call site] 00976
36 UnsafeCell::new [function] [call site] 00977
36 LinkedList::new [function] [call site] 00978
36 get_next_id [function] [call site] 00979
35 UnsafeCell::new [function] [call site] 00980
35 VecDeque::with_capacity [function] [call site] 00981
36 StreamMap::<&str, [call site] 00982
35 Mutex::new [function] [call site] 00983
35 Some [function] [call site] 00984
35 VecDeque::with_capacity [function] [call site] 00985
35 AtomicWaker::new [function] [call site] 00986
36 AtomicUsize::new [function] [call site] 00987
36 UnsafeCell::new [function] [call site] 00988
35 Cell::new [function] [call site] 00989
32 Poll::Ready [function] [call site] 00990
30 tokio_test::assert_pending [function] [call site] 00991
30 tokio::task::yield_now [function] [call site] 00992
31 std::future::poll_fn [function] [call site] 00993
31 Poll::Ready [function] [call site] 00994
31 context::defer [function] [call site] 00995
31 CachedParkThread::waker [function] [call site] 00996
28 unpack [function] [call site] 00997
28 group_b::complete_block_on_under_load [function] [call site] 00998
28 wrapping_sub [function] [call site] 00999
28 Steal::steal_into2 [function] [call site] 01000
29 group_b::complete_block_on_under_load [function] [call site] 01001
29 unpack [function] [call site] 01002
29 group_b::complete_block_on_under_load [function] [call site] 01003
29 wrapping_sub [function] [call site] 01004
29 wrapping_add [function] [call site] 01005
29 pack [function] [call site] 01006
30 mem::size_of::<UnsignedShort> [function] [call site] 01007
29 StaticAtomicU64::compare_exchange_weak [function] [call site] 01008
29 unpack [function] [call site] 01009
29 wrapping_add [function] [call site] 01010
29 UnsignedShort::wrapping_add [function] [call site] 01011
29 with [function] [call site] 01012
29 ptr::read [function] [call site] 01013
30 tempfile [function] [call site] 01014
30 NamedTempFile::write_all [function] [call site] 01015
30 WriteAll::unwrap [function] [call site] 01016
30 File::open [function] [call site] 01017
30 NamedTempFile::path [function] [call site] 01018
30 unwrap [function] [call site] 01019
30 NamedTempFile::read [function] [call site] 01020
30 unwrap [function] [call site] 01021
29 as_ptr [function] [call site] 01022
29 CoreStage::with_mut [function] [call site] 01023
29 ptr::write [function] [call site] 01024
30 tempfile [function] [call site] 01025
30 File::create [function] [call site] 01026
30 NamedTempFile::path [function] [call site] 01027
30 unwrap [function] [call site] 01028
30 NamedTempFile::write_all [function] [call site] 01029
30 unwrap [function] [call site] 01030
30 RW::poll_flush [function] [call site] 01031
30 unwrap [function] [call site] 01032
30 std::fs::read [function] [call site] 01033
30 NamedTempFile::path [function] [call site] 01034
30 unwrap [function] [call site] 01035
29 as_mut_ptr [function] [call site] 01036
29 unpack [function] [call site] 01037
29 pack [function] [call site] 01038
29 StaticAtomicU64::compare_exchange_weak [function] [call site] 01039
28 Stats::incr_steal_count [function] [call site] 01040
29 Stats::incr_steal_count [function] [call site] 01041
30 Stats::incr_steal_count [function] [call site] 01042
28 Stats::incr_steal_operations [function] [call site] 01043
29 Stats::incr_steal_operations [function] [call site] 01044
30 Stats::incr_steal_operations [function] [call site] 01045
28 wrapping_add [function] [call site] 01046
28 with [function] [call site] 01047
28 ptr::read [function] [call site] 01048
28 as_ptr [function] [call site] 01049
28 Some [function] [call site] 01050
28 AtomicU64::store [function] [call site] 01051
28 wrapping_add [function] [call site] 01052
28 Some [function] [call site] 01053
24 ms [function] [call site] 01054
23 Duration::from_secs [function] [call site] 01055
23 StreamExt::map [function] [call site] 01056
23 Inner::into_iter [function] [call site] 01057
23 stream::iter [function] [call site] 01058
23 StreamExt::then [function] [call site] 01059
23 time::sleep [function] [call site] 01060
23 Duration::from_secs [function] [call site] 01061
23 StreamExt::map [function] [call site] 01062
23 StreamExt::chain [function] [call site] 01063
23 StreamExt::chain [function] [call site] 01064
24 Chain::new [function] [call site] 01065
23 StreamExt::chunks_timeout [function] [call site] 01066
23 Duration::from_secs [function] [call site] 01067
23 my_custom_runtime::spawn [function] [call site] 01068
23 tokio_test::assert_pending [function] [call site] 01069
23 time::advance [function] [call site] 01070
23 Duration::from_secs [function] [call site] 01071
23 tokio_test::assert_pending [function] [call site] 01072
23 time::advance [function] [call site] 01073
23 Duration::from_secs [function] [call site] 01074
22 Duration::from_secs [function] [call site] 01075
22 std::io::Result::write_all [function] [call site] 01076
20 shutdown [function] [call site] 01077
20 Some [function] [call site] 01078
19 Duration::from_secs [function] [call site] 01079
19 Throttle::get_ref [function] [call site] 01080
19 new_multi_thread [function] [call site] 01081
20 tokio::runtime::Builder::new_multi_thread [function] [call site] 01082
20 Builder::worker_threads [function] [call site] 01083
20 Builder::enable_all [function] [call site] 01084
20 Configuration::build [function] [call site] 01085
20 Result::unwrap [function] [call site] 01086
19 tokio::runtime::Runtime::enter [function] [call site] 01087
19 Throttle::get_ref [function] [call site] 01088
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 01089
19 Duration::from_secs [function] [call site] 01090
19 Throttle::get_ref [function] [call site] 01091
19 new_multi_thread [function] [call site] 01092
19 tokio::runtime::Runtime::enter [function] [call site] 01093
19 Throttle::get_ref [function] [call site] 01094
19 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 01095
19 Duration::from_secs [function] [call site] 01096
19 Throttle::get_ref [function] [call site] 01097
18 mpsc::channel [function] [call site] 01098
18 Handle::current [function] [call site] 01099
19 scheduler::Handle::current [function] [call site] 01100
18 Self::block_on [function] [call site] 01101
19 Builder::new_current_thread [function] [call site] 01102
19 Builder::enable_all [function] [call site] 01103
19 Configuration::build [function] [call site] 01104
19 Result::unwrap [function] [call site] 01105
19 tokio::runtime::Runtime::handle [function] [call site] 01106
19 &Handle::clone [function] [call site] 01107
19 StreamNotifyClose::new [function] [call site] 01108
19 Notify::new [function] [call site] 01109
19 clone [function] [call site] 01110
19 std::thread::spawn [function] [call site] 01111
19 std::thread::sleep [function] [call site] 01112
19 std::time::Duration::from_millis [function] [call site] 01113
19 block_on [function] [call site] 01114
19 Condvar::notify_one [function] [call site] 01115
19 tokio::runtime::Runtime::block_on [function] [call site] 01116
19 Snapshot::is_notified [function] [call site] 01117
19 Result::join [function] [call site] 01118
19 unwrap [function] [call site] 01119
18 send [function] [call site] 01120
18 unwrap [function] [call site] 01121
18 Handle::current [function] [call site] 01122
18 Self::block_on [function] [call site] 01123
18 recv [function] [call site] 01124
19 recv [function] [call site] 01125
19 &mut [call site] 01126
19 Bytes::copy_from_slice [function] [call site] 01127
18 unwrap [function] [call site] 01128
17 send [function] [call site] 01129
17 unwrap [function] [call site] 01130
17 send [function] [call site] 01131
17 unwrap [function] [call site] 01132
17 ReceiverStream::new [function] [call site] 01133
17 Alternate::poll_next [function] [call site] 01134
17 Alternate::poll_next [function] [call site] 01135
15 NamedTempFile::path [function] [call site] 01136
15 unwrap [function] [call site] 01137
15 NamedTempFile::read [function] [call site] 01138
15 unwrap [function] [call site] 01139
14 NamedTempFile::path [function] [call site] 01140
14 unwrap [function] [call site] 01141
13 write [function] [call site] 01142
13 Configuration::build [function] [call site] 01143
13 write_all [function] [call site] 01144
13 expect [function] [call site] 01145
13 write_all [function] [call site] 01146
13 expect [function] [call site] 01147
12 write [function] [call site] 01148
11 &mut [call site] 01149
11 open_options_truncate [function] [call site] 01150
11 size_hint_stream_open [function] [call site] 01151
12 mpsc::channel [function] [call site] 01152
12 send [function] [call site] 01153
12 unwrap [function] [call site] 01154
12 send [function] [call site] 01155
12 unwrap [function] [call site] 01156
12 ReceiverStream::new [function] [call site] 01157
12 Alternate::poll_next [function] [call site] 01158
12 Alternate::poll_next [function] [call site] 01159
10 NamedTempFile::path [function] [call site] 01160
10 unwrap [function] [call site] 01161
10 File::try_clone [function] [call site] 01162
10 unwrap [function] [call site] 01163
10 RawWaker::write_all [function] [call site] 01164
10 unwrap [function] [call site] 01165
10 RW::poll_flush [function] [call site] 01166
10 unwrap [function] [call site] 01167
10 std::fs::read [function] [call site] 01168
10 NamedTempFile::path [function] [call site] 01169
10 unwrap [function] [call site] 01170
9 to_raw [function] [call site] 01171
10 StreamNotifyClose::new [function] [call site] 01172
11 Some [function] [call site] 01173
10 Inner::into_raw [function] [call site] 01174
11 Inner::into_raw [function] [call site] 01175
8 panic::set_hook [function] [call site] 01176
8 StreamNotifyClose::new [function] [call site] 01177
8 Header::get_spawn_location [function] [call site] 01178
9 Header::get_spawn_location_ptr [function] [call site] 01179
9 NonNull::as_ptr [function] [call site] 01180
8 unwrap [function] [call site] 01181
8 try_lock [function] [call site] 01182
8 clone_from [function] [call site] 01183
8 Some [function] [call site] 01184
8 tempfile [function] [call site] 01185
9 StreamNotifyClose::new [function] [call site] 01186
9 Self::unwrap [function] [call site] 01187
8 read_to_string [function] [call site] 01188
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] 01189
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] 01190
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] 01191
10 std::panic::AssertUnwindSafe [function] [call site] 01192
9 std::panic::AssertUnwindSafe [function] [call site] 01193
8 panic::set_hook [function] [call site] 01194
8 is_err [function] [call site] 01195
8 try_lock [function] [call site] 01196
8 clone [function] [call site] 01197
7 Inner::into_iter [function] [call site] 01198
7 stream::iter [function] [call site] 01199
7 StreamExt::chunks_timeout [function] [call site] 01200
7 Duration::from_secs [function] [call site] 01201
7 Ok [function] [call site] 01202
6 in_scope [function] [call site] 01203
6 semaphore::Semaphore::new [function] [call site] 01204
7 in_scope [function] [call site] 01205
7 AtomicUsize::new [function] [call site] 01206
7 Mutex::new [function] [call site] 01207
7 LinkedList::new [function] [call site] 01208
6 semaphore::Semaphore::new [function] [call site] 01209
6 UnsafeCell::new [function] [call site] 01210
5 Condvar::new [function] [call site] 01211
6 Condvar [function] [call site] 01212
6 parking_lot::Condvar::new [function] [call site] 01213
7 Condvar [function] [call site] 01214
7 parking_lot::Condvar::new [function] [call site] 01215
3 Box::pin [function] [call site] 01216
1 StreamMap::new [function] [call site] 01217
1 iter [function] [call site] 01218
1 copied [function] [call site] 01219
1 enumerate [function] [call site] 01220
1 pin_box [function] [call site] 01221
2 Box::pin [function] [call site] 01222
1 stream::empty::<()> [function] [call site] 01223
1 pin_box [function] [call site] 01224
1 stream::pending::<()> [function] [call site] 01225
1 StreamMap::insert [function] [call site] 01226
1 assert_ready_none [function] [call site] 01227
2 tokio_test::assert_ready [function] [call site] 01228
1 tokio_test::assert_pending [function] [call site] 01229
1 StreamMap::values [function] [call site] 01230
2 StreamMap::iter [function] [call site] 01231
3 iter [function] [call site] 01232
2 StreamExt::map [function] [call site] 01233
3 Map::new [function] [call site] 01234