| /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.
67 // 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"
53 std::unique_ptr<Barrier> barrier_;
54 std::unique_ptr<Barrier> complete_barrier_;
140 } // Need to drop the mutator lock to use the barrier.
301 // Create the barrier used to synchronize.
302 test->barrier_ = std::unique_ptr<Barrier>(new Barrier(2));
303 test->complete_barrier_ = std::unique_ptr<Barrier>(new Barrier(3));
330 // Wait on completion barrier
[all...] |
| read_barrier.h | 43 // Enable the read barrier checks.
50 ALWAYS_INLINE static MirrorType* Barrier(
|
| thread_pool.h | 23 #include "barrier.h"
147 Barrier creation_barier_;
|
| profiler.h | 26 #include "barrier.h"
186 Barrier& GetBarrier() {
228 std::unique_ptr<Barrier> profiler_barrier_;
|
| /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 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 | 30 #include "Barrier.h"
49 void wait() const { barrier.wait(); }
57 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/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...] |
| tsan_thread_wrappers_pthread.h | 554 class Barrier{
556 explicit Barrier(int n_threads) {CHECK(0 == pthread_barrier_init(&b_, 0, n_threads));}
557 ~Barrier() {CHECK(0 == pthread_barrier_destroy(&b_));}
559 // helgrind 3.3.0 does not have an interceptor for barrier.
|
| bar_bad_xml.stderr.exp | 32 initialise a barrier with zero count
37 <what>pthread_barrier_init: 'count' argument is zero: barrier 0x........</what>
59 initialise a barrier twice
64 <what>Barrier reinitialization: barrier 0x........</what>
84 <what>barrier</what>
108 initialise a barrier which has threads waiting on it
113 <what>Barrier reinitialization: barrier 0x........</what>
133 <what>barrier</what
[all...] |
| /external/llvm/test/MC/AArch64/ |
| arm64-optional-hash.s | 19 ; Barrier operand
|
| /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:__anon38970
556 Barrier barrier B32;
585 Barrier barrier B32
[all...] |
| /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
|
| XI2proto.h | 70 #define Barrier uint32_t
823 Barrier barrier; member in struct:__anon36754
1068 Barrier barrier; member in struct:__anon36765
[all...] |
| /external/llvm/include/llvm/MC/ |
| MCInstrDesc.h | 103 Barrier,
219 bool isBarrier() const { return Flags & (1 << MCID::Barrier); }
|
| /art/runtime/gc/collector/ |
| concurrent_copying.h | 20 #include "barrier.h"
104 Barrier& GetBarrier() {
190 std::unique_ptr<Barrier> gc_barrier_;
|
