| /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...] |
| /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
|
| Android.mk | 11 Semaphore.cpp \
|
| /cts/suite/audio_quality/lib/include/audio/ |
| AudioLocal.h | 24 #include <Semaphore.h>
89 Semaphore mClientCommandWait;
90 Semaphore mClientCompletionWait;
91 Semaphore mAudioThreadWait;
|
| RemoteAudio.h | 31 #include "Semaphore.h"
78 // this is just semaphore wait without any addition
94 Semaphore mInitWait;
134 Semaphore mClientWait;
|
| /external/replicaisland/src/com/replica/replicaisland/ |
| RenderingWatchDog.java | 18 import java.util.concurrent.Semaphore;
34 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0);
|
| /cts/libs/util/src/android/cts/util/ |
| WatchDog.java | 18 import java.util.concurrent.Semaphore;
32 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0);
|
| /frameworks/volley/tests/src/com/android/volley/mock/ |
| WaitableQueue.java | 24 import java.util.concurrent.Semaphore;
32 private final Semaphore mStopEvent = new Semaphore(0);
|
| /cts/tests/tests/openglperf/src/android/openglperf/cts/ |
| GlPlanetsActivity.java | 24 import java.util.concurrent.Semaphore;
42 private final Semaphore mSem = new Semaphore(0);
|
| /cts/tests/tests/textureview/src/android/textureview/cts/ |
| TextureViewSnapshotTestActivity.java | 25 import java.util.concurrent.Semaphore;
37 private final Semaphore mSemaphore = new Semaphore(0);
|
| GLProducerThread.java | 23 import java.util.concurrent.Semaphore;
40 private final Semaphore mSemaphore;
59 int frames, int delayMs, Semaphore semaphore) {
63 mSemaphore = semaphore;
69 Semaphore semaphore) {
70 this(surfaceTexture, renderer, null, frames, delayMs, semaphore);
74 int delayMs, Semaphore semaphore) {
[all...] |
| TextureViewTestActivity.java | 24 import java.util.concurrent.Semaphore;
36 private final Semaphore mSemaphore = new Semaphore(0);
|
| /external/jmdns/src/javax/jmdns/impl/ |
| DNSStatefulObject.java | 7 import java.util.concurrent.Semaphore;
25 * This class define a semaphore. On this multiple threads can wait the arrival of one event. Thread wait for a maximum defined by the timeout.
27 * Implementation note: this class is based on {@link java.util.concurrent.Semaphore} so that they can be released by the timeout timer.
37 private final ConcurrentMap<Thread, Semaphore> _semaphores;
41 * Semaphore name for debugging purposes.
46 _semaphores = new ConcurrentHashMap<Thread, Semaphore>(50);
57 Semaphore semaphore = _semaphores.get(thread); local
58 if (semaphore == null) {
59 semaphore = new Semaphore(1, true)
[all...] |
| /frameworks/base/core/java/android/provider/ |
| SearchRecentSuggestions.java | 27 import java.util.concurrent.Semaphore;
116 private static final Semaphore sWritesInProgress = new Semaphore(0);
180 // Acquire writes semaphore until there is nothing available.
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| Semaphore.java | 12 * A counting semaphore. Conceptually, a semaphore maintains a set of
16 * However, no actual permit objects are used; the {@code Semaphore} just
21 * a class that uses a semaphore to control access to a pool of items:
25 * private final Semaphore available = new Semaphore(MAX_AVAILABLE, true);
67 * the semaphore, guaranteeing that an item is available for use. When
69 * pool and a permit is returned to the semaphore, allowing another
72 * from being returned to the pool. The semaphore encapsulates the
77 * <p>A semaphore initialized to one, and which is used such that i
[all...] |
| /external/v8/src/ |
| debug-agent.h | 81 Semaphore* terminate_now_; // Semaphore to signal termination.
82 Semaphore* listening_;
|
| platform.h | 94 class Semaphore;
234 // Factory method for creating platform dependent Semaphore.
235 // Please use delete to reclaim the storage for the returned Semaphore.
236 static Semaphore* CreateSemaphore(int count);
579 // Semaphore
581 // A semaphore object is a synchronization object that maintains a count. The
582 // count is decremented each time a thread completes a wait for the semaphore
583 // object and incremented each time a thread signals the semaphore. When the
584 // count reaches zero, threads waiting for the semaphore blocks until the
587 class Semaphore {
[all...] |
| /external/valgrind/main/drd/tests/ |
| tc18_semabuse.stderr.exp | 2 Semaphore reinitialization: semaphore 0x........
5 semaphore 0x........ was first observed at:
9 Invalid semaphore: semaphore 0x........
12 semaphore 0x........ was first observed at:
|
| /frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/functional/videoeditor/ |
| VideoEditorPreviewTest.java | 22 import java.util.concurrent.Semaphore;
98 /* Minimum waiting time for Semaphore to wait for release */
152 final Semaphore blockTillPreviewCompletes = new Semaphore(1);
285 final Semaphore blockTillPreviewCompletes = new Semaphore(1);
342 final Semaphore blockTillPreviewCompletes = new Semaphore(1);
409 final Semaphore blockTillPreviewCompletes = new Semaphore(1)
[all...] |
| /frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/functional/camera/ |
| CameraFunctionalTest.java | 27 import java.util.concurrent.Semaphore;
72 final Semaphore sem = new Semaphore(0);
111 final Semaphore sem = new Semaphore(0);
|
| /frameworks/base/media/tests/MediaFrameworkTest/src/com/android/mediaframeworktest/stress/ |
| CameraStressTest.java | 27 import java.util.concurrent.Semaphore;
72 final Semaphore sem = new Semaphore(0);
117 final Semaphore sem = new Semaphore(0);
|
| /external/v8/test/cctest/ |
| test-threads.cc | 146 i::Semaphore* semaphore)
149 semaphore_(semaphore) {
169 i::Semaphore* semaphore_;
176 i::Semaphore* semaphore = i::OS::CreateSemaphore(0); local
180 new ThreadIdValidationThread(prev, &refs, i, semaphore);
187 semaphore->Wait();
|
| /frameworks/base/tests/CoreTests/android/core/ |
| SocketTest.java | 30 import java.util.concurrent.Semaphore;
117 final Semaphore semThreadEnd = new Semaphore(0);
|
