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
892 1134 StreamMap::insert call site: 01134 ServerOptions::create
695 361 ThreadWaker::new call site: 00361 ItemFn::parse
314 43 from_raw call site: 00043 Steal::steal_into
49 1059 to_raw call site: 01059 ItemFn::parse
42 0 EP call site: 00000 Steal::steal_into
18 1115 StreamMap::insert call site: 01115 wake_reader_on_write_outside_lock
4 1109 StreamMap::insert call site: 01109 StreamMap::insert
1 1057 to_raw call site: 01057
1 2029 StreamMap::values call site: 02029

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 Pin<&mut [call site] 00006
3 std::io::Error::from [function] [call site] 00007
4 Steal::steal_into [function] [call site] 00008
5 AtomicU16::unsync_load [function] [call site] 00009
6 core::ptr::read [function] [call site] 00010
7 tempfile [function] [call site] 00011
8 StreamNotifyClose::new [function] [call site] 00012
9 Some [function] [call site] 00013
8 Self::unwrap [function] [call site] 00014
7 NamedTempFile::write_all [function] [call site] 00015
7 WriteAll::unwrap [function] [call site] 00016
7 File::open [function] [call site] 00017
8 File::options [function] [call site] 00018
9 OpenOptions::new [function] [call site] 00019
10 Kind::Uring [function] [call site] 00020
10 UringOpenOptions::new [function] [call site] 00021
10 Kind::Std [function] [call site] 00022
10 StreamNotifyClose::new [function] [call site] 00023
11 Some [function] [call site] 00024
8 OpenOptions::read [function] [call site] 00025
9 read [function] [call site] 00026
10 Builder::new [function] [call site] 00027
11 StreamMap::default [function] [call site] 00028
12 StreamNotifyClose::new [function] [call site] 00029
13 Some [function] [call site] 00030
10 Self::read [function] [call site] 00031
11 tempfile [function] [call site] 00032
11 NamedTempFile::write_all [function] [call site] 00033
11 WriteAll::unwrap [function] [call site] 00034
11 File::open [function] [call site] 00035
11 NamedTempFile::path [function] [call site] 00036
12 syn::Error::new [function] [call site] 00037
13 Some [function] [call site] 00038
12 parse::<syn::Path> [function] [call site] 00039
12 map_err [function] [call site] 00040
12 clone [function] [call site] 00041
13 from_raw [function] [call site] 00042
14 Arc::from_raw [function] [call site] 00043
15 Arc::from_raw [function] [call site] 00044
15 NonNull::as_ptr [function] [call site] 00045
13 mem::forget [function] [call site] 00046
14 StreamNotifyClose::new [function] [call site] 00047
15 Some [function] [call site] 00048
14 Semaphore::new [function] [call site] 00049
15 in_scope [function] [call site] 00050
15 AtomicUsize::new [function] [call site] 00051
16 UnsafeCell::new [function] [call site] 00052
17 UnsafeCell [function] [call site] 00053
17 std::cell::UnsafeCell::new [function] [call site] 00054
18 UnsafeCell [function] [call site] 00055
18 std::cell::UnsafeCell::new [function] [call site] 00056
16 std::sync::atomic::AtomicUsize::new [function] [call site] 00057
17 UnsafeCell::new [function] [call site] 00058
17 std::sync::atomic::AtomicUsize::new [function] [call site] 00059
15 Mutex::new [function] [call site] 00060
16 std::panic::Location::caller [function] [call site] 00061
17 test_panic [function] [call site] 00062
18 wake_reader_on_write_outside_lock [function] [call site] 00063
19 tokio::io::duplex [function] [call site] 00064
20 StreamNotifyClose::new [function] [call site] 00065
20 Mutex::new [function] [call site] 00066
20 SimplexStream::new_unsplit [function] [call site] 00067
21 StreamNotifyClose::new [function] [call site] 00068
22 Some [function] [call site] 00069
20 StreamNotifyClose::new [function] [call site] 00070
20 Mutex::new [function] [call site] 00071
20 SimplexStream::new_unsplit [function] [call site] 00072
20 clone [function] [call site] 00073
20 clone [function] [call site] 00074
19 poll_on_wake [function] [call site] 00075
20 StreamNotifyClose::new [function] [call site] 00076
20 StreamNotifyClose::new [function] [call site] 00077
21 Some [function] [call site] 00078
20 StreamNotifyClose::new [function] [call site] 00079
20 Mutex::new [function] [call site] 00080
20 Box::pin [function] [call site] 00081
20 bool::clone [function] [call site] 00082
21 tempfile [function] [call site] 00083
21 File::create [function] [call site] 00084
22 File::options [function] [call site] 00085
22 OpenOptions::write [function] [call site] 00086
23 write [function] [call site] 00087
24 Builder::new [function] [call site] 00088
24 Self::write [function] [call site] 00089
25 tempfile [function] [call site] 00090
25 File::create [function] [call site] 00091
25 NamedTempFile::path [function] [call site] 00092
25 unwrap [function] [call site] 00093
25 NamedTempFile::write_all [function] [call site] 00094
25 unwrap [function] [call site] 00095
25 RW::poll_flush [function] [call site] 00096
26 Poll::Ready [function] [call site] 00097
26 Ok [function] [call site] 00098
25 unwrap [function] [call site] 00099
25 std::fs::read [function] [call site] 00100
26 tempfile [function] [call site] 00101
26 NamedTempFile::write_all [function] [call site] 00102
26 WriteAll::unwrap [function] [call site] 00103
26 File::open [function] [call site] 00104
26 NamedTempFile::path [function] [call site] 00105
26 unwrap [function] [call site] 00106
26 NamedTempFile::read [function] [call site] 00107
27 tempfile [function] [call site] 00108
27 NamedTempFile::write_all [function] [call site] 00109
27 WriteAll::unwrap [function] [call site] 00110
27 File::open [function] [call site] 00111
27 NamedTempFile::path [function] [call site] 00112
27 unwrap [function] [call site] 00113
27 NamedTempFile::read [function] [call site] 00114
27 unwrap [function] [call site] 00115
26 unwrap [function] [call site] 00116
25 NamedTempFile::path [function] [call site] 00117
25 unwrap [function] [call site] 00118
24 write [function] [call site] 00119
24 Configuration::build [function] [call site] 00120
25 unwrap_or [function] [call site] 00121
25 Err [function] [call site] 00122
25 syn::Error::new [function] [call site] 00123
25 StreamExt::map [function] [call site] 00124
26 Map::new [function] [call site] 00125
25 is_none [function] [call site] 00126
25 Err [function] [call site] 00127
25 syn::Error::new [function] [call site] 00128
25 Span::call_site [function] [call site] 00129
25 Err [function] [call site] 00130
25 syn::Error::new [function] [call site] 00131
25 Some [function] [call site] 00132
25 Err [function] [call site] 00133
25 syn::Error::new [function] [call site] 00134
25 Some [function] [call site] 00135
25 Ok [function] [call site] 00136
25 clone [function] [call site] 00137
25 clone [function] [call site] 00138
24 write_all [function] [call site] 00139
24 expect [function] [call site] 00140
24 write_all [function] [call site] 00141
24 expect [function] [call site] 00142
23 write [function] [call site] 00143
22 &mut [call site] 00144
22 open_options_truncate [function] [call site] 00145
22 open [function] [call site] 00146
23 Op::open [function] [call site] 00147
24 super::utils::cstr [function] [call site] 00148
25 Ok [function] [call site] 00149
25 StreamNotifyClose::new [function] [call site] 00150
26 Some [function] [call site] 00151
25 i32::as_os_str [function] [call site] 00152
25 as_bytes [function] [call site] 00153
24 UringOpenOptions::access_mode [function] [call site] 00154
25 Ok [function] [call site] 00155
25 Ok [function] [call site] 00156
25 Ok [function] [call site] 00157
25 Ok [function] [call site] 00158
25 Ok [function] [call site] 00159
25 Err [function] [call site] 00160
25 io::Error::from_raw_os_error [function] [call site] 00161
24 UringOpenOptions::creation_mode [function] [call site] 00162
25 Err [function] [call site] 00163
25 io::Error::from_raw_os_error [function] [call site] 00164
25 Err [function] [call site] 00165
25 io::Error::from_raw_os_error [function] [call site] 00166
25 Ok [function] [call site] 00167
24 opcode::OpenAt::new [function] [call site] 00168
25 Some [function] [call site] 00169
24 types::Fd [function] [call site] 00170
24 Result::as_ptr [function] [call site] 00171
24 Self::flags [function] [call site] 00172
24 open_options_windows_access_mode [function] [call site] 00173
24 Configuration::build [function] [call site] 00174
24 Op::new [function] [call site] 00175
25 Handle::current [function] [call site] 00176
26 scheduler::Handle::current [function] [call site] 00177
27 scheduler::Handle::current [function] [call site] 00178
25 Some [function] [call site] 00179
25 State::Initialize [function] [call site] 00180
25 Some [function] [call site] 00181
24 Ok [function] [call site] 00182
23 Ok [function] [call site] 00183
23 kind [function] [call site] 00184
23 Err [function] [call site] 00185
21 NamedTempFile::path [function] [call site] 00186
21 unwrap [function] [call site] 00187
21 File::try_clone [function] [call site] 00188
22 wake_reader_on_write_outside_lock [function] [call site] 00189
22 Inner::complete_inflight [function] [call site] 00190
23 poll_fn [function] [call site] 00191
23 Inner::poll_complete_inflight [function] [call site] 00192
24 Inner::poll_flush [function] [call site] 00193
25 take [function] [call site] 00194
25 Poll::Ready [function] [call site] 00195
25 Err [function] [call site] 00196
25 Steal::steal_into [function] [call site] 00197
25 Poll::Ready [function] [call site] 00198
25 Ok [function] [call site] 00199
25 is_err [function] [call site] 00200
25 State::Idle [function] [call site] 00201
25 Some [function] [call site] 00202
25 Buf::with_capacity [function] [call site] 00203
26 Vec::with_capacity [function] [call site] 00204
27 StreamMap::<&str, [call site] 00205
28 StreamMap::<&str, [call site] 00206
25 State::Idle [function] [call site] 00207
25 Some [function] [call site] 00208
25 Poll::Ready [function] [call site] 00209
25 Ok [function] [call site] 00210
25 Poll::Ready [function] [call site] 00211
25 Poll::Ready [function] [call site] 00212
25 Ok [function] [call site] 00213
24 Some [function] [call site] 00214
24 kind [function] [call site] 00215
24 Poll::Ready [function] [call site] 00216
24 Poll::Ready [function] [call site] 00217
22 clone [function] [call site] 00218
22 fs::asyncify [function] [call site] 00219
23 mocks::spawn_blocking [function] [call site] 00220
24 task::spawn_blocking [function] [call site] 00221
25 task::spawn_blocking [function] [call site] 00222
25 unwrap [function] [call site] 00223
24 unwrap [function] [call site] 00224
23 Err [function] [call site] 00225
23 io::Error::other [function] [call site] 00226
24 symmetric [function] [call site] 00227
25 make_socketpair [function] [call site] 00228
26 tokio::net::TcpListener::bind [function] [call site] 00229
27 Harness::get_new_task [function] [call site] 00230
28 Task::from_raw [function] [call site] 00231
29 Task::from_raw [function] [call site] 00232
28 Shared::broadcast [function] [call site] 00233
29 StreamNotifyClose::new [function] [call site] 00234
30 Some [function] [call site] 00235
29 io::Result::to_string [function] [call site] 00236
30 UnboundedReceiverStream::as_ref [function] [call site] 00237
30 &UnboundedReceiver::to_owned [function] [call site] 00238
30 fs::asyncify [function] [call site] 00239
30 std::fs::read_to_string [function] [call site] 00240
31 UnboundedReceiverStream::as_ref [function] [call site] 00241
31 &UnboundedReceiver::to_owned [function] [call site] 00242
31 fs::asyncify [function] [call site] 00243
31 std::fs::read_to_string [function] [call site] 00244
29 iter [function] [call site] 00245
30 Inner::into_iter [function] [call site] 00246
31 Iter [function] [call site] 00247
29 send [function] [call site] 00248
30 PendingOnce::poll_next [function] [call site] 00249
31 Poll::Ready [function] [call site] 00250
31 Some [function] [call site] 00251
31 Pin<&mut [call site] 00252
31 wake_by_ref [function] [call site] 00253
32 from_raw [function] [call site] 00254
32 wake [function] [call site] 00255
33 from_raw [function] [call site] 00256
33 wake [function] [call site] 00257
32 mem::forget [function] [call site] 00258
30 send [function] [call site] 00259
30 Ok [function] [call site] 00260
29 io::Result::clone [function] [call site] 00261
30 tempfile [function] [call site] 00262
30 File::create [function] [call site] 00263
30 NamedTempFile::path [function] [call site] 00264
30 unwrap [function] [call site] 00265
30 File::try_clone [function] [call site] 00266
30 unwrap [function] [call site] 00267
30 RawWaker::write_all [function] [call site] 00268
30 unwrap [function] [call site] 00269
30 RW::poll_flush [function] [call site] 00270
31 Poll::Ready [function] [call site] 00271
31 Ok [function] [call site] 00272
30 unwrap [function] [call site] 00273
30 std::fs::read [function] [call site] 00274
30 NamedTempFile::path [function] [call site] 00275
30 unwrap [function] [call site] 00276
29 Result::is_err [function] [call site] 00277
29 ShardedImpl::push [function] [call site] 00278
30 ShardedImpl::push_shard_index [function] [call site] 00279
31 StaticAtomicU64::fetch_add [function] [call site] 00280
32 StaticAtomicU64::inner [function] [call site] 00281
33 get_or_init [function] [call site] 00282
34 runtime::Builder::new_current_thread [function] [call site] 00283
35 Builder::new [function] [call site] 00284
34 Builder::enable_time [function] [call site] 00285
34 Configuration::set_start_paused [function] [call site] 00286
35 is_some [function] [call site] 00287
35 Err [function] [call site] 00288
35 syn::Error::new [function] [call site] 00289
35 parse_bool [function] [call site] 00290
36 Ok [function] [call site] 00291
36 Err [function] [call site] 00292
36 syn::Error::new [function] [call site] 00293
35 Some [function] [call site] 00294
35 Ok [function] [call site] 00295
34 Configuration::build [function] [call site] 00296
34 unwrap [function] [call site] 00297
34 tokio::runtime::Runtime::block_on [function] [call site] 00298
35 mem::size_of::<F> [function] [call site] 00299
35 Runtime::block_on_inner [function] [call site] 00300
36 super::task::trace::Trace::root [function] [call site] 00301
36 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] 00302
37 std::thread::sleep [function] [call site] 00303
38 tokio::time::sleep [function] [call site] 00304
39 tokio::time::sleep [function] [call site] 00305
39 ms [function] [call site] 00306
40 subsec_nanos [function] [call site] 00307
40 div_ceil [function] [call site] 00308
40 subsec_millis [function] [call site] 00309
40 as_secs [function] [call site] 00310
40 saturating_mul [function] [call site] 00311
40 saturating_add [function] [call site] 00312
40 std::io::Error::from [function] [call site] 00313
41 Steal::steal_into [function] [call site] 00314
38 ms [function] [call site] 00315
37 std::time::Duration::from_micros [function] [call site] 00316
36 crate::runtime::task::Id::next [function] [call site] 00317
37 group_b::complete_block_on_under_load [function] [call site] 00318
38 loom::model [function] [call site] 00319
39 loom::model [function] [call site] 00320
38 mk_pool [function] [call site] 00321
39 runtime::Builder::new_multi_thread [function] [call site] 00322
40 Builder::new [function] [call site] 00323
39 Builder::worker_threads [function] [call site] 00324
40 Some [function] [call site] 00325
39 Builder::event_interval [function] [call site] 00326
39 Configuration::build [function] [call site] 00327
40 unwrap_or [function] [call site] 00328
40 Err [function] [call site] 00329
40 syn::Error::new [function] [call site] 00330
40 StreamExt::map [function] [call site] 00331
40 is_none [function] [call site] 00332
40 Err [function] [call site] 00333
40 syn::Error::new [function] [call site] 00334
40 Span::call_site [function] [call site] 00335
40 Err [function] [call site] 00336
40 syn::Error::new [function] [call site] 00337
40 Some [function] [call site] 00338
40 Err [function] [call site] 00339
40 syn::Error::new [function] [call site] 00340
40 Some [function] [call site] 00341
40 Ok [function] [call site] 00342
40 clone [function] [call site] 00343
40 clone [function] [call site] 00344
39 Result::unwrap [function] [call site] 00345
38 block_on [function] [call site] 00346
39 runtime::Builder::new_current_thread [function] [call site] 00347
39 Builder::enable_all [function] [call site] 00348
40 Builder::enable_io [function] [call site] 00349
40 Builder::enable_io_uring [function] [call site] 00350
40 Builder::enable_time [function] [call site] 00351
39 Configuration::build [function] [call site] 00352
39 Result::unwrap [function] [call site] 00353
39 tokio::runtime::Runtime::block_on [function] [call site] 00354
38 my_custom_runtime::spawn [function] [call site] 00355
39 spawn [function] [call site] 00356
40 MockTask::new [function] [call site] 00357
41 StreamNotifyClose::new [function] [call site] 00358
41 ThreadWaker::new [function] [call site] 00359
42 Mutex::new [function] [call site] 00360
42 Condvar::new [function] [call site] 00361
43 Condvar [function] [call site] 00362
43 parking_lot::Condvar::new [function] [call site] 00363
44 Condvar [function] [call site] 00364
44 parking_lot::Condvar::new [function] [call site] 00365
40 Box::pin [function] [call site] 00366
38 track [function] [call site] 00367
39 StreamNotifyClose::new [function] [call site] 00368
38 task::yield_now [function] [call site] 00369
39 std::future::poll_fn [function] [call site] 00370
39 Poll::Ready [function] [call site] 00371
39 context::defer [function] [call site] 00372
40 Defer [function] [call site] 00373
40 StreamNotifyClose::new [function] [call site] 00374
41 Some [function] [call site] 00375
39 check_drop_replaced_waker [function] [call site] 00376
40 std::io::Error::from [function] [call site] 00377
40 StreamNotifyClose::new [function] [call site] 00378
40 tokio_test::assert_pending [function] [call site] 00379
40 size_hint_stream_closed_permits_drop [function] [call site] 00380
41 mpsc::channel [function] [call site] 00381
42 test_with_runtimes [function] [call site] 00382
43 new_current_thread [function] [call site] 00383
44 tokio::runtime::Builder::new_current_thread [function] [call site] 00384
45 Builder::new [function] [call site] 00385
44 Builder::enable_all [function] [call site] 00386
44 Configuration::build [function] [call site] 00387
44 Result::unwrap [function] [call site] 00388
43 tokio::runtime::Runtime::enter [function] [call site] 00389
44 basic_enter [function] [call site] 00390
45 rt [function] [call site] 00391
46 tokio::runtime::Builder::new_multi_thread [function] [call site] 00392
47 Builder::new [function] [call site] 00393
46 Builder::worker_threads [function] [call site] 00394
46 Configuration::build [function] [call site] 00395
46 Result::unwrap [function] [call site] 00396
45 rt [function] [call site] 00397
45 tokio::runtime::Runtime::enter [function] [call site] 00398
45 tokio::runtime::Runtime::enter [function] [call site] 00399
45 size_hint_stream_closed_permits_drop [function] [call site] 00400
45 size_hint_stream_closed_permits_drop [function] [call site] 00401
43 Filter::get_ref [function] [call site] 00402
43 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00403
44 shutdown [function] [call site] 00404
45 Harness::<T, [call site] 00405
46 Self [function] [call site] 00406
45 Self::shutdown [function] [call site] 00407
46 time::timeout [function] [call site] 00408
47 Inner::into_iter [function] [call site] 00409
47 stream::iter [function] [call site] 00410
48 tokio_stream::iter [function] [call site] 00411
49 tokio_stream::iter [function] [call site] 00412
49 StreamExt::fuse [function] [call site] 00413
50 Fuse::new [function] [call site] 00414
51 Some [function] [call site] 00415
48 StreamExt::fuse [function] [call site] 00416
47 Inner::into_iter [function] [call site] 00417
47 stream::iter [function] [call site] 00418
47 StreamExt::then [function] [call site] 00419
48 Then::new [function] [call site] 00420
47 time::sleep [function] [call site] 00421
48 tokio::time::sleep [function] [call site] 00422
48 ms [function] [call site] 00423
47 Duration::from_secs [function] [call site] 00424
47 StreamExt::map [function] [call site] 00425
48 Map::new [function] [call site] 00426
47 Inner::into_iter [function] [call site] 00427
47 stream::iter [function] [call site] 00428
47 StreamExt::then [function] [call site] 00429
47 time::sleep [function] [call site] 00430
47 Duration::from_secs [function] [call site] 00431
47 StreamExt::map [function] [call site] 00432
47 StreamExt::chain [function] [call site] 00433
48 Chain::new [function] [call site] 00434
49 Fuse::new [function] [call site] 00435
47 StreamExt::chain [function] [call site] 00436
48 Chain::new [function] [call site] 00437
47 StreamExt::chunks_timeout [function] [call site] 00438
48 ChunksTimeout::new [function] [call site] 00439
49 Fuse::new [function] [call site] 00440
49 Vec::with_capacity [function] [call site] 00441
47 Duration::from_secs [function] [call site] 00442
47 my_custom_runtime::spawn [function] [call site] 00443
48 spawn [function] [call site] 00444
47 tokio_test::assert_pending [function] [call site] 00445
47 time::advance [function] [call site] 00446
48 Instant::now [function] [call site] 00447
49 variant::now [function] [call site] 00448
50 crate::time::clock::now [function] [call site] 00449
51 Now [function] [call site] 00450
48 time::advance [function] [call site] 00451
48 Duration::from_millis [function] [call site] 00452
48 my_custom_runtime::spawn [function] [call site] 00453
48 time::sleep_until [function] [call site] 00454
49 Sleep::new_timeout [function] [call site] 00455
50 scheduler::Handle::current [function] [call site] 00456
50 zero_duration_does_not_require_time_driver [function] [call site] 00457
51 tokio::runtime::Builder::new_current_thread [function] [call site] 00458
51 Builder::build [function] [call site] 00459
52 Builder::build_with_handle [function] [call site] 00460
53 Inner::new [function] [call site] 00461
54 mpsc::unbounded_channel [function] [call site] 00462
55 chan::channel [function] [call site] 00463
56 test_with_runtimes [function] [call site] 00464
56 mpsc::channel [function] [call site] 00465
56 Handle::current [function] [call site] 00466
56 Self::block_on [function] [call site] 00467
57 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] 00468
58 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] 00469
58 std::panic::AssertUnwindSafe [function] [call site] 00470
57 std::panic::AssertUnwindSafe [function] [call site] 00471
57 std::thread::Result::expect_err [function] [call site] 00472
57 downcast_ref::<String> [function] [call site] 00473
57 StreamExt::map [function] [call site] 00474
58 Map::new [function] [call site] 00475
57 or_else [function] [call site] 00476
57 downcast_ref::<&str> [function] [call site] 00477
57 copied [function] [call site] 00478
57 unwrap_or [function] [call site] 00479
56 send [function] [call site] 00480
56 unwrap [function] [call site] 00481
56 Handle::current [function] [call site] 00482
56 Self::block_on [function] [call site] 00483
56 recv [function] [call site] 00484
57 recv [function] [call site] 00485
57 &mut [call site] 00486
57 Bytes::copy_from_slice [function] [call site] 00487
56 unwrap [function] [call site] 00488
55 Semaphore [function] [call site] 00489
55 AtomicUsize::new [function] [call site] 00490
55 UnboundedSender::new [function] [call site] 00491
55 UnboundedReceiver::new [function] [call site] 00492
54 UnboundedReceiverStream::new [function] [call site] 00493
53 clone [function] [call site] 00494
53 clone [function] [call site] 00495
51 Mock::unwrap [function] [call site] 00496
51 tokio::runtime::Runtime::block_on [function] [call site] 00497
51 futures::stream::iter [function] [call site] 00498
52 tokio_stream::iter [function] [call site] 00499
52 StreamExt::fuse [function] [call site] 00500
51 StreamExt::throttle [function] [call site] 00501
52 throttle [function] [call site] 00502
51 Duration::from_millis [function] [call site] 00503
50 throttle_can_be_created_outside_runtime [function] [call site] 00504
51 futures::stream::iter [function] [call site] 00505
51 StreamExt::throttle [function] [call site] 00506
51 Duration::from_millis [function] [call site] 00507
50 &'static [call site] 00508
49 trace::caller_location [function] [call site] 00509
48 Duration::from_secs [function] [call site] 00510
48 tokio_test::assert_pending [function] [call site] 00511
48 Instant::now [function] [call site] 00512
48 Duration::from_micros [function] [call site] 00513
48 time::advance [function] [call site] 00514
48 tokio_test::assert_pending [function] [call site] 00515
47 Duration::from_secs [function] [call site] 00516
47 tokio_test::assert_pending [function] [call site] 00517
47 time::advance [function] [call site] 00518
47 Duration::from_secs [function] [call site] 00519
46 Duration::from_secs [function] [call site] 00520
46 std::io::Result::write_all [function] [call site] 00521
44 shutdown [function] [call site] 00522
44 Some [function] [call site] 00523
43 Duration::from_secs [function] [call site] 00524
43 Filter::get_ref [function] [call site] 00525
43 new_multi_thread [function] [call site] 00526
44 tokio::runtime::Builder::new_multi_thread [function] [call site] 00527
44 Builder::worker_threads [function] [call site] 00528
44 Builder::enable_all [function] [call site] 00529
45 Builder::enable_io [function] [call site] 00530
45 Builder::enable_io_uring [function] [call site] 00531
45 Builder::enable_time [function] [call site] 00532
44 Configuration::build [function] [call site] 00533
44 Result::unwrap [function] [call site] 00534
43 tokio::runtime::Runtime::enter [function] [call site] 00535
43 Filter::get_ref [function] [call site] 00536
43 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00537
43 Duration::from_secs [function] [call site] 00538
43 Filter::get_ref [function] [call site] 00539
43 new_multi_thread [function] [call site] 00540
43 tokio::runtime::Runtime::enter [function] [call site] 00541
43 Filter::get_ref [function] [call site] 00542
43 tokio::runtime::Runtime::shutdown_timeout [function] [call site] 00543
43 Duration::from_secs [function] [call site] 00544
43 Filter::get_ref [function] [call site] 00545
42 mpsc::channel [function] [call site] 00546
42 Handle::current [function] [call site] 00547
42 Self::block_on [function] [call site] 00548
42 send [function] [call site] 00549
42 unwrap [function] [call site] 00550
42 Handle::current [function] [call site] 00551
42 Self::block_on [function] [call site] 00552
42 recv [function] [call site] 00553
42 unwrap [function] [call site] 00554
41 send [function] [call site] 00555
41 unwrap [function] [call site] 00556
41 VecWithInitialized::reserve [function] [call site] 00557
42 UnboundedReceiverStream::as_mut [function] [call site] 00558
42 with_capacity [function] [call site] 00559
43 StreamMap::<&str, [call site] 00560
42 len [function] [call site] 00561
43 wrapping_sub [function] [call site] 00562
42 len [function] [call site] 00563
42 VecWithInitialized::reserve [function] [call site] 00564
41 unwrap [function] [call site] 00565
41 VecWithInitialized::reserve [function] [call site] 00566
41 unwrap [function] [call site] 00567
41 ReceiverStream::new [function] [call site] 00568
41 UnboundedReceiverStream::close [function] [call site] 00569
42 UnboundedReceiverStream::close [function] [call site] 00570
41 size_hint_stream_closed_permits_drop [function] [call site] 00571
41 PendingOnce::poll_next [function] [call site] 00572
42 Poll::Ready [function] [call site] 00573
42 Some [function] [call site] 00574
42 Pin<&mut [call site] 00575
42 wake_by_ref [function] [call site] 00576
41 size_hint_stream_closed_permits_drop [function] [call site] 00577
40 Context::from_waker [function] [call site] 00578
40 futures::task::noop_waker_ref [function] [call site] 00579
40 tokio_test::assert_pending [function] [call site] 00580
40 tokio_test::assert_ready [function] [call site] 00581
38 gated2 [function] [call site] 00582
39 StreamNotifyClose::new [function] [call site] 00583
39 StreamNotifyClose::new [function] [call site] 00584
39 std::future::poll_fn [function] [call site] 00585
39 clone [function] [call site] 00586
39 check_drop_replaced_waker [function] [call site] 00587
39 clone [function] [call site] 00588
39 my_custom_runtime::spawn [function] [call site] 00589
40 spawn [function] [call site] 00590
39 AtomicU64::store [function] [call site] 00591
40 wake_reader_on_write_outside_lock [function] [call site] 00592
39 wake_by_ref [function] [call site] 00593
39 spawn [function] [call site] 00594
39 track [function] [call site] 00595
39 AtomicU64::store [function] [call site] 00596
39 wake_by_ref [function] [call site] 00597
39 group_b::complete_block_on_under_load [function] [call site] 00598
39 Poll::Ready [function] [call site] 00599
37 Instant::checked_add [function] [call site] 00600
38 Instant::checked_add [function] [call site] 00601
38 StreamExt::map [function] [call site] 00602
37 exhausted [function] [call site] 00603
37 StaticAtomicU64::compare_exchange_weak [function] [call site] 00604
38 StaticAtomicU64::inner [function] [call site] 00605
38 &Mutex::lock [function] [call site] 00606
39 tokio::io::duplex [function] [call site] 00607
39 poll_on_wake [function] [call site] 00608
38 Ok [function] [call site] 00609
38 Err [function] [call site] 00610
37 ThreadId [function] [call site] 00611
37 StreamNotifyClose::new [function] [call site] 00612
38 Some [function] [call site] 00613
37 Self::unwrap [function] [call site] 00614
36 Id::as_u64 [function] [call site] 00615
37 test_iter_coop_budget [function] [call site] 00616
38 my_custom_runtime::spawn [function] [call site] 00617
38 stream::iter [function] [call site] 00618
38 iter::repeat [function] [call site] 00619
39 LinesCodec::new_with_max_length [function] [call site] 00620
40 LinesCodec::new [function] [call site] 00621
39 StreamNotifyClose::new [function] [call site] 00622
39 VecWithInitialized::reserve [function] [call site] 00623
39 ReadBuf::put_slice [function] [call site] 00624
40 len [function] [call site] 00625
40 as_mut_ptr [function] [call site] 00626
40 buf[self.filled..end] [call site] 00627
8 .as_mut_ptr() [call site] 00628
8 .cast::<u8> [function] [call site] 00629
40 copy_from_nonoverlapping [function] [call site] 00630
40 as_ptr [function] [call site] 00631
39 ReadBuf::put_slice [function] [call site] 00632
38 poll_next [function] [call site] 00633
39 Interval::enter [function] [call site] 00634
40 rt [function] [call site] 00635
40 rt [function] [call site] 00636
40 tokio::runtime::Runtime::enter [function] [call site] 00637
40 tokio::runtime::Runtime::enter [function] [call site] 00638
40 size_hint_stream_closed_permits_drop [function] [call site] 00639
40 size_hint_stream_closed_permits_drop [function] [call site] 00640
39 Interval::poll_tick [function] [call site] 00641
40 completed_future_past_deadline [function] [call site] 00642
41 my_custom_runtime::spawn [function] [call site] 00643
41 tokio::time::timeout_at [function] [call site] 00644
42 select_into_future [function] [call site] 00645
42 Some [function] [call site] 00646
42 Sleep::new_timeout [function] [call site] 00647
42 trace::caller_location [function] [call site] 00648
41 Instant::now [function] [call site] 00649
41 ms [function] [call site] 00650
41 assert_ready_ok [function] [call site] 00651
42 assert_ready [function] [call site] 00652
42 assert_ok [function] [call site] 00653
40 Instant::now [function] [call site] 00654
40 Duration::from_millis [function] [call site] 00655
40 MissedTickBehavior::next_timeout [function] [call site] 00656
41 Duration::from_nanos [function] [call site] 00657
41 as_nanos [function] [call site] 00658
41 Duration::as_nanos [function] [call site] 00659
41 ChildStdin::try_into [function] [call site] 00660
42 ChildStdio::into_stdio [function] [call site] 00661
43 convert_to_file [function] [call site] 00662
44 size_hint_stream_closed_permits_drop [function] [call site] 00663
44 Arc::try_unwrap [function] [call site] 00664
44 or_else [function] [call site] 00665
44 duplicate_handle [function] [call site] 00666
45 GetCurrentProcess [function] [call site] 00667
45 windows_sys:: [call site] 00668
0 Win32::Foundation::DuplicateHandle [function] [call site] 00669
45 NamedPipeServer::as_raw_handle [function] [call site] 00670
46 NamedPipeServer::as_raw_handle [function] [call site] 00671
47 NamedPipeServer::as_raw_handle [function] [call site] 00672
45 Err [function] [call site] 00673
45 io::Error::last_os_error [function] [call site] 00674
45 Ok [function] [call site] 00675
45 NamedPipeServer::from_raw_handle [function] [call site] 00676
46 mio_windows::NamedPipe::from_raw_handle [function] [call site] 00677
47 mio_windows::NamedPipe::from_raw_handle [function] [call site] 00678
47 Ok [function] [call site] 00679
47 PollEvented::new [function] [call site] 00680
48 PollEvented::new_with_interest [function] [call site] 00681
49 PollEvented::new_with_interest_and_handle [function] [call site] 00682
50 Registration::new_with_interest_and_handle [function] [call site] 00683
51 zero_duration_does_not_require_time_driver [function] [call site] 00684
51 std::io [function] [call site] 00685
52 Builder::new_current_thread [function] [call site] 00686
53 Builder::new [function] [call site] 00687
52 Builder::build [function] [call site] 00688
52 Mock::unwrap [function] [call site] 00689
51 Handle::add_source [function] [call site] 00690
52 RegistrationSet::allocate [function] [call site] 00691
53 Err [function] [call site] 00692
53 io::Error::other [function] [call site] 00693
53 StreamNotifyClose::new [function] [call site] 00694
53 ScheduledIo::default [function] [call site] 00695
54 UnsafeCell::new [function] [call site] 00696
54 linked_list::Pointers::new [function] [call site] 00697
55 UnsafeCell::new [function] [call site] 00698
54 AtomicUsize::new [function] [call site] 00699
54 Mutex::new [function] [call site] 00700
54 StreamMap::default [function] [call site] 00701
55 StreamNotifyClose::new [function] [call site] 00702
53 WakeQueue::push_front [function] [call site] 00703
54 WakeQueue::push_front [function] [call site] 00704
53 Self::clone [function] [call site] 00705
54 tempfile [function] [call site] 00706
54 File::create [function] [call site] 00707
54 NamedTempFile::path [function] [call site] 00708
54 unwrap [function] [call site] 00709
54 File::try_clone [function] [call site] 00710
54 unwrap [function] [call site] 00711
54 RawWaker::write_all [function] [call site] 00712
54 unwrap [function] [call site] 00713
54 RW::poll_flush [function] [call site] 00714
54 unwrap [function] [call site] 00715
54 std::fs::read [function] [call site] 00716
54 NamedTempFile::path [function] [call site] 00717
54 unwrap [function] [call site] 00718
53 Ok [function] [call site] 00719
52 wake_reader_on_write_outside_lock [function] [call site] 00720
52 ScheduledIo::token [function] [call site] 00721
53 mio::Token [function] [call site] 00722
53 PtrExposeDomain::expose_provenance [function] [call site] 00723
54 NonNull::addr [function] [call site] 00724
55 ItemFn::parse [function] [call site] 00725
56 delegate_call [function] [call site] 00726
57 get_unchecked_mut [function] [call site] 00727
57 Pin::new_unchecked [function] [call site] 00728
57 Pin::new_unchecked [function] [call site] 00729
56 ItemFn::parse [function] [call site] 00730
57 delegate_call [function] [call site] 00731
57 ItemFn::parse [function] [call site] 00732
57 ItemFn::parse [function] [call site] 00733
57 Attribute::parse_inner [function] [call site] 00734
57 proc_macro2::TokenStream::new [function] [call site] 00735
58 Some [function] [call site] 00736
57 StreamNotifyClose::new [function] [call site] 00737
57 StreamMap::is_empty [function] [call site] 00738
58 StreamMap::is_empty [function] [call site] 00739
57 parse::<Option<syn::Token![;]>> [function] [call site] 00740
57 UnhandledPanic::into_tokens [function] [call site] 00741
57 ShardedImpl::push [function] [call site] 00742
57 proc_macro2::TokenStream::new [function] [call site] 00743
57 extend [function] [call site] 00744
58 StreamExt::map [function] [call site] 00745
58 StreamExt::collect [function] [call site] 00746
59 Collect::new [function] [call site] 00747
60 size_hint [function] [call site] 00748
61 futures::stream::iter [function] [call site] 00749
61 StreamExt::throttle [function] [call site] 00750
61 Duration::from_secs [function] [call site] 00751
60 ()::initialize [function] [call site] 00752
58 extend [function] [call site] 00753
58 StreamExt::map [function] [call site] 00754
58 try_join_next [function] [call site] 00755
59 tokio::sync::watch::channel [function] [call site] 00756
60 test_with_runtimes [function] [call site] 00757
60 mpsc::channel [function] [call site] 00758
60 Handle::current [function] [call site] 00759
60 Self::block_on [function] [call site] 00760
60 send [function] [call site] 00761
60 unwrap [function] [call site] 00762
60 Handle::current [function] [call site] 00763
60 Self::block_on [function] [call site] 00764
60 recv [function] [call site] 00765
60 unwrap [function] [call site] 00766
59 JoinSet::new [function] [call site] 00767
60 IdleNotifiedSet::new [function] [call site] 00768
61 Mutex::new [function] [call site] 00769
61 LinkedList::new [function] [call site] 00770
61 LinkedList::new [function] [call site] 00771
61 StreamNotifyClose::new [function] [call site] 00772
59 Result::clone [function] [call site] 00773
60 tempfile [function] [call site] 00774
60 File::create [function] [call site] 00775
60 NamedTempFile::path [function] [call site] 00776
60 unwrap [function] [call site] 00777
60 File::try_clone [function] [call site] 00778
60 unwrap [function] [call site] 00779
60 RawWaker::write_all [function] [call site] 00780
60 unwrap [function] [call site] 00781
60 RW::poll_flush [function] [call site] 00782
60 unwrap [function] [call site] 00783
60 std::fs::read [function] [call site] 00784
60 NamedTempFile::path [function] [call site] 00785
60 unwrap [function] [call site] 00786
59 spawn [function] [call site] 00787
59 Result::changed [function] [call site] 00788
60 watch::channel [function] [call site] 00789
61 test_with_runtimes [function] [call site] 00790
61 mpsc::channel [function] [call site] 00791
61 Handle::current [function] [call site] 00792
61 Self::block_on [function] [call site] 00793
61 send [function] [call site] 00794
61 unwrap [function] [call site] 00795
61 Handle::current [function] [call site] 00796
61 Self::block_on [function] [call site] 00797
61 recv [function] [call site] 00798
61 unwrap [function] [call site] 00799
60 clone [function] [call site] 00800
60 clone [function] [call site] 00801
60 clone [function] [call site] 00802
60 rx_mark_changed [function] [call site] 00803
61 watch::channel [function] [call site] 00804
61 clone [function] [call site] 00805
61 clone [function] [call site] 00806
61 clone [function] [call site] 00807
61 rx_mark_changed [function] [call site] 00808
61 tokio_test::task::spawn [function] [call site] 00809
62 spawn [function] [call site] 00810
61 rx_mark_changed [function] [call site] 00811
62 watch::channel [function] [call site] 00812
62 clone [function] [call site] 00813
62 clone [function] [call site] 00814
62 clone [function] [call site] 00815
62 rx_mark_changed [function] [call site] 00816
62 tokio_test::task::spawn [function] [call site] 00817
62 rx_mark_changed [function] [call site] 00818
62 tokio_test::assert_ready_ok [function] [call site] 00819
63 assert_ready [function] [call site] 00820
63 assert_ok [function] [call site] 00821
62 tokio_test::task::spawn [function] [call site] 00822
62 RawWaker::changed [function] [call site] 00823
63 watch::channel [function] [call site] 00824
63 clone [function] [call site] 00825
63 clone [function] [call site] 00826
63 clone [function] [call site] 00827
63 rx_mark_changed [function] [call site] 00828
63 tokio_test::task::spawn [function] [call site] 00829
63 rx_mark_changed [function] [call site] 00830
63 tokio_test::assert_ready_ok [function] [call site] 00831
63 tokio_test::task::spawn [function] [call site] 00832
63 RawWaker::changed [function] [call site] 00833
63 assert_pending [function] [call site] 00834
63 RawWaker::mark_changed [function] [call site] 00835
64 watch::channel [function] [call site] 00836
64 clone [function] [call site] 00837
64 clone [function] [call site] 00838
64 clone [function] [call site] 00839
64 rx_mark_changed [function] [call site] 00840
64 tokio_test::task::spawn [function] [call site] 00841
64 rx_mark_changed [function] [call site] 00842
64 tokio_test::assert_ready_ok [function] [call site] 00843
64 tokio_test::task::spawn [function] [call site] 00844
64 RawWaker::changed [function] [call site] 00845
64 assert_pending [function] [call site] 00846
64 RawWaker::mark_changed [function] [call site] 00847
64 tokio_test::task::spawn [function] [call site] 00848
64 RawWaker::changed [function] [call site] 00849
64 assert_pending [function] [call site] 00850
64 send [function] [call site] 00851
64 Result::unwrap [function] [call site] 00852
64 RawWaker::mark_changed [function] [call site] 00853
63 tokio_test::task::spawn [function] [call site] 00854
63 RawWaker::changed [function] [call site] 00855
63 assert_pending [function] [call site] 00856
63 send [function] [call site] 00857
63 Result::unwrap [function] [call site] 00858
63 RawWaker::mark_changed [function] [call site] 00859
62 assert_pending [function] [call site] 00860
62 RawWaker::mark_changed [function] [call site] 00861
62 tokio_test::task::spawn [function] [call site] 00862
62 RawWaker::changed [function] [call site] 00863
62 assert_pending [function] [call site] 00864
62 send [function] [call site] 00865
62 Result::unwrap [function] [call site] 00866
62 RawWaker::mark_changed [function] [call site] 00867
61 tokio_test::assert_ready_ok [function] [call site] 00868
61 tokio_test::task::spawn [function] [call site] 00869
61 RawWaker::changed [function] [call site] 00870
61 assert_pending [function] [call site] 00871
61 RawWaker::mark_changed [function] [call site] 00872
61 tokio_test::task::spawn [function] [call site] 00873
61 RawWaker::changed [function] [call site] 00874
61 assert_pending [function] [call site] 00875
61 send [function] [call site] 00876
61 Result::unwrap [function] [call site] 00877
61 RawWaker::mark_changed [function] [call site] 00878
60 tokio_test::task::spawn [function] [call site] 00879
60 rx_mark_changed [function] [call site] 00880
60 tokio_test::assert_ready_ok [function] [call site] 00881
60 tokio_test::task::spawn [function] [call site] 00882
60 RawWaker::changed [function] [call site] 00883
60 assert_pending [function] [call site] 00884
60 RawWaker::mark_changed [function] [call site] 00885
60 tokio_test::task::spawn [function] [call site] 00886
60 RawWaker::changed [function] [call site] 00887
60 assert_pending [function] [call site] 00888
60 send [function] [call site] 00889
60 Result::unwrap [function] [call site] 00890
60 RawWaker::mark_changed [function] [call site] 00891
59 unwrap [function] [call site] 00892
59 size_hint_stream_closed_permits_drop [function] [call site] 00893
59 Sender::send_replace [function] [call site] 00894
60 Sender::send_modify [function] [call site] 00895
61 Sender::send_if_modified [function] [call site] 00896
62 write [function] [call site] 00897
62 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] 00898
63 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] 00899
63 std::panic::AssertUnwindSafe [function] [call site] 00900
62 panic::AssertUnwindSafe [function] [call site] 00901
62 Sender::send_modify [function] [call site] 00902
63 Sender::send_if_modified [function] [call site] 00903
63 Sender::send_modify [function] [call site] 00904
62 size_hint_stream_closed_permits_drop [function] [call site] 00905
62 panic::resume_unwind [function] [call site] 00906
62 increment_version_while_locked [function] [call site] 00907
62 size_hint_stream_closed_permits_drop [function] [call site] 00908
62 notify_waiters [function] [call site] 00909
63 rt [function] [call site] 00910
63 StreamNotifyClose::new [function] [call site] 00911
63 Notify::new [function] [call site] 00912
64 AtomicUsize::new [function] [call site] 00913
64 Mutex::new [function] [call site] 00914
64 LinkedList::new [function] [call site] 00915
63 StreamNotifyClose::new [function] [call site] 00916
63 AtomicUsize::new [function] [call site] 00917
63 tokio::runtime::Runtime::spawn [function] [call site] 00918
64 OwnedTasks::bind [function] [call site] 00919
65 Harness::get_new_task [function] [call site] 00920
65 OwnedTasks::bind_inner [function] [call site] 00921
66 Harness::header [function] [call site] 00922
67 Harness::header_ptr [function] [call site] 00923
68 Shared::broadcast [function] [call site] 00924
67 NonNull::as_ptr [function] [call site] 00925
66 Header::set_owner_id [function] [call site] 00926
67 CoreStage::with_mut [function] [call site] 00927
68 CoreStage::with_mut [function] [call site] 00928
67 Some [function] [call site] 00929
66 ShardedList::lock_shard [function] [call site] 00930
67 Task::get_shard_id [function] [call site] 00931
68 Header::get_id [function] [call site] 00932
69 Header::get_id_ptr [function] [call site] 00933
70 UnboundedReceiverStream::as_ref [function] [call site] 00934
70 as_ptr [function] [call site] 00935
70 as_ptr().cast::<u8> [function] [call site] 00936
70 Interest::add [function] [call site] 00937
71 Self [function] [call site] 00938
70 as_ptr().cast::<u8>().add(offset).cast::<Id> [function] [call site] 00939
70 NonNull::new_unchecked [function] [call site] 00940
69 NonNull::as_ptr [function] [call site] 00941
68 test_iter_coop_budget [function] [call site] 00942
67 Waiter::as_raw [function] [call site] 00943
67 ShardedList::shard_inner [function] [call site] 00944
68 SetOnce::get_unchecked [function] [call site] 00945
69 with [function] [call site] 00946
70 Runtime [function] [call site] 00947
70 StreamNotifyClose::new [function] [call site] 00948
70 OwnedTasks::new [function] [call site] 00949
71 OwnedTasks::gen_sharded_list_size [function] [call site] 00950
72 usize::min [function] [call site] 00951
72 usize::next_power_of_two [function] [call site] 00952
71 ShardedList::new [function] [call site] 00953
72 std::iter::repeat_with [function] [call site] 00954
72 Mutex::new [function] [call site] 00955
72 LinkedList::new [function] [call site] 00956
72 take [function] [call site] 00957
72 StreamExt::collect [function] [call site] 00958
72 StreamNotifyClose::new [function] [call site] 00959
73 Some [function] [call site] 00960
72 MetricAtomicUsize::new [function] [call site] 00961
73 AtomicUsize::new [function] [call site] 00962
71 StreamNotifyClose::new [function] [call site] 00963
71 get_next_id [function] [call site] 00964
70 Mutex::new [function] [call site] 00965
70 StreamNotifyClose::new [function] [call site] 00966
71 Some [function] [call site] 00967
70 try_lock [function] [call site] 00968
71 Mutex::new [function] [call site] 00969
71 try_lock [function] [call site] 00970
71 try_lock [function] [call site] 00971
71 try_lock [function] [call site] 00972
70 unwrap [function] [call site] 00973
70 Some [function] [call site] 00974
70 tokio::runtime::Runtime::clone [function] [call site] 00975
71 tempfile [function] [call site] 00976
71 File::create [function] [call site] 00977
71 NamedTempFile::path [function] [call site] 00978
71 unwrap [function] [call site] 00979
71 File::try_clone [function] [call site] 00980
71 unwrap [function] [call site] 00981
71 RawWaker::write_all [function] [call site] 00982
71 unwrap [function] [call site] 00983
71 RW::poll_flush [function] [call site] 00984
71 unwrap [function] [call site] 00985
71 std::fs::read [function] [call site] 00986
71 NamedTempFile::path [function] [call site] 00987
71 unwrap [function] [call site] 00988
69 as_ptr [function] [call site] 00989
68 wake_reader_on_write_outside_lock [function] [call site] 00990
66 group_b::complete_block_on_under_load [function] [call site] 00991
66 size_hint_stream_closed_permits_drop [function] [call site] 00992
66 shutdown [function] [call site] 00993
66 ShardGuard::push [function] [call site] 00994
67 Task::get_shard_id [function] [call site] 00995
67 Waiter::as_raw [function] [call site] 00996
67 WakeQueue::push_front [function] [call site] 00997
67 Interest::add [function] [call site] 00998
67 MetricAtomicUsize::increment [function] [call site] 00999
68 StaticAtomicU64::fetch_add [function] [call site] 01000
66 Some [function] [call site] 01001
64 Runtime::clone [function] [call site] 01002
65 tempfile [function] [call site] 01003
65 File::create [function] [call site] 01004
65 NamedTempFile::path [function] [call site] 01005
65 unwrap [function] [call site] 01006
65 File::try_clone [function] [call site] 01007
65 unwrap [function] [call site] 01008
65 RawWaker::write_all [function] [call site] 01009
65 unwrap [function] [call site] 01010
65 RW::poll_flush [function] [call site] 01011
65 unwrap [function] [call site] 01012
65 std::fs::read [function] [call site] 01013
65 NamedTempFile::path [function] [call site] 01014
65 unwrap [function] [call site] 01015
64 Id::next [function] [call site] 01016
65 StaticAtomicU64::fetch_add [function] [call site] 01017
65 StreamNotifyClose::new [function] [call site] 01018
65 Self [function] [call site] 01019
64 SpawnLocation::capture [function] [call site] 01020
65 std::io::Error::from [function] [call site] 01021
66 Steal::steal_into [function] [call site] 01022
65 Location::caller [function] [call site] 01023
66 test_panic [function] [call site] 01024
66 Inner::into_iter [function] [call site] 01025
66 stream::iter [function] [call site] 01026
66 StreamExt::chunks_timeout [function] [call site] 01027
67 ChunksTimeout::new [function] [call site] 01028
66 Duration::from_secs [function] [call site] 01029
66 Ok [function] [call site] 01030
64 Runtime::schedule [function] [call site] 01031
65 try_lock [function] [call site] 01032
65 unwrap [function] [call site] 01033
65 LocalState::task_push_back [function] [call site] 01034
66 LocalState::assert_called_from_owner_thread [function] [call site] 01035
66 CoreStage::with_mut [function] [call site] 01036
66 LocalState::task_push_back [function] [call site] 01037
63 clone [function] [call site] 01038
63 clone [function] [call site] 01039
63 Snapshot::is_notified [function] [call site] 01040
63 StaticAtomicU64::fetch_add [function] [call site] 01041
63 bench_function [function] [call site] 01042
63 read_to_string [function] [call site] 01043
64 UnboundedReceiverStream::as_ref [function] [call site] 01044
64 &UnboundedReceiver::to_owned [function] [call site] 01045
64 fs::asyncify [function] [call site] 01046
64 std::fs::read_to_string [function] [call site] 01047
63 iter [function] [call site] 01048
63 AtomicU64::store [function] [call site] 01049
63 notify_waiters [function] [call site] 01050
63 group_b::complete_block_on_under_load [function] [call site] 01051
61 Sender::send_modify [function] [call site] 01052
60 AtomicCell::swap [function] [call site] 01053
61 AtomicCell::swap [function] [call site] 01054
62 AtomicCell::swap [function] [call site] 01055
62 to_raw [function] [call site] 01056
63 StreamNotifyClose::new [function] [call site] 01057
64 Some [function] [call site] 01058
63 Inner::into_raw [function] [call site] 01059
64 Inner::into_raw [function] [call site] 01060
62 from_raw [function] [call site] 01061
61 to_raw [function] [call site] 01062
61 from_raw [function] [call site] 01063
59 Result::closed [function] [call site] 01064
60 mpsc::channel [function] [call site] 01065
60 send [function] [call site] 01066
60 unwrap [function] [call site] 01067
60 send [function] [call site] 01068
60 unwrap [function] [call site] 01069
60 ReceiverStream::new [function] [call site] 01070
60 UnboundedReceiverStream::close [function] [call site] 01071
60 PendingOnce::poll_next [function] [call site] 01072
60 PendingOnce::poll_next [function] [call site] 01073
59 try_join_next [function] [call site] 01074
60 tokio::sync::watch::channel [function] [call site] 01075
60 JoinSet::new [function] [call site] 01076
60 Result::clone [function] [call site] 01077
60 spawn [function] [call site] 01078
60 Result::changed [function] [call site] 01079
60 unwrap [function] [call site] 01080
60 size_hint_stream_closed_permits_drop [function] [call site] 01081
60 Sender::send_replace [function] [call site] 01082
60 Result::closed [function] [call site] 01083
60 try_join_next [function] [call site] 01084
58 unwrap [function] [call site] 01085
57 parse::<TokenTree> [function] [call site] 01086
57 StreamMap::is_empty [function] [call site] 01087
57 ShardedImpl::push [function] [call site] 01088
57 Ok [function] [call site] 01089
56 ItemFn::parse [function] [call site] 01090
56 Attribute::parse_inner [function] [call site] 01091
56 proc_macro2::TokenStream::new [function] [call site] 01092
56 StreamNotifyClose::new [function] [call site] 01093
56 StreamMap::is_empty [function] [call site] 01094
56 parse::<Option<syn::Token![;]>> [function] [call site] 01095
56 UnhandledPanic::into_tokens [function] [call site] 01096
56 ShardedImpl::push [function] [call site] 01097
56 proc_macro2::TokenStream::new [function] [call site] 01098
56 extend [function] [call site] 01099
56 parse::<TokenTree> [function] [call site] 01100
56 StreamMap::is_empty [function] [call site] 01101
56 ShardedImpl::push [function] [call site] 01102
56 Ok [function] [call site] 01103
55 syn::Result::unwrap [function] [call site] 01104
55 tokio_test::assert_ok [function] [call site] 01105
55 await).collect::<Vec<_>> [function] [call site] 01106
54 wake_reader_on_write_outside_lock [function] [call site] 01107
54 StreamMap::insert [function] [call site] 01108
55 StreamMap::remove [function] [call site] 01109
56 len [function] [call site] 01110
56 contains_key_borrow [function] [call site] 01111
57 StreamMap::new [function] [call site] 01112
57 StreamMap::insert [function] [call site] 01113
58 StreamMap::remove [function] [call site] 01114
58 ShardedImpl::push [function] [call site] 01115
59 ShardedImpl::push_shard_index [function] [call site] 01116
59 wake_reader_on_write_outside_lock [function] [call site] 01117
59 Err [function] [call site] 01118
59 LocalState::task_push_back [function] [call site] 01119
59 SpawnerMetrics::inc_queue_depth [function] [call site] 01120
60 MetricAtomicUsize::increment [function] [call site] 01121
59 len [function] [call site] 01122
59 AtomicU64::fetch_or [function] [call site] 01123
60 wake_reader_on_write_outside_lock [function] [call site] 01124
59 Ok [function] [call site] 01125
57 &str::to_string [function] [call site] 01126
58 UnboundedReceiverStream::as_ref [function] [call site] 01127
58 &UnboundedReceiver::to_owned [function] [call site] 01128
58 fs::asyncify [function] [call site] 01129
58 std::fs::read_to_string [function] [call site] 01130
57 pending::<()> [function] [call site] 01131
56 Some [function] [call site] 01132
56 swap_remove [function] [call site] 01133
55 ShardedImpl::push [function] [call site] 01134
52 reregister [function] [call site] 01135
53 socketpair [function] [call site] 01136
54 socket::socketpair [function] [call site] 01137
55 socket::socketpair [function] [call site] 01138
55 SockFlag::empty [function] [call site] 01139
56 tokio_stream::empty::<i32> [function] [call site] 01140
56 throttle [function] [call site] 01141
56 Duration::from_millis [function] [call site] 01142
55 (FileDescriptor, [call site] 01143
55 set_nonblocking [function] [call site] 01144
56 FileDescriptor::as_raw_fd [function] [call site] 01145
57 FileDescriptor::as_raw_fd [function] [call site] 01146
56 libc::fcntl [function] [call site] 01147
56 Err [function] [call site] 01148
56 io::Error::last_os_error [function] [call site] 01149
56 libc::fcntl [function] [call site] 01150
56 Err [function] [call site] 01151
56 io::Error::last_os_error [function] [call site] 01152
56 Ok [function] [call site] 01153
55 set_nonblocking [function] [call site] 01154
54 SockFlag::empty [function] [call site] 01155
54 (FileDescriptor, [call site] 01156
54 set_nonblocking [function] [call site] 01157
54 set_nonblocking [function] [call site] 01158
53 AsyncFd::register [function] [call site] 01159
54 AsyncFd::register_with_interest [function] [call site] 01160
55 FileDescriptor::as_raw_fd [function] [call site] 01161
55 Registration::new_with_interest_and_handle [function] [call site] 01162
55 mio::unix::SourceFd [function] [call site] 01163
55 scheduler::Handle::current [function] [call site] 01164
55 Ok [function] [call site] 01165
55 Some [function] [call site] 01166
55 Err [function] [call site] 01167
53 unwrap [function] [call site] 01168
53 into_inner [function] [call site] 01169
54 RwLock::new [function] [call site] 01170
55 std::panic::Location::caller [function] [call site] 01171
55 in_scope [function] [call site] 01172
55 in_scope [function] [call site] 01173
55 Semaphore::new [function] [call site] 01174
55 Semaphore::new [function] [call site] 01175
55 UnsafeCell::new [function] [call site] 01176
53 AsyncFd::register [function] [call site] 01177
53 unwrap [function] [call site] 01178
52 Interest::to_mio [function] [call site] 01179
53 Interest::is_readable [function] [call site] 01180
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01181
54 Some [function] [call site] 01182
53 Interest::is_writable [function] [call site] 01183
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01184
53 Interest::is_priority [function] [call site] 01185
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01186
53 Interest::is_aio [function] [call site] 01187
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01188
53 Interest::is_lio [function] [call site] 01189
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01190
53 Interest::is_error [function] [call site] 01191
53 I::n::t::e::r::e::s::t::::::::t::o::_::m::i::o::mio_add [function] [call site] 01192
53 mio::Interest::unwrap_or [function] [call site] 01193
52 remove [function] [call site] 01194
53 tempfile::tempdir [function] [call site] 01195
54 tempfile::tempdir [function] [call site] 01196
54 tempfile::TempDir::unwrap [function] [call site] 01197
53 tempfile::TempDir::unwrap [function] [call site] 01198
53 parse_path [function] [call site] 01199
54 syn::Error::new [function] [call site] 01200
54 parse::<syn::Path> [function] [call site] 01201
54 map_err [function] [call site] 01202
54 clone [function] [call site] 01203
54 Err [function] [call site] 01204
54 syn::Error::new [function] [call site] 01205
53 join [function] [call site] 01206
53 clone [function] [call site] 01207
53 std::fs::create_dir [function] [call site] 01208
54 UnboundedReceiverStream::as_ref [function] [call site] 01209
54 &UnboundedReceiver::to_owned [function] [call site] 01210
54 fs::asyncify [function] [call site] 01211
54 std::fs::create_dir [function] [call site] 01212
53 clone [function] [call site] 01213
53 io::Result::unwrap [function] [call site] 01214
53 tokio_test::assert_ok [function] [call site] 01215
52 wake_reader_on_write_outside_lock [function] [call site] 01216
52 Err [function] [call site] 01217
52 IoDriverMetrics::incr_fd_count [function] [call site] 01218
53 Interest::add [function] [call site] 01219
52 Ok [function] [call site] 01220
51 Ok [function] [call site] 01221
50 Ok [function] [call site] 01222
50 Some [function] [call site] 01223
49 scheduler::Handle::current [function] [call site] 01224
46 Ok [function] [call site] 01225
46 PollEvented::new [function] [call site] 01226
43 io::Result::map [function] [call site] 01227
44 Map::new [function] [call site] 01228
41 expect [function] [call site] 01229
40 UnboundedReceiverStream::as_mut [function] [call site] 01230
40 Sleep::reset_without_timer [function] [call site] 01231
41 Notified::project [function] [call site] 01232
42 is_unpin::<&Notify> [function] [call site] 01233
42 is_unpin::<State> [function] [call site] 01234
42 is_unpin::<usize> [function] [call site] 01235
42 OnceCell::get_unchecked_mut [function] [call site] 01236
43 CoreStage::with_mut [function] [call site] 01237
43 as_mut_ptr [function] [call site] 01238
41 spawn_wakes_localset [function] [call site] 01239
42 LocalSet::new [function] [call site] 01240
43 context::thread_id [function] [call site] 01241
44 runtime::Builder::new_multi_thread [function] [call site] 01242
44 Builder::worker_threads [function] [call site] 01243
44 Builder::enable_all [function] [call site] 01244
44 Configuration::build [function] [call site] 01245
44 Result::unwrap [function] [call site] 01246
44 tokio::runtime::Runtime::metrics [function] [call site] 01247
45 cfg_metrics [function] [call site] 01248
44 tokio::runtime::Runtime::block_on [function] [call site] 01249
44 tokio::task::spawn [function] [call site] 01250
45 spawn [function] [call site] 01251
44 Context::worker_index [function] [call site] 01252
44 usize::expect [function] [call site] 01253
44 std::thread::current [function] [call site] 01254
45 StreamExt::map [function] [call site] 01255
45 StreamExt::map [function] [call site] 01256
45 StreamExt::collect [function] [call site] 01257
45 create_temp_file [function] [call site] 01258
46 StreamNotifyClose::new [function] [call site] 01259
46 Self::unwrap [function] [call site] 01260
46 write_all [function] [call site] 01261
46 unwrap [function] [call site] 01262
46 flush [function] [call site] 01263
47 Poll::Ready [function] [call site] 01264
47 Ok [function] [call site] 01265
46 unwrap [function] [call site] 01266
46 parse_path [function] [call site] 01267
46 to_path_buf [function] [call site] 01268
45 StreamExt::collect [function] [call site] 01269
45 JoinSet::new [function] [call site] 01270
45 iter [function] [call site] 01271
45 Iter::enumerate [function] [call site] 01272
45 Result::clone [function] [call site] 01273
45 StreamExt::map [function] [call site] 01274
45 StreamExt::collect [function] [call site] 01275
45 spawn [function] [call site] 01276
45 File::open [function] [call site] 01277
45 unwrap [function] [call site] 01278
45 StreamNotifyClose::new [function] [call site] 01279
45 NamedTempFile::read_to_end [function] [call site] 01280
46 VecWithInitialized::new [function] [call site] 01281
47 UnboundedReceiverStream::as_mut [function] [call site] 01282
47 StreamMap::len [function] [call site] 01283
48 len [function] [call site] 01284
47 UnboundedReceiverStream::as_ref [function] [call site] 01285
47 &UnboundedReceiver::capacity [function] [call site] 01286
48 StreamMap::<&str, [call site] 01287
45 unwrap [function] [call site] 01288
45 join_all [function] [call site] 01289
46 JoinSet::new [function] [call site] 01290
46 spawn [function] [call site] 01291
46 join_all [function] [call site] 01292
46 Inner::into_iter [function] [call site] 01293
44 id [function] [call site] 01294
45 context::current_task_id [function] [call site] 01295
45 expect [function] [call site] 01296
44 worker_index_matches_metrics_worker_thread_id [function] [call site] 01297
45 runtime::Builder::new_multi_thread [function] [call site] 01298
45 Builder::worker_threads [function] [call site] 01299
45 Builder::enable_all [function] [call site] 01300
45 Configuration::build [function] [call site] 01301
45 Result::unwrap [function] [call site] 01302
45 tokio::runtime::Runtime::metrics [function] [call site] 01303
45 tokio::runtime::Runtime::block_on [function] [call site] 01304
45 tokio::task::spawn [function] [call site] 01305
45 Context::worker_index [function] [call site] 01306
45 usize::expect [function] [call site] 01307
45 std::thread::current [function] [call site] 01308
45 id [function] [call site] 01309
45 worker_index_matches_metrics_worker_thread_id [function] [call site] 01310
45 unwrap [function] [call site] 01311
44 unwrap [function] [call site] 01312
43 expect [function] [call site] 01313
43 Cell::new [function] [call site] 01314
44 id [function] [call site] 01315
44 raw::vtable::<T, [call site] 01316
44 StreamNotifyClose::new [function] [call site] 01317
45 Some [function] [call site] 01318
44 Trailer::new [function] [call site] 01319
45 UnsafeCell::new [function] [call site] 01320
45 linked_list::Pointers::new [function] [call site] 01321
44 Arc::hooks [function] [call site] 01322
45 clone [function] [call site] 01323
44 C::e::l::l::::::::n::e::w::new_header [function] [call site] 01324
45 UnsafeCell::new [function] [call site] 01325
45 UnsafeCell::new [function] [call site] 01326
45 UnsafeCell::new [function] [call site] 01327
45 ScheduleLatencyInstant::new [function] [call site] 01328
46 Self [function] [call site] 01329
46 StreamExt::map [function] [call site] 01330
47 Map::new [function] [call site] 01331
46 StreamNotifyClose::new [function] [call site] 01332
46 Option<Instant>::elapsed [function] [call site] 01333
47 Instant::now [function] [call site] 01334
47 &mut [call site] 01335
48 Instant::now [function] [call site] 01336
48 &mut [call site] 01337
48 std::thread::sleep [function] [call site] 01338
47 std::thread::sleep [function] [call site] 01339
46 as_nanos [function] [call site] 01340
46 Self::unwrap_or [function] [call site] 01341
44 UnsafeCell::new [function] [call site] 01342
44 Stage::Running [function] [call site] 01343
44 Header::get_trailer [function] [call site] 01344
45 UnboundedReceiverStream::as_ref [function] [call site] 01345
45 as_ptr [function] [call site] 01346
45 as_ptr().cast::<u8> [function] [call site] 01347
45 Interest::add [function] [call site] 01348
45 as_ptr().cast::<u8>().add(offset).cast::<Trailer> [function] [call site] 01349
45 NonNull::new_unchecked [function] [call site] 01350
44 NonNull::from [function] [call site] 01351
45 NonNull::new_unchecked [function] [call site] 01352
45 Arc::as_ptr [function] [call site] 01353
44 Header::get_scheduler::<S> [function] [call site] 01354
44 NonNull::from [function] [call site] 01355
44 Header::get_id_ptr [function] [call site] 01356
44 NonNull::from [function] [call site] 01357
44 Header::get_spawn_location_ptr [function] [call site] 01358
45 UnboundedReceiverStream::as_ref [function] [call site] 01359
45 as_ptr [function] [call site] 01360
45 as_ptr() [call site] 01361
6 .cast::<u8> [function] [call site] 01362
45 Interest::add [function] [call site] 01363
45 as_ptr() [call site] 01364
6 .cast::<u8>() [call site] 01365
6 .add(offset) [call site] 01366
6 .cast::<&'static [call site] 01367
45 NonNull::new_unchecked [function] [call site] 01368
44 NonNull::from [function] [call site] 01369
44 test::bucket_computation_spot_check [function] [call site] 01370
45 HistogramType::H2 [function] [call site] 01371
43 StreamNotifyClose::new [function] [call site] 01372
44 Some [function] [call site] 01373
43 StreamNotifyClose::new [function] [call site] 01374
43 LocalOwnedTasks::new [function] [call site] 01375
44 UnsafeCell::new [function] [call site] 01376
44 LinkedList::new [function] [call site] 01377
44 get_next_id [function] [call site] 01378
43 UnsafeCell::new [function] [call site] 01379
43 VecDeque::with_capacity [function] [call site] 01380
44 StreamMap::<&str, [call site] 01381
43 Mutex::new [function] [call site] 01382
43 Some [function] [call site] 01383
43 VecDeque::with_capacity [function] [call site] 01384
43 AtomicWaker::new [function] [call site] 01385
44 AtomicUsize::new [function] [call site] 01386
44 UnsafeCell::new [function] [call site] 01387
43 Cell::new [function] [call site] 01388
40 Poll::Ready [function] [call site] 01389
38 tokio_test::assert_pending [function] [call site] 01390
38 tokio::task::yield_now [function] [call site] 01391
39 std::future::poll_fn [function] [call site] 01392
39 Poll::Ready [function] [call site] 01393
39 context::defer [function] [call site] 01394
39 check_drop_replaced_waker [function] [call site] 01395
36 Runtime::enter [function] [call site] 01396
37 basic_enter [function] [call site] 01397
36 &mut [call site] 01398
37 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] 01399
37 std::panic::AssertUnwindSafe [function] [call site] 01400
37 std::thread::Result::expect_err [function] [call site] 01401
37 downcast_ref::<String> [function] [call site] 01402
37 StreamExt::map [function] [call site] 01403
37 or_else [function] [call site] 01404
37 downcast_ref::<&str> [function] [call site] 01405
37 copied [function] [call site] 01406
37 unwrap_or [function] [call site] 01407
36 &mut [call site] 01408
35 Box::pin [function] [call site] 01409
35 SpawnMeta::new_unnamed [function] [call site] 01410
35 Runtime::block_on_inner [function] [call site] 01411
35 SpawnMeta::new_unnamed [function] [call site] 01412
34 tokio::runtime::Runtime::spawn [function] [call site] 01413
34 get_or_init [function] [call site] 01414
34 tokio::runtime::Runtime::spawn [function] [call site] 01415
34 get_or_init [function] [call site] 01416
34 time::advance [function] [call site] 01417
34 Duration::from_millis [function] [call site] 01418
34 time::resume [function] [call site] 01419
35 Instant::now [function] [call site] 01420
35 time::pause [function] [call site] 01421
35 time::advance [function] [call site] 01422
35 Duration::from_secs [function] [call site] 01423
35 time::resume [function] [call site] 01424
35 time::pause [function] [call site] 01425
35 time::advance [function] [call site] 01426
35 Duration::from_secs [function] [call site] 01427
34 unwrap [function] [call site] 01428
34 unwrap [function] [call site] 01429
33 Mutex::new [function] [call site] 01430
32 &Mutex::lock [function] [call site] 01431
30 wake_reader_on_write_outside_lock [function] [call site] 01432
30 Err [function] [call site] 01433
30 LocalState::task_push_back [function] [call site] 01434
30 SpawnerMetrics::inc_queue_depth [function] [call site] 01435
30 len [function] [call site] 01436
30 AtomicU64::fetch_or [function] [call site] 01437
30 Ok [function] [call site] 01438
29 remove [function] [call site] 01439
27 OwnedTasks::bind_inner [function] [call site] 01440
26 unwrap [function] [call site] 01441
26 UdpSocket::local_addr [function] [call site] 01442
27 UdpSocket::local_addr [function] [call site] 01443
26 io::Result::unwrap [function] [call site] 01444
26 TcpStream::connect [function] [call site] 01445
27 TcpStream::connect [function] [call site] 01446
27 split [function] [call site] 01447
28 ReadHalf [function] [call site] 01448
28 WriteHalf [function] [call site] 01449
27 FramedWrite::new [function] [call site] 01450
28 WriteFrame::default [function] [call site] 01451
29 BytesMut::with_capacity [function] [call site] 01452
30 StreamMap::<&str, [call site] 01453
27 BytesCodec::new [function] [call site] 01454
28 BytesCodec [function] [call site] 01455
27 FramedRead::new [function] [call site] 01456
28 StreamMap::default [function] [call site] 01457
29 StreamNotifyClose::new [function] [call site] 01458
27 BytesCodec::new [function] [call site] 01459
27 StreamExt::filter_map [function] [call site] 01460
28 FilterMap::new [function] [call site] 01461
27 future::ready [function] [call site] 01462
28 ServerOptions::new [function] [call site] 01463
28 ServerOptions::create [function] [call site] 01464
29 ServerOptions::create_with_security_attributes_raw [function] [call site] 01465
30 encode_addr [function] [call site] 01466
31 UnboundedReceiverStream::as_ref [function] [call site] 01467
31 &UnboundedReceiver::encode_wide [function] [call site] 01468
31 count [function] [call site] 01469
31 Vec::with_capacity [function] [call site] 01470
31 extend [function] [call site] 01471
31 UnboundedReceiverStream::as_ref [function] [call site] 01472
31 &UnboundedReceiver::encode_wide [function] [call site] 01473
31 ShardedImpl::push [function] [call site] 01474
31 into_boxed_slice [function] [call site] 01475
30 windows_sys::CreateNamedPipeW [function] [call site] 01476
30 as_ptr [function] [call site] 01477
30 Err [function] [call site] 01478
30 io::Error::last_os_error [function] [call site] 01479
30 NamedPipeServer::from_raw_handle [function] [call site] 01480
31 mio_windows::NamedPipe::from_raw_handle [function] [call site] 01481
31 Ok [function] [call site] 01482
31 PollEvented::new [function] [call site] 01483
29 ptr::null_mut [function] [call site] 01484
28 my_custom_runtime::spawn [function] [call site] 01485
29 spawn [function] [call site] 01486
28 connect [function] [call site] 01487
29 TcpStream::connect [function] [call site] 01488
29 split [function] [call site] 01489
29 FramedWrite::new [function] [call site] 01490
29 BytesCodec::new [function] [call site] 01491
29 FramedRead::new [function] [call site] 01492
29 BytesCodec::new [function] [call site] 01493
29 StreamExt::filter_map [function] [call site] 01494
29 future::ready [function] [call site] 01495
29 Some [function] [call site] 01496
29 freeze [function] [call site] 01497
29 future::ready [function] [call site] 01498
29 StreamExt::map [function] [call site] 01499
30 Map::new [function] [call site] 01500
29 Ok [function] [call site] 01501
28 ServerOptions::new [function] [call site] 01502
28 ServerOptions::create [function] [call site] 01503
28 my_custom_runtime::spawn [function] [call site] 01504
28 reset_readable [function] [call site] 01505
29 socketpair [function] [call site] 01506
29 AsyncFd::register [function] [call site] 01507
29 unwrap [function] [call site] 01508
29 reset_readable [function] [call site] 01509
29 write_all [function] [call site] 01510
29 WriteAll::unwrap [function] [call site] 01511
29 unwrap [function] [call site] 01512
29 guard_try_io [function] [call site] 01513
30 socketpair [function] [call site] 01514
30 write_all [function] [call site] 01515
30 WriteAll::unwrap [function] [call site] 01516
30 AsyncFd::register [function] [call site] 01517
30 unwrap [function] [call site] 01518
30 reset_readable [function] [call site] 01519
30 unwrap [function] [call site] 01520
30 Filter::get_ref [function] [call site] 01521
30 read_exact [function] [call site] 01522
31 ReadBuf::new [function] [call site] 01523
32 len [function] [call site] 01524
32 slice_to_uninit_mut [function] [call site] 01525
30 unwrap [function] [call site] 01526
30 guard_try_io [function] [call site] 01527
30 Ok [function] [call site] 01528
30 reset_readable [function] [call site] 01529
30 unwrap [function] [call site] 01530
30 guard_try_io [function] [call site] 01531
30 io::Result::<()>::Err [function] [call site] 01532
30 Steal::steal_into [function] [call site] 01533
30 reset_readable [function] [call site] 01534
30 write_all [function] [call site] 01535
30 WriteAll::unwrap [function] [call site] 01536
30 unwrap [function] [call site] 01537
29 Filter::get_ref [function] [call site] 01538
29 nix::unistd::read [function] [call site] 01539
30 tempfile [function] [call site] 01540
30 NamedTempFile::write_all [function] [call site] 01541
30 WriteAll::unwrap [function] [call site] 01542
30 File::open [function] [call site] 01543
30 NamedTempFile::path [function] [call site] 01544
30 unwrap [function] [call site] 01545
30 NamedTempFile::read [function] [call site] 01546
30 unwrap [function] [call site] 01547
29 unwrap [function] [call site] 01548
29 unwrap [function] [call site] 01549
29 reset_readable [function] [call site] 01550
29 unwrap [function] [call site] 01551
29 AsyncFdReadyGuard::retain_ready [function] [call site] 01552
29 AsyncFdReadyGuard::clear_ready [function] [call site] 01553
30 take [function] [call site] 01554
30 driver_shutdown_then_clear_readiness [function] [call site] 01555
31 rt [function] [call site] 01556
31 socketpair [function] [call site] 01557
31 tokio::runtime::Runtime::enter [function] [call site] 01558
31 AsyncFd::register [function] [call site] 01559
31 unwrap [function] [call site] 01560
31 tokio::runtime::Runtime::block_on [function] [call site] 01561
31 pair_starts_writable [function] [call site] 01562
32 UnixStream::pair [function] [call site] 01563
33 mio::net::UnixStream::pair [function] [call site] 01564
34 mio::net::UnixStream::pair [function] [call site] 01565
34 UnixStream::new [function] [call site] 01566
35 PollEvented::new [function] [call site] 01567
35 Ok [function] [call site] 01568
34 UnixStream::new [function] [call site] 01569
34 shutdown_drops_waker_holding_registration [function] [call site] 01570
35 rt [function] [call site] 01571
35 tokio::runtime::Runtime::enter [function] [call site] 01572
35 std::net::TcpListener::bind [function] [call site] 01573
36 Harness::get_new_task [function] [call site] 01574
36 OwnedTasks::bind_inner [function] [call site] 01575
35 (JoinHandle::unwrap [function] [call site] 01576
35 set_nonblocking [function] [call site] 01577
35 io::Result::unwrap [function] [call site] 01578
35 StreamNotifyClose::new [function] [call site] 01579
35 TcpListener::from_std [function] [call site] 01580
36 util::check_socket_for_blocking [function] [call site] 01581
37 Ok [function] [call site] 01582
36 mio::net::TcpListener::from_std [function] [call site] 01583
37 util::check_socket_for_blocking [function] [call site] 01584
37 mio::net::TcpListener::from_std [function] [call site] 01585
37 PollEvented::new [function] [call site] 01586
37 Ok [function] [call site] 01587
36 PollEvented::new [function] [call site] 01588
36 Ok [function] [call site] 01589
35 io::Result::unwrap [function] [call site] 01590
35 StreamNotifyClose::new [function] [call site] 01591
35 StreamNotifyClose::new [function] [call site] 01592
35 StreamNotifyClose::new [function] [call site] 01593
35 clone [function] [call site] 01594
35 clone [function] [call site] 01595
35 futures::task::waker_ref [function] [call site] 01596
36 Arc::as_ptr [function] [call site] 01597
36 cast::<()> [function] [call site] 01598
36 SignalKind::from_raw [function] [call site] 01599
37 Self [function] [call site] 01600
36 StreamNotifyClose::new [function] [call site] 01601
36 waker_vtable::<W> [function] [call site] 01602
36 StreamNotifyClose::new [function] [call site] 01603
35 Context::from_waker [function] [call site] 01604
35 tokio_test::assert_pending [function] [call site] 01605
35 size_hint_stream_closed_permits_drop [function] [call site] 01606
35 size_hint_stream_closed_permits_drop [function] [call site] 01607
35 size_hint_stream_closed_permits_drop [function] [call site] 01608
34 ScheduledIo::assume_ready [function] [call site] 01609
35 State::fetch_update [function] [call site] 01610
36 State::load [function] [call site] 01611
37 group_b::complete_block_on_under_load [function] [call site] 01612
37 State [function] [call site] 01613
36 Filter::get_ref [function] [call site] 01614
36 Err [function] [call site] 01615
36 AtomicU64::compare_exchange [function] [call site] 01616
37 wake_reader_on_write_outside_lock [function] [call site] 01617
37 Ok [function] [call site] 01618
37 Err [function] [call site] 01619
36 Ok [function] [call site] 01620
36 Snapshot [function] [call site] 01621
35 unpack [function] [call site] 01622
35 StreamExt::then [function] [call site] 01623
36 Then::new [function] [call site] 01624
35 pack [function] [call site] 01625
36 mem::size_of::<UnsignedShort> [function] [call site] 01626
35 unpack [function] [call site] 01627
35 Ready::as_usize [function] [call site] 01628
34 shutdown_drops_waker_holding_registration [function] [call site] 01629
34 ScheduledIo::assume_ready [function] [call site] 01630
34 Ok [function] [call site] 01631
33 UnixStream::new [function] [call site] 01632
33 UnixStream::new [function] [call site] 01633
33 shutdown_drops_waker_holding_registration [function] [call site] 01634
33 ScheduledIo::assume_ready [function] [call site] 01635
33 shutdown_drops_waker_holding_registration [function] [call site] 01636
33 ScheduledIo::assume_ready [function] [call site] 01637
33 Ok [function] [call site] 01638
32 my_custom_runtime::spawn [function] [call site] 01639
32 pair_starts_writable [function] [call site] 01640
32 tokio_test::assert_ready_ok [function] [call site] 01641
32 my_custom_runtime::spawn [function] [call site] 01642
32 write_all [function] [call site] 01643
32 tokio_test::assert_ready_ok [function] [call site] 01644
32 size_hint_stream_closed_permits_drop [function] [call site] 01645
32 UnixStream::pair [function] [call site] 01646
32 my_custom_runtime::spawn [function] [call site] 01647
32 reset_readable [function] [call site] 01648
32 tokio_test::assert_pending [function] [call site] 01649
32 reset_readable [function] [call site] 01650
32 Ok [function] [call site] 01651
31 F::Output::unwrap [function] [call site] 01652
31 std::mem::drop [function] [call site] 01653
32 mpsc::channel [function] [call site] 01654
32 send [function] [call site] 01655
32 unwrap [function] [call site] 01656
32 VecWithInitialized::reserve [function] [call site] 01657
32 unwrap [function] [call site] 01658
32 VecWithInitialized::reserve [function] [call site] 01659
32 unwrap [function] [call site] 01660
32 ReceiverStream::new [function] [call site] 01661
32 UnboundedReceiverStream::close [function] [call site] 01662
32 size_hint_stream_closed_permits_drop [function] [call site] 01663
32 PendingOnce::poll_next [function] [call site] 01664
32 size_hint_stream_closed_permits_drop [function] [call site] 01665
31 AsyncFdReadyGuard::clear_ready [function] [call site] 01666
29 reset_readable [function] [call site] 01667
29 write_all [function] [call site] 01668
29 WriteAll::unwrap [function] [call site] 01669
29 reset_readable [function] [call site] 01670
29 unwrap [function] [call site] 01671
29 AsyncFdReadyGuard::clear_ready [function] [call site] 01672
28 ReadHalf::try_read [function] [call site] 01673
29 ReadHalf::try_read [function] [call site] 01674
28 io::Result::len [function] [call site] 01675
29 len [function] [call site] 01676
28 kind [function] [call site] 01677
28 Err [function] [call site] 01678
28 pair_starts_writable [function] [call site] 01679
28 try_write [function] [call site] 01680
29 RwLock::new [function] [call site] 01681
29 read [function] [call site] 01682
29 size_hint_stream_closed_permits_drop [function] [call site] 01683
28 StreamMap::len [function] [call site] 01684
29 len [function] [call site] 01685
28 kind [function] [call site] 01686
28 Err [function] [call site] 01687
28 Ok::<_, [call site] 01688
28 Ok::<_, [call site] 01689
28 StreamNotifyClose::new [function] [call site] 01690
28 ShardedImpl::push [function] [call site] 01691
29 ShardedImpl::push_shard_index [function] [call site] 01692
29 wake_reader_on_write_outside_lock [function] [call site] 01693
29 Err [function] [call site] 01694
29 LocalState::task_push_back [function] [call site] 01695
29 SpawnerMetrics::inc_queue_depth [function] [call site] 01696
29 len [function] [call site] 01697
29 AtomicU64::fetch_or [function] [call site] 01698
29 Ok [function] [call site] 01699
28 my_custom_runtime::spawn [function] [call site] 01700
28 ClientOptions::new [function] [call site] 01701
28 Self::open [function] [call site] 01702
29 mpsc::channel [function] [call site] 01703
29 send [function] [call site] 01704
29 unwrap [function] [call site] 01705
29 send [function] [call site] 01706
29 unwrap [function] [call site] 01707
29 ReceiverStream::new [function] [call site] 01708
29 PendingOnce::poll_next [function] [call site] 01709
29 PendingOnce::poll_next [function] [call site] 01710
28 raw_os_error [function] [call site] 01711
28 Some [function] [call site] 01712
28 kind [function] [call site] 01713
28 Err [function] [call site] 01714
28 time::sleep [function] [call site] 01715
28 Duration::from_millis [function] [call site] 01716
28 StreamMap::len [function] [call site] 01717
28 StdStream::ready [function] [call site] 01718
29 ServerOptions::new [function] [call site] 01719
29 ServerOptions::create [function] [call site] 01720
29 my_custom_runtime::spawn [function] [call site] 01721
29 connect [function] [call site] 01722
29 ServerOptions::new [function] [call site] 01723
29 ServerOptions::create [function] [call site] 01724
29 my_custom_runtime::spawn [function] [call site] 01725
29 reset_readable [function] [call site] 01726
29 ReadHalf::try_read [function] [call site] 01727
29 io::Result::len [function] [call site] 01728
29 kind [function] [call site] 01729
29 Err [function] [call site] 01730
29 pair_starts_writable [function] [call site] 01731
29 try_write [function] [call site] 01732
29 StreamMap::len [function] [call site] 01733
29 kind [function] [call site] 01734
29 Err [function] [call site] 01735
29 Ok::<_, [call site] 01736
29 Ok::<_, [call site] 01737
29 StreamNotifyClose::new [function] [call site] 01738
29 ShardedImpl::push [function] [call site] 01739
29 my_custom_runtime::spawn [function] [call site] 01740
29 ClientOptions::new [function] [call site] 01741
29 Self::open [function] [call site] 01742
29 raw_os_error [function] [call site] 01743
29 Some [function] [call site] 01744
29 kind [function] [call site] 01745
29 Err [function] [call site] 01746
29 time::sleep [function] [call site] 01747
29 Duration::from_millis [function] [call site] 01748
29 StreamMap::len [function] [call site] 01749
29 StdStream::ready [function] [call site] 01750
29 Interest::is_readable [function] [call site] 01751
29 ReadHalf::try_read [function] [call site] 01752
30 ReadHalf::try_read [function] [call site] 01753
29 io::Result::len [function] [call site] 01754
29 kind [function] [call site] 01755
29 Err [function] [call site] 01756
29 Interest::is_writable [function] [call site] 01757
29 StreamMap::is_empty [function] [call site] 01758
29 StdStream::try_write [function] [call site] 01759
30 RwLock::new [function] [call site] 01760
30 read [function] [call site] 01761
30 size_hint_stream_closed_permits_drop [function] [call site] 01762
29 kind [function] [call site] 01763
29 Err [function] [call site] 01764
29 String::from_utf8_lossy [function] [call site] 01765
29 into_owned [function] [call site] 01766
29 Ok::<_, [call site] 01767
29 Ok [function] [call site] 01768
28 Interest::is_readable [function] [call site] 01769
28 ReadHalf::try_read [function] [call site] 01770
28 io::Result::len [function] [call site] 01771
28 kind [function] [call site] 01772
28 Err [function] [call site] 01773
28 Interest::is_writable [function] [call site] 01774
28 StreamMap::is_empty [function] [call site] 01775
28 StdStream::try_write [function] [call site] 01776
28 kind [function] [call site] 01777
28 Err [function] [call site] 01778
28 String::from_utf8_lossy [function] [call site] 01779
28 into_owned [function] [call site] 01780
28 Ok::<_, [call site] 01781
28 Ok [function] [call site] 01782
27 Some [function] [call site] 01783
27 freeze [function] [call site] 01784
27 future::ready [function] [call site] 01785
27 StreamExt::map [function] [call site] 01786
27 Ok [function] [call site] 01787
26 test_accept [function] [call site] 01788
27 tokio_test::assert_ok [function] [call site] 01789
27 local_addr [function] [call site] 01790
27 io::Result::unwrap [function] [call site] 01791
27 oneshot::channel [function] [call site] 01792
27 tokio::spawn [function] [call site] 01793
27 tokio_test::assert_ok [function] [call site] 01794
27 tokio_test::assert_ok [function] [call site] 01795
27 tokio_test::assert_ok [function] [call site] 01796
27 tokio_test::assert_ok [function] [call site] 01797
26 u32::unwrap [function] [call site] 01798
26 u32::unwrap [function] [call site] 01799
25 make_socketpair [function] [call site] 01800
25 my_custom_runtime::spawn [function] [call site] 01801
25 tokio::io::copy_bidirectional [function] [call site] 01802
26 copy_bidirectional_impl [function] [call site] 01803
27 TransferState::Running [function] [call site] 01804
27 TransferState::Running [function] [call site] 01805
27 std::future::poll_fn [function] [call site] 01806
27 transfer_one_direction [function] [call site] 01807
28 StreamNotifyClose::new [function] [call site] 01808
28 StreamNotifyClose::new [function] [call site] 01809
28 TransferState::ShuttingDown [function] [call site] 01810
28 TransferState::Done [function] [call site] 01811
28 Poll::Ready [function] [call site] 01812
28 Ok [function] [call site] 01813
27 transfer_one_direction [function] [call site] 01814
27 Poll::Ready [function] [call site] 01815
27 Ok [function] [call site] 01816
26 CopyBuffer::new [function] [call site] 01817
27 into_boxed_slice [function] [call site] 01818
26 CopyBuffer::new [function] [call site] 01819
25 cb [function] [call site] 01820
25 make_socketpair [function] [call site] 01821
25 make_socketpair [function] [call site] 01822
25 my_custom_runtime::spawn [function] [call site] 01823
25 tokio::io::copy_bidirectional [function] [call site] 01824
25 cb [function] [call site] 01825
24 block_write [function] [call site] 01826
24 write_all [function] [call site] 01827
24 unwrap [function] [call site] 01828
24 read_exact [function] [call site] 01829
24 unwrap [function] [call site] 01830
24 AsyncWriteExt::shutdown [function] [call site] 01831
25 time::timeout [function] [call site] 01832
25 Duration::from_secs [function] [call site] 01833
25 std::io::Result::write_all [function] [call site] 01834
24 unwrap [function] [call site] 01835
24 StreamNotifyClose::new [function] [call site] 01836
24 read_to_end [function] [call site] 01837
25 VecWithInitialized::new [function] [call site] 01838
24 unwrap [function] [call site] 01839
24 size_hint_stream_closed_permits_drop [function] [call site] 01840
22 File::try_clone [function] [call site] 01841
23 wake_reader_on_write_outside_lock [function] [call site] 01842
23 Inner::complete_inflight [function] [call site] 01843
23 clone [function] [call site] 01844
23 fs::asyncify [function] [call site] 01845
23 File::try_clone [function] [call site] 01846
23 File::from_std [function] [call site] 01847
24 StreamNotifyClose::new [function] [call site] 01848
24 Mutex::new [function] [call site] 01849
24 State::Idle [function] [call site] 01850
24 Some [function] [call site] 01851
24 Buf::with_capacity [function] [call site] 01852
23 File::set_max_buf_size [function] [call site] 01853
23 Ok [function] [call site] 01854
22 File::from_std [function] [call site] 01855
22 File::set_max_buf_size [function] [call site] 01856
22 Ok [function] [call site] 01857
21 unwrap [function] [call site] 01858
21 RawWaker::write_all [function] [call site] 01859
21 unwrap [function] [call site] 01860
21 RW::poll_flush [function] [call site] 01861
21 unwrap [function] [call site] 01862
21 std::fs::read [function] [call site] 01863
21 NamedTempFile::path [function] [call site] 01864
21 unwrap [function] [call site] 01865
20 std::io::Error::from [function] [call site] 01866
20 clone [function] [call site] 01867
20 Context::from_waker [function] [call site] 01868
20 tokio_test::assert_pending [function] [call site] 01869
18 StreamNotifyClose::new [function] [call site] 01870
18 Mutex::new [function] [call site] 01871
18 panic::take_hook [function] [call site] 01872
18 clone [function] [call site] 01873
18 panic::set_hook [function] [call site] 01874
18 StreamNotifyClose::new [function] [call site] 01875
18 Header::get_spawn_location [function] [call site] 01876
19 Header::get_spawn_location_ptr [function] [call site] 01877
19 NonNull::as_ptr [function] [call site] 01878
18 unwrap [function] [call site] 01879
18 wake_reader_on_write_outside_lock [function] [call site] 01880
18 clone_from [function] [call site] 01881
18 Some [function] [call site] 01882
18 tempfile [function] [call site] 01883
19 StreamNotifyClose::new [function] [call site] 01884
19 Self::unwrap [function] [call site] 01885
18 read_to_string [function] [call site] 01886
18 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] 01887
18 panic::set_hook [function] [call site] 01888
18 is_err [function] [call site] 01889
18 wake_reader_on_write_outside_lock [function] [call site] 01890
18 clone [function] [call site] 01891
17 Inner::into_iter [function] [call site] 01892
17 stream::iter [function] [call site] 01893
17 StreamExt::chunks_timeout [function] [call site] 01894
17 Duration::from_secs [function] [call site] 01895
17 Ok [function] [call site] 01896
16 in_scope [function] [call site] 01897
16 semaphore::Semaphore::new [function] [call site] 01898
17 in_scope [function] [call site] 01899
17 AtomicUsize::new [function] [call site] 01900
17 Mutex::new [function] [call site] 01901
17 LinkedList::new [function] [call site] 01902
16 semaphore::Semaphore::new [function] [call site] 01903
16 UnsafeCell::new [function] [call site] 01904
15 LinkedList::new [function] [call site] 01905
14 Self::try_acquire [function] [call site] 01906
15 Semaphore::new [function] [call site] 01907
15 Self::try_acquire [function] [call site] 01908
15 Self::try_acquire [function] [call site] 01909
15 Self::try_acquire [function] [call site] 01910
14 unwrap [function] [call site] 01911
14 i32::forget [function] [call site] 01912
15 StreamNotifyClose::new [function] [call site] 01913
15 Semaphore::new [function] [call site] 01914
15 Self::try_acquire [function] [call site] 01915
15 unwrap [function] [call site] 01916
15 i32::forget [function] [call site] 01917
13 clone [function] [call site] 01918
13 to_raw [function] [call site] 01919
12 Err [function] [call site] 01920
12 syn::Error::new [function] [call site] 01921
11 unwrap [function] [call site] 01922
11 NamedTempFile::read [function] [call site] 01923
11 unwrap [function] [call site] 01924
10 read [function] [call site] 01925
10 Configuration::build [function] [call site] 01926
10 read [function] [call site] 01927
10 expect [function] [call site] 01928
10 read [function] [call site] 01929
10 expect [function] [call site] 01930
9 read [function] [call site] 01931
8 &mut [call site] 01932
9 mpsc::channel [function] [call site] 01933
9 send [function] [call site] 01934
9 unwrap [function] [call site] 01935
9 send [function] [call site] 01936
9 unwrap [function] [call site] 01937
9 ReceiverStream::new [function] [call site] 01938
9 PendingOnce::poll_next [function] [call site] 01939
9 PendingOnce::poll_next [function] [call site] 01940
7 NamedTempFile::path [function] [call site] 01941
7 unwrap [function] [call site] 01942
7 NamedTempFile::read [function] [call site] 01943
7 unwrap [function] [call site] 01944
6 test_iter_coop_budget [function] [call site] 01945
5 unpack [function] [call site] 01946
5 group_b::complete_block_on_under_load [function] [call site] 01947
5 wrapping_sub [function] [call site] 01948
5 Steal::steal_into2 [function] [call site] 01949
6 group_b::complete_block_on_under_load [function] [call site] 01950
6 unpack [function] [call site] 01951
6 group_b::complete_block_on_under_load [function] [call site] 01952
6 wrapping_sub [function] [call site] 01953
6 wrapping_add [function] [call site] 01954
6 pack [function] [call site] 01955
6 StaticAtomicU64::compare_exchange_weak [function] [call site] 01956
6 unpack [function] [call site] 01957
6 wrapping_add [function] [call site] 01958
6 UnsignedShort::wrapping_add [function] [call site] 01959
6 with [function] [call site] 01960
6 ptr::read [function] [call site] 01961
7 tempfile [function] [call site] 01962
7 NamedTempFile::write_all [function] [call site] 01963
7 WriteAll::unwrap [function] [call site] 01964
7 File::open [function] [call site] 01965
7 NamedTempFile::path [function] [call site] 01966
7 unwrap [function] [call site] 01967
7 NamedTempFile::read [function] [call site] 01968
7 unwrap [function] [call site] 01969
6 as_ptr [function] [call site] 01970
6 CoreStage::with_mut [function] [call site] 01971
6 ptr::write [function] [call site] 01972
7 tempfile [function] [call site] 01973
7 File::create [function] [call site] 01974
7 NamedTempFile::path [function] [call site] 01975
7 unwrap [function] [call site] 01976
7 NamedTempFile::write_all [function] [call site] 01977
7 unwrap [function] [call site] 01978
7 RW::poll_flush [function] [call site] 01979
7 unwrap [function] [call site] 01980
7 std::fs::read [function] [call site] 01981
7 NamedTempFile::path [function] [call site] 01982
7 unwrap [function] [call site] 01983
6 as_mut_ptr [function] [call site] 01984
6 unpack [function] [call site] 01985
6 pack [function] [call site] 01986
6 StaticAtomicU64::compare_exchange_weak [function] [call site] 01987
5 Stats::incr_steal_count [function] [call site] 01988
6 Stats::incr_steal_count [function] [call site] 01989
7 Stats::incr_steal_count [function] [call site] 01990
5 Stats::incr_steal_operations [function] [call site] 01991
6 Stats::incr_steal_operations [function] [call site] 01992
7 Stats::incr_steal_operations [function] [call site] 01993
5 wrapping_add [function] [call site] 01994
5 with [function] [call site] 01995
5 ptr::read [function] [call site] 01996
5 as_ptr [function] [call site] 01997
5 Some [function] [call site] 01998
5 AtomicU64::store [function] [call site] 01999
5 wrapping_add [function] [call site] 02000
5 Some [function] [call site] 02001
3 StreamNotifyClose::new [function] [call site] 02002
3 tokio_test::assert_pending [function] [call site] 02003
3 size_hint_stream_closed_permits_drop [function] [call site] 02004
3 Context::from_waker [function] [call site] 02005
3 futures::task::noop_waker_ref [function] [call site] 02006
3 tokio_test::assert_pending [function] [call site] 02007
3 tokio_test::assert_ready [function] [call site] 02008
2 wake_by_ref [function] [call site] 02009
1 StreamMap::len [function] [call site] 02010
2 len [function] [call site] 02011
1 my_custom_runtime::spawn [function] [call site] 02012
1 StreamMap::new [function] [call site] 02013
1 iter [function] [call site] 02014
1 copied [function] [call site] 02015
1 enumerate [function] [call site] 02016
1 pin_box [function] [call site] 02017
2 Box::pin [function] [call site] 02018
1 stream::empty::<()> [function] [call site] 02019
1 pin_box [function] [call site] 02020
1 stream::pending::<()> [function] [call site] 02021
1 StreamMap::insert [function] [call site] 02022
1 assert_ready_none [function] [call site] 02023
2 tokio_test::assert_ready [function] [call site] 02024
1 tokio_test::assert_pending [function] [call site] 02025
1 StreamMap::values [function] [call site] 02026
2 StreamMap::iter [function] [call site] 02027
3 iter [function] [call site] 02028
2 StreamExt::map [function] [call site] 02029
3 Map::new [function] [call site] 02030