/art/runtime/ |
barrier.cc | 17 #include "barrier.h" 26 Barrier::Barrier(int count) 28 lock_("GC barrier lock", kThreadSuspendCountLock), 29 condition_("GC barrier condition", lock_) { 32 void Barrier::Pass(Thread* self) { 37 void Barrier::Wait(Thread* self) { 41 void Barrier::Init(Thread* self, int count) { 46 void Barrier::Increment(Thread* self, int delta) { 51 // then all the threads have already passed the barrier. I [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 { 38 explicit Barrier(int count); 39 virtual ~Barrier(); 41 // Pass through the barrier, decrement the count but do not block. 44 // Wait on the barrier, decrement the count. 69 // 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 | 17 #include "barrier.h" 54 std::unique_ptr<Barrier> barrier_; 55 std::unique_ptr<Barrier> complete_barrier_; 141 } // Need to drop the mutator lock to use the barrier. 302 // Create the barrier used to synchronize. 303 test->barrier_ = std::unique_ptr<Barrier>(new Barrier(2)); 304 test->complete_barrier_ = std::unique_ptr<Barrier>(new Barrier(3)); 331 // Wait on completion barrier [all...] |
read_barrier.h | 42 // Enable the read barrier checks. 49 ALWAYS_INLINE static MirrorType* Barrier( 98 // subsequent load to prevent the reordering of the read barrier bit load and the subsequent 104 // This uses a load-acquire to load the read barrier bit internally to prevent the reordering of 105 // the read barrier bit load and the subsequent load.
|
thread_pool.h | 23 #include "barrier.h" 166 Barrier creation_barier_;
|
/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) : mType(type), mOpened(false) { } 28 ~Barrier() { }
|
Future.h | 22 #include "Barrier.h" 51 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/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
|
/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.25/gas/testsuite/gas/arm/ |
barrier.d | 2 #name: Barrier Instruction Operands 7 # Test Barrier Instruction Operands
|
barrier-thumb.d | 2 #name: Barrier Instruction Operands (Thumb) 3 #source: barrier.s 8 # 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:__anon48810 556 Barrier barrier B32; 585 Barrier barrier B32 [all...] |
/art/test/004-ThreadStress/src/ |
Main.java | 414 final Barrier startBarrier = new Barrier(numberOfThreads + numberOfDaemons + 1); 519 // instead of waiting indefinitely for some Barrier. 602 Barrier startBarrier) { 637 // instead of waiting indefinitely for some Barrier. 643 final Barrier startBarrier; 647 // That is highly undesirable in this test, so we use our own simple barrier class. 651 private static class Barrier { 652 public Barrier(int initialCount) {
|
/prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/sysroot/usr/include/X11/extensions/ |
xfixesproto.h | 506 #define Barrier CARD32 512 Barrier barrier B32; 530 Barrier barrier B32; 535 #undef Barrier
|