| /third_party/rust/crates/signal-hook/src/iterator/ |
| D | backend.rs | 27 use std::sync::{Arc, Mutex};
102 self: Arc<Self>, in add_signal()
103 write: Arc<dyn SelfPipeWrite>, in add_signal()
121 self: Arc<Self>, in add_signal()
122 write: Arc<dyn SelfPipeWrite>, in add_signal()
159 pending: Arc<dyn AddSignal>,
160 write: Arc<dyn SelfPipeWrite>,
161 delivery_state: Arc<DeliveryState>,
165 fn new<W>(write: W, pending: Arc<dyn AddSignal>) -> Self in new()
171 write: Arc::new(write), in new()
[all …]
|
| /third_party/rust/crates/tracing/tracing-subscriber/tests/ |
| D | event_enabling.rs | 3 use std::sync::{Arc, Mutex};
9 event_enabled_count: Arc<Mutex<usize>>,
11 on_event_count: Arc<Mutex<usize>>,
34 let event_enabled_count = Arc::new(Mutex::default()); in event_enabled_is_only_called_once()
40 on_event_count: Arc::new(Mutex::default()), in event_enabled_is_only_called_once()
51 let event_enabled_count = Arc::new(Mutex::default()); in event_enabled_not_called_when_not_enabled()
57 on_event_count: Arc::new(Mutex::default()), in event_enabled_not_called_when_not_enabled()
68 let on_event_count = Arc::new(Mutex::default()); in event_disabled_does_disable_event()
72 event_enabled_count: Arc::new(Mutex::default()), in event_disabled_does_disable_event()
|
| /third_party/rust/crates/signal-hook/src/ |
| D | flag.rs | 142 use std::sync::Arc;
153 pub fn register(signal: c_int, flag: Arc<AtomicBool>) -> Result<SigId, Error> { in register()
162 pub fn register_usize(signal: c_int, flag: Arc<AtomicUsize>, value: usize) -> Result<SigId, Error> { in register_usize()
189 condition: Arc<AtomicBool>, in register_conditional_shutdown()
219 condition: Arc<AtomicBool>, in register_conditional_default()
266 let flag = Arc::new(AtomicBool::new(false)); in register_unregister()
268 let signal = register(SIGUSR1, Arc::clone(&flag)).unwrap(); in register_unregister()
270 let signal = register(crate::SIGTERM, Arc::clone(&flag)).unwrap(); in register_unregister()
279 assert_eq!(1, Arc::strong_count(&flag)); in register_unregister()
|
| /third_party/rust/crates/tracing/tracing-subscriber/benches/support/ |
| D | mod.rs | 2 sync::{Arc, Barrier},
10 start: Arc<Barrier>,
11 end: Arc<Barrier>,
18 start: Arc::new(Barrier::new(5)), in new()
19 end: Arc::new(Barrier::new(5)), in new()
|
| /third_party/rust/crates/tracing/tracing-subscriber/src/registry/ |
| D | extensions.rs | 248 use std::sync::Arc; in clear_drops_elements()
249 struct DropMePlease(Arc<()>); in clear_drops_elements()
250 struct DropMeTooPlease(Arc<()>); in clear_drops_elements()
253 let val1 = DropMePlease(Arc::new(())); in clear_drops_elements()
254 let val2 = DropMeTooPlease(Arc::new(())); in clear_drops_elements()
256 let val1_dropped = Arc::downgrade(&val1.0); in clear_drops_elements()
257 let val2_dropped = Arc::downgrade(&val2.0); in clear_drops_elements()
|
| D | mod.rs | 235 sync::Arc
259 impl<'a, S> LookupSpan<'a> for Arc<S>
589 use std::sync::{Arc, Mutex};
594 let last_entered_scope = Arc::new(Mutex::new(Vec::new())); in spanref_scope_iteration_order()
598 last_entered_scope: Arc<Mutex<Vec<&'static str>>>, in spanref_scope_iteration_order()
629 let last_entered_scope = Arc::new(Mutex::new(Vec::new())); in spanref_scope_fromroot_iteration_order()
633 last_entered_scope: Arc<Mutex<Vec<&'static str>>>, in spanref_scope_fromroot_iteration_order()
|
| /third_party/rust/crates/rustix/tests/net/ |
| D | v6.rs | 11 use std::sync::{Arc, Condvar, Mutex};
16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server()
49 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client()
78 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_v6()
79 let ready_clone = Arc::clone(&ready); in test_v6()
|
| D | v4.rs | 11 use std::sync::{Arc, Condvar, Mutex};
16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server()
45 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client()
69 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_v4()
70 let ready_clone = Arc::clone(&ready); in test_v4()
|
| D | unix.rs | 25 use std::sync::{Arc, Condvar, Mutex};
30 fn server(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path) { in server()
72 fn client(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path, runs: &[(&[&str], i32)]) { in client()
117 let ready = Arc::new((Mutex::new(false), Condvar::new())); in test_unix()
118 let ready_clone = Arc::clone(&ready); in test_unix()
|
| D | poll.rs | 10 use std::sync::{Arc, Condvar, Mutex};
15 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server()
61 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client()
102 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_poll()
103 let ready_clone = Arc::clone(&ready); in test_poll()
|
| /third_party/rust/crates/tracing/tracing-subscriber/src/fmt/ |
| D | writer.rs | 7 sync::{Arc, Mutex, MutexGuard},
659 pub struct ArcWriter<W>(Arc<W>);
685 impl<'a, W> MakeWriter<'a> for Arc<W> implementation
1210 use std::sync::{Arc, Mutex};
1254 let buf = Arc::new(Mutex::new(Vec::new())); in custom_writer_closure()
1263 let buf = Arc::new(Mutex::new(Vec::new())); in custom_writer_struct()
1271 let buf = Arc::new(Mutex::new(Vec::new())); in custom_writer_mutex()
1280 let info_buf = Arc::new(Mutex::new(Vec::new())); in combinators_level_filters()
1283 let debug_buf = Arc::new(Mutex::new(Vec::new())); in combinators_level_filters()
1286 let warn_buf = Arc::new(Mutex::new(Vec::new())); in combinators_level_filters()
[all …]
|
| /third_party/rust/crates/signal-hook/signal-hook-tokio/tests/ |
| D | tests.rs | 6 use std::sync::Arc;
40 async fn get_signal(mut signals: Signals, recieved: Arc<AtomicBool>) { in delayed()
46 let recieved = Arc::new(AtomicBool::new(false)); in delayed()
48 let signals_task = tokio::spawn(get_signal(signals, Arc::clone(&recieved))); in delayed()
|
| /third_party/rust/crates/signal-hook/signal-hook-async-std/tests/ |
| D | async_std.rs | 4 use std::sync::Arc;
38 async fn get_signal(mut signals: Signals, recieved: Arc<AtomicBool>) { in delayed()
44 let recieved = Arc::new(AtomicBool::new(false)); in delayed()
46 let signals_task = async_std::task::spawn(get_signal(signals, Arc::clone(&recieved))); in delayed()
|
| /third_party/rust/crates/signal-hook/tests/ |
| D | iterator.rs | 8 use std::sync::Arc;
58 let stopped = Arc::new(AtomicBool::new(false)); in forever_terminates_when_closed()
60 let stopped_bg = Arc::clone(&stopped); in forever_terminates_when_closed()
87 let finish = Arc::new(AtomicBool::new(false)); in signals_block_wait()
89 let finish = Arc::clone(&finish); in signals_block_wait()
112 finish: Arc<AtomicBool>, in signals_block_wait()
|
| D | shutdown.rs | 16 use std::sync::Arc;
62 let shutdown_cond = Arc::new(AtomicBool::new(false)); in cleanup_inside_signal()
64 flag::register_conditional_shutdown(SIGTERM, 0, Arc::clone(&shutdown_cond)).unwrap(); in cleanup_inside_signal()
78 flag::register_conditional_shutdown(SIGTERM, 0, Arc::new(AtomicBool::new(true))).unwrap(); in cleanup_after_signal()
|
| /third_party/rust/crates/tracing/tracing/test-log-support/src/ |
| D | lib.rs | 2 use std::sync::{Arc, Mutex};
5 state: Arc<State>,
14 state: Arc<State>,
46 let me = Arc::new(State { in with_filters()
|
| /third_party/rust/crates/rustix/tests/io/ |
| D | epoll.rs | 11 use std::sync::{Arc, Condvar, Mutex};
16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server()
62 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client()
87 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_epoll()
88 let ready_clone = Arc::clone(&ready); in test_epoll()
|
| /third_party/rust/crates/tracing/tracing/test_static_max_level_features/tests/ |
| D | test.rs | 3 use std::sync::{Arc, Mutex};
14 struct TestSubscriber(Arc<State>);
53 let me = Arc::new(State { in test_static_max_level_events()
74 let me = Arc::new(State { in test_static_max_level_spans()
114 let me = Arc::new(State { in test_static_max_level_instrument()
|
| /third_party/rust/crates/clang-sys/src/ |
| D | link.rs | 43 use std::sync::{Arc};
124 thread_local!(static LIBRARY: RefCell<Option<Arc<SharedLibrary>>> = RefCell::new(None));
214 let library = Arc::new(load_manually()?);
236 pub fn get_library() -> Option<Arc<SharedLibrary>> {
243 pub fn set_library(library: Option<Arc<SharedLibrary>>) -> Option<Arc<SharedLibrary>> {
|
| /third_party/rust/crates/signal-hook/signal-hook-registry/tests/ |
| D | unregister_signal.rs | 13 use std::sync::Arc;
20 let called = Arc::new(AtomicUsize::new(0)); in register_unregister()
23 let called = Arc::clone(&called); in register_unregister()
|
| /third_party/rust/crates/clap/src/parser/matches/ |
| D | any_value.rs | 3 inner: std::sync::Arc<dyn std::any::Any + Send + Sync + 'static>,
12 let inner = std::sync::Arc::new(inner); in new()
25 ok!(std::sync::Arc::downcast::<T>(self.inner).map_err(|inner| Self { inner, id })); in downcast_into()
26 let value = std::sync::Arc::try_unwrap(value).unwrap_or_else(|arc| (*arc).clone()); in downcast_into()
|
| /third_party/rust/crates/tracing/tracing/tests/ |
| D | filters_are_not_reevaluated_for_the_same_span.rs | 14 Arc,
22 let alice_count = Arc::new(AtomicUsize::new(0)); in filters_are_not_reevaluated_for_the_same_span()
23 let bob_count = Arc::new(AtomicUsize::new(0)); in filters_are_not_reevaluated_for_the_same_span()
|
| D | filters_are_reevaluated_for_different_call_sites.rs | 14 Arc,
22 let charlie_count = Arc::new(AtomicUsize::new(0)); in filters_are_reevaluated_for_different_call_sites()
23 let dave_count = Arc::new(AtomicUsize::new(0)); in filters_are_reevaluated_for_different_call_sites()
|
| /third_party/rust/crates/signal-hook/signal-hook-registry/src/ |
| D | lib.rs | 75 use std::sync::{Arc, Once};
141 actions: BTreeMap<ActionId, Arc<Action>>,
578 let action = Arc::from(action); in register_unchecked_impl()
680 use std::sync::Arc;
709 let status = Arc::new(AtomicUsize::new(0)); in signal_without_pid()
711 let status = Arc::clone(&status); in signal_without_pid()
737 let status = Arc::new(AtomicUsize::new(0)); in signal_with_pid()
739 let status = Arc::clone(&status); in signal_with_pid()
|
| /third_party/rust/crates/log/test_max_level_features/ |
| D | main.rs | 4 use std::sync::{Arc, Mutex};
18 struct Logger(Arc<State>);
33 let me = Arc::new(State { last_log: Mutex::new(None) }); in main()
|