/external/deqp/framework/delibs/decpp/ |
H A D | 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 class in namespace:de 45 Semaphore (int initialValue, deUint32 flags = 0); 46 ~Semaphore (void); 53 Semaphore (const Semaphore& other); // Not allowed! 54 Semaphore& operator= (const Semaphore [all...] |
H A D | deSemaphore.cpp | 35 * \param flags Semaphore flags (reserved for further use). 37 Semaphore::Semaphore (int initialValue, deUint32 flags) function in class:de::Semaphore 48 Semaphore::~Semaphore (void)
|
H A D | deThreadSafeRingBuffer.hpp | 60 Semaphore m_fill; 61 Semaphore m_empty;
|
/external/chromium_org/v8/src/base/platform/ |
H A D | semaphore.h | 26 // Semaphore 34 class Semaphore FINAL { 36 explicit Semaphore(int count); 37 ~Semaphore(); 70 DISALLOW_COPY_AND_ASSIGN(Semaphore); 74 // POD Semaphore initialized lazily (i.e. the first time Pointer() is called). 86 static Semaphore* Create() { 87 return new Semaphore(N); 93 typedef typename LazyDynamicInstance<Semaphore, CreateSemaphoreTrait<N>,
|
H A D | semaphore-unittest.cc | 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) 87 Semaphore* cons [all...] |
H A D | semaphore.cc | 23 Semaphore::Semaphore(int count) { function in class:v8::base::Semaphore 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) { 67 if (result == KERN_SUCCESS) return true; // Semaphore was signalled. 76 Semaphore [all...] |
H A D | platform.h | 441 start_semaphore_ = new Semaphore(0); 509 Semaphore* start_semaphore_;
|
/external/chromium_org/v8/src/heap/ |
H A D | sweeper-thread.h | 37 base::Semaphore start_sweeping_semaphore_; 38 base::Semaphore end_sweeping_semaphore_; 39 base::Semaphore stop_semaphore_;
|
/external/chromium_org/content/public/test/android/javatests/src/org/chromium/content/browser/test/util/ |
H A D | UiUtils.java | 14 import java.util.concurrent.Semaphore; 31 final Semaphore finishedSemaphore = new Semaphore(0);
|
/external/replicaisland/src/com/replica/replicaisland/ |
H A D | RenderingWatchDog.java | 18 import java.util.concurrent.Semaphore; 34 private Semaphore mSemaphore; 50 mSemaphore = new Semaphore(0);
|
/external/chromium_org/v8/src/libplatform/ |
H A D | task-queue.h | 37 base::Semaphore process_queue_semaphore_;
|
/external/chromium_org/v8/src/ |
H A D | runtime-profiler.h | 13 class Semaphore;
|
H A D | optimizing-compiler-thread.h | 112 base::Semaphore stop_semaphore_; 113 base::Semaphore input_queue_semaphore_;
|
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/sync/ |
H A D | ChromiumSyncAdapter.java | 24 import java.util.concurrent.Semaphore; 64 Semaphore semaphore = new Semaphore(0); 83 final SyncResult syncResult, Semaphore semaphore) { 129 final SyncResult syncResult, final Semaphore semaphore) {
|
/external/jmdns/src/javax/jmdns/impl/ |
H A D | DNSStatefulObject.java | 7 import java.util.concurrent.Semaphore; 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); 59 semaphore = new Semaphore(1, true); 75 Collection<Semaphore> semaphores = _semaphores.values(); 76 for (Semaphore semaphore : semaphores) { 85 aLog.append("Semaphore [all...] |
/external/chromium_org/sync/test/android/javatests/src/org/chromium/sync/test/util/ |
H A D | MockSyncContentResolverDelegate.java | 22 import java.util.concurrent.Semaphore; 43 private Semaphore mPendingObserverCount; 158 mPendingObserverCount = new Semaphore(1 - mObservers.size()); 189 private void notifyObserverAsync(final Semaphore pendingObserverCount) {
|
/external/valgrind/main/drd/tests/ |
H A D | tc18_semabuse.stderr.exp | 2 Semaphore reinitialization: semaphore 0x........
|
/external/chromium_org/android_webview/javatests/src/org/chromium/android_webview/test/ |
H A D | ArchiveTest.java | 18 import java.util.concurrent.Semaphore; 55 final Semaphore s = new Semaphore(0);
|
/external/chromium_org/v8/test/cctest/ |
H A D | test-threads.cc | 129 v8::base::Semaphore* semaphore) 153 v8::base::Semaphore* semaphore_; 161 v8::base::Semaphore semaphore(0);
|
H A D | test-circular-queue.cc | 109 v8::base::Semaphore* finished) 131 v8::base::Semaphore* finished_; 144 v8::base::Semaphore semaphore(0);
|
/external/deqp/framework/platform/android/ |
H A D | tcuAndroidRenderActivity.hpp | 52 MESSAGE_SYNC, //!< Main thread requests sync. Data argument is de::Semaphore* that needs to be incremented. 64 de::Semaphore* semaphore; 99 Message (MessageType type_, de::Semaphore* semaphore)
|
/external/deqp/executor/ |
H A D | xeCallQueue.hpp | 117 de::Semaphore m_callSem;
|
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/signin/ |
H A D | OAuth2TokenService.java | 24 import java.util.concurrent.Semaphore; 183 final Semaphore semaphore = new Semaphore(0);
|
/external/nist-sip/java/gov/nist/javax/sip/stack/ |
H A D | IOHandler.java | 38 import java.util.concurrent.Semaphore; 62 private Semaphore ioSemaphore = new Semaphore(1); 183 "Could not acquire IO Semaphore after 10 seconds -- giving up ");
|
/external/chromium_org/chrome/test/android/javatests/src/org/chromium/chrome/test/util/browser/sync/ |
H A D | SyncTestUtil.java | 35 import java.util.concurrent.Semaphore; 222 final Semaphore s = new Semaphore(0);
|