| /external/rust/crates/tokio/src/runtime/scheduler/inject/ |
| D | shared.rs | 9 pub(crate) struct Shared<T: 'static> { struct
17 unsafe impl<T> Send for Shared<T> {} implementation
18 unsafe impl<T> Sync for Shared<T> {} implementation
20 impl<T: 'static> Shared<T> { impl
|
| /external/rust/cxx/tests/ui/ |
| D | array_len_expr.rs | 3 struct Shared { struct
4 arraystr: [String; "13"],
5 arraysub: [String; 15 - 1],
6 arrayzero: [String; 0],
|
| D | drop_shared.rs | 3 struct Shared { struct
8 impl Drop for ffi::Shared {
|
| D | unique_ptr_as_mut.rs | 5 struct Shared { struct
18 let mut shared = UniquePtr::<ffi::Shared>::null(); in main()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | event.h | 106 struct Shared { struct
123 containers::vector<std::shared_ptr<Shared>, 1> deps; argument
128 const std::shared_ptr<Shared> shared; argument
131 Event::Shared::Shared(Allocator* allocator, Mode mode_, bool initialState) in Shared() function
|
| /external/rust/crates/tower/src/make/make_service/ |
| D | shared.rs | 72 pub struct Shared<S> { struct
76 impl<S> Shared<S> { implementation
83 impl<S, T> Service<T> for Shared<S> implementation
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 241 struct Shared { struct
249 queue: Mutex<Option<VecDeque<task::Notified<Arc<Shared>>>>>, argument
266 local_queue: UnsafeCell<VecDeque<task::Notified<Arc<Shared>>>>, argument
628 fn next_task(&self) -> Option<task::LocalNotified<Arc<Shared>>> { in next_task()
659 fn pop_local(&self) -> Option<task::Notified<Arc<Shared>>> { in pop_local()
964 impl Shared { implementation
1013 unsafe impl Sync for Shared {} implementation
1052 unsafe fn task_pop_front(&self) -> Option<task::Notified<Arc<Shared>>> { in task_pop_front()
1060 unsafe fn task_push_back(&self, task: task::Notified<Arc<Shared>>) { in task_push_back()
1068 unsafe fn take_local_queue(&self) -> VecDeque<task::Notified<Arc<Shared>>> { in take_local_queue()
[all …]
|
| /external/rust/crates/futures-util/src/future/future/ |
| D | shared.rs | 16 pub struct Shared<Fut: Future> { struct
31 /// A weak reference to a [`Shared`] that can be upgraded much like an `Arc`. argument
40 impl<Fut: Future> fmt::Debug for Shared<Fut> { implementation
87 impl<Fut: Future> Shared<Fut> { implementation
101 impl<Fut> Shared<Fut> implementation
243 impl<Fut> FusedFuture for Shared<Fut> implementation
253 impl<Fut> Future for Shared<Fut> implementation
362 impl<Fut> Clone for Shared<Fut> implementation
371 impl<Fut> Drop for Shared<Fut> implementation
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 102 struct Shared { in BM_MutexEnqueue() struct
103 absl::Mutex mu; in BM_MutexEnqueue()
104 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
105 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
106 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
182 struct Shared { in BM_Contended() struct
183 MutexType mu; in BM_Contended()
184 int data = 0; in BM_Contended()
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 102 struct Shared { in BM_MutexEnqueue() struct
103 absl::Mutex mu; in BM_MutexEnqueue()
104 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
105 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
106 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
182 struct Shared { in BM_Contended() struct
183 MutexType mu; in BM_Contended()
184 int data = 0; in BM_Contended()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 102 struct Shared { in BM_MutexEnqueue() struct
103 absl::Mutex mu; in BM_MutexEnqueue()
104 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
105 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
106 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
182 struct Shared { in BM_Contended() struct
183 MutexType mu; in BM_Contended()
184 int data = 0; in BM_Contended()
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 102 struct Shared { in BM_MutexEnqueue() struct
103 absl::Mutex mu; in BM_MutexEnqueue()
104 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
105 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
106 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
182 struct Shared { in BM_Contended() struct
183 MutexType mu; in BM_Contended()
184 int data = 0; in BM_Contended()
|
| /external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/synchronization/ |
| D | mutex_benchmark.cc | 102 struct Shared { in BM_MutexEnqueue() struct
103 absl::Mutex mu; in BM_MutexEnqueue()
104 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
105 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
106 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
182 struct Shared { in BM_Contended() struct
183 MutexType mu; in BM_Contended()
184 int data = 0; in BM_Contended()
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 130 struct Shared { in BM_MutexEnqueue() struct
131 absl::Mutex mu; in BM_MutexEnqueue()
132 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
133 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
134 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
210 struct Shared { in BM_Contended() struct
211 MutexType mu; in BM_Contended()
212 int data = 0; in BM_Contended()
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 131 struct Shared { in BM_MutexEnqueue() struct
132 absl::Mutex mu; in BM_MutexEnqueue()
133 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
134 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
135 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
211 struct Shared { in BM_Contended() struct
212 MutexType mu; in BM_Contended()
213 int data = 0; in BM_Contended()
|
| /external/abseil-cpp/absl/synchronization/ |
| D | mutex_benchmark.cc | 131 struct Shared { in BM_MutexEnqueue() struct
132 absl::Mutex mu; in BM_MutexEnqueue()
133 std::atomic<int> looping_threads{0}; in BM_MutexEnqueue()
134 std::atomic<int> blocked_threads{0}; in BM_MutexEnqueue()
135 std::atomic<bool> thread_has_mutex{false}; in BM_MutexEnqueue()
211 struct Shared { in BM_Contended() struct
212 MutexType mu; in BM_Contended()
213 int data = 0; in BM_Contended()
|
| /external/rust/crates/hyper/src/proto/h2/ |
| D | ping.rs | 128 struct Shared { struct
129 ping_pong: PingPong,
130 ping_sent_at: Option<Instant>,
135 bytes: Option<usize>,
138 next_bdp_at: Option<Instant>,
144 last_read_at: Option<Instant>,
147 is_keep_alive_timed_out: bool,
372 impl Shared { implementation
474 fn schedule(&mut self, is_idle: bool, shared: &Shared) { in schedule()
498 fn maybe_ping(&mut self, cx: &mut task::Context<'_>, shared: &mut Shared) { in maybe_ping()
|
| /external/rust/crates/sharded-slab/src/page/ |
| D | mod.rs | 76 pub(crate) struct Shared<T, C> { struct
80 remote: stack::TransferStack<C>,
86 size: usize,
87 prev_sz: usize,
88 slab: UnsafeCell<Option<Slots<T, C>>>,
120 impl<T, C> Shared<T, C> implementation
199 impl<'a, T, C> Shared<Option<T>, C> impl
258 impl<T, C> Shared<T, C> implementation
362 impl<C, T> fmt::Debug for Shared<C, T> { implementation
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/worker/ |
| D | metrics.rs | 3 impl Shared { implementation
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread_alt/worker/ |
| D | metrics.rs | 3 impl Shared { impl
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_semaphore_batch.rs | 18 struct Shared { in basic_usage() struct
19 semaphore: Semaphore, in basic_usage()
20 active: AtomicUsize, in basic_usage()
23 async fn actor(shared: Arc<Shared>) { in basic_usage()
|
| /external/rust/crates/hyper/src/common/ |
| D | watch.rs | 45 struct Shared { struct
46 value: AtomicUsize,
47 waker: AtomicWaker,
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread_alt/ |
| D | worker.rs | 137 pub(crate) struct Shared { struct
144 pub(super) inject: inject::Shared<Arc<Handle>>, argument
147 idle: Idle,
150 pub(super) owned: OwnedTasks<Arc<Handle>>,
153 pub(super) synced: Mutex<Synced>,
157 driver: AtomicCell<Driver>,
161 pub(super) condvars: Vec<Condvar>,
164 pub(super) trace_status: TraceStatus,
167 config: Config,
170 pub(super) scheduler_metrics: SchedulerMetrics,
[all …]
|
| /external/rust/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 147 pub(crate) struct Shared { struct
155 pub(super) inject: inject::Shared<Arc<Handle>>, argument
158 idle: Idle,
161 pub(crate) owned: OwnedTasks<Arc<Handle>>,
164 pub(super) synced: Mutex<Synced>,
171 shutdown_cores: Mutex<Vec<Box<Core>>>,
174 pub(super) trace_status: TraceStatus,
177 config: Config,
180 pub(super) scheduler_metrics: SchedulerMetrics,
182 pub(super) worker_metrics: Box<[WorkerMetrics]>,
[all …]
|
| /external/rust/crates/crossbeam-epoch/src/ |
| D | atomic.rs | 1297 pub struct Shared<'g, T: 'g + ?Sized + Pointable> { struct
1302 impl<T: ?Sized + Pointable> Clone for Shared<'_, T> { argument
1308 impl<T: ?Sized + Pointable> Copy for Shared<'_, T> {} implementation
1310 impl<T: ?Sized + Pointable> Pointer<T> for Shared<'_, T> { implementation
1325 impl<'g, T> Shared<'g, T> { implementation
1349 impl<'g, T: ?Sized + Pointable> Shared<'g, T> { impl
1609 impl<T> From<*const T> for Shared<'_, T> { implementation
1632 impl<'g, T: ?Sized + Pointable> PartialEq<Shared<'g, T>> for Shared<'g, T> { implementation
1638 impl<T: ?Sized + Pointable> Eq for Shared<'_, T> {} implementation
1640 impl<'g, T: ?Sized + Pointable> PartialOrd<Shared<'g, T>> for Shared<'g, T> { implementation
[all …]
|