| /external/opencv3/3rdparty/openexr/IlmThread/ |
| IlmThreadSemaphore.cpp | 37 // class Semaphore -- dummy implementation for
50 Semaphore::Semaphore (unsigned int value) {}
51 Semaphore::~Semaphore () {}
52 void Semaphore::wait () {}
53 bool Semaphore::tryWait () {return true;}
54 void Semaphore::post () {}
55 int Semaphore::value () const {return 0;}
|
| IlmThreadSemaphorePosix.cpp | 37 // class Semaphore -- implementation for platforms
53 Semaphore::Semaphore (unsigned int value)
56 Iex::throwErrnoExc ("Cannot initialize semaphore (%T).");
60 Semaphore::~Semaphore ()
68 Semaphore::wait ()
75 Semaphore::tryWait ()
82 Semaphore::post ()
85 Iex::throwErrnoExc ("Post operation on semaphore failed (%T).")
[all...] |
| IlmThreadSemaphore.h | 40 // class Semaphore -- a wrapper class for
56 #include <semaphore.h>
62 class Semaphore
66 Semaphore (unsigned int value = 0);
67 virtual ~Semaphore();
103 void operator = (const Semaphore& s); // not implemented
104 Semaphore (const Semaphore& s); // not implemented
|
| IlmThreadSemaphorePosixCompat.cpp | 37 // class Semaphore -- implementation for for platforms that do
54 Semaphore::Semaphore (unsigned int value)
68 Semaphore::~Semaphore ()
78 Semaphore::wait ()
104 Semaphore::tryWait ()
123 Semaphore::post ()
144 Semaphore::value () const
|
| IlmThreadSemaphoreWin32.cpp | 37 // class Semaphore -- implementation for Windows
86 Semaphore::Semaphore (unsigned int value)
90 THROW (LogicExc, "Could not create semaphore "
96 Semaphore::~Semaphore()
104 Semaphore::wait()
108 THROW (LogicExc, "Could not wait on semaphore "
115 Semaphore::tryWait()
122 Semaphore::post(
[all...] |
| /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.cc | 5 #include "src/base/platform/semaphore.h"
23 Semaphore::Semaphore(int count) {
31 Semaphore::~Semaphore() {
37 void Semaphore::Signal() {
44 void Semaphore::Wait() {
47 if (result == KERN_SUCCESS) return; // Semaphore was signalled.
53 bool Semaphore::WaitFor(const TimeDelta& rel_time) {
59 // 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/test/unittests/base/platform/ |
| semaphore-unittest.cc | 8 #include "src/base/platform/semaphore.h"
25 ProducerThread(char* buffer, Semaphore* free_space, Semaphore* used_space)
41 Semaphore* const free_space_;
42 Semaphore* const used_space_;
48 ConsumerThread(const char* buffer, Semaphore* free_space,
49 Semaphore* used_space)
65 Semaphore* const free_space_;
66 Semaphore* const used_space_;
72 explicit WaitAndSignalThread(Semaphore* semaphore
[all...] |
| /system/core/libmemunreachable/ |
| Semaphore.h | 25 class Semaphore {
27 Semaphore(int count = 0) : count_(count) {}
28 ~Semaphore() = default;
48 DISALLOW_COPY_AND_ASSIGN(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 | 32 import java.util.concurrent.Semaphore;
42 final Semaphore lock = new Semaphore(0);
129 final Semaphore lock = new Semaphore(0);
144 final Semaphore lock = new Semaphore(0);
159 final Semaphore lock = new Semaphore(0);
176 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;
35 static class PublicSemaphore extends Semaphore {
53 final Semaphore lock;
54 InterruptibleLockRunnable(Semaphore s) { lock = s; }
67 final Semaphore lock;
68 InterruptedLockRunnable(Semaphore s) { lock = s; }
91 void waitForQueuedThreads(Semaphore s) {
102 void acquire(Semaphore s) throws InterruptedException {
107 void acquire(Semaphore s, int permits) throws InterruptedException {
112 void acquire(Semaphore s)
[all...] |
| /external/v8/src/libplatform/ |
| task-queue.h | 12 #include "src/base/platform/semaphore.h"
36 base::Semaphore process_queue_semaphore_;
|
| /packages/services/Car/tests/carservice_test/src/com/android/car/test/ |
| MockedCarTestBase.java | 29 import java.util.concurrent.Semaphore;
45 private final Semaphore mConnectionWaitForSupportCar = new Semaphore(0);
46 private final Semaphore mConnectionWaitForCar = new Semaphore(0);
47 private final Semaphore mWaitForMain = new Semaphore(0);
|
| /external/sl4a/ScriptingLayerForAndroid/src/org/connectbot/service/ |
| PromptHelper.java | 20 import java.util.concurrent.Semaphore;
35 private Semaphore promptToken;
36 private Semaphore promptResponse;
48 promptToken = new Semaphore(1);
50 // Responses will release this semaphore.
51 promptResponse = new Semaphore(0);
|
