| /external/chromium_org/net/socket/ |
| D | websocket_endpoint_lock_manager_unittest.cc | 129 FakeWaiter waiters[2]; in TEST_F() local
130 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0])); in TEST_F()
132 instance()->LockEndpoint(DummyEndpoint(), &waiters[1])); in TEST_F()
146 FakeWaiter waiters[2]; in TEST_F() local
147 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0])); in TEST_F()
149 instance()->LockEndpoint(DummyEndpoint(), &waiters[1])); in TEST_F()
150 EXPECT_FALSE(waiters[1].called()); in TEST_F()
156 FakeWaiter waiters[2]; in TEST_F() local
157 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0])); in TEST_F()
159 instance()->LockEndpoint(DummyEndpoint(), &waiters[1])); in TEST_F()
[all …]
|
| /external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
| D | sem_post_multiple.c | 80 long waiters; in sem_post_multiple() local
100 waiters = -s->value; in sem_post_multiple()
102 if (waiters > 0) in sem_post_multiple()
107 waiters--; in sem_post_multiple()
109 if (s->leftToUnblock > waiters) in sem_post_multiple()
111 s->leftToUnblock = waiters; in sem_post_multiple()
115 if (ReleaseSemaphore (s->sem, (waiters<=count)?waiters:count, 0)) in sem_post_multiple()
|
| /external/libvpx/libvpx/vpx_ports/ |
| D | vpx_once.h | 22 static LONG waiters; in once() local
33 InterlockedIncrement(&waiters); in once()
67 if(!InterlockedDecrement(&waiters)) in once()
|
| /external/chromium_org/third_party/libusb/src/libusb/os/ |
| D | threads_windows.c | 88 list_init(&cond->waiters ); in usbi_cond_init()
96 if(!list_empty(&cond->waiters)) return ((errno=EBUSY )); // (!see above!) in usbi_cond_destroy()
113 list_for_each_entry(pos, &cond->waiters, list, struct usbi_cond_perthread) { in usbi_cond_broadcast()
126 if(list_empty(&cond->waiters)) return 0; // no one to wakeup. in usbi_cond_signal()
127 pos = list_entry(&cond->waiters.next, struct usbi_cond_perthread, list); in usbi_cond_signal()
157 list_add(&pos->list, &cond->waiters); in usbi_cond_intwait()
|
| D | threads_windows.h | 38 struct list_head waiters; member
|
| /external/chromium_org/third_party/libvpx/source/libvpx/vpx_ports/ |
| D | vpx_once.h | 22 static LONG waiters; in once() local
33 InterlockedIncrement(&waiters); in once()
67 if(!InterlockedDecrement(&waiters)) in once()
|
| /external/fio/ |
| D | mutex.c | 110 mutex->waiters++; in fio_mutex_down_timeout()
120 mutex->waiters--; in fio_mutex_down_timeout()
154 mutex->waiters++; in fio_mutex_down()
156 mutex->waiters--; in fio_mutex_down()
169 if (!mutex->value && mutex->waiters) in fio_mutex_up()
|
| D | mutex.h | 13 int waiters; member
|
| /external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/os/ |
| D | os_thread.h | 342 unsigned waiters; member
351 barrier->waiters = 0; in pipe_barrier_init()
359 assert(barrier->waiters == 0); in pipe_barrier_destroy()
368 assert(barrier->waiters < barrier->count); in pipe_barrier_wait()
369 barrier->waiters++; in pipe_barrier_wait()
371 if (barrier->waiters < barrier->count) { in pipe_barrier_wait()
378 barrier->waiters = 0; in pipe_barrier_wait()
|
| /external/mesa3d/src/gallium/auxiliary/os/ |
| D | os_thread.h | 342 unsigned waiters; member
351 barrier->waiters = 0; in pipe_barrier_init()
359 assert(barrier->waiters == 0); in pipe_barrier_destroy()
368 assert(barrier->waiters < barrier->count); in pipe_barrier_wait()
369 barrier->waiters++; in pipe_barrier_wait()
371 if (barrier->waiters < barrier->count) { in pipe_barrier_wait()
378 barrier->waiters = 0; in pipe_barrier_wait()
|
| /external/qemu/util/ |
| D | qemu-thread-win32.c | 113 if (cond->waiters == 0) { in qemu_cond_signal()
123 cond->target = cond->waiters - 1; in qemu_cond_signal()
138 if (cond->waiters == 0) { in qemu_cond_broadcast()
143 result = ReleaseSemaphore(cond->sema, cond->waiters, NULL); in qemu_cond_broadcast()
164 cond->waiters++; in qemu_cond_wait()
188 if (InterlockedDecrement(&cond->waiters) == cond->target) { in qemu_cond_wait()
|
| /external/valgrind/main/drd/ |
| D | drd_semaphore.c | 107 p->waiters = 0; in drd_semaphore_initialize()
121 if (p->waiters > 0) in semaphore_cleanup()
327 p->waiters++; in DRD_()
329 if ((Word)(p->waiters) <= 0) in DRD_()
359 p->waiters--; in DRD_()
370 if (p == NULL || (Int)(p->value) < 0 || (Word)(p->waiters) < 0) in DRD_()
|
| D | drd_pthread_intercepts.c | 141 int waiters; member
187 sema->waiters = 0; in DRD_()
201 sema->waiters++; in DRD_()
221 sema->waiters--; in DRD_()
232 if (sema->waiters > 0) in DRD_()
|
| D | drd_clientobj.h | 109 UWord waiters; // Number of threads inside sem_wait(). member
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| D | CurrentContendedMonitorTest.java | 109 int waiters = replyObj.getNextValueAsInt(); in testCurrentContendedMonitor001() local
112 for (int i = 0; i < waiters; i++) { in testCurrentContendedMonitor001()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 805 int waiters = guard.waiterCount++; in incrementWaiters() local
806 if (waiters == 0) { in incrementWaiters()
813 int waiters = --guard.waiterCount; in decrementWaiters() local
814 if (waiters == 0) { in decrementWaiters()
|
| /external/chromium_org/third_party/libxml/src/ |
| D | threads.c | 124 unsigned int waiters; member
307 tok->waiters = 0; in xmlNewRMutex()
370 tok->waiters++; in xmlRMutexLock()
373 tok->waiters--; in xmlRMutexLock()
411 if (tok->waiters) in xmlRMutexUnlock()
|
| /external/qemu/include/qemu/ |
| D | thread-win32.h | 11 LONG waiters, target; member
|
| /external/libxml2/ |
| D | threads.c | 124 unsigned int waiters; member
307 tok->waiters = 0; in xmlNewRMutex()
370 tok->waiters++; in xmlRMutexLock()
373 tok->waiters--; in xmlRMutexLock()
411 if (tok->waiters) in xmlRMutexUnlock()
|
| /external/deqp/modules/egl/ |
| D | teglMultiThreadTests.cpp | 265 const deInt32 waiters = deAtomicIncrement32(&m_barrierWaiters); in barrier() local
267 if (waiters == m_threadCount) in barrier()
280 const deInt32 waiters = deAtomicDecrement32(&m_barrierWaiters); in barrier() local
282 if (waiters == 0) in barrier()
|
| /external/libusb/ |
| D | ChangeLog | 890 when a thread gets terminated with a signal, meaning that event waiters
928 Take lock before raising event waiters condition
|
| /external/valgrind/main/ |
| D | NEWS.old | 1983 - Fixed a bug causing an assertion failure of "waiters == 1"
|
| /external/srec/config/en.us/dictionary/ |
| D | large.ok | 31303 waiters wAdPz
|