/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 \
|
/external/chromium_org/v8/src/ |
marking-thread.h | 61 Semaphore* start_marking_semaphore_; 62 Semaphore* end_marking_semaphore_; 63 Semaphore* stop_semaphore_;
|
sweeper-thread.h | 63 Semaphore* start_sweeping_semaphore_; 64 Semaphore* end_sweeping_semaphore_; 65 Semaphore* stop_semaphore_;
|
optimizing-compiler-thread.h | 108 Semaphore* stop_semaphore_; 109 Semaphore* input_queue_semaphore_;
|
runtime-profiler.h | 40 class Semaphore;
|
/cts/suite/audio_quality/lib/include/audio/ |
AudioLocal.h | 24 #include <Semaphore.h> 89 Semaphore mClientCommandWait; 90 Semaphore mClientCompletionWait; 91 Semaphore mAudioThreadWait;
|
/external/chromium_org/content/public/test/android/javatests/src/org/chromium/content/browser/test/util/ |
UiUtils.java | 12 import java.util.concurrent.Semaphore; 28 final Semaphore finishedSemaphore = 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);
|
/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);
|
/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...] |
/cts/suite/cts/hostTests/uihost/control/src/com/android/cts/taskswitching/control/ |
TaskswitchingDeviceTest.java | 19 import java.util.concurrent.Semaphore; 103 private final Semaphore mSemaphore = new Semaphore(0);
|
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/signin/ |
AndroidProfileOAuth2TokenServiceHelper.java | 16 import java.util.concurrent.Semaphore; 114 final Semaphore semaphore = new Semaphore(0); local 121 semaphore.release(); 125 if (semaphore.tryAcquire(timeout, unit)) {
|
/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/chromium_org/sync/test/android/javatests/src/org/chromium/sync/test/util/ |
MockSyncContentResolverDelegate.java | 22 import java.util.concurrent.Semaphore; 40 private Semaphore mPendingObserverCount; 144 mPendingObserverCount = new Semaphore(1 - mObservers.size()); 171 private void notifyObserverAsync(final Semaphore pendingObserverCount) {
|