crossbeam-channel/src/context.rs
Line | Count | Source (jump to first uncovered line) |
1 | | //! Thread-local context used in select. |
2 | | |
3 | | use std::cell::Cell; |
4 | | use std::sync::atomic::{AtomicUsize, Ordering}; |
5 | | use std::sync::Arc; |
6 | | use std::thread::{self, Thread, ThreadId}; |
7 | | use std::time::Instant; |
8 | | |
9 | | use crossbeam_utils::Backoff; |
10 | | |
11 | | use crate::select::Selected; |
12 | | |
13 | | /// Thread-local context used in select. |
14 | 10.7M | #[derive(Debug, Clone)] <crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 423k | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 5.99M | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 46.1k | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 697 | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 2 | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 1.83k | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 159k | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 4.09M | #[derive(Debug, Clone)] |
<crossbeam_channel::context::Context as core::clone::Clone>::clone Line | Count | Source | 14 | 75.0k | #[derive(Debug, Clone)] |
|
15 | | pub struct Context { |
16 | | inner: Arc<Inner>, |
17 | | } |
18 | | |
19 | | /// Inner representation of `Context`. |
20 | 0 | #[derive(Debug)] |
21 | | struct Inner { |
22 | | /// Selected operation. |
23 | | select: AtomicUsize, |
24 | | |
25 | | /// A slot into which another thread may store a pointer to its `Packet`. |
26 | | packet: AtomicUsize, |
27 | | |
28 | | /// Thread handle. |
29 | | thread: Thread, |
30 | | |
31 | | /// Thread id. |
32 | | thread_id: ThreadId, |
33 | | } |
34 | | |
35 | | impl Context { |
36 | | /// Creates a new context for the duration of the closure. |
37 | | #[inline] |
38 | 10.7M | pub fn with<F, R>(f: F) -> R |
39 | 10.7M | where |
40 | 10.7M | F: FnOnce(&Context) -> R, |
41 | 10.7M | { |
42 | 10.7M | thread_local! { |
43 | 10.7M | /// Cached thread-local context. |
44 | 10.7M | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); |
45 | 10.7M | } |
46 | 10.7M | |
47 | 10.7M | let mut f = Some(f); |
48 | 10.7M | let mut f = move |cx: &Context| -> R { |
49 | 10.7M | let f = f.take().unwrap(); |
50 | 10.7M | f(cx) |
51 | 10.7M | }; <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::recv::{closure#1}, core::result::Result<zero::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 77.3k | let mut f = move |cx: &Context| -> R { | 49 | 77.3k | let f = f.take().unwrap(); | 50 | 77.3k | f(cx) | 51 | 77.3k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 486 | let mut f = move |cx: &Context| -> R { | 49 | 486 | let f = f.take().unwrap(); | 50 | 486 | f(cx) | 51 | 486 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#0} Line | Count | Source | 48 | 113k | let mut f = move |cx: &Context| -> R { | 49 | 113k | let f = f.take().unwrap(); | 50 | 113k | f(cx) | 51 | 113k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 493 | let mut f = move |cx: &Context| -> R { | 49 | 493 | let f = f.take().unwrap(); | 50 | 493 | f(cx) | 51 | 493 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>>::{closure#0} Line | Count | Source | 48 | 507 | let mut f = move |cx: &Context| -> R { | 49 | 507 | let f = f.take().unwrap(); | 50 | 507 | f(cx) | 51 | 507 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#0} Line | Count | Source | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | 7 | let f = f.take().unwrap(); | 50 | 7 | f(cx) | 51 | 7 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<zero::drops::DropCounter>>>::{closure#0} Line | Count | Source | 48 | 77.7k | let mut f = move |cx: &Context| -> R { | 49 | 77.7k | let f = f.take().unwrap(); | 50 | 77.7k | f(cx) | 51 | 77.7k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | 7 | let f = f.take().unwrap(); | 50 | 7 | f(cx) | 51 | 7 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 1.00k | let mut f = move |cx: &Context| -> R { | 49 | 1.00k | let f = f.take().unwrap(); | 50 | 1.00k | f(cx) | 51 | 1.00k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 112k | let mut f = move |cx: &Context| -> R { | 49 | 112k | let f = f.take().unwrap(); | 50 | 112k | f(cx) | 51 | 112k | }; |
<crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_select::{closure#0}, core::option::Option<(usize, *const u8)>>::{closure#0} Line | Count | Source | 48 | 8.51M | let mut f = move |cx: &Context| -> R { | 49 | 8.51M | let f = f.take().unwrap(); | 50 | 8.51M | f(cx) | 51 | 8.51M | }; |
<crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_ready::{closure#0}, core::option::Option<usize>>::{closure#0} Line | Count | Source | 48 | 55 | let mut f = move |cx: &Context| -> R { | 49 | 55 | let f = f.take().unwrap(); | 50 | 55 | f(cx) | 51 | 55 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 39.7k | let mut f = move |cx: &Context| -> R { | 49 | 39.7k | let f = f.take().unwrap(); | 50 | 39.7k | f(cx) | 51 | 39.7k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#0} Line | Count | Source | 48 | 31.1k | let mut f = move |cx: &Context| -> R { | 49 | 31.1k | let f = f.take().unwrap(); | 50 | 31.1k | f(cx) | 51 | 31.1k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 767k | let mut f = move |cx: &Context| -> R { | 49 | 767k | let f = f.take().unwrap(); | 50 | 767k | f(cx) | 51 | 767k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#0} Line | Count | Source | 48 | 19.5k | let mut f = move |cx: &Context| -> R { | 49 | 19.5k | let f = f.take().unwrap(); | 50 | 19.5k | f(cx) | 51 | 19.5k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#0} Line | Count | Source | 48 | 20.9k | let mut f = move |cx: &Context| -> R { | 49 | 20.9k | let f = f.take().unwrap(); | 50 | 20.9k | f(cx) | 51 | 20.9k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 218 | let mut f = move |cx: &Context| -> R { | 49 | 218 | let f = f.take().unwrap(); | 50 | 218 | f(cx) | 51 | 218 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | 5 | let f = f.take().unwrap(); | 50 | 5 | f(cx) | 51 | 5 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 14.5k | let mut f = move |cx: &Context| -> R { | 49 | 14.5k | let f = f.take().unwrap(); | 50 | 14.5k | f(cx) | 51 | 14.5k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#0} Line | Count | Source | 48 | 100 | let mut f = move |cx: &Context| -> R { | 49 | 100 | let f = f.take().unwrap(); | 50 | 100 | f(cx) | 51 | 100 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 8 | let mut f = move |cx: &Context| -> R { | 49 | 8 | let f = f.take().unwrap(); | 50 | 8 | f(cx) | 51 | 8 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<i32>>>>::{closure#0} Line | Count | Source | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | 5 | let f = f.take().unwrap(); | 50 | 5 | f(cx) | 51 | 5 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<i32>, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | 7 | let f = f.take().unwrap(); | 50 | 7 | f(cx) | 51 | 7 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | 2 | let f = f.take().unwrap(); | 50 | 2 | f(cx) | 51 | 2 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 641 | let mut f = move |cx: &Context| -> R { | 49 | 641 | let f = f.take().unwrap(); | 50 | 641 | f(cx) | 51 | 641 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#0} Line | Count | Source | 48 | 12 | let mut f = move |cx: &Context| -> R { | 49 | 12 | let f = f.take().unwrap(); | 50 | 12 | f(cx) | 51 | 12 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 14 | let mut f = move |cx: &Context| -> R { | 49 | 14 | let f = f.take().unwrap(); | 50 | 14 | f(cx) | 51 | 14 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<array::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 21 | let mut f = move |cx: &Context| -> R { | 49 | 21 | let f = f.take().unwrap(); | 50 | 21 | f(cx) | 51 | 21 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#0} Line | Count | Source | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | 5 | let f = f.take().unwrap(); | 50 | 5 | f(cx) | 51 | 5 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#0} Line | Count | Source | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | 2 | let f = f.take().unwrap(); | 50 | 2 | f(cx) | 51 | 2 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<list::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 43 | let mut f = move |cx: &Context| -> R { | 49 | 43 | let f = f.take().unwrap(); | 50 | 43 | f(cx) | 51 | 43 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1.76k | let mut f = move |cx: &Context| -> R { | 49 | 1.76k | let f = f.take().unwrap(); | 50 | 1.76k | f(cx) | 51 | 1.76k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | 2 | let f = f.take().unwrap(); | 50 | 2 | f(cx) | 51 | 2 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 25 | let mut f = move |cx: &Context| -> R { | 49 | 25 | let f = f.take().unwrap(); | 50 | 25 | f(cx) | 51 | 25 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 21.9k | let mut f = move |cx: &Context| -> R { | 49 | 21.9k | let f = f.take().unwrap(); | 50 | 21.9k | f(cx) | 51 | 21.9k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<bool>>>::{closure#0} Line | Count | Source | 48 | 202 | let mut f = move |cx: &Context| -> R { | 49 | 202 | let f = f.take().unwrap(); | 50 | 202 | f(cx) | 51 | 202 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::string::String>>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#0} Line | Count | Source | 48 | 17.1k | let mut f = move |cx: &Context| -> R { | 49 | 17.1k | let f = f.take().unwrap(); | 50 | 17.1k | f(cx) | 51 | 17.1k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u8>>::recv::{closure#1}, core::result::Result<u8, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 9.50k | let mut f = move |cx: &Context| -> R { | 49 | 9.50k | let f = f.take().unwrap(); | 50 | 9.50k | f(cx) | 51 | 9.50k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::recv::{closure#1}, core::result::Result<i64, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::recv::{closure#1}, core::result::Result<alloc::string::String, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 23.4k | let mut f = move |cx: &Context| -> R { | 49 | 23.4k | let f = f.take().unwrap(); | 50 | 23.4k | f(cx) | 51 | 23.4k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i64>>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 97 | let mut f = move |cx: &Context| -> R { | 49 | 97 | let f = f.take().unwrap(); | 50 | 97 | f(cx) | 51 | 97 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::recv::{closure#1}, core::result::Result<bool, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 124 | let mut f = move |cx: &Context| -> R { | 49 | 124 | let f = f.take().unwrap(); | 50 | 124 | f(cx) | 51 | 124 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<bool>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#0} Line | Count | Source | 48 | 17.8k | let mut f = move |cx: &Context| -> R { | 49 | 17.8k | let f = f.take().unwrap(); | 50 | 17.8k | f(cx) | 51 | 17.8k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 4 | let mut f = move |cx: &Context| -> R { | 49 | 4 | let f = f.take().unwrap(); | 50 | 4 | f(cx) | 51 | 4 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#0} Line | Count | Source | 48 | 108k | let mut f = move |cx: &Context| -> R { | 49 | 108k | let f = f.take().unwrap(); | 50 | 108k | f(cx) | 51 | 108k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | 2 | let f = f.take().unwrap(); | 50 | 2 | f(cx) | 51 | 2 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | 7 | let f = f.take().unwrap(); | 50 | 7 | f(cx) | 51 | 7 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 689k | let mut f = move |cx: &Context| -> R { | 49 | 689k | let f = f.take().unwrap(); | 50 | 689k | f(cx) | 51 | 689k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 29.8k | let mut f = move |cx: &Context| -> R { | 49 | 29.8k | let f = f.take().unwrap(); | 50 | 29.8k | f(cx) | 51 | 29.8k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#0} Line | Count | Source | 48 | 9.94k | let mut f = move |cx: &Context| -> R { | 49 | 9.94k | let f = f.take().unwrap(); | 50 | 9.94k | f(cx) | 51 | 9.94k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 832 | let mut f = move |cx: &Context| -> R { | 49 | 832 | let f = f.take().unwrap(); | 50 | 832 | f(cx) | 51 | 832 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#0} Line | Count | Source | 48 | 10.0k | let mut f = move |cx: &Context| -> R { | 49 | 10.0k | let f = f.take().unwrap(); | 50 | 10.0k | f(cx) | 51 | 10.0k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 19.9k | let mut f = move |cx: &Context| -> R { | 49 | 19.9k | let f = f.take().unwrap(); | 50 | 19.9k | f(cx) | 51 | 19.9k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#0} Line | Count | Source | 48 | 3 | let mut f = move |cx: &Context| -> R { | 49 | 3 | let f = f.take().unwrap(); | 50 | 3 | f(cx) | 51 | 3 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | 1 | let f = f.take().unwrap(); | 50 | 1 | f(cx) | 51 | 1 | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#0} Line | Count | Source | 48 | 29.8k | let mut f = move |cx: &Context| -> R { | 49 | 29.8k | let f = f.take().unwrap(); | 50 | 29.8k | f(cx) | 51 | 29.8k | }; |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#0} Line | Count | Source | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | 2 | let f = f.take().unwrap(); | 50 | 2 | f(cx) | 51 | 2 | }; |
|
52 | | |
53 | 10.7M | CONTEXT |
54 | 10.7M | .try_with(|cell| match cell.take() { |
55 | 18.4E | None => f(&Context::new()), |
56 | 10.7M | Some(cx) => { |
57 | 10.7M | cx.reset(); |
58 | 10.7M | let res = f(&cx); |
59 | 10.7M | cell.set(Some(cx)); |
60 | 10.7M | res |
61 | | } |
62 | 10.7M | }) Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 112k | .try_with(|cell| match cell.take() { | 55 | 112k | None => f(&Context::new())38 , | 56 | 111k | Some(cx) => { | 57 | 111k | cx.reset(); | 58 | 111k | let res = f(&cx); | 59 | 111k | cell.set(Some(cx)); | 60 | 111k | res | 61 | | } | 62 | 112k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::recv::{closure#1}, core::result::Result<zero::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 77.3k | .try_with(|cell| match cell.take() { | 55 | 77.3k | None => f(&Context::new())0 , | 56 | 77.3k | Some(cx) => { | 57 | 77.3k | cx.reset(); | 58 | 77.3k | let res = f(&cx); | 59 | 77.3k | cell.set(Some(cx)); | 60 | 77.3k | res | 61 | | } | 62 | 77.3k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 486 | .try_with(|cell| match cell.take() { | 55 | 486 | None => f(&Context::new())0 , | 56 | 486 | Some(cx) => { | 57 | 486 | cx.reset(); | 58 | 486 | let res = f(&cx); | 59 | 486 | cell.set(Some(cx)); | 60 | 486 | res | 61 | | } | 62 | 486 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Line | Count | Source | 54 | 113k | .try_with(|cell| match cell.take() { | 55 | 113k | None => f(&Context::new())51 , | 56 | 113k | Some(cx) => { | 57 | 113k | cx.reset(); | 58 | 113k | let res = f(&cx); | 59 | 113k | cell.set(Some(cx)); | 60 | 113k | res | 61 | | } | 62 | 113k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 493 | .try_with(|cell| match cell.take() { | 55 | 493 | None => f(&Context::new())0 , | 56 | 493 | Some(cx) => { | 57 | 493 | cx.reset(); | 58 | 493 | let res = f(&cx); | 59 | 493 | cell.set(Some(cx)); | 60 | 493 | res | 61 | | } | 62 | 493 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<zero::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<zero::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>>::{closure#1} Line | Count | Source | 54 | 507 | .try_with(|cell| match cell.take() { | 55 | 507 | None => f(&Context::new())0 , | 56 | 507 | Some(cx) => { | 57 | 507 | cx.reset(); | 58 | 507 | let res = f(&cx); | 59 | 507 | cell.set(Some(cx)); | 60 | 507 | res | 61 | | } | 62 | 507 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Line | Count | Source | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | 7 | None => f(&Context::new())0 , | 56 | 7 | Some(cx) => { | 57 | 7 | cx.reset(); | 58 | 7 | let res = f(&cx); | 59 | 7 | cell.set(Some(cx)); | 60 | 7 | res | 61 | | } | 62 | 7 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<zero::drops::DropCounter>>>::{closure#1} Line | Count | Source | 54 | 77.7k | .try_with(|cell| match cell.take() { | 55 | 77.7k | None => f(&Context::new())0 , | 56 | 77.7k | Some(cx) => { | 57 | 77.7k | cx.reset(); | 58 | 77.7k | let res = f(&cx); | 59 | 77.7k | cell.set(Some(cx)); | 60 | 77.7k | res | 61 | | } | 62 | 77.7k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | 7 | None => f(&Context::new())0 , | 56 | 7 | Some(cx) => { | 57 | 7 | cx.reset(); | 58 | 7 | let res = f(&cx); | 59 | 7 | cell.set(Some(cx)); | 60 | 7 | res | 61 | | } | 62 | 7 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 1.00k | .try_with(|cell| match cell.take() { | 55 | 1.00k | None => f(&Context::new())0 , | 56 | 1.00k | Some(cx) => { | 57 | 1.00k | cx.reset(); | 58 | 1.00k | let res = f(&cx); | 59 | 1.00k | cell.set(Some(cx)); | 60 | 1.00k | res | 61 | | } | 62 | 1.00k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<zero::drops::DropCounter>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_ready::{closure#0}, core::option::Option<usize>>::{closure#1} Line | Count | Source | 54 | 54 | .try_with(|cell| match cell.take() { | 55 | 54 | None => f(&Context::new())0 , | 56 | 54 | Some(cx) => { | 57 | 54 | cx.reset(); | 58 | 54 | let res = f(&cx); | 59 | 54 | cell.set(Some(cx)); | 60 | 54 | res | 61 | | } | 62 | 54 | }) |
<crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_select::{closure#0}, core::option::Option<(usize, *const u8)>>::{closure#1} Line | Count | Source | 54 | 8.51M | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 8.52M | Some(cx) => { | 57 | 8.52M | cx.reset(); | 58 | 8.52M | let res = f(&cx); | 59 | 8.52M | cell.set(Some(cx)); | 60 | 8.52M | res | 61 | | } | 62 | 8.51M | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 39.7k | .try_with(|cell| match cell.take() { | 55 | 39.7k | None => f(&Context::new())33 , | 56 | 39.7k | Some(cx) => { | 57 | 39.7k | cx.reset(); | 58 | 39.7k | let res = f(&cx); | 59 | 39.7k | cell.set(Some(cx)); | 60 | 39.7k | res | 61 | | } | 62 | 39.7k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Line | Count | Source | 54 | 31.1k | .try_with(|cell| match cell.take() { | 55 | 31.1k | None => f(&Context::new())0 , | 56 | 31.1k | Some(cx) => { | 57 | 31.1k | cx.reset(); | 58 | 31.1k | let res = f(&cx); | 59 | 31.1k | cell.set(Some(cx)); | 60 | 31.1k | res | 61 | | } | 62 | 31.1k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 767k | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 767k | Some(cx) => { | 57 | 767k | cx.reset(); | 58 | 767k | let res = f(&cx); | 59 | 767k | cell.set(Some(cx)); | 60 | 767k | res | 61 | | } | 62 | 767k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Line | Count | Source | 54 | 19.5k | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 19.5k | Some(cx) => { | 57 | 19.5k | cx.reset(); | 58 | 19.5k | let res = f(&cx); | 59 | 19.5k | cell.set(Some(cx)); | 60 | 19.5k | res | 61 | | } | 62 | 19.5k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Line | Count | Source | 54 | 20.8k | .try_with(|cell| match cell.take() { | 55 | 20.8k | None => f(&Context::new())13 , | 56 | 20.8k | Some(cx) => { | 57 | 20.8k | cx.reset(); | 58 | 20.8k | let res = f(&cx); | 59 | 20.8k | cell.set(Some(cx)); | 60 | 20.8k | res | 61 | | } | 62 | 20.8k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 218 | .try_with(|cell| match cell.take() { | 55 | 218 | None => f(&Context::new())0 , | 56 | 218 | Some(cx) => { | 57 | 218 | cx.reset(); | 58 | 218 | let res = f(&cx); | 59 | 218 | cell.set(Some(cx)); | 60 | 218 | res | 61 | | } | 62 | 218 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<i32>>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<isize>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<isize>>>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | 5 | None => f(&Context::new())0 , | 56 | 5 | Some(cx) => { | 57 | 5 | cx.reset(); | 58 | 5 | let res = f(&cx); | 59 | 5 | cell.set(Some(cx)); | 60 | 5 | res | 61 | | } | 62 | 5 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<isize>>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<isize>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 14.5k | .try_with(|cell| match cell.take() { | 55 | 14.5k | None => f(&Context::new())13 , | 56 | 14.5k | Some(cx) => { | 57 | 14.5k | cx.reset(); | 58 | 14.5k | let res = f(&cx); | 59 | 14.5k | cell.set(Some(cx)); | 60 | 14.5k | res | 61 | | } | 62 | 14.5k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Line | Count | Source | 54 | 100 | .try_with(|cell| match cell.take() { | 55 | 100 | None => f(&Context::new())0 , | 56 | 100 | Some(cx) => { | 57 | 100 | cx.reset(); | 58 | 100 | let res = f(&cx); | 59 | 100 | cell.set(Some(cx)); | 60 | 100 | res | 61 | | } | 62 | 100 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 8 | .try_with(|cell| match cell.take() { | 55 | 8 | None => f(&Context::new())0 , | 56 | 8 | Some(cx) => { | 57 | 8 | cx.reset(); | 58 | 8 | let res = f(&cx); | 59 | 8 | cell.set(Some(cx)); | 60 | 8 | res | 61 | | } | 62 | 8 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<i32>>>>::{closure#1} Line | Count | Source | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | 5 | None => f(&Context::new())0 , | 56 | 5 | Some(cx) => { | 57 | 5 | cx.reset(); | 58 | 5 | let res = f(&cx); | 59 | 5 | cell.set(Some(cx)); | 60 | 5 | res | 61 | | } | 62 | 5 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<i32>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | 7 | None => f(&Context::new())0 , | 56 | 7 | Some(cx) => { | 57 | 7 | cx.reset(); | 58 | 7 | let res = f(&cx); | 59 | 7 | cell.set(Some(cx)); | 60 | 7 | res | 61 | | } | 62 | 7 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Line | Count | Source | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | 5 | None => f(&Context::new())0 , | 56 | 5 | Some(cx) => { | 57 | 5 | cx.reset(); | 58 | 5 | let res = f(&cx); | 59 | 5 | cell.set(Some(cx)); | 60 | 5 | res | 61 | | } | 62 | 5 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Line | Count | Source | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | 2 | None => f(&Context::new())0 , | 56 | 2 | Some(cx) => { | 57 | 2 | cx.reset(); | 58 | 2 | let res = f(&cx); | 59 | 2 | cell.set(Some(cx)); | 60 | 2 | res | 61 | | } | 62 | 2 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<array::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<array::drops::DropCounter>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<array::drops::DropCounter>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | 2 | None => f(&Context::new())0 , | 56 | 2 | Some(cx) => { | 57 | 2 | cx.reset(); | 58 | 2 | let res = f(&cx); | 59 | 2 | cell.set(Some(cx)); | 60 | 2 | res | 61 | | } | 62 | 2 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 641 | .try_with(|cell| match cell.take() { | 55 | 641 | None => f(&Context::new())0 , | 56 | 641 | Some(cx) => { | 57 | 641 | cx.reset(); | 58 | 641 | let res = f(&cx); | 59 | 641 | cell.set(Some(cx)); | 60 | 641 | res | 61 | | } | 62 | 641 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Line | Count | Source | 54 | 12 | .try_with(|cell| match cell.take() { | 55 | 12 | None => f(&Context::new())0 , | 56 | 12 | Some(cx) => { | 57 | 12 | cx.reset(); | 58 | 12 | let res = f(&cx); | 59 | 12 | cell.set(Some(cx)); | 60 | 12 | res | 61 | | } | 62 | 12 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<array::drops::DropCounter>>::recv::{closure#1}, core::result::Result<array::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 14 | .try_with(|cell| match cell.take() { | 55 | 14 | None => f(&Context::new())0 , | 56 | 14 | Some(cx) => { | 57 | 14 | cx.reset(); | 58 | 14 | let res = f(&cx); | 59 | 14 | cell.set(Some(cx)); | 60 | 14 | res | 61 | | } | 62 | 14 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<array::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 21 | .try_with(|cell| match cell.take() { | 55 | 21 | None => f(&Context::new())0 , | 56 | 21 | Some(cx) => { | 57 | 21 | cx.reset(); | 58 | 21 | let res = f(&cx); | 59 | 21 | cell.set(Some(cx)); | 60 | 21 | res | 61 | | } | 62 | 21 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<array::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 25 | .try_with(|cell| match cell.take() { | 55 | 25 | None => f(&Context::new())0 , | 56 | 25 | Some(cx) => { | 57 | 25 | cx.reset(); | 58 | 25 | let res = f(&cx); | 59 | 25 | cell.set(Some(cx)); | 60 | 25 | res | 61 | | } | 62 | 25 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<list::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 43 | .try_with(|cell| match cell.take() { | 55 | 43 | None => f(&Context::new())0 , | 56 | 43 | Some(cx) => { | 57 | 43 | cx.reset(); | 58 | 43 | let res = f(&cx); | 59 | 43 | cell.set(Some(cx)); | 60 | 43 | res | 61 | | } | 62 | 43 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<list::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<list::drops::DropCounter>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<list::drops::DropCounter>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1.76k | .try_with(|cell| match cell.take() { | 55 | 1.76k | None => f(&Context::new())0 , | 56 | 1.76k | Some(cx) => { | 57 | 1.76k | cx.reset(); | 58 | 1.76k | let res = f(&cx); | 59 | 1.76k | cell.set(Some(cx)); | 60 | 1.76k | res | 61 | | } | 62 | 1.76k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | 2 | None => f(&Context::new())0 , | 56 | 2 | Some(cx) => { | 57 | 2 | cx.reset(); | 58 | 2 | let res = f(&cx); | 59 | 2 | cell.set(Some(cx)); | 60 | 2 | res | 61 | | } | 62 | 2 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<list::drops::DropCounter>>::recv::{closure#1}, core::result::Result<list::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<list::drops::DropCounter>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i64>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Line | Count | Source | 54 | 17.1k | .try_with(|cell| match cell.take() { | 55 | 17.1k | None => f(&Context::new())0 , | 56 | 17.1k | Some(cx) => { | 57 | 17.1k | cx.reset(); | 58 | 17.1k | let res = f(&cx); | 59 | 17.1k | cell.set(Some(cx)); | 60 | 17.1k | res | 61 | | } | 62 | 17.1k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<u32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<bool>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u32>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i64>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::recv::{closure#1}, core::result::Result<alloc::string::String, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 23.4k | .try_with(|cell| match cell.take() { | 55 | 23.4k | None => f(&Context::new())3 , | 56 | 23.4k | Some(cx) => { | 57 | 23.4k | cx.reset(); | 58 | 23.4k | let res = f(&cx); | 59 | 23.4k | cell.set(Some(cx)); | 60 | 23.4k | res | 61 | | } | 62 | 23.4k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i64>>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 97 | .try_with(|cell| match cell.take() { | 55 | 97 | None => f(&Context::new())0 , | 56 | 97 | Some(cx) => { | 57 | 97 | cx.reset(); | 58 | 97 | let res = f(&cx); | 59 | 97 | cell.set(Some(cx)); | 60 | 97 | res | 61 | | } | 62 | 97 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any>>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::string::String>>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u8>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<u8>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u8>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i64>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 21.8k | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 21.8k | Some(cx) => { | 57 | 21.8k | cx.reset(); | 58 | 21.8k | let res = f(&cx); | 59 | 21.8k | cell.set(Some(cx)); | 60 | 21.8k | res | 61 | | } | 62 | 21.8k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::string::String>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::string::String>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u8>>::recv::{closure#1}, core::result::Result<u8, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 9.50k | .try_with(|cell| match cell.take() { | 55 | 9.50k | None => f(&Context::new())0 , | 56 | 9.50k | Some(cx) => { | 57 | 9.50k | cx.reset(); | 58 | 9.50k | let res = f(&cx); | 59 | 9.50k | cell.set(Some(cx)); | 60 | 9.50k | res | 61 | | } | 62 | 9.50k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any>>>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::recv::{closure#1}, core::result::Result<i64, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u8>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<u8>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<bool>>>::{closure#1} Line | Count | Source | 54 | 202 | .try_with(|cell| match cell.take() { | 55 | 202 | None => f(&Context::new())0 , | 56 | 202 | Some(cx) => { | 57 | 202 | cx.reset(); | 58 | 202 | let res = f(&cx); | 59 | 202 | cell.set(Some(cx)); | 60 | 202 | res | 61 | | } | 62 | 202 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::string::String>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<bool>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u32>>::recv::{closure#1}, core::result::Result<u32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::recv::{closure#1}, core::result::Result<bool, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 124 | .try_with(|cell| match cell.take() { | 55 | 124 | None => f(&Context::new())0 , | 56 | 124 | Some(cx) => { | 57 | 124 | cx.reset(); | 58 | 124 | let res = f(&cx); | 59 | 124 | cell.set(Some(cx)); | 60 | 124 | res | 61 | | } | 62 | 124 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<bool>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Line | Count | Source | 54 | 17.8k | .try_with(|cell| match cell.take() { | 55 | 17.8k | None => f(&Context::new())14 , | 56 | 17.8k | Some(cx) => { | 57 | 17.8k | cx.reset(); | 58 | 17.8k | let res = f(&cx); | 59 | 17.8k | cell.set(Some(cx)); | 60 | 17.8k | res | 61 | | } | 62 | 17.8k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 4 | .try_with(|cell| match cell.take() { | 55 | 4 | None => f(&Context::new())0 , | 56 | 4 | Some(cx) => { | 57 | 4 | cx.reset(); | 58 | 4 | let res = f(&cx); | 59 | 4 | cell.set(Some(cx)); | 60 | 4 | res | 61 | | } | 62 | 4 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Line | Count | Source | 54 | 108k | .try_with(|cell| match cell.take() { | 55 | 108k | None => f(&Context::new())13 , | 56 | 108k | Some(cx) => { | 57 | 108k | cx.reset(); | 58 | 108k | let res = f(&cx); | 59 | 108k | cell.set(Some(cx)); | 60 | 108k | res | 61 | | } | 62 | 108k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | 2 | None => f(&Context::new())0 , | 56 | 2 | Some(cx) => { | 57 | 2 | cx.reset(); | 58 | 2 | let res = f(&cx); | 59 | 2 | cell.set(Some(cx)); | 60 | 2 | res | 61 | | } | 62 | 2 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | 7 | None => f(&Context::new())0 , | 56 | 7 | Some(cx) => { | 57 | 7 | cx.reset(); | 58 | 7 | let res = f(&cx); | 59 | 7 | cell.set(Some(cx)); | 60 | 7 | res | 61 | | } | 62 | 7 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 689k | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 689k | Some(cx) => { | 57 | 689k | cx.reset(); | 58 | 689k | let res = f(&cx); | 59 | 689k | cell.set(Some(cx)); | 60 | 689k | res | 61 | | } | 62 | 689k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 29.8k | .try_with(|cell| match cell.take() { | 55 | 29.8k | None => f(&Context::new())0 , | 56 | 29.8k | Some(cx) => { | 57 | 29.8k | cx.reset(); | 58 | 29.8k | let res = f(&cx); | 59 | 29.8k | cell.set(Some(cx)); | 60 | 29.8k | res | 61 | | } | 62 | 29.8k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Line | Count | Source | 54 | 9.94k | .try_with(|cell| match cell.take() { | 55 | 9.94k | None => f(&Context::new())0 , | 56 | 9.94k | Some(cx) => { | 57 | 9.94k | cx.reset(); | 58 | 9.94k | let res = f(&cx); | 59 | 9.94k | cell.set(Some(cx)); | 60 | 9.94k | res | 61 | | } | 62 | 9.94k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 832 | .try_with(|cell| match cell.take() { | 55 | 832 | None => f(&Context::new())0 , | 56 | 832 | Some(cx) => { | 57 | 832 | cx.reset(); | 58 | 832 | let res = f(&cx); | 59 | 832 | cell.set(Some(cx)); | 60 | 832 | res | 61 | | } | 62 | 832 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>>::{closure#1} Line | Count | Source | 54 | 10.0k | .try_with(|cell| match cell.take() { | 55 | 10.0k | None => f(&Context::new())0 , | 56 | 10.0k | Some(cx) => { | 57 | 10.0k | cx.reset(); | 58 | 10.0k | let res = f(&cx); | 59 | 10.0k | cell.set(Some(cx)); | 60 | 10.0k | res | 61 | | } | 62 | 10.0k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 19.9k | .try_with(|cell| match cell.take() { | 55 | 19.9k | None => f(&Context::new())0 , | 56 | 19.9k | Some(cx) => { | 57 | 19.9k | cx.reset(); | 58 | 19.9k | let res = f(&cx); | 59 | 19.9k | cell.set(Some(cx)); | 60 | 19.9k | res | 61 | | } | 62 | 19.9k | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | 1 | None => f(&Context::new())0 , | 56 | 1 | Some(cx) => { | 57 | 1 | cx.reset(); | 58 | 1 | let res = f(&cx); | 59 | 1 | cell.set(Some(cx)); | 60 | 1 | res | 61 | | } | 62 | 1 | }) |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>>::{closure#1} Line | Count | Source | 54 | 3 | .try_with(|cell| match cell.take() { | 55 | 3 | None => f(&Context::new())0 , | 56 | 3 | Some(cx) => { | 57 | 3 | cx.reset(); | 58 | 3 | let res = f(&cx); | 59 | 3 | cell.set(Some(cx)); | 60 | 3 | res | 61 | | } | 62 | 3 | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>>::{closure#1} Line | Count | Source | 54 | 29.8k | .try_with(|cell| match cell.take() { | 55 | 18.4E | None => f(&Context::new()), | 56 | 29.8k | Some(cx) => { | 57 | 29.8k | cx.reset(); | 58 | 29.8k | let res = f(&cx); | 59 | 29.8k | cell.set(Some(cx)); | 60 | 29.8k | res | 61 | | } | 62 | 29.8k | }) |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()>::{closure#1} Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()>::{closure#1} <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>>::{closure#1} Line | Count | Source | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | 2 | None => f(&Context::new())0 , | 56 | 2 | Some(cx) => { | 57 | 2 | cx.reset(); | 58 | 2 | let res = f(&cx); | 59 | 2 | cell.set(Some(cx)); | 60 | 2 | res | 61 | | } | 62 | 2 | }) |
|
63 | 10.7M | .unwrap_or_else(|_| f(&Context::new())) |
64 | 10.7M | } Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<zero::drops::DropCounter>>> Line | Count | Source | 38 | 77.7k | pub fn with<F, R>(f: F) -> R | 39 | 77.7k | where | 40 | 77.7k | F: FnOnce(&Context) -> R, | 41 | 77.7k | { | 42 | 77.7k | thread_local! { | 43 | 77.7k | /// Cached thread-local context. | 44 | 77.7k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 77.7k | } | 46 | 77.7k | | 47 | 77.7k | let mut f = Some(f); | 48 | 77.7k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 77.7k | CONTEXT | 54 | 77.7k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 77.7k | }) | 63 | 77.7k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 77.7k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 111k | pub fn with<F, R>(f: F) -> R | 39 | 111k | where | 40 | 111k | F: FnOnce(&Context) -> R, | 41 | 111k | { | 42 | 111k | thread_local! { | 43 | 111k | /// Cached thread-local context. | 44 | 111k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 111k | } | 46 | 111k | | 47 | 111k | let mut f = Some(f); | 48 | 111k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 111k | CONTEXT | 54 | 111k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 111k | }) | 63 | 111k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 111k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<zero::drops::DropCounter>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<zero::drops::DropCounter>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Line | Count | Source | 38 | 7 | pub fn with<F, R>(f: F) -> R | 39 | 7 | where | 40 | 7 | F: FnOnce(&Context) -> R, | 41 | 7 | { | 42 | 7 | thread_local! { | 43 | 7 | /// Cached thread-local context. | 44 | 7 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 7 | } | 46 | 7 | | 47 | 7 | let mut f = Some(f); | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 7 | CONTEXT | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 7 | }) | 63 | 7 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 7 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 486 | pub fn with<F, R>(f: F) -> R | 39 | 486 | where | 40 | 486 | F: FnOnce(&Context) -> R, | 41 | 486 | { | 42 | 486 | thread_local! { | 43 | 486 | /// Cached thread-local context. | 44 | 486 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 486 | } | 46 | 486 | | 47 | 486 | let mut f = Some(f); | 48 | 486 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 486 | CONTEXT | 54 | 486 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 486 | }) | 63 | 486 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 486 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 1.00k | pub fn with<F, R>(f: F) -> R | 39 | 1.00k | where | 40 | 1.00k | F: FnOnce(&Context) -> R, | 41 | 1.00k | { | 42 | 1.00k | thread_local! { | 43 | 1.00k | /// Cached thread-local context. | 44 | 1.00k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1.00k | } | 46 | 1.00k | | 47 | 1.00k | let mut f = Some(f); | 48 | 1.00k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1.00k | CONTEXT | 54 | 1.00k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1.00k | }) | 63 | 1.00k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1.00k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>> Line | Count | Source | 38 | 507 | pub fn with<F, R>(f: F) -> R | 39 | 507 | where | 40 | 507 | F: FnOnce(&Context) -> R, | 41 | 507 | { | 42 | 507 | thread_local! { | 43 | 507 | /// Cached thread-local context. | 44 | 507 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 507 | } | 46 | 507 | | 47 | 507 | let mut f = Some(f); | 48 | 507 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 507 | CONTEXT | 54 | 507 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 507 | }) | 63 | 507 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 507 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 7 | pub fn with<F, R>(f: F) -> R | 39 | 7 | where | 40 | 7 | F: FnOnce(&Context) -> R, | 41 | 7 | { | 42 | 7 | thread_local! { | 43 | 7 | /// Cached thread-local context. | 44 | 7 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 7 | } | 46 | 7 | | 47 | 7 | let mut f = Some(f); | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 7 | CONTEXT | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 7 | }) | 63 | 7 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 7 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Line | Count | Source | 38 | 113k | pub fn with<F, R>(f: F) -> R | 39 | 113k | where | 40 | 113k | F: FnOnce(&Context) -> R, | 41 | 113k | { | 42 | 113k | thread_local! { | 43 | 113k | /// Cached thread-local context. | 44 | 113k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 113k | } | 46 | 113k | | 47 | 113k | let mut f = Some(f); | 48 | 113k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 113k | CONTEXT | 54 | 113k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 113k | }) | 63 | 113k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 113k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<zero::drops::DropCounter>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<zero::drops::DropCounter>>::recv::{closure#1}, core::result::Result<zero::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 77.3k | pub fn with<F, R>(f: F) -> R | 39 | 77.3k | where | 40 | 77.3k | F: FnOnce(&Context) -> R, | 41 | 77.3k | { | 42 | 77.3k | thread_local! { | 43 | 77.3k | /// Cached thread-local context. | 44 | 77.3k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 77.3k | } | 46 | 77.3k | | 47 | 77.3k | let mut f = Some(f); | 48 | 77.3k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 77.3k | CONTEXT | 54 | 77.3k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 77.3k | }) | 63 | 77.3k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 77.3k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 493 | pub fn with<F, R>(f: F) -> R | 39 | 493 | where | 40 | 493 | F: FnOnce(&Context) -> R, | 41 | 493 | { | 42 | 493 | thread_local! { | 43 | 493 | /// Cached thread-local context. | 44 | 493 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 493 | } | 46 | 493 | | 47 | 493 | let mut f = Some(f); | 48 | 493 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 493 | CONTEXT | 54 | 493 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 493 | }) | 63 | 493 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 493 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_select::{closure#0}, core::option::Option<(usize, *const u8)>> Line | Count | Source | 38 | 8.51M | pub fn with<F, R>(f: F) -> R | 39 | 8.51M | where | 40 | 8.51M | F: FnOnce(&Context) -> R, | 41 | 8.51M | { | 42 | 8.51M | thread_local! { | 43 | 8.51M | /// Cached thread-local context. | 44 | 8.51M | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 8.51M | } | 46 | 8.51M | | 47 | 8.51M | let mut f = Some(f); | 48 | 8.51M | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 8.51M | CONTEXT | 54 | 8.51M | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 8.51M | }) | 63 | 8.51M | .unwrap_or_else(|_| f(&Context::new())) | 64 | 8.51M | } |
<crossbeam_channel::context::Context>::with::<crossbeam_channel::select::run_ready::{closure#0}, core::option::Option<usize>> Line | Count | Source | 38 | 55 | pub fn with<F, R>(f: F) -> R | 39 | 55 | where | 40 | 55 | F: FnOnce(&Context) -> R, | 41 | 55 | { | 42 | 55 | thread_local! { | 43 | 55 | /// Cached thread-local context. | 44 | 55 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 55 | } | 46 | 55 | | 47 | 55 | let mut f = Some(f); | 48 | 55 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 55 | CONTEXT | 54 | 55 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 55 | }) | 63 | 55 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 55 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Line | Count | Source | 38 | 19.5k | pub fn with<F, R>(f: F) -> R | 39 | 19.5k | where | 40 | 19.5k | F: FnOnce(&Context) -> R, | 41 | 19.5k | { | 42 | 19.5k | thread_local! { | 43 | 19.5k | /// Cached thread-local context. | 44 | 19.5k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 19.5k | } | 46 | 19.5k | | 47 | 19.5k | let mut f = Some(f); | 48 | 19.5k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 19.5k | CONTEXT | 54 | 19.5k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 19.5k | }) | 63 | 19.5k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 19.5k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 765k | pub fn with<F, R>(f: F) -> R | 39 | 765k | where | 40 | 765k | F: FnOnce(&Context) -> R, | 41 | 765k | { | 42 | 765k | thread_local! { | 43 | 765k | /// Cached thread-local context. | 44 | 765k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 765k | } | 46 | 765k | | 47 | 765k | let mut f = Some(f); | 48 | 765k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 765k | CONTEXT | 54 | 765k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 765k | }) | 63 | 765k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 765k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Line | Count | Source | 38 | 31.1k | pub fn with<F, R>(f: F) -> R | 39 | 31.1k | where | 40 | 31.1k | F: FnOnce(&Context) -> R, | 41 | 31.1k | { | 42 | 31.1k | thread_local! { | 43 | 31.1k | /// Cached thread-local context. | 44 | 31.1k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 31.1k | } | 46 | 31.1k | | 47 | 31.1k | let mut f = Some(f); | 48 | 31.1k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 31.1k | CONTEXT | 54 | 31.1k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 31.1k | }) | 63 | 31.1k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 31.1k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 39.6k | pub fn with<F, R>(f: F) -> R | 39 | 39.6k | where | 40 | 39.6k | F: FnOnce(&Context) -> R, | 41 | 39.6k | { | 42 | 39.6k | thread_local! { | 43 | 39.6k | /// Cached thread-local context. | 44 | 39.6k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 39.6k | } | 46 | 39.6k | | 47 | 39.6k | let mut f = Some(f); | 48 | 39.6k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 39.6k | CONTEXT | 54 | 39.6k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 39.6k | }) | 63 | 39.6k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 39.6k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Line | Count | Source | 38 | 100 | pub fn with<F, R>(f: F) -> R | 39 | 100 | where | 40 | 100 | F: FnOnce(&Context) -> R, | 41 | 100 | { | 42 | 100 | thread_local! { | 43 | 100 | /// Cached thread-local context. | 44 | 100 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 100 | } | 46 | 100 | | 47 | 100 | let mut f = Some(f); | 48 | 100 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 100 | CONTEXT | 54 | 100 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 100 | }) | 63 | 100 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 100 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<isize>>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 14.5k | pub fn with<F, R>(f: F) -> R | 39 | 14.5k | where | 40 | 14.5k | F: FnOnce(&Context) -> R, | 41 | 14.5k | { | 42 | 14.5k | thread_local! { | 43 | 14.5k | /// Cached thread-local context. | 44 | 14.5k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 14.5k | } | 46 | 14.5k | | 47 | 14.5k | let mut f = Some(f); | 48 | 14.5k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 14.5k | CONTEXT | 54 | 14.5k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 14.5k | }) | 63 | 14.5k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 14.5k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<i32>, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 7 | pub fn with<F, R>(f: F) -> R | 39 | 7 | where | 40 | 7 | F: FnOnce(&Context) -> R, | 41 | 7 | { | 42 | 7 | thread_local! { | 43 | 7 | /// Cached thread-local context. | 44 | 7 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 7 | } | 46 | 7 | | 47 | 7 | let mut f = Some(f); | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 7 | CONTEXT | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 7 | }) | 63 | 7 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 7 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Line | Count | Source | 38 | 20.7k | pub fn with<F, R>(f: F) -> R | 39 | 20.7k | where | 40 | 20.7k | F: FnOnce(&Context) -> R, | 41 | 20.7k | { | 42 | 20.7k | thread_local! { | 43 | 20.7k | /// Cached thread-local context. | 44 | 20.7k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 20.7k | } | 46 | 20.7k | | 47 | 20.7k | let mut f = Some(f); | 48 | 20.7k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 20.7k | CONTEXT | 54 | 20.7k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 20.7k | }) | 63 | 20.7k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 20.7k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<i32>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<isize>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<isize>>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 218 | pub fn with<F, R>(f: F) -> R | 39 | 218 | where | 40 | 218 | F: FnOnce(&Context) -> R, | 41 | 218 | { | 42 | 218 | thread_local! { | 43 | 218 | /// Cached thread-local context. | 44 | 218 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 218 | } | 46 | 218 | | 47 | 218 | let mut f = Some(f); | 48 | 218 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 218 | CONTEXT | 54 | 218 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 218 | }) | 63 | 218 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 218 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 5 | pub fn with<F, R>(f: F) -> R | 39 | 5 | where | 40 | 5 | F: FnOnce(&Context) -> R, | 41 | 5 | { | 42 | 5 | thread_local! { | 43 | 5 | /// Cached thread-local context. | 44 | 5 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 5 | } | 46 | 5 | | 47 | 5 | let mut f = Some(f); | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 5 | CONTEXT | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 5 | }) | 63 | 5 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 5 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<isize>, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<isize>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<i32>>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<i32>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<i32>>>> Line | Count | Source | 38 | 5 | pub fn with<F, R>(f: F) -> R | 39 | 5 | where | 40 | 5 | F: FnOnce(&Context) -> R, | 41 | 5 | { | 42 | 5 | thread_local! { | 43 | 5 | /// Cached thread-local context. | 44 | 5 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 5 | } | 46 | 5 | | 47 | 5 | let mut f = Some(f); | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 5 | CONTEXT | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 5 | }) | 63 | 5 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 5 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 8 | pub fn with<F, R>(f: F) -> R | 39 | 8 | where | 40 | 8 | F: FnOnce(&Context) -> R, | 41 | 8 | { | 42 | 8 | thread_local! { | 43 | 8 | /// Cached thread-local context. | 44 | 8 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 8 | } | 46 | 8 | | 47 | 8 | let mut f = Some(f); | 48 | 8 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 8 | CONTEXT | 54 | 8 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 8 | }) | 63 | 8 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 8 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> Line | Count | Source | 38 | 5 | pub fn with<F, R>(f: F) -> R | 39 | 5 | where | 40 | 5 | F: FnOnce(&Context) -> R, | 41 | 5 | { | 42 | 5 | thread_local! { | 43 | 5 | /// Cached thread-local context. | 44 | 5 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 5 | } | 46 | 5 | | 47 | 5 | let mut f = Some(f); | 48 | 5 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 5 | CONTEXT | 54 | 5 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 5 | }) | 63 | 5 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 5 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 2 | pub fn with<F, R>(f: F) -> R | 39 | 2 | where | 40 | 2 | F: FnOnce(&Context) -> R, | 41 | 2 | { | 42 | 2 | thread_local! { | 43 | 2 | /// Cached thread-local context. | 44 | 2 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 2 | } | 46 | 2 | | 47 | 2 | let mut f = Some(f); | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 2 | CONTEXT | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 2 | }) | 63 | 2 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 2 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 14 | pub fn with<F, R>(f: F) -> R | 39 | 14 | where | 40 | 14 | F: FnOnce(&Context) -> R, | 41 | 14 | { | 42 | 14 | thread_local! { | 43 | 14 | /// Cached thread-local context. | 44 | 14 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 14 | } | 46 | 14 | | 47 | 14 | let mut f = Some(f); | 48 | 14 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 14 | CONTEXT | 54 | 14 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 14 | }) | 63 | 14 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 14 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Line | Count | Source | 38 | 2 | pub fn with<F, R>(f: F) -> R | 39 | 2 | where | 40 | 2 | F: FnOnce(&Context) -> R, | 41 | 2 | { | 42 | 2 | thread_local! { | 43 | 2 | /// Cached thread-local context. | 44 | 2 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 2 | } | 46 | 2 | | 47 | 2 | let mut f = Some(f); | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 2 | CONTEXT | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 2 | }) | 63 | 2 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<array::drops::DropCounter>>::recv::{closure#1}, core::result::Result<array::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<array::drops::DropCounter>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 21 | pub fn with<F, R>(f: F) -> R | 39 | 21 | where | 40 | 21 | F: FnOnce(&Context) -> R, | 41 | 21 | { | 42 | 21 | thread_local! { | 43 | 21 | /// Cached thread-local context. | 44 | 21 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 21 | } | 46 | 21 | | 47 | 21 | let mut f = Some(f); | 48 | 21 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 21 | CONTEXT | 54 | 21 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 21 | }) | 63 | 21 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 21 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<array::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<array::drops::DropCounter>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<array::drops::DropCounter>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<array::drops::DropCounter>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Line | Count | Source | 38 | 12 | pub fn with<F, R>(f: F) -> R | 39 | 12 | where | 40 | 12 | F: FnOnce(&Context) -> R, | 41 | 12 | { | 42 | 12 | thread_local! { | 43 | 12 | /// Cached thread-local context. | 44 | 12 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 12 | } | 46 | 12 | | 47 | 12 | let mut f = Some(f); | 48 | 12 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 12 | CONTEXT | 54 | 12 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 12 | }) | 63 | 12 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 12 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 641 | pub fn with<F, R>(f: F) -> R | 39 | 641 | where | 40 | 641 | F: FnOnce(&Context) -> R, | 41 | 641 | { | 42 | 641 | thread_local! { | 43 | 641 | /// Cached thread-local context. | 44 | 641 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 641 | } | 46 | 641 | | 47 | 641 | let mut f = Some(f); | 48 | 641 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 641 | CONTEXT | 54 | 641 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 641 | }) | 63 | 641 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 641 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 2 | pub fn with<F, R>(f: F) -> R | 39 | 2 | where | 40 | 2 | F: FnOnce(&Context) -> R, | 41 | 2 | { | 42 | 2 | thread_local! { | 43 | 2 | /// Cached thread-local context. | 44 | 2 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 2 | } | 46 | 2 | | 47 | 2 | let mut f = Some(f); | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 2 | CONTEXT | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 2 | }) | 63 | 2 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<list::drops::DropCounter>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<list::drops::DropCounter>>::recv::{closure#1}, core::result::Result<list::drops::DropCounter, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<list::drops::DropCounter>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<list::drops::DropCounter>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 43 | pub fn with<F, R>(f: F) -> R | 39 | 43 | where | 40 | 43 | F: FnOnce(&Context) -> R, | 41 | 43 | { | 42 | 43 | thread_local! { | 43 | 43 | /// Cached thread-local context. | 44 | 43 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 43 | } | 46 | 43 | | 47 | 43 | let mut f = Some(f); | 48 | 43 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 43 | CONTEXT | 54 | 43 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 43 | }) | 63 | 43 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 43 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1.76k | pub fn with<F, R>(f: F) -> R | 39 | 1.76k | where | 40 | 1.76k | F: FnOnce(&Context) -> R, | 41 | 1.76k | { | 42 | 1.76k | thread_local! { | 43 | 1.76k | /// Cached thread-local context. | 44 | 1.76k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1.76k | } | 46 | 1.76k | | 47 | 1.76k | let mut f = Some(f); | 48 | 1.76k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1.76k | CONTEXT | 54 | 1.76k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1.76k | }) | 63 | 1.76k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1.76k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<list::drops::DropCounter>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<list::drops::DropCounter>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 25 | pub fn with<F, R>(f: F) -> R | 39 | 25 | where | 40 | 25 | F: FnOnce(&Context) -> R, | 41 | 25 | { | 42 | 25 | thread_local! { | 43 | 25 | /// Cached thread-local context. | 44 | 25 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 25 | } | 46 | 25 | | 47 | 25 | let mut f = Some(f); | 48 | 25 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 25 | CONTEXT | 54 | 25 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 25 | }) | 63 | 25 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 25 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i64>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any>>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<bool>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<std::time::Instant>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 21.8k | pub fn with<F, R>(f: F) -> R | 39 | 21.8k | where | 40 | 21.8k | F: FnOnce(&Context) -> R, | 41 | 21.8k | { | 42 | 21.8k | thread_local! { | 43 | 21.8k | /// Cached thread-local context. | 44 | 21.8k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 21.8k | } | 46 | 21.8k | | 47 | 21.8k | let mut f = Some(f); | 48 | 21.8k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 21.8k | CONTEXT | 54 | 21.8k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 21.8k | }) | 63 | 21.8k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 21.8k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<std::time::Instant>>::recv::{closure#1}, core::result::Result<std::time::Instant, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u8>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<bool>>> Line | Count | Source | 38 | 202 | pub fn with<F, R>(f: F) -> R | 39 | 202 | where | 40 | 202 | F: FnOnce(&Context) -> R, | 41 | 202 | { | 42 | 202 | thread_local! { | 43 | 202 | /// Cached thread-local context. | 44 | 202 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 202 | } | 46 | 202 | | 47 | 202 | let mut f = Some(f); | 48 | 202 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 202 | CONTEXT | 54 | 202 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 202 | }) | 63 | 202 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 202 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<bool>>::recv::{closure#1}, core::result::Result<bool, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 124 | pub fn with<F, R>(f: F) -> R | 39 | 124 | where | 40 | 124 | F: FnOnce(&Context) -> R, | 41 | 124 | { | 42 | 124 | thread_local! { | 43 | 124 | /// Cached thread-local context. | 44 | 124 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 124 | } | 46 | 124 | | 47 | 124 | let mut f = Some(f); | 48 | 124 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 124 | CONTEXT | 54 | 124 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 124 | }) | 63 | 124 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 124 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<u8>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<std::time::Instant>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::recv::{closure#1}, core::result::Result<alloc::string::String, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u8>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::string::String>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> Line | Count | Source | 38 | 17.0k | pub fn with<F, R>(f: F) -> R | 39 | 17.0k | where | 40 | 17.0k | F: FnOnce(&Context) -> R, | 41 | 17.0k | { | 42 | 17.0k | thread_local! { | 43 | 17.0k | /// Cached thread-local context. | 44 | 17.0k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 17.0k | } | 46 | 17.0k | | 47 | 17.0k | let mut f = Some(f); | 48 | 17.0k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 17.0k | CONTEXT | 54 | 17.0k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 17.0k | }) | 63 | 17.0k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 17.0k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u8>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<u8>>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 23.4k | pub fn with<F, R>(f: F) -> R | 39 | 23.4k | where | 40 | 23.4k | F: FnOnce(&Context) -> R, | 41 | 23.4k | { | 42 | 23.4k | thread_local! { | 43 | 23.4k | /// Cached thread-local context. | 44 | 23.4k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 23.4k | } | 46 | 23.4k | | 47 | 23.4k | let mut f = Some(f); | 48 | 23.4k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 23.4k | CONTEXT | 54 | 23.4k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 23.4k | }) | 63 | 23.4k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 23.4k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 97 | pub fn with<F, R>(f: F) -> R | 39 | 97 | where | 40 | 97 | F: FnOnce(&Context) -> R, | 41 | 97 | { | 42 | 97 | thread_local! { | 43 | 97 | /// Cached thread-local context. | 44 | 97 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 97 | } | 46 | 97 | | 47 | 97 | let mut f = Some(f); | 48 | 97 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 97 | CONTEXT | 54 | 97 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 97 | }) | 63 | 97 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 97 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i64>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::string::String>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::string::String>>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Line | Count | Source | 38 | 17.8k | pub fn with<F, R>(f: F) -> R | 39 | 17.8k | where | 40 | 17.8k | F: FnOnce(&Context) -> R, | 41 | 17.8k | { | 42 | 17.8k | thread_local! { | 43 | 17.8k | /// Cached thread-local context. | 44 | 17.8k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 17.8k | } | 46 | 17.8k | | 47 | 17.8k | let mut f = Some(f); | 48 | 17.8k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 17.8k | CONTEXT | 54 | 17.8k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 17.8k | }) | 63 | 17.8k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 17.8k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::string::String>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i64>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any>>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<alloc::boxed::Box<dyn core::any::Any>>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u32>>::recv::{closure#1}, core::result::Result<u32, crossbeam_channel::err::RecvTimeoutError>> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<bool>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<u32>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i64>>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<bool>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<u32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::string::String>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i64>>::recv::{closure#1}, core::result::Result<i64, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<u8>>::recv::{closure#1}, core::result::Result<u8, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 9.50k | pub fn with<F, R>(f: F) -> R | 39 | 9.50k | where | 40 | 9.50k | F: FnOnce(&Context) -> R, | 41 | 9.50k | { | 42 | 9.50k | thread_local! { | 43 | 9.50k | /// Cached thread-local context. | 44 | 9.50k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 9.50k | } | 46 | 9.50k | | 47 | 9.50k | let mut f = Some(f); | 48 | 9.50k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 9.50k | CONTEXT | 54 | 9.50k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 9.50k | }) | 63 | 9.50k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 9.50k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, core::result::Result<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 832 | pub fn with<F, R>(f: F) -> R | 39 | 832 | where | 40 | 832 | F: FnOnce(&Context) -> R, | 41 | 832 | { | 42 | 832 | thread_local! { | 43 | 832 | /// Cached thread-local context. | 44 | 832 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 832 | } | 46 | 832 | | 47 | 832 | let mut f = Some(f); | 48 | 832 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 832 | CONTEXT | 54 | 832 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 832 | }) | 63 | 832 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 832 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Line | Count | Source | 38 | 9.94k | pub fn with<F, R>(f: F) -> R | 39 | 9.94k | where | 40 | 9.94k | F: FnOnce(&Context) -> R, | 41 | 9.94k | { | 42 | 9.94k | thread_local! { | 43 | 9.94k | /// Cached thread-local context. | 44 | 9.94k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 9.94k | } | 46 | 9.94k | | 47 | 9.94k | let mut f = Some(f); | 48 | 9.94k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 9.94k | CONTEXT | 54 | 9.94k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 9.94k | }) | 63 | 9.94k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 9.94k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Line | Count | Source | 38 | 108k | pub fn with<F, R>(f: F) -> R | 39 | 108k | where | 40 | 108k | F: FnOnce(&Context) -> R, | 41 | 108k | { | 42 | 108k | thread_local! { | 43 | 108k | /// Cached thread-local context. | 44 | 108k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 108k | } | 46 | 108k | | 47 | 108k | let mut f = Some(f); | 48 | 108k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 108k | CONTEXT | 54 | 108k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 108k | }) | 63 | 108k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 108k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 4 | pub fn with<F, R>(f: F) -> R | 39 | 4 | where | 40 | 4 | F: FnOnce(&Context) -> R, | 41 | 4 | { | 42 | 4 | thread_local! { | 43 | 4 | /// Cached thread-local context. | 44 | 4 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 4 | } | 46 | 4 | | 47 | 4 | let mut f = Some(f); | 48 | 4 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 4 | CONTEXT | 54 | 4 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 4 | }) | 63 | 4 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 4 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 29.8k | pub fn with<F, R>(f: F) -> R | 39 | 29.8k | where | 40 | 29.8k | F: FnOnce(&Context) -> R, | 41 | 29.8k | { | 42 | 29.8k | thread_local! { | 43 | 29.8k | /// Cached thread-local context. | 44 | 29.8k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 29.8k | } | 46 | 29.8k | | 47 | 29.8k | let mut f = Some(f); | 48 | 29.8k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 29.8k | CONTEXT | 54 | 29.8k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 29.8k | }) | 63 | 29.8k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 29.8k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 687k | pub fn with<F, R>(f: F) -> R | 39 | 687k | where | 40 | 687k | F: FnOnce(&Context) -> R, | 41 | 687k | { | 42 | 687k | thread_local! { | 43 | 687k | /// Cached thread-local context. | 44 | 687k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 687k | } | 46 | 687k | | 47 | 687k | let mut f = Some(f); | 48 | 687k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 687k | CONTEXT | 54 | 687k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 687k | }) | 63 | 687k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 687k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 2 | pub fn with<F, R>(f: F) -> R | 39 | 2 | where | 40 | 2 | F: FnOnce(&Context) -> R, | 41 | 2 | { | 42 | 2 | thread_local! { | 43 | 2 | /// Cached thread-local context. | 44 | 2 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 2 | } | 46 | 2 | | 47 | 2 | let mut f = Some(f); | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 2 | CONTEXT | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 2 | }) | 63 | 2 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 2 | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 7 | pub fn with<F, R>(f: F) -> R | 39 | 7 | where | 40 | 7 | F: FnOnce(&Context) -> R, | 41 | 7 | { | 42 | 7 | thread_local! { | 43 | 7 | /// Cached thread-local context. | 44 | 7 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 7 | } | 46 | 7 | | 47 | 7 | let mut f = Some(f); | 48 | 7 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 7 | CONTEXT | 54 | 7 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 7 | }) | 63 | 7 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 7 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<alloc::boxed::Box<dyn core::any::Any + core::marker::Send>>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<usize>>> Line | Count | Source | 38 | 10.0k | pub fn with<F, R>(f: F) -> R | 39 | 10.0k | where | 40 | 10.0k | F: FnOnce(&Context) -> R, | 41 | 10.0k | { | 42 | 10.0k | thread_local! { | 43 | 10.0k | /// Cached thread-local context. | 44 | 10.0k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 10.0k | } | 46 | 10.0k | | 47 | 10.0k | let mut f = Some(f); | 48 | 10.0k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 10.0k | CONTEXT | 54 | 10.0k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 10.0k | }) | 63 | 10.0k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 10.0k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<i32>>> Line | Count | Source | 38 | 2 | pub fn with<F, R>(f: F) -> R | 39 | 2 | where | 40 | 2 | F: FnOnce(&Context) -> R, | 41 | 2 | { | 42 | 2 | thread_local! { | 43 | 2 | /// Cached thread-local context. | 44 | 2 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 2 | } | 46 | 2 | | 47 | 2 | let mut f = Some(f); | 48 | 2 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 2 | CONTEXT | 54 | 2 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 2 | }) | 63 | 2 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<usize>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::recv::{closure#1}, core::result::Result<(), crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 19.9k | pub fn with<F, R>(f: F) -> R | 39 | 19.9k | where | 40 | 19.9k | F: FnOnce(&Context) -> R, | 41 | 19.9k | { | 42 | 19.9k | thread_local! { | 43 | 19.9k | /// Cached thread-local context. | 44 | 19.9k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 19.9k | } | 46 | 19.9k | | 47 | 19.9k | let mut f = Some(f); | 48 | 19.9k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 19.9k | CONTEXT | 54 | 19.9k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 19.9k | }) | 63 | 19.9k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 19.9k | } |
<crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<()>>::send::{closure#0}, core::result::Result<(), crossbeam_channel::err::SendTimeoutError<()>>> Line | Count | Source | 38 | 3 | pub fn with<F, R>(f: F) -> R | 39 | 3 | where | 40 | 3 | F: FnOnce(&Context) -> R, | 41 | 3 | { | 42 | 3 | thread_local! { | 43 | 3 | /// Cached thread-local context. | 44 | 3 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 3 | } | 46 | 3 | | 47 | 3 | let mut f = Some(f); | 48 | 3 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 3 | CONTEXT | 54 | 3 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 3 | }) | 63 | 3 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 3 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::recv::{closure#1}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<usize>>::recv::{closure#1}, core::result::Result<usize, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 29.8k | pub fn with<F, R>(f: F) -> R | 39 | 29.8k | where | 40 | 29.8k | F: FnOnce(&Context) -> R, | 41 | 29.8k | { | 42 | 29.8k | thread_local! { | 43 | 29.8k | /// Cached thread-local context. | 44 | 29.8k | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 29.8k | } | 46 | 29.8k | | 47 | 29.8k | let mut f = Some(f); | 48 | 29.8k | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 29.8k | CONTEXT | 54 | 29.8k | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 29.8k | }) | 63 | 29.8k | .unwrap_or_else(|_| f(&Context::new())) | 64 | 29.8k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<()>>::recv::{closure#1}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::list::Channel<i32>>::recv::{closure#1}, ()> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<i32>>::send::{closure#0}, ()> <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::zero::Channel<i32>>::recv::{closure#1}, core::result::Result<i32, crossbeam_channel::err::RecvTimeoutError>> Line | Count | Source | 38 | 1 | pub fn with<F, R>(f: F) -> R | 39 | 1 | where | 40 | 1 | F: FnOnce(&Context) -> R, | 41 | 1 | { | 42 | 1 | thread_local! { | 43 | 1 | /// Cached thread-local context. | 44 | 1 | static CONTEXT: Cell<Option<Context>> = Cell::new(Some(Context::new())); | 45 | 1 | } | 46 | 1 | | 47 | 1 | let mut f = Some(f); | 48 | 1 | let mut f = move |cx: &Context| -> R { | 49 | | let f = f.take().unwrap(); | 50 | | f(cx) | 51 | | }; | 52 | | | 53 | 1 | CONTEXT | 54 | 1 | .try_with(|cell| match cell.take() { | 55 | | None => f(&Context::new()), | 56 | | Some(cx) => { | 57 | | cx.reset(); | 58 | | let res = f(&cx); | 59 | | cell.set(Some(cx)); | 60 | | res | 61 | | } | 62 | 1 | }) | 63 | 1 | .unwrap_or_else(|_| f(&Context::new())) | 64 | 1 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<()>>::send::{closure#0}, ()> Unexecuted instantiation: <crossbeam_channel::context::Context>::with::<<crossbeam_channel::flavors::array::Channel<usize>>::recv::{closure#1}, ()> |
65 | | |
66 | | /// Creates a new `Context`. |
67 | | #[cold] |
68 | 4.68k | fn new() -> Context { |
69 | 4.68k | Context { |
70 | 4.68k | inner: Arc::new(Inner { |
71 | 4.68k | select: AtomicUsize::new(Selected::Waiting.into()), |
72 | 4.68k | packet: AtomicUsize::new(0), |
73 | 4.68k | thread: thread::current(), |
74 | 4.68k | thread_id: thread::current().id(), |
75 | 4.68k | }), |
76 | 4.68k | } |
77 | 4.68k | } |
78 | | |
79 | | /// Resets `select` and `packet`. |
80 | | #[inline] |
81 | 10.7M | fn reset(&self) { |
82 | 10.7M | self.inner |
83 | 10.7M | .select |
84 | 10.7M | .store(Selected::Waiting.into(), Ordering::Release); |
85 | 10.7M | self.inner.packet.store(0, Ordering::Release); |
86 | 10.7M | } <crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 372k | fn reset(&self) { | 82 | 372k | self.inner | 83 | 372k | .select | 84 | 372k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 372k | self.inner.packet.store(0, Ordering::Release); | 86 | 372k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 8.51M | fn reset(&self) { | 82 | 8.51M | self.inner | 83 | 8.51M | .select | 84 | 8.51M | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 8.51M | self.inner.packet.store(0, Ordering::Release); | 86 | 8.51M | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 855k | fn reset(&self) { | 82 | 855k | self.inner | 83 | 855k | .select | 84 | 855k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 855k | self.inner.packet.store(0, Ordering::Release); | 86 | 855k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 34.9k | fn reset(&self) { | 82 | 34.9k | self.inner | 83 | 34.9k | .select | 84 | 34.9k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 34.9k | self.inner.packet.store(0, Ordering::Release); | 86 | 34.9k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 697 | fn reset(&self) { | 82 | 697 | self.inner | 83 | 697 | .select | 84 | 697 | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 697 | self.inner.packet.store(0, Ordering::Release); | 86 | 697 | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 2 | fn reset(&self) { | 82 | 2 | self.inner | 83 | 2 | .select | 84 | 2 | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 2 | self.inner.packet.store(0, Ordering::Release); | 86 | 2 | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 1.83k | fn reset(&self) { | 82 | 1.83k | self.inner | 83 | 1.83k | .select | 84 | 1.83k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 1.83k | self.inner.packet.store(0, Ordering::Release); | 86 | 1.83k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 89.9k | fn reset(&self) { | 82 | 89.9k | self.inner | 83 | 89.9k | .select | 84 | 89.9k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 89.9k | self.inner.packet.store(0, Ordering::Release); | 86 | 89.9k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 836k | fn reset(&self) { | 82 | 836k | self.inner | 83 | 836k | .select | 84 | 836k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 836k | self.inner.packet.store(0, Ordering::Release); | 86 | 836k | } |
<crossbeam_channel::context::Context>::reset Line | Count | Source | 81 | 59.0k | fn reset(&self) { | 82 | 59.0k | self.inner | 83 | 59.0k | .select | 84 | 59.0k | .store(Selected::Waiting.into(), Ordering::Release); | 85 | 59.0k | self.inner.packet.store(0, Ordering::Release); | 86 | 59.0k | } |
|
87 | | |
88 | | /// Attempts to select an operation. |
89 | | /// |
90 | | /// On failure, the previously selected operation is returned. |
91 | | #[inline] |
92 | 10.8M | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { |
93 | 10.8M | self.inner |
94 | 10.8M | .select |
95 | 10.8M | .compare_exchange( |
96 | 10.8M | Selected::Waiting.into(), |
97 | 10.8M | select.into(), |
98 | 10.8M | Ordering::AcqRel, |
99 | 10.8M | Ordering::Acquire, |
100 | 10.8M | ) |
101 | 10.8M | .map(|_| ()10.7M ) |
102 | 10.8M | .map_err(|e| e.into()18.3k ) |
103 | 10.8M | } <crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 401k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 401k | self.inner | 94 | 401k | .select | 95 | 401k | .compare_exchange( | 96 | 401k | Selected::Waiting.into(), | 97 | 401k | select.into(), | 98 | 401k | Ordering::AcqRel, | 99 | 401k | Ordering::Acquire, | 100 | 401k | ) | 101 | 401k | .map(|_| ()) | 102 | 401k | .map_err(|e| e.into()) | 103 | 401k | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 8.45M | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 8.45M | self.inner | 94 | 8.45M | .select | 95 | 8.45M | .compare_exchange( | 96 | 8.45M | Selected::Waiting.into(), | 97 | 8.45M | select.into(), | 98 | 8.45M | Ordering::AcqRel, | 99 | 8.45M | Ordering::Acquire, | 100 | 8.45M | ) | 101 | 8.45M | .map(|_| ()) | 102 | 8.45M | .map_err(|e| e.into()) | 103 | 8.45M | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 862k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 862k | self.inner | 94 | 862k | .select | 95 | 862k | .compare_exchange( | 96 | 862k | Selected::Waiting.into(), | 97 | 862k | select.into(), | 98 | 862k | Ordering::AcqRel, | 99 | 862k | Ordering::Acquire, | 100 | 862k | ) | 101 | 862k | .map(|_| ()) | 102 | 862k | .map_err(|e| e.into()) | 103 | 862k | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 38.1k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 38.1k | self.inner | 94 | 38.1k | .select | 95 | 38.1k | .compare_exchange( | 96 | 38.1k | Selected::Waiting.into(), | 97 | 38.1k | select.into(), | 98 | 38.1k | Ordering::AcqRel, | 99 | 38.1k | Ordering::Acquire, | 100 | 38.1k | ) | 101 | 38.1k | .map(|_| ()) | 102 | 38.1k | .map_err(|e| e.into()) | 103 | 38.1k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select <crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 856 | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 856 | self.inner | 94 | 856 | .select | 95 | 856 | .compare_exchange( | 96 | 856 | Selected::Waiting.into(), | 97 | 856 | select.into(), | 98 | 856 | Ordering::AcqRel, | 99 | 856 | Ordering::Acquire, | 100 | 856 | ) | 101 | 856 | .map(|_| ()) | 102 | 856 | .map_err(|e| e.into()) | 103 | 856 | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 2 | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 2 | self.inner | 94 | 2 | .select | 95 | 2 | .compare_exchange( | 96 | 2 | Selected::Waiting.into(), | 97 | 2 | select.into(), | 98 | 2 | Ordering::AcqRel, | 99 | 2 | Ordering::Acquire, | 100 | 2 | ) | 101 | 2 | .map(|_| ()) | 102 | 2 | .map_err(|e| e.into()) | 103 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select Unexecuted instantiation: <crossbeam_channel::context::Context>::try_select <crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 2.13k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 2.13k | self.inner | 94 | 2.13k | .select | 95 | 2.13k | .compare_exchange( | 96 | 2.13k | Selected::Waiting.into(), | 97 | 2.13k | select.into(), | 98 | 2.13k | Ordering::AcqRel, | 99 | 2.13k | Ordering::Acquire, | 100 | 2.13k | ) | 101 | 2.13k | .map(|_| ()) | 102 | 2.13k | .map_err(|e| e.into()) | 103 | 2.13k | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 127k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 127k | self.inner | 94 | 127k | .select | 95 | 127k | .compare_exchange( | 96 | 127k | Selected::Waiting.into(), | 97 | 127k | select.into(), | 98 | 127k | Ordering::AcqRel, | 99 | 127k | Ordering::Acquire, | 100 | 127k | ) | 101 | 127k | .map(|_| ()) | 102 | 127k | .map_err(|e| e.into()) | 103 | 127k | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 840k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 840k | self.inner | 94 | 840k | .select | 95 | 840k | .compare_exchange( | 96 | 840k | Selected::Waiting.into(), | 97 | 840k | select.into(), | 98 | 840k | Ordering::AcqRel, | 99 | 840k | Ordering::Acquire, | 100 | 840k | ) | 101 | 840k | .map(|_| ()) | 102 | 840k | .map_err(|e| e.into()) | 103 | 840k | } |
<crossbeam_channel::context::Context>::try_select Line | Count | Source | 92 | 75.6k | pub fn try_select(&self, select: Selected) -> Result<(), Selected> { | 93 | 75.6k | self.inner | 94 | 75.6k | .select | 95 | 75.6k | .compare_exchange( | 96 | 75.6k | Selected::Waiting.into(), | 97 | 75.6k | select.into(), | 98 | 75.6k | Ordering::AcqRel, | 99 | 75.6k | Ordering::Acquire, | 100 | 75.6k | ) | 101 | 75.6k | .map(|_| ()) | 102 | 75.6k | .map_err(|e| e.into()) | 103 | 75.6k | } |
|
104 | | |
105 | | /// Returns the selected operation. |
106 | | #[inline] |
107 | 8.64M | pub fn selected(&self) -> Selected { |
108 | 8.64M | Selected::from(self.inner.select.load(Ordering::Acquire)) |
109 | 8.64M | } <crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 13.1k | pub fn selected(&self) -> Selected { | 108 | 13.1k | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 13.1k | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 8.55M | pub fn selected(&self) -> Selected { | 108 | 8.55M | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 8.55M | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 3.08k | pub fn selected(&self) -> Selected { | 108 | 3.08k | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 3.08k | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 1 | pub fn selected(&self) -> Selected { | 108 | 1 | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 1 | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 13.1k | pub fn selected(&self) -> Selected { | 108 | 13.1k | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 13.1k | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 3.73k | pub fn selected(&self) -> Selected { | 108 | 3.73k | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 3.73k | } |
<crossbeam_channel::context::Context>::selected Line | Count | Source | 107 | 55.9k | pub fn selected(&self) -> Selected { | 108 | 55.9k | Selected::from(self.inner.select.load(Ordering::Acquire)) | 109 | 55.9k | } |
|
110 | | |
111 | | /// Stores a packet. |
112 | | /// |
113 | | /// This method must be called after `try_select` succeeds and there is a packet to provide. |
114 | | #[inline] |
115 | 2.31M | pub fn store_packet(&self, packet: usize) { |
116 | 2.31M | if packet != 0 { |
117 | 2.27M | self.inner.packet.store(packet, Ordering::Release); |
118 | 2.27M | }42.9k |
119 | 2.31M | } <crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 397k | pub fn store_packet(&self, packet: usize) { | 116 | 397k | if packet != 0 { | 117 | 395k | self.inner.packet.store(packet, Ordering::Release); | 118 | 395k | }1.57k | 119 | 397k | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 861k | pub fn store_packet(&self, packet: usize) { | 116 | 861k | if packet != 0 { | 117 | 860k | self.inner.packet.store(packet, Ordering::Release); | 118 | 860k | }897 | 119 | 861k | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 37.4k | pub fn store_packet(&self, packet: usize) { | 116 | 37.4k | if packet != 0 { | 117 | 35.3k | self.inner.packet.store(packet, Ordering::Release); | 118 | 35.3k | }2.08k | 119 | 37.4k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::store_packet <crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 121 | pub fn store_packet(&self, packet: usize) { | 116 | 121 | if packet != 0 { | 117 | 0 | self.inner.packet.store(packet, Ordering::Release); | 118 | 121 | } | 119 | 121 | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 2 | pub fn store_packet(&self, packet: usize) { | 116 | 2 | if packet != 0 { | 117 | 0 | self.inner.packet.store(packet, Ordering::Release); | 118 | 2 | } | 119 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::store_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::store_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::store_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::store_packet <crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 291 | pub fn store_packet(&self, packet: usize) { | 116 | 291 | if packet != 0 { | 117 | 0 | self.inner.packet.store(packet, Ordering::Release); | 118 | 291 | } | 119 | 291 | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 107k | pub fn store_packet(&self, packet: usize) { | 116 | 107k | if packet != 0 { | 117 | 71.5k | self.inner.packet.store(packet, Ordering::Release); | 118 | 71.5k | }36.1k | 119 | 107k | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 840k | pub fn store_packet(&self, packet: usize) { | 116 | 840k | if packet != 0 { | 117 | 838k | self.inner.packet.store(packet, Ordering::Release); | 118 | 838k | }1.57k | 119 | 840k | } |
<crossbeam_channel::context::Context>::store_packet Line | Count | Source | 115 | 75.5k | pub fn store_packet(&self, packet: usize) { | 116 | 75.5k | if packet != 0 { | 117 | 75.3k | self.inner.packet.store(packet, Ordering::Release); | 118 | 75.3k | }198 | 119 | 75.5k | } |
|
120 | | |
121 | | /// Waits until a packet is provided and returns it. |
122 | | #[inline] |
123 | 60.6k | pub fn wait_packet(&self) -> usize { |
124 | 60.6k | let backoff = Backoff::new(); |
125 | | loop { |
126 | 60.6k | let packet = self.inner.packet.load(Ordering::Acquire); |
127 | 60.6k | if packet != 0 { |
128 | 60.6k | return packet; |
129 | 0 | } |
130 | 0 | backoff.snooze(); |
131 | | } |
132 | 60.6k | } <crossbeam_channel::context::Context>::wait_packet Line | Count | Source | 123 | 19.9k | pub fn wait_packet(&self) -> usize { | 124 | 19.9k | let backoff = Backoff::new(); | 125 | | loop { | 126 | 19.9k | let packet = self.inner.packet.load(Ordering::Acquire); | 127 | 19.9k | if packet != 0 { | 128 | 19.9k | return packet; | 129 | 0 | } | 130 | 0 | backoff.snooze(); | 131 | | } | 132 | 19.9k | } |
<crossbeam_channel::context::Context>::wait_packet Line | Count | Source | 123 | 2.80k | pub fn wait_packet(&self) -> usize { | 124 | 2.80k | let backoff = Backoff::new(); | 125 | | loop { | 126 | 2.80k | let packet = self.inner.packet.load(Ordering::Acquire); | 127 | 2.80k | if packet != 0 { | 128 | 2.80k | return packet; | 129 | 0 | } | 130 | 0 | backoff.snooze(); | 131 | | } | 132 | 2.80k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_packet <crossbeam_channel::context::Context>::wait_packet Line | Count | Source | 123 | 20.5k | pub fn wait_packet(&self) -> usize { | 124 | 20.5k | let backoff = Backoff::new(); | 125 | | loop { | 126 | 20.5k | let packet = self.inner.packet.load(Ordering::Acquire); | 127 | 20.5k | if packet != 0 { | 128 | 20.5k | return packet; | 129 | 0 | } | 130 | 0 | backoff.snooze(); | 131 | | } | 132 | 20.5k | } |
<crossbeam_channel::context::Context>::wait_packet Line | Count | Source | 123 | 1.01k | pub fn wait_packet(&self) -> usize { | 124 | 1.01k | let backoff = Backoff::new(); | 125 | | loop { | 126 | 1.01k | let packet = self.inner.packet.load(Ordering::Acquire); | 127 | 1.01k | if packet != 0 { | 128 | 1.01k | return packet; | 129 | 0 | } | 130 | 0 | backoff.snooze(); | 131 | | } | 132 | 1.01k | } |
<crossbeam_channel::context::Context>::wait_packet Line | Count | Source | 123 | 16.2k | pub fn wait_packet(&self) -> usize { | 124 | 16.2k | let backoff = Backoff::new(); | 125 | | loop { | 126 | 16.2k | let packet = self.inner.packet.load(Ordering::Acquire); | 127 | 16.2k | if packet != 0 { | 128 | 16.2k | return packet; | 129 | 0 | } | 130 | 0 | backoff.snooze(); | 131 | | } | 132 | 16.2k | } |
|
133 | | |
134 | | /// Waits until an operation is selected and returns it. |
135 | | /// |
136 | | /// If the deadline is reached, `Selected::Aborted` will be selected. |
137 | | #[inline] |
138 | 2.29M | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { |
139 | 2.29M | // Spin for a short time, waiting until an operation is selected. |
140 | 2.29M | let backoff = Backoff::new(); |
141 | 7.98M | loop { |
142 | 7.98M | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); |
143 | 7.98M | if sel != Selected::Waiting { |
144 | 2.29M | return sel; |
145 | 5.69M | } |
146 | 5.69M | |
147 | 5.69M | if backoff.is_completed() { |
148 | 4.19k | break; |
149 | 5.69M | } else { |
150 | 5.69M | backoff.snooze(); |
151 | 5.69M | } |
152 | | } |
153 | | |
154 | 9.42k | loop { |
155 | 9.42k | // Check whether an operation has been selected. |
156 | 9.42k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); |
157 | 9.42k | if sel != Selected::Waiting { |
158 | 1.29k | return sel; |
159 | 8.13k | } |
160 | | |
161 | | // If there's a deadline, park the current thread until the deadline is reached. |
162 | 8.13k | if let Some(end6.66k ) = deadline { |
163 | 6.66k | let now = Instant::now(); |
164 | 6.66k | |
165 | 6.66k | if now < end { |
166 | 3.76k | thread::park_timeout(end - now); |
167 | 3.76k | } else { |
168 | | // The deadline has been reached. Try aborting select. |
169 | 2.89k | return match self.try_select(Selected::Aborted) { |
170 | 3.54k | Ok(()) => Selected::Aborted, |
171 | 2 | Err(s) => s, |
172 | | }; |
173 | | } |
174 | 1.46k | } else { |
175 | 1.46k | thread::park(); |
176 | 1.46k | } |
177 | | } |
178 | 2.29M | } <crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 368k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 368k | // Spin for a short time, waiting until an operation is selected. | 140 | 368k | let backoff = Backoff::new(); | 141 | 1.32M | loop { | 142 | 1.32M | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 1.32M | if sel != Selected::Waiting { | 144 | 371k | return sel; | 145 | 948k | } | 146 | 948k | | 147 | 948k | if backoff.is_completed() { | 148 | 18.4E | break; | 149 | 951k | } else { | 150 | 951k | backoff.snooze(); | 151 | 951k | } | 152 | | } | 153 | | | 154 | 18.4E | loop { | 155 | 18.4E | // Check whether an operation has been selected. | 156 | 18.4E | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 18.4E | if sel != Selected::Waiting { | 158 | 43 | return sel; | 159 | 18.4E | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 18.4E | if let Some(end18.4E ) = deadline { | 163 | 18.4E | let now = Instant::now(); | 164 | 18.4E | | 165 | 18.4E | if now < end { | 166 | 42 | thread::park_timeout(end - now); | 167 | 42 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 18.4E | return match self.try_select(Selected::Aborted) { | 170 | 18.4E | Ok(()) => Selected::Aborted2 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 21 | } else { | 175 | 21 | thread::park(); | 176 | 21 | } | 177 | | } | 178 | 371k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 51.9k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 51.9k | // Spin for a short time, waiting until an operation is selected. | 140 | 51.9k | let backoff = Backoff::new(); | 141 | 311k | loop { | 142 | 311k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 311k | if sel != Selected::Waiting { | 144 | 48.3k | return sel; | 145 | 263k | } | 146 | 263k | | 147 | 263k | if backoff.is_completed() { | 148 | 3.64k | break; | 149 | 259k | } else { | 150 | 259k | backoff.snooze(); | 151 | 259k | } | 152 | | } | 153 | | | 154 | 7.31k | loop { | 155 | 7.31k | // Check whether an operation has been selected. | 156 | 7.31k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 7.31k | if sel != Selected::Waiting { | 158 | 120 | return sel; | 159 | 7.19k | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 7.19k | if let Some(end7.01k ) = deadline { | 163 | 7.01k | let now = Instant::now(); | 164 | 7.01k | | 165 | 7.01k | if now < end { | 166 | 3.49k | thread::park_timeout(end - now); | 167 | 3.49k | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 3.52k | return match self.try_select(Selected::Aborted) { | 170 | 3.52k | Ok(()) => Selected::Aborted3.44k , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 181 | } else { | 175 | 181 | thread::park(); | 176 | 181 | } | 177 | | } | 178 | 51.8k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 853k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 853k | // Spin for a short time, waiting until an operation is selected. | 140 | 853k | let backoff = Backoff::new(); | 141 | 2.76M | loop { | 142 | 2.76M | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 2.76M | if sel != Selected::Waiting { | 144 | 852k | return sel; | 145 | 1.91M | } | 146 | 1.91M | | 147 | 1.91M | if backoff.is_completed() { | 148 | 1.52k | break; | 149 | 1.91M | } else { | 150 | 1.91M | backoff.snooze(); | 151 | 1.91M | } | 152 | | } | 153 | | | 154 | 1.60k | loop { | 155 | 1.60k | // Check whether an operation has been selected. | 156 | 1.60k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 1.60k | if sel != Selected::Waiting { | 158 | 41 | return sel; | 159 | 1.56k | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 1.56k | if let Some(end1.48k ) = deadline { | 163 | 1.48k | let now = Instant::now(); | 164 | 1.48k | | 165 | 1.48k | if now < end { | 166 | 0 | thread::park_timeout(end - now); | 167 | 0 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 1.48k | return match self.try_select(Selected::Aborted) { | 170 | 1.48k | Ok(()) => Selected::Aborted0 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 77 | } else { | 175 | 77 | thread::park(); | 176 | 77 | } | 177 | | } | 178 | 852k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 34.5k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 34.5k | // Spin for a short time, waiting until an operation is selected. | 140 | 34.5k | let backoff = Backoff::new(); | 141 | 126k | loop { | 142 | 126k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 126k | if sel != Selected::Waiting { | 144 | 34.8k | return sel; | 145 | 92.0k | } | 146 | 92.0k | | 147 | 92.0k | if backoff.is_completed() { | 148 | 18.4E | break; | 149 | 92.3k | } else { | 150 | 92.3k | backoff.snooze(); | 151 | 92.3k | } | 152 | | } | 153 | | | 154 | 18.4E | loop { | 155 | 18.4E | // Check whether an operation has been selected. | 156 | 18.4E | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 18.4E | if sel != Selected::Waiting { | 158 | 132 | return sel; | 159 | 18.4E | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 18.4E | if let Some(end18.4E ) = deadline { | 163 | 18.4E | let now = Instant::now(); | 164 | 18.4E | | 165 | 18.4E | if now < end { | 166 | 224 | thread::park_timeout(end - now); | 167 | 224 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 18.4E | return match self.try_select(Selected::Aborted) { | 170 | 18.4E | Ok(()) => Selected::Aborted95 , | 171 | 2 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 9 | } else { | 175 | 9 | thread::park(); | 176 | 9 | } | 177 | | } | 178 | 35.1k | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_until <crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 697 | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 697 | // Spin for a short time, waiting until an operation is selected. | 140 | 697 | let backoff = Backoff::new(); | 141 | 1.58k | loop { | 142 | 1.58k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 1.58k | if sel != Selected::Waiting { | 144 | 679 | return sel; | 145 | 902 | } | 146 | 902 | | 147 | 902 | if backoff.is_completed() { | 148 | 18 | break; | 149 | 884 | } else { | 150 | 884 | backoff.snooze(); | 151 | 884 | } | 152 | | } | 153 | | | 154 | 36 | loop { | 155 | 36 | // Check whether an operation has been selected. | 156 | 36 | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 36 | if sel != Selected::Waiting { | 158 | 14 | return sel; | 159 | 22 | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 22 | if let Some(end9 ) = deadline { | 163 | 9 | let now = Instant::now(); | 164 | 9 | | 165 | 9 | if now < end { | 166 | 5 | thread::park_timeout(end - now); | 167 | 5 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 4 | return match self.try_select(Selected::Aborted) { | 170 | 4 | Ok(()) => Selected::Aborted3 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 13 | } else { | 175 | 13 | thread::park(); | 176 | 13 | } | 177 | | } | 178 | 696 | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 2 | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 2 | // Spin for a short time, waiting until an operation is selected. | 140 | 2 | let backoff = Backoff::new(); | 141 | 22 | loop { | 142 | 22 | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 22 | if sel != Selected::Waiting { | 144 | 1 | return sel; | 145 | 21 | } | 146 | 21 | | 147 | 21 | if backoff.is_completed() { | 148 | 1 | break; | 149 | 20 | } else { | 150 | 20 | backoff.snooze(); | 151 | 20 | } | 152 | | } | 153 | | | 154 | 2 | loop { | 155 | 2 | // Check whether an operation has been selected. | 156 | 2 | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 2 | if sel != Selected::Waiting { | 158 | 1 | return sel; | 159 | 1 | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 1 | if let Some(end0 ) = deadline { | 163 | 0 | let now = Instant::now(); | 164 | 0 |
| 165 | 0 | if now < end { | 166 | 0 | thread::park_timeout(end - now); | 167 | 0 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 0 | return match self.try_select(Selected::Aborted) { | 170 | 0 | Ok(()) => Selected::Aborted, | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 1 | } else { | 175 | 1 | thread::park(); | 176 | 1 | } | 177 | | } | 178 | 2 | } |
Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_until Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_until Unexecuted instantiation: <crossbeam_channel::context::Context>::wait_until <crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 1.83k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 1.83k | // Spin for a short time, waiting until an operation is selected. | 140 | 1.83k | let backoff = Backoff::new(); | 141 | 3.74k | loop { | 142 | 3.74k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 3.74k | if sel != Selected::Waiting { | 144 | 1.81k | return sel; | 145 | 1.92k | } | 146 | 1.92k | | 147 | 1.92k | if backoff.is_completed() { | 148 | 26 | break; | 149 | 1.90k | } else { | 150 | 1.90k | backoff.snooze(); | 151 | 1.90k | } | 152 | | } | 153 | | | 154 | 51 | loop { | 155 | 51 | // Check whether an operation has been selected. | 156 | 51 | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 51 | if sel != Selected::Waiting { | 158 | 24 | return sel; | 159 | 27 | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 27 | if let Some(end7 ) = deadline { | 163 | 7 | let now = Instant::now(); | 164 | 7 | | 165 | 7 | if now < end { | 166 | 5 | thread::park_timeout(end - now); | 167 | 5 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 2 | return match self.try_select(Selected::Aborted) { | 170 | 2 | Ok(()) => Selected::Aborted, | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 20 | } else { | 175 | 20 | thread::park(); | 176 | 20 | } | 177 | | } | 178 | 1.83k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 90.1k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 90.1k | // Spin for a short time, waiting until an operation is selected. | 140 | 90.1k | let backoff = Backoff::new(); | 141 | 459k | loop { | 142 | 459k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 459k | if sel != Selected::Waiting { | 144 | 89.0k | return sel; | 145 | 370k | } | 146 | 370k | | 147 | 370k | if backoff.is_completed() { | 148 | 1.03k | break; | 149 | 369k | } else { | 150 | 369k | backoff.snooze(); | 151 | 369k | } | 152 | | } | 153 | | | 154 | 2.08k | loop { | 155 | 2.08k | // Check whether an operation has been selected. | 156 | 2.08k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 2.08k | if sel != Selected::Waiting { | 158 | 860 | return sel; | 159 | 1.22k | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 1.22k | if let Some(end172 ) = deadline { | 163 | 172 | let now = Instant::now(); | 164 | 172 | | 165 | 172 | if now < end { | 166 | 0 | thread::park_timeout(end - now); | 167 | 0 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 172 | return match self.try_select(Selected::Aborted) { | 170 | 172 | Ok(()) => Selected::Aborted0 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 1.04k | } else { | 175 | 1.04k | thread::park(); | 176 | 1.04k | } | 177 | | } | 178 | 89.9k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 835k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 835k | // Spin for a short time, waiting until an operation is selected. | 140 | 835k | let backoff = Backoff::new(); | 141 | 2.76M | loop { | 142 | 2.76M | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 2.76M | if sel != Selected::Waiting { | 144 | 833k | return sel; | 145 | 1.93M | } | 146 | 1.93M | | 147 | 1.93M | if backoff.is_completed() { | 148 | 1.89k | break; | 149 | 1.92M | } else { | 150 | 1.92M | backoff.snooze(); | 151 | 1.92M | } | 152 | | } | 153 | | | 154 | 1.98k | loop { | 155 | 1.98k | // Check whether an operation has been selected. | 156 | 1.98k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 1.98k | if sel != Selected::Waiting { | 158 | 55 | return sel; | 159 | 1.93k | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 1.93k | if let Some(end1.84k ) = deadline { | 163 | 1.84k | let now = Instant::now(); | 164 | 1.84k | | 165 | 1.84k | if now < end { | 166 | 3 | thread::park_timeout(end - now); | 167 | 3 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 1.83k | return match self.try_select(Selected::Aborted) { | 170 | 1.83k | Ok(()) => Selected::Aborted1 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 90 | } else { | 175 | 90 | thread::park(); | 176 | 90 | } | 177 | | } | 178 | 833k | } |
<crossbeam_channel::context::Context>::wait_until Line | Count | Source | 138 | 58.6k | pub fn wait_until(&self, deadline: Option<Instant>) -> Selected { | 139 | 58.6k | // Spin for a short time, waiting until an operation is selected. | 140 | 58.6k | let backoff = Backoff::new(); | 141 | 232k | loop { | 142 | 232k | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 143 | 232k | if sel != Selected::Waiting { | 144 | 59.0k | return sel; | 145 | 173k | } | 146 | 173k | | 147 | 173k | if backoff.is_completed() { | 148 | 18.4E | break; | 149 | 174k | } else { | 150 | 174k | backoff.snooze(); | 151 | 174k | } | 152 | | } | 153 | | | 154 | 18.4E | loop { | 155 | 18.4E | // Check whether an operation has been selected. | 156 | 18.4E | let sel = Selected::from(self.inner.select.load(Ordering::Acquire)); | 157 | 18.4E | if sel != Selected::Waiting { | 158 | 5 | return sel; | 159 | 18.4E | } | 160 | | | 161 | | // If there's a deadline, park the current thread until the deadline is reached. | 162 | 18.4E | if let Some(end18.4E ) = deadline { | 163 | 18.4E | let now = Instant::now(); | 164 | 18.4E | | 165 | 18.4E | if now < end { | 166 | 0 | thread::park_timeout(end - now); | 167 | 0 | } else { | 168 | | // The deadline has been reached. Try aborting select. | 169 | 18.4E | return match self.try_select(Selected::Aborted) { | 170 | 18.4E | Ok(()) => Selected::Aborted0 , | 171 | 0 | Err(s) => s, | 172 | | }; | 173 | | } | 174 | 8 | } else { | 175 | 8 | thread::park(); | 176 | 8 | } | 177 | | } | 178 | 59.0k | } |
|
179 | | |
180 | | /// Unparks the thread this context belongs to. |
181 | | #[inline] |
182 | 2.32M | pub fn unpark(&self) { |
183 | 2.32M | self.inner.thread.unpark(); |
184 | 2.32M | } <crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 398k | pub fn unpark(&self) { | 183 | 398k | self.inner.thread.unpark(); | 184 | 398k | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 861k | pub fn unpark(&self) { | 183 | 861k | self.inner.thread.unpark(); | 184 | 861k | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 37.5k | pub fn unpark(&self) { | 183 | 37.5k | self.inner.thread.unpark(); | 184 | 37.5k | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 123 | pub fn unpark(&self) { | 183 | 123 | self.inner.thread.unpark(); | 184 | 123 | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 2 | pub fn unpark(&self) { | 183 | 2 | self.inner.thread.unpark(); | 184 | 2 | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 292 | pub fn unpark(&self) { | 183 | 292 | self.inner.thread.unpark(); | 184 | 292 | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 107k | pub fn unpark(&self) { | 183 | 107k | self.inner.thread.unpark(); | 184 | 107k | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 840k | pub fn unpark(&self) { | 183 | 840k | self.inner.thread.unpark(); | 184 | 840k | } |
<crossbeam_channel::context::Context>::unpark Line | Count | Source | 182 | 75.7k | pub fn unpark(&self) { | 183 | 75.7k | self.inner.thread.unpark(); | 184 | 75.7k | } |
|
185 | | |
186 | | /// Returns the id of the thread this context belongs to. |
187 | | #[inline] |
188 | 2.42M | pub fn thread_id(&self) -> ThreadId { |
189 | 2.42M | self.inner.thread_id |
190 | 2.42M | } Unexecuted instantiation: <crossbeam_channel::context::Inner as core::fmt::Debug>::fmt <crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 411k | pub fn thread_id(&self) -> ThreadId { | 189 | 411k | self.inner.thread_id | 190 | 411k | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 865k | pub fn thread_id(&self) -> ThreadId { | 189 | 865k | self.inner.thread_id | 190 | 865k | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 37.7k | pub fn thread_id(&self) -> ThreadId { | 189 | 37.7k | self.inner.thread_id | 190 | 37.7k | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 280 | pub fn thread_id(&self) -> ThreadId { | 189 | 280 | self.inner.thread_id | 190 | 280 | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 2 | pub fn thread_id(&self) -> ThreadId { | 189 | 2 | self.inner.thread_id | 190 | 2 | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 590 | pub fn thread_id(&self) -> ThreadId { | 189 | 590 | self.inner.thread_id | 190 | 590 | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 133k | pub fn thread_id(&self) -> ThreadId { | 189 | 133k | self.inner.thread_id | 190 | 133k | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 844k | pub fn thread_id(&self) -> ThreadId { | 189 | 844k | self.inner.thread_id | 190 | 844k | } |
<crossbeam_channel::context::Context>::thread_id Line | Count | Source | 188 | 130k | pub fn thread_id(&self) -> ThreadId { | 189 | 130k | self.inner.thread_id | 190 | 130k | } |
|
191 | | } |