| /art/runtime/ |
| barrier.cc | 17 #include "barrier.h"
28 Barrier::Barrier(int count)
30 lock_("GC barrier lock", kThreadSuspendCountLock),
31 condition_("GC barrier condition", lock_) {
34 template void Barrier::Increment<Barrier::kAllowHoldingLocks>(Thread* self, int delta);
35 template void Barrier::Increment<Barrier::kDisallowHoldingLocks>(Thread* self, int delta);
37 void Barrier::Pass(Thread* self)
[all...] |
| barrier.h | 17 // CAUTION: THIS IS NOT A FULLY GENERAL BARRIER API.
19 // It may either be used as a "latch" or single-use barrier, or it may be reused under
36 class Barrier {
43 explicit Barrier(int count);
44 virtual ~Barrier();
46 // Pass through the barrier, decrement the count but do not block.
49 // Wait on the barrier, decrement the count.
60 template <Barrier::LockHandling locks = kDisallowHoldingLocks>
76 // Counter, when this reaches 0 all people blocked on the barrier are signalled.
|
| barrier_test.cc | 17 #include "barrier.h"
30 CheckWaitTask(Barrier* barrier, AtomicInteger* count1, AtomicInteger* count2)
31 : barrier_(barrier),
36 LOG(INFO) << "Before barrier" << *self;
40 LOG(INFO) << "After barrier" << *self;
48 Barrier* const barrier_;
60 // Check that barrier wait and barrier increment work.
63 ThreadPool thread_pool("Barrier test thread pool", num_threads)
[all...] |
| monitor_test.cc | 22 #include "barrier.h"
51 std::unique_ptr<Barrier> barrier_;
52 std::unique_ptr<Barrier> complete_barrier_;
92 } // Need to drop the mutator lock to use the barrier.
253 // Create the barrier used to synchronize.
254 test->barrier_ = std::unique_ptr<Barrier>(new Barrier(2));
255 test->complete_barrier_ = std::unique_ptr<Barrier>(new Barrier(3));
278 // Wait on completion barrier
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/java/org/antlr/misc/ |
| Barrier.java | 30 /**A very simple barrier wait. Once a thread has requested a
31 * wait on the barrier with waitForRelease, it cannot fool the
32 * barrier into releasing by "hitting" the barrier multiple times--
35 public class Barrier {
39 public Barrier(int t) {
47 // The final thread to reach barrier resets barrier and
59 /** What to do when everyone reaches barrier */
|
| /frameworks/base/libs/hwui/thread/ |
| Barrier.h | 25 class Barrier {
27 explicit Barrier(Condition::WakeUpType type = Condition::WAKE_UP_ALL)
29 ~Barrier() {}
|
| Future.h | 22 #include "Barrier.h"
52 Barrier mBarrier;
|
| /frameworks/native/services/surfaceflinger/ |
| Barrier.h | 26 class Barrier
29 inline Barrier() : state(CLOSED) { }
30 inline ~Barrier() { }
32 // Release any threads waiting at the Barrier.
41 // Reset the Barrier, so wait() will block until open() has been called.
47 // Wait until the Barrier is OPEN.
|
| MessageQueue.h | 31 #include "Barrier.h"
50 void wait() const { barrier.wait(); }
58 mutable Barrier barrier; member in class:android::MessageBase
|
| /external/antlr/antlr-3.4/tool/src/main/java/org/antlr/analysis/ |
| NFAConversionThread.java | 30 import org.antlr.misc.Barrier;
38 Barrier barrier; field in class:NFAConversionThread
40 Barrier barrier,
45 this.barrier = barrier;
58 barrier.waitForRelease();
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| TensorDeviceThreadPool.h | 26 // Barrier is an object that allows one or more threads to wait until
28 class Barrier {
30 Barrier(unsigned int count) : state_(count << 1), notified_(false) {
33 ~Barrier() {
71 struct Notification : Barrier {
72 Notification() : Barrier(1) {};
90 static void run(Barrier* b, Function f, Args... args) {
159 EIGEN_STRONG_INLINE void enqueue_with_barrier(Barrier* b,
247 Barrier barrier(static_cast<unsigned int>(block_count))
[all...] |
| /external/valgrind/drd/tests/ |
| pth_barrier_reinit.stderr.exp | 2 Barrier reinitialization: barrier 0x........
5 barrier 0x........ was first observed at:
|
| bar_bad.stderr.exp | 3 initialise a barrier with zero count
4 pthread_barrier_init: 'count' argument is zero: barrier 0x........
9 initialise a barrier twice
10 Barrier reinitialization: barrier 0x........
13 barrier 0x........ was first observed at:
18 initialise a barrier which has threads waiting on it
19 Barrier reinitialization: barrier 0x........
22 barrier 0x........ was first observed at
[all...] |
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| barrier_ops_test.py | 15 """Tests for barrier ops."""
36 b = data_flow_ops.Barrier(
43 name:'B' op:'Barrier'
71 b = data_flow_ops.Barrier(
90 data_flow_ops.Barrier(
95 b = data_flow_ops.Barrier((dtypes.float32, dtypes.float32), name="B")
107 b = data_flow_ops.Barrier(
132 b = data_flow_ops.Barrier(
141 # After insert_1_1_op, we'll have two ready elements in the barrier,
153 # Now we have a closed barrier with 2 ready elements. Running take_
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| barrier_ops.cc | 41 namespace barrier { namespace in namespace:tensorflow
43 class Barrier : public ResourceBase {
50 Barrier(const DataTypeVector& value_component_types,
118 "Barrier ", name_, " is closed. Pending enqueues cancelled: ",
146 "Barrier has had ", input_index_,
224 "Barrier '", name_, "' is closed and has ",
261 errors::Cancelled("Barrier '", name_, "' is already closed."));
297 ~Barrier() override EXCLUSIVE_LOCKS_REQUIRED(mu_) {
303 string DebugString() override { return "A barrier"; }
320 "Barrier ", name_
509 Barrier* barrier = nullptr; variable
[all...] |
| /external/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /external/libcxx/utils/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/utils/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /external/llvm/test/MC/AArch64/ |
| arm64-optional-hash.s | 19 ; Barrier operand
|
| /external/compiler-rt/lib/tsan/rtl/ |
| tsan_interceptors_mac.cc | 30 // The non-barrier versions of OSAtomic* functions are semantically mo_relaxed,
34 // conservative and treat the non-barrier versions as mo_acq_rel.
66 m(int32_t, int32_t, a32, f##32##Barrier, __tsan_atomic32_##tsan_atomic_f, \
70 m(int64_t, int64_t, a64, f##64##Barrier, __tsan_atomic64_##tsan_atomic_f, \
76 m(int32_t, uint32_t, a32, f##32##Barrier, __tsan_atomic32_##tsan_atomic_f, \
104 TSAN_INTERCEPTOR(bool, f##Barrier, t old_value, t new_value, \
106 SCOPED_TSAN_INTERCEPTOR(f##Barrier, old_value, new_value, ptr); \
134 OSATOMIC_INTERCEPTOR_BITOP(f##Barrier, op, m, kMacOrderBarrier)
255 dispatch_block_t barrier) {
256 SCOPED_TSAN_INTERCEPTOR(xpc_connection_send_barrier, connection, barrier);
[all...] |
| /external/swiftshader/third_party/LLVM/include/llvm/MC/ |
| MCInstrDesc.h | 103 Barrier,
298 return Flags & (1 << MCID::Barrier);
|
| /toolchain/binutils/binutils-2.27/gas/testsuite/gas/arm/ |
| barrier.d | 2 #name: Barrier Instruction Operands
7 # Test Barrier Instruction Operands
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/X11/extensions/ |
| xfixesproto.h | 506 #define Barrier CARD32
512 Barrier barrier B32;
530 Barrier barrier B32;
545 Barrier barrier; member in struct:__anon62018
556 Barrier barrier B32;
585 Barrier barrier B32
[all...] |
| /art/test/004-ThreadStress/src-art/ |
| Main.java | 583 final Barrier startBarrier = new Barrier(numberOfThreads + numberOfDaemons + 1);
688 // instead of waiting indefinitely for some Barrier.
771 Barrier startBarrier) {
808 // instead of waiting indefinitely for some Barrier.
814 final Barrier startBarrier;
818 // That is highly undesirable in this test, so we use our own simple barrier class.
822 private static class Barrier {
823 public Barrier(int initialCount) {
[all...] |
| /external/python/cpython3/Lib/multiprocessing/ |
| context.py | 94 def Barrier(self, parties, action=None, timeout=None):
95 '''Returns a barrier object'''
96 from .synchronize import Barrier
97 return Barrier(parties, action, timeout, ctx=self.get_context())
|
