| /external/chromium_org/native_client_sdk/src/libraries/third_party/pthreads-win32/ |
| sem_post_multiple.c | 80 long waiters; local
100 waiters = -s->value;
102 if (waiters > 0)
107 waiters--;
109 if (s->leftToUnblock > waiters)
111 s->leftToUnblock = waiters;
115 if (ReleaseSemaphore (s->sem, (waiters<=count)?waiters:count, 0))
|
| /external/chromium_org/net/socket/ |
| websocket_endpoint_lock_manager_unittest.cc | 129 FakeWaiter waiters[2]; local
130 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0]));
132 instance()->LockEndpoint(DummyEndpoint(), &waiters[1]));
146 FakeWaiter waiters[2]; local
147 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0]));
149 instance()->LockEndpoint(DummyEndpoint(), &waiters[1]));
150 EXPECT_FALSE(waiters[1].called());
156 FakeWaiter waiters[2]; local
157 EXPECT_EQ(OK, instance()->LockEndpoint(DummyEndpoint(), &waiters[0]));
159 instance()->LockEndpoint(DummyEndpoint(), &waiters[1]))
186 FakeWaiter waiters[2]; local
214 FakeWaiter waiters[2]; local
[all...] |
| /external/libvpx/libvpx/vpx_ports/ |
| vpx_once.h | 22 static LONG waiters; local
33 InterlockedIncrement(&waiters);
67 if(!InterlockedDecrement(&waiters))
|
| /hardware/intel/common/omx-components/videocodec/libvpx_internal/libvpx/vpx_ports/ |
| vpx_once.h | 22 static LONG waiters; local
33 InterlockedIncrement(&waiters);
67 if(!InterlockedDecrement(&waiters))
|
| /external/qemu/include/qemu/ |
| thread-win32.h | 11 LONG waiters, target; member in struct:QemuCond
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/uicc/ |
| AdnRecordCache.java | 80 ArrayList<Message> waiters = mAdnLikeWaiters.valueAt(i); local
82 notifyWaiters(waiters, ar);
247 ArrayList<Message> waiters; local
268 waiters = mAdnLikeWaiters.get(efid);
270 if (waiters != null) {
274 waiters.add(response);
280 waiters = new ArrayList<Message>();
281 waiters.add(response);
283 mAdnLikeWaiters.put(efid, waiters);
305 notifyWaiters(ArrayList<Message> waiters, AsyncResult ar)
332 ArrayList<Message> waiters; local
[all...] |
| /external/chromium_org/third_party/libvpx/source/libvpx/vpx_ports/ |
| vpx_once.h | 22 static LONG waiters; local
33 InterlockedIncrement(&waiters);
67 if(!InterlockedDecrement(&waiters))
|
| /external/fio/ |
| mutex.h | 13 int waiters; member in struct:fio_mutex
|
| mutex.c | 110 mutex->waiters++;
120 mutex->waiters--;
154 mutex->waiters++;
156 mutex->waiters--;
169 if (!mutex->value && mutex->waiters)
|
| /external/chromium_org/third_party/libusb/src/libusb/os/ |
| threads_windows.c | 88 list_init(&cond->waiters );
96 if(!list_empty(&cond->waiters)) return ((errno=EBUSY )); // (!see above!)
113 list_for_each_entry(pos, &cond->waiters, list, struct usbi_cond_perthread) {
126 if(list_empty(&cond->waiters)) return 0; // no one to wakeup.
127 pos = list_entry(&cond->waiters.next, struct usbi_cond_perthread, list);
157 list_add(&pos->list, &cond->waiters);
|
| threads_windows.h | 38 struct list_head waiters; member in struct:usbi_cond_t_
|
| /external/qemu/util/ |
| qemu-thread-win32.c | 109 * Signal only when there are waiters. cond->waiters is
113 if (cond->waiters == 0) {
123 cond->target = cond->waiters - 1;
135 * As in pthread_cond_signal, access to cond->waiters and
138 if (cond->waiters == 0) {
143 result = ReleaseSemaphore(cond->sema, cond->waiters, NULL);
149 * At this point all waiters continue. Each one takes its
164 cond->waiters++;
169 * waiters count above, so there's no problem wit
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.6/sysroot/usr/include/X11/ |
| Xthreads.h | 107 struct _xthread_waiter *waiters; member in struct:__anon25064
130 (cv)->waiters = NULL; \
137 _tmpthr->next = (cv)->waiters; \
138 (cv)->waiters = _tmpthr; \
146 if ((cv)->waiters) { \
147 ReleaseSemaphore((cv)->waiters->sem, 1, NULL); \
148 (cv)->waiters = (cv)->waiters->next; \
155 for (_tmpthr = (cv)->waiters; _tmpthr; _tmpthr = _tmpthr->next) \
157 (cv)->waiters = NULL;
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/sysroot/usr/include/X11/ |
| Xthreads.h | 107 struct _xthread_waiter *waiters; member in struct:__anon26800
130 (cv)->waiters = NULL; \
137 _tmpthr->next = (cv)->waiters; \
138 (cv)->waiters = _tmpthr; \
146 if ((cv)->waiters) { \
147 ReleaseSemaphore((cv)->waiters->sem, 1, NULL); \
148 (cv)->waiters = (cv)->waiters->next; \
155 for (_tmpthr = (cv)->waiters; _tmpthr; _tmpthr = _tmpthr->next) \
157 (cv)->waiters = NULL;
[all...] |
| /external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/os/ |
| os_thread.h | 342 unsigned waiters; member in struct:__anon18349
351 barrier->waiters = 0;
359 assert(barrier->waiters == 0);
368 assert(barrier->waiters < barrier->count);
369 barrier->waiters++;
371 if (barrier->waiters < barrier->count) {
378 barrier->waiters = 0;
|
| /external/mesa3d/src/gallium/auxiliary/os/ |
| os_thread.h | 342 unsigned waiters; member in struct:__anon10833
351 barrier->waiters = 0;
359 assert(barrier->waiters == 0);
368 assert(barrier->waiters < barrier->count);
369 barrier->waiters++;
371 if (barrier->waiters < barrier->count) {
378 barrier->waiters = 0;
|
| /external/valgrind/main/drd/ |
| drd_semaphore.c | 107 p->waiters = 0;
121 if (p->waiters > 0)
327 p->waiters++;
329 if ((Word)(p->waiters) <= 0)
359 p->waiters--;
365 * the current thread was waiting in sem_wait, p->waiters may have been
370 if (p == NULL || (Int)(p->value) < 0 || (Word)(p->waiters) < 0)
|
| drd_clientobj.h | 109 UWord waiters; // Number of threads inside sem_wait(). member in struct:semaphore_info
125 Word pre_waiters_left; // number of waiters left for a complete barrier.
126 Word post_waiters_left; // number of waiters left for a complete barrier.
|
| drd_pthread_intercepts.c | 141 int waiters; member in struct:__anon16466
187 sema->waiters = 0;
201 sema->waiters++;
221 sema->waiters--;
232 if (sema->waiters > 0)
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| FutureTask.java | 79 private volatile WaitNode waiters; field in class:FutureTask
337 for (WaitNode q; (q = waiters) != null;) {
390 q.next = waiters, q);
419 for (WaitNode pred = null, q = waiters, s; q != null; q = s) {
451 (k.getDeclaredField("waiters"));
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| CurrentContendedMonitorTest.java | 109 int waiters = replyObj.getNextValueAsInt(); local
112 for (int i = 0; i < waiters; i++) {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| Monitor.java | 264 * The guards associated with this monitor that currently have waiters ({@code waiterCount > 0}).
762 * upper bound on the actual number of waiters. This method is designed for use in monitoring of
805 int waiters = guard.waiterCount++; local
806 if (waiters == 0) {
813 int waiters = --guard.waiterCount; local
814 if (waiters == 0) {
|
| /external/chromium_org/third_party/libxml/src/ |
| threads.c | 124 unsigned int waiters; member in struct:_xmlRMutex
307 tok->waiters = 0;
370 tok->waiters++;
373 tok->waiters--;
411 if (tok->waiters)
|
| /external/libxml2/ |
| threads.c | 124 unsigned int waiters; member in struct:_xmlRMutex
307 tok->waiters = 0;
370 tok->waiters++;
373 tok->waiters--;
411 if (tok->waiters)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| threading.py | 385 waiters = __waiters[:n]
386 if not waiters:
388 self._note("%s.notify(): no waiters", self)
392 for waiter in waiters:
865 # DummyThreads delete self.__block, but they have no waiters to
[all...] |
