| /aosp_15_r20/external/rust/android-crates-io/crates/spin/src/ |
| D | barrier.rs | 45 pub struct Barrier<R = Spin> { struct
46 lock: Mutex<BarrierState, R>, argument
56 /// A `BarrierWaitResult` is returned by [`wait`] when all threads in the [`Barrier`] argument
72 impl<R: RelaxStrategy> Barrier<R> { impl
134 impl<R> Barrier<R> { implementation
191 type Barrier = super::Barrier; typedef
193 fn use_barrier(n: usize, barrier: Arc<Barrier>) { in use_barrier()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/ |
| D | barrier.rs | 42 pub struct Barrier { struct
43 state: Mutex<BarrierState>, argument
57 impl Barrier { argument
63 pub fn new(mut n: usize) -> Barrier { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/ |
| H A D | barrier.rs | 35 pub struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
62 impl fmt::Debug for Barrier { implementation
68 impl Barrier { implementation
87 pub const fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/ |
| H A D | barrier.rs | 35 pub struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
62 impl fmt::Debug for Barrier { implementation
68 impl Barrier { impl
87 pub const fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/sync/ |
| H A D | barrier.rs | 35 pub struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
62 impl fmt::Debug for Barrier { implementation
68 impl Barrier { impl
87 pub const fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/sync/ |
| H A D | barrier.rs | 35 pub struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
62 impl fmt::Debug for Barrier { implementation
68 impl Barrier { implementation
87 pub const fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/sync/ |
| H A D | barrier.rs | 35 pub struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
62 impl fmt::Debug for Barrier { implementation
68 impl Barrier { implementation
87 pub const fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/loom/std/ |
| D | barrier.rs | 35 pub(crate) struct Barrier { struct
36 lock: Mutex<BarrierState>, argument
47 /// A `BarrierWaitResult` is returned by [`Barrier::wait()`] when all threads argument
60 impl fmt::Debug for Barrier { implementation
66 impl Barrier { implementation
82 pub(crate) fn new(n: usize) -> Barrier { in new()
|
| /aosp_15_r20/external/libcxxabi/test/ |
| H A D | guard_threaded_test.pass.cpp | 135 struct Barrier { struct
136 explicit Barrier(int n) : m_wait_for(n) { reset(); } in Barrier() function
139 void wait() { in wait()
148 int num_waiting() const { in num_waiting()
152 void reset() { in reset()
157 const int m_wait_for;
158 std::atomic<int> m_entered;
159 std::atomic<int> m_exited;
|
| /aosp_15_r20/external/cronet/third_party/libc++abi/src/test/ |
| H A D | guard_threaded_test.pass.cpp | 48 struct Barrier { struct
49 explicit Barrier(int n) : m_threads(n), m_remaining(n) { } in Barrier() function
53 void arrive_and_wait() const { in arrive_and_wait()
60 void arrive_and_drop() const { in arrive_and_drop()
64 void wait_for_threads(int n) const { in wait_for_threads()
71 const int m_threads;
72 mutable std::atomic<int> m_remaining;
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vhost-user-backend/tests/ |
| D | vhost-user-server.rs | 125 fn vhost_user_client(path: &Path, barrier: Arc<Barrier>) { in vhost_user_client()
218 fn vhost_user_server(cb: fn(&Path, Arc<Barrier>)) { in vhost_user_server()
246 fn vhost_user_enable(path: &Path, barrier: Arc<Barrier>) { in vhost_user_enable()
257 fn vhost_user_set_inflight(path: &Path, barrier: Arc<Barrier>) { in vhost_user_set_inflight()
277 fn vhost_user_get_inflight(path: &Path, barrier: Arc<Barrier>) { in vhost_user_get_inflight()
|
| /aosp_15_r20/frameworks/av/media/libstagefright/renderfright/gl/ |
| H A D | ImageManager.h | 34 struct Barrier { struct
46 void cacheAsync(const sp<GraphicBuffer>& buffer, const std::shared_ptr<Barrier>& barrier) argument
|
| /aosp_15_r20/external/antlr/tool/src/main/java/org/antlr/misc/ |
| H A D | Barrier.java | 35 public class Barrier { class
39 public Barrier(int t) { in Barrier() method in Barrier
|
| /aosp_15_r20/system/security/keystore2/tests/ |
| H A D | user_auth.rs | 174 type Barrier = BarrierReachedWithData<Option<i64>>; in test_auth_bound_timeout_with_gk() typedef
424 type Barrier = BarrierReachedWithData<Option<i64>>; in test_auth_bound_per_op_with_gk() typedef
558 type Barrier = BarrierReachedWithData<i64>; in test_auth_bound_per_op_failure() typedef
|
| /aosp_15_r20/external/boringssl/src/util/fipstools/acvp/acvptool/subprocess/ |
| H A D | subprocess.go | 34 Barrier(callback func()) error methodSpec
248 func (m *Subprocess) Barrier(callback func()) error { func
|
| /aosp_15_r20/external/cronet/third_party/boringssl/src/util/fipstools/acvp/acvptool/subprocess/ |
| H A D | subprocess.go | 34 Barrier(callback func()) error methodSpec
247 func (m *Subprocess) Barrier(callback func()) error { func
|
| /aosp_15_r20/external/skia/tests/ |
| H A D | SkStrikeTest.cpp | 57 class Barrier { class
59 Barrier(int threadCount) : fThreadCount(threadCount) { } in Barrier() function in Barrier
|
| /aosp_15_r20/external/grpc-grpc/test/core/promise/ |
| H A D | activity_test.cc | 42 class Barrier { class
137 TYPED_TEST(BarrierTest, Barrier) { in TYPED_TEST() argument
|
| /aosp_15_r20/art/test/004-ThreadStress/src-art/ |
| H A D | Main.java | 845 private static class Barrier { class in Main
846 public Barrier(int initialCount) { in Barrier() method in Main.Barrier
|
| /aosp_15_r20/external/pytorch/test/cpp/api/ |
| H A D | dataloader.cpp | 1295 struct Barrier { struct
1296 explicit Barrier(size_t target) : counter_(target) {} in Barrier() function
1297 void wait() { in wait()
1306 size_t counter_;
1307 std::condition_variable cv_;
1308 std::mutex mutex_;
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/kernels/ |
| H A D | barrier_ops.cc | 44 class Barrier : public ResourceBase { class
51 Barrier(const DataTypeVector& value_component_types, in Barrier() function in tensorflow::barrier::Barrier
|
| /aosp_15_r20/external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| H A D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| /aosp_15_r20/external/openscreen/third_party/abseil/src/absl/synchronization/ |
| H A D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| /aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/synchronization/ |
| H A D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| /aosp_15_r20/external/abseil-cpp/absl/synchronization/ |
| H A D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|