| /external/deqp/framework/delibs/decpp/ |
| deSemaphore.hpp | 33 * \brief Semaphore
35 * Semaphore provides standard semaphore functionality.
37 * Semaphore is thread-safe counter that can be used to control access
42 class Semaphore
45 Semaphore (int initialValue, deUint32 flags = 0);
46 ~Semaphore (void);
53 Semaphore (const Semaphore& other); // Not allowed!
54 Semaphore& operator= (const Semaphore& other); // Not allowed
[all...] |
| deSemaphore.cpp | 33 * \brief Construct semaphore.
34 * \param initialValue Initial value for semaphore. Must be 0 or greater.
35 * \param flags Semaphore flags (reserved for further use).
37 Semaphore::Semaphore (int initialValue, deUint32 flags)
48 Semaphore::~Semaphore (void)
|
| /cts/suite/audio_quality/lib/include/ |
| Semaphore.h | 21 #include <semaphore.h>
26 * Simple semaphore interface for synchronization between client and server
28 class Semaphore {
30 Semaphore(int count = 0);
32 ~Semaphore();
34 /// down semaphore if it is already positive.
|
| /cts/suite/audio_quality/lib/src/ |
| Semaphore.cpp | 17 #include "Semaphore.h"
20 Semaphore::Semaphore(int count)
27 Semaphore::~Semaphore()
32 void Semaphore::tryWait()
37 bool Semaphore::wait()
46 bool Semaphore::timedWait(int timeInMSec)
67 //LOGV("Semaphore::timedWait now %d-%d until %d-%d for %d msecs",
76 void Semaphore::post(
[all...] |
| /external/v8/src/base/platform/ |
| semaphore.h | 14 #include <mach/semaphore.h> // NOLINT
16 #include <semaphore.h> // NOLINT
26 // Semaphore
28 // A semaphore object is a synchronization object that maintains a count. The
29 // count is decremented each time a thread completes a wait for the semaphore
30 // object and incremented each time a thread signals the semaphore. When the
31 // count reaches zero, threads waiting for the semaphore blocks until the
34 class Semaphore FINAL {
36 explicit Semaphore(int count);
37 ~Semaphore();
[all...] |
| semaphore-unittest.cc | 8 #include "src/base/platform/semaphore.h"
25 ProducerThread(char* buffer, Semaphore* free_space, Semaphore* used_space)
42 Semaphore* const free_space_;
43 Semaphore* const used_space_;
49 ConsumerThread(const char* buffer, Semaphore* free_space,
50 Semaphore* used_space)
67 Semaphore* const free_space_;
68 Semaphore* const used_space_;
74 explicit WaitAndSignalThread(Semaphore* semaphore
[all...] |
| semaphore.cc | 5 #include "src/base/platform/semaphore.h"
23 Semaphore::Semaphore(int count) {
31 Semaphore::~Semaphore() {
38 void Semaphore::Signal() {
45 void Semaphore::Wait() {
48 if (result == KERN_SUCCESS) return; // Semaphore was signalled.
54 bool Semaphore::WaitFor(const TimeDelta& rel_time) {
60 // Return immediately if semaphore was not signalled
[all...] |
| /hardware/ti/omap4-aah/libtiutils/ |
| Semaphore.cpp | 19 #include "Semaphore.h"
28 @brief Constructor for the semaphore class
33 Semaphore::Semaphore()
35 ///Initialize the semaphore to NULL
40 @brief Destructor of the semaphore class
46 Semaphore::~Semaphore()
52 @brief: Releases semaphore
56 @return One of the android error codes based on semaphore de-initializatio
[all...] |
| Semaphore.h | 20 #include <semaphore.h>
32 class Semaphore
36 Semaphore();
37 ~Semaphore();
39 //Release semaphore
42 ///Create the semaphore with initial count value
51 ///Current semaphore count
|
| /hardware/ti/omap4xxx/libtiutils/ |
| Semaphore.cpp | 19 #include "Semaphore.h"
27 @brief Constructor for the semaphore class
32 Semaphore::Semaphore()
34 ///Initialize the semaphore to NULL
39 @brief Destructor of the semaphore class
45 Semaphore::~Semaphore()
51 @brief: Releases semaphore
55 @return One of the android error codes based on semaphore de-initializatio
[all...] |
| Semaphore.h | 20 #include <semaphore.h>
29 class Semaphore
33 Semaphore();
34 ~Semaphore();
36 //Release semaphore
39 ///Create the semaphore with initial count value
48 ///Current semaphore count
|
| /external/v8/src/heap/ |
| sweeper-thread.h | 37 base::Semaphore start_sweeping_semaphore_;
38 base::Semaphore end_sweeping_semaphore_;
39 base::Semaphore stop_semaphore_;
|
| /cts/suite/audio_quality/lib/include/audio/ |
| AudioLocal.h | 24 #include <Semaphore.h>
89 Semaphore mClientCommandWait;
90 Semaphore mClientCompletionWait;
91 Semaphore mAudioThreadWait;
|
| /cts/tests/tests/telecom/src/android/telecom/cts/ |
| ConnectionTest.java | 30 import java.util.concurrent.Semaphore;
40 final Semaphore lock = new Semaphore(0);
123 final Semaphore lock = new Semaphore(0);
138 final Semaphore lock = new Semaphore(0);
153 final Semaphore lock = new Semaphore(0);
170 final Semaphore lock = new Semaphore(0)
[all...] |
| /cts/hostsidetests/devicepolicy/app/ManagedProfile/src/com/android/cts/managedprofile/ |
| TestActivity.java | 22 import java.util.concurrent.Semaphore;
31 private final Semaphore mActivityStartedSemaphore = new Semaphore(0);
|
| /external/replicaisland/src/com/replica/replicaisland/ |
| RenderingWatchDog.java | 18 import java.util.concurrent.Semaphore;
34 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0);
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| SemaphoreTest.java | 15 import java.util.concurrent.Semaphore;
34 static class PublicSemaphore extends Semaphore {
52 final Semaphore lock;
53 InterruptibleLockRunnable(Semaphore s) { lock = s; }
66 final Semaphore lock;
67 InterruptedLockRunnable(Semaphore s) { lock = s; }
90 void waitForQueuedThreads(Semaphore s) {
101 void acquire(Semaphore s) throws InterruptedException {
106 void acquire(Semaphore s, int permits) throws InterruptedException {
111 void acquire(Semaphore s)
[all...] |
| /external/v8/src/libplatform/ |
| task-queue.h | 12 #include "src/base/platform/semaphore.h"
37 base::Semaphore process_queue_semaphore_;
|
| /external/v8/src/ |
| runtime-profiler.h | 13 class Semaphore;
|
| /cts/common/device-side/util/src/com/android/compatibility/common/util/ |
| WatchDog.java | 18 import java.util.concurrent.Semaphore;
31 private Semaphore mSemaphore;
49 mSemaphore = new Semaphore(0);
|
| /cts/hostsidetests/devicepolicy/app/IntentReceiver/src/com/android/cts/intent/receiver/ |
| OwnerChangedBroadcastTest.java | 26 import java.util.concurrent.Semaphore;
46 final Semaphore mPreferenceChanged = new Semaphore(0);
|
| /cts/libs/deviceutil/src/android/cts/util/ |
| WatchDog.java | 18 import java.util.concurrent.Semaphore;
32 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0);
|
| /cts/suite/cts/deviceTests/opengl/src/com/android/cts/opengl/reference/ |
| GLReferenceActivity.java | 22 import java.util.concurrent.Semaphore;
36 private Semaphore mSemaphore = new Semaphore(0);
|
| /cts/tests/tests/renderscript/src/android/renderscript/cts/ |
| SendToClientBlockingTest.java | 21 import java.util.concurrent.Semaphore;
25 private static final Semaphore mSync = new Semaphore(0);
|
| /frameworks/data-binding/integration-tests/TestApp/app/src/androidTestApi7/java/android/databinding/testapp/ |
| InvalidateAllTest.java | 8 import java.util.concurrent.Semaphore;
18 final Semaphore semaphore = new Semaphore(1); local
19 semaphore.acquire();
29 semaphore.release();
34 assertTrue(semaphore.tryAcquire(2, TimeUnit.SECONDS));
40 assertTrue(semaphore.tryAcquire(2, TimeUnit.SECONDS));
|
