| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/task/ |
| D | local.rs | 243 struct Shared { struct
251 queue: Mutex<Option<VecDeque<task::Notified<Arc<Shared>>>>>, argument
268 local_queue: UnsafeCell<VecDeque<task::Notified<Arc<Shared>>>>, argument
750 fn next_task(&self) -> Option<task::LocalNotified<Arc<Shared>>> { in next_task()
781 fn pop_local(&self) -> Option<task::Notified<Arc<Shared>>> { in pop_local()
1056 impl Shared { implementation
1108 unsafe impl Sync for Shared {} implementation
1154 unsafe fn task_pop_front(&self) -> Option<task::Notified<Arc<Shared>>> { in task_pop_front()
1162 unsafe fn task_push_back(&self, task: task::Notified<Arc<Shared>>) { in task_push_back()
1170 unsafe fn take_local_queue(&self) -> VecDeque<task::Notified<Arc<Shared>>> { in take_local_queue()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/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> { impl
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
|
| /aosp_15_r20/external/rust/android-crates-io/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 { impl
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()
|
| /aosp_15_r20/external/rust/android-crates-io/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> impl
199 impl<'a, T, C> Shared<Option<T>, C> implementation
258 impl<T, C> Shared<T, C> implementation
362 impl<C, T> fmt::Debug for Shared<C, T> { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/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
|
| /aosp_15_r20/frameworks/av/media/libnblog/include/media/nblog/ |
| H A D | Timeline.h | 31 struct Shared { struct
32 Shared() /* mRear initialized via default constructor */ {} in Shared() function
33 ~Shared() {} in ~Shared() argument
58 bool mOwn; // whether I own the memory at mShared argument
59 Shared* const mShared; // pointer to shared memory argument
|
| /aosp_15_r20/external/rust/android-crates-io/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 …]
|
| /aosp_15_r20/frameworks/av/media/libnbaio/include_mono/media/nbaio/ |
| H A D | SingleStateQueue.h | 41 struct Shared { struct
57 Mutator(Shared *shared) in Mutator() argument
|
| /aosp_15_r20/external/swiftshader/third_party/marl/include/marl/ |
| H A 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
|
| /aosp_15_r20/external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| H A 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()
|
| /aosp_15_r20/external/rust/android-crates-io/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()
|
| /aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/synchronization/ |
| H A 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()
|
| /aosp_15_r20/external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| H A 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()
|
| /aosp_15_r20/external/angle/third_party/abseil-cpp/absl/synchronization/ |
| H A 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()
|
| /aosp_15_r20/external/abseil-cpp/absl/synchronization/ |
| H A 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()
|
| /aosp_15_r20/external/rust/android-crates-io/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 …]
|
| /aosp_15_r20/frameworks/libs/binary_translation/tests/tests_apk/jni/ |
| D | shared_library_test.cc | 63 TEST(Shared, CallFunction) { in TEST() argument
67 TEST(Shared, DlOpen) { in TEST() argument
71 TEST(Shared, DlOpenGreylistedLibrariesAndroidM) { in TEST() argument
78 TEST(Shared, DlOpenSystemLibraries) { in TEST() argument
111 TEST(Shared, DlSym) { in TEST() argument
118 TEST(Shared, DlIteratePhdr) { in TEST() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/scheduler/multi_thread/ |
| D | worker.rs | 146 pub(crate) struct Shared { struct
154 pub(super) inject: inject::Shared<Arc<Handle>>, argument
157 idle: Idle,
160 pub(crate) owned: OwnedTasks<Arc<Handle>>,
163 pub(super) synced: Mutex<Synced>,
170 shutdown_cores: Mutex<Vec<Box<Core>>>,
173 pub(super) trace_status: TraceStatus,
176 config: Config,
179 pub(super) scheduler_metrics: SchedulerMetrics,
181 pub(super) worker_metrics: Box<[WorkerMetrics]>,
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tower/src/make/make_service/ |
| D | shared.rs | 72 pub struct Shared<S> { struct
76 impl<S> Shared<S> { impl
83 impl<S, T> Service<T> for Shared<S> implementation
|
| /aosp_15_r20/external/rust/cxx/tests/ffi/ |
| D | lib.rs | 29 struct Shared { struct
30 z: usize,
136 fn c_take_shared(shared: Shared); in c_take_shared()
142 fn c_take_slice_shared(s: &[Shared]); in c_take_slice_shared()
143 fn c_take_slice_shared_sort(s: &mut [Shared]); in c_take_slice_shared_sort()
151 fn c_take_unique_ptr_vector_shared(v: UniquePtr<CxxVector<Shared>>); in c_take_unique_ptr_vector_shared()
154 fn c_take_rust_vec_shared(v: Vec<Shared>); in c_take_rust_vec_shared()
157 fn c_take_rust_vec_shared_index(v: Vec<Shared>); in c_take_rust_vec_shared_index()
158 fn c_take_rust_vec_shared_push(v: Vec<Shared>); in c_take_rust_vec_shared_push()
159 fn c_take_rust_vec_shared_truncate(v: Vec<Shared>); in c_take_rust_vec_shared_truncate()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 105 struct Shared { struct
106 queue: VecDeque<Task>,
107 num_notify: u32,
108 shutdown: bool,
109 shutdown_tx: Option<shutdown::Sender>,
115 last_exiting_thread: Option<thread::JoinHandle<()>>,
118 worker_threads: HashMap<usize, thread::JoinHandle<()>>,
121 worker_thread_index: usize,
|
| /aosp_15_r20/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],
|
| /aosp_15_r20/external/cronet/third_party/rust/chromium_crates_io/vendor/cxx-1.0.120/tests/ui/ |
| H A D | array_len_expr.rs | 3 struct Shared { struct
4 arraystr: [String; "13"],
5 arraysub: [String; 15 - 1],
6 arrayzero: [String; 0],
|
| /aosp_15_r20/bootable/libbootloader/gbl/libgbl/src/fastboot/ |
| H A D | shared.rs | 21 pub struct Shared<T>(RefCell<T>); struct
23 impl<T> From<T> for Shared<T> { implementation
29 impl<T> Deref for Shared<T> { implementation
37 impl<T> DerefMut for Shared<T> { implementation
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | watch.rs | 245 struct Shared<T> { struct
268 impl<T: fmt::Debug> fmt::Debug for Shared<T> { implementation
|