Searched refs:Semaphore (Results 1 - 25 of 60) sorted by relevance

123

/external/deqp/framework/delibs/decpp/
H A DdeSemaphore.hpp33 * \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 DdeSemaphore.cpp35 * \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 DdeThreadSafeRingBuffer.hpp60 Semaphore m_fill;
61 Semaphore m_empty;
/external/chromium_org/v8/src/base/platform/
H A Dsemaphore.h26 // 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 Dsemaphore-unittest.cc25 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 Dsemaphore.cc23 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 Dplatform.h441 start_semaphore_ = new Semaphore(0);
509 Semaphore* start_semaphore_;
/external/chromium_org/v8/src/heap/
H A Dsweeper-thread.h37 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 DUiUtils.java14 import java.util.concurrent.Semaphore;
31 final Semaphore finishedSemaphore = new Semaphore(0);
/external/replicaisland/src/com/replica/replicaisland/
H A DRenderingWatchDog.java18 import java.util.concurrent.Semaphore;
34 private Semaphore mSemaphore;
50 mSemaphore = new Semaphore(0);
/external/chromium_org/v8/src/libplatform/
H A Dtask-queue.h37 base::Semaphore process_queue_semaphore_;
/external/chromium_org/v8/src/
H A Druntime-profiler.h13 class Semaphore;
H A Doptimizing-compiler-thread.h112 base::Semaphore stop_semaphore_;
113 base::Semaphore input_queue_semaphore_;
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/sync/
H A DChromiumSyncAdapter.java24 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 DDNSStatefulObject.java7 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 DMockSyncContentResolverDelegate.java22 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 Dtc18_semabuse.stderr.exp2 Semaphore reinitialization: semaphore 0x........
/external/chromium_org/android_webview/javatests/src/org/chromium/android_webview/test/
H A DArchiveTest.java18 import java.util.concurrent.Semaphore;
55 final Semaphore s = new Semaphore(0);
/external/chromium_org/v8/test/cctest/
H A Dtest-threads.cc129 v8::base::Semaphore* semaphore)
153 v8::base::Semaphore* semaphore_;
161 v8::base::Semaphore semaphore(0);
H A Dtest-circular-queue.cc109 v8::base::Semaphore* finished)
131 v8::base::Semaphore* finished_;
144 v8::base::Semaphore semaphore(0);
/external/deqp/framework/platform/android/
H A DtcuAndroidRenderActivity.hpp52 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 DxeCallQueue.hpp117 de::Semaphore m_callSem;
/external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/signin/
H A DOAuth2TokenService.java24 import java.util.concurrent.Semaphore;
183 final Semaphore semaphore = new Semaphore(0);
/external/nist-sip/java/gov/nist/javax/sip/stack/
H A DIOHandler.java38 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 DSyncTestUtil.java35 import java.util.concurrent.Semaphore;
222 final Semaphore s = new Semaphore(0);

Completed in 654 milliseconds

123