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
824 372 ThreadWaker::new call site: 00372 Steal::steal_into
287 81 from_raw call site: 00081 Steal::steal_into
57 1199 to_raw call site: 01199 get_or_init
40 40 StreamMap::insert call site: 00040 StaticAtomicU64::fetch_add
25 14 StreamMap::insert call site: 00014 StreamMap::insert
13 0 EP call site: 00000 StreamMap::insert
1 1197 to_raw call site: 01197
1 1259 StreamMap::values call site: 01259

Fuzzer calltree

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