| /external/valgrind/drd/ |
| D | drd_semaphore.c | 97 const Addr semaphore) in drd_semaphore_initialize() argument
99 tl_assert(semaphore != 0); in drd_semaphore_initialize()
100 tl_assert(p->a1 == semaphore); in drd_semaphore_initialize()
143 drd_semaphore_get_or_allocate(const Addr semaphore) in drd_semaphore_get_or_allocate() argument
147 tl_assert(offsetof(DrdClientobj, semaphore) == 0); in drd_semaphore_get_or_allocate()
148 p = &(DRD_(clientobj_get)(semaphore, ClientSemaphore)->semaphore); in drd_semaphore_get_or_allocate()
151 tl_assert(offsetof(DrdClientobj, semaphore) == 0); in drd_semaphore_get_or_allocate()
152 p = &(DRD_(clientobj_add)(semaphore, ClientSemaphore)->semaphore); in drd_semaphore_get_or_allocate()
153 drd_semaphore_initialize(p, semaphore); in drd_semaphore_get_or_allocate()
162 static struct semaphore_info* semaphore_get(const Addr semaphore) in semaphore_get() argument
[all …]
|
| D | drd_semaphore.h | 40 struct semaphore_info* DRD_(semaphore_init)(const Addr semaphore,
43 void DRD_(semaphore_destroy)(const Addr semaphore);
44 struct semaphore_info* DRD_(semaphore_open)(const Addr semaphore,
47 void DRD_(semaphore_close)(const Addr semaphore);
48 void DRD_(semaphore_pre_wait)(const Addr semaphore);
49 void DRD_(semaphore_post_wait)(const DrdThreadId tid, const Addr semaphore,
51 void DRD_(semaphore_pre_post)(const DrdThreadId tid, const Addr semaphore);
52 void DRD_(semaphore_post_post)(const DrdThreadId tid, const Addr semaphore,
|
| /external/deqp/framework/delibs/dethread/unix/ |
| D | deNamedSemaphoreUnix.c | 36 sem_t* semaphore; member
59 sem->semaphore = sem_open(name, O_CREAT|O_EXCL, mode, initialValue); in deSemaphore_create()
61 if (sem->semaphore == SEM_FAILED) in deSemaphore_create()
70 void deSemaphore_destroy (deSemaphore semaphore) in deSemaphore_destroy() argument
72 NamedSemaphore* sem = (NamedSemaphore*)semaphore; in deSemaphore_destroy()
78 res = sem_close(sem->semaphore); in deSemaphore_destroy()
86 void deSemaphore_increment (deSemaphore semaphore) in deSemaphore_increment() argument
88 sem_t* sem = ((NamedSemaphore*)semaphore)->semaphore; in deSemaphore_increment()
94 void deSemaphore_decrement (deSemaphore semaphore) in deSemaphore_decrement() argument
96 sem_t* sem = ((NamedSemaphore*)semaphore)->semaphore; in deSemaphore_decrement()
[all …]
|
| D | deSemaphoreUnix.c | 53 void deSemaphore_destroy (deSemaphore semaphore) in deSemaphore_destroy() argument
55 sem_t* sem = (sem_t*)semaphore; in deSemaphore_destroy()
61 void deSemaphore_increment (deSemaphore semaphore) in deSemaphore_increment() argument
63 sem_t* sem = (sem_t*)semaphore; in deSemaphore_increment()
69 void deSemaphore_decrement (deSemaphore semaphore) in deSemaphore_decrement() argument
71 sem_t* sem = (sem_t*)semaphore; in deSemaphore_decrement()
77 deBool deSemaphore_tryDecrement (deSemaphore semaphore) in deSemaphore_tryDecrement() argument
79 sem_t* sem = (sem_t*)semaphore; in deSemaphore_tryDecrement()
|
| /external/v8/test/unittests/base/platform/ |
| D | semaphore-unittest.cc | 72 explicit WaitAndSignalThread(Semaphore* semaphore) in WaitAndSignalThread() argument
73 : Thread(Options("WaitAndSignalThread")), semaphore_(semaphore) {} in WaitAndSignalThread()
105 Semaphore semaphore(0); in TEST() local
106 WaitAndSignalThread t1(&semaphore); in TEST()
107 WaitAndSignalThread t2(&semaphore); in TEST()
113 semaphore.Signal(); in TEST()
118 semaphore.Wait(); in TEST()
120 EXPECT_FALSE(semaphore.WaitFor(TimeDelta::FromMicroseconds(1))); in TEST()
125 Semaphore semaphore(0); in TEST() local
128 ASSERT_FALSE(semaphore.WaitFor(TimeDelta::FromMicroseconds(0))); in TEST()
[all …]
|
| /external/ImageMagick/MagickCore/ |
| D | linked-list.c | 79 *semaphore; member
125 LockSemaphoreInfo(list_info->semaphore); in AppendValueToLinkedList()
134 UnlockSemaphoreInfo(list_info->semaphore); in AppendValueToLinkedList()
175 LockSemaphoreInfo(list_info->semaphore); in ClearLinkedList()
189 UnlockSemaphoreInfo(list_info->semaphore); in ClearLinkedList()
229 LockSemaphoreInfo(list_info->semaphore); in DestroyLinkedList()
239 UnlockSemaphoreInfo(list_info->semaphore); in DestroyLinkedList()
240 RelinquishSemaphoreInfo(&list_info->semaphore); in DestroyLinkedList()
276 LockSemaphoreInfo(list_info->semaphore); in GetLastValueInLinkedList()
278 UnlockSemaphoreInfo(list_info->semaphore); in GetLastValueInLinkedList()
[all …]
|
| D | splay-tree.c | 108 *semaphore; member
162 LockSemaphoreInfo(splay_tree->semaphore); in AddValueToSplayTree()
184 UnlockSemaphoreInfo(splay_tree->semaphore); in AddValueToSplayTree()
191 UnlockSemaphoreInfo(splay_tree->semaphore); in AddValueToSplayTree()
217 UnlockSemaphoreInfo(splay_tree->semaphore); in AddValueToSplayTree()
361 LockSemaphoreInfo(splay_tree->semaphore); in CloneSplayTree()
364 UnlockSemaphoreInfo(splay_tree->semaphore); in CloneSplayTree()
382 UnlockSemaphoreInfo(splay_tree->semaphore); in CloneSplayTree()
496 LockSemaphoreInfo(splay_tree->semaphore); in DeleteNodeByValueFromSplayTree()
499 UnlockSemaphoreInfo(splay_tree->semaphore); in DeleteNodeByValueFromSplayTree()
[all …]
|
| D | exception.c | 164 LockSemaphoreInfo(exception->semaphore); in ClearMagickException()
170 UnlockSemaphoreInfo(exception->semaphore); in ClearMagickException()
209 LockSemaphoreInfo(exception->semaphore); in CatchException()
232 UnlockSemaphoreInfo(exception->semaphore); in CatchException()
427 if (exception->semaphore == (SemaphoreInfo *) NULL) in DestroyExceptionInfo()
428 ActivateSemaphoreInfo(&exception->semaphore); in DestroyExceptionInfo()
429 LockSemaphoreInfo(exception->semaphore); in DestroyExceptionInfo()
442 UnlockSemaphoreInfo(exception->semaphore); in DestroyExceptionInfo()
445 RelinquishSemaphoreInfo(&exception->semaphore); in DestroyExceptionInfo()
649 LockSemaphoreInfo(relative->semaphore); in InheritException()
[all …]
|
| D | random.c | 104 *semaphore; member
191 random_info->semaphore=AcquireSemaphoreInfo(); in AcquireRandomInfo()
280 LockSemaphoreInfo(random_info->semaphore); in DestroyRandomInfo()
290 UnlockSemaphoreInfo(random_info->semaphore); in DestroyRandomInfo()
291 RelinquishSemaphoreInfo(&random_info->semaphore); in DestroyRandomInfo()
370 LockSemaphoreInfo(random_info->semaphore); in GenerateEntropicChaos()
587 UnlockSemaphoreInfo(random_info->semaphore); in GenerateEntropicChaos()
901 LockSemaphoreInfo(random_info->semaphore); in SetRandomKey()
935 UnlockSemaphoreInfo(random_info->semaphore); in SetRandomKey()
|
| D | matrix.c | 88 *semaphore; member
142 LockSemaphoreInfo(matrix_info->semaphore); in WriteMatrixElements()
145 UnlockSemaphoreInfo(matrix_info->semaphore); in WriteMatrixElements()
167 UnlockSemaphoreInfo(matrix_info->semaphore); in WriteMatrixElements()
220 matrix_info->semaphore=AcquireSemaphoreInfo(); in AcquireMatrixInfo()
376 LockSemaphoreInfo(matrix_info->semaphore); in DestroyMatrixInfo()
408 UnlockSemaphoreInfo(matrix_info->semaphore); in DestroyMatrixInfo()
409 RelinquishSemaphoreInfo(&matrix_info->semaphore); in DestroyMatrixInfo()
678 LockSemaphoreInfo(matrix_info->semaphore); in ReadMatrixElements()
681 UnlockSemaphoreInfo(matrix_info->semaphore); in ReadMatrixElements()
[all …]
|
| /external/deqp/framework/delibs/dethread/win32/ |
| D | deSemaphoreWin32.c | 51 void deSemaphore_destroy (deSemaphore semaphore) in deSemaphore_destroy() argument
53 HANDLE handle = (HANDLE)semaphore; in deSemaphore_destroy()
57 void deSemaphore_increment (deSemaphore semaphore) in deSemaphore_increment() argument
59 HANDLE handle = (HANDLE)semaphore; in deSemaphore_increment()
65 void deSemaphore_decrement (deSemaphore semaphore) in deSemaphore_decrement() argument
67 HANDLE handle = (HANDLE)semaphore; in deSemaphore_decrement()
73 deBool deSemaphore_tryDecrement (deSemaphore semaphore) in deSemaphore_tryDecrement() argument
75 HANDLE handle = (HANDLE)semaphore; in deSemaphore_tryDecrement()
|
| /external/dng_sdk/source/ |
| D | dng_pthread.cpp | 62 HANDLE semaphore; member
184 HANDLE semaphore = ::TlsGetValue(thread_wait_sema_TLS_index); in GetThreadSemaphore() local
185 if (semaphore == NULL) in GetThreadSemaphore()
187 semaphore = ::CreateSemaphore(NULL, 0, 1, NULL); in GetThreadSemaphore()
188 ::TlsSetValue(thread_wait_sema_TLS_index, semaphore); in GetThreadSemaphore()
191 return semaphore; in GetThreadSemaphore()
198 HANDLE semaphore = (HANDLE)::TlsGetValue(thread_wait_sema_TLS_index); in FreeThreadSemaphore() local
200 if (semaphore != NULL) in FreeThreadSemaphore()
203 ::CloseHandle(semaphore); in FreeThreadSemaphore()
577 HANDLE semaphore = GetThreadSemaphore(); in cond_wait_internal() local
[all …]
|
| /external/squashfs-tools/kernel-2.4/include/linux/ |
| D | squashfs_fs_sb.h | 60 struct semaphore read_data_mutex;
61 struct semaphore read_page_mutex;
62 struct semaphore block_cache_mutex;
63 struct semaphore fragment_mutex;
64 struct semaphore meta_index_mutex;
|
| /external/jmdns/src/javax/jmdns/impl/ |
| D | DNSStatefulObject.java | 57 Semaphore semaphore = _semaphores.get(thread); in waitForEvent() local
58 if (semaphore == null) { in waitForEvent()
59 semaphore = new Semaphore(1, true); in waitForEvent()
60 semaphore.drainPermits(); in waitForEvent()
61 _semaphores.putIfAbsent(thread, semaphore); in waitForEvent()
63 semaphore = _semaphores.get(thread); in waitForEvent()
65 semaphore.tryAcquire(timeout, TimeUnit.MILLISECONDS); in waitForEvent()
76 for (Semaphore semaphore : semaphores) { in signalEvent()
77 semaphore.release(); in signalEvent()
78 semaphores.remove(semaphore); in signalEvent()
|
| /external/deqp/framework/delibs/dethread/ |
| D | deSemaphore.h | 42 void deSemaphore_destroy (deSemaphore semaphore);
44 void deSemaphore_increment (deSemaphore semaphore);
45 void deSemaphore_decrement (deSemaphore semaphore);
47 deBool deSemaphore_tryDecrement (deSemaphore semaphore);
|
| D | deThreadTest.c | 428 deSemaphore semaphore = deSemaphore_create(1, DE_NULL); in deSemaphore_selfTest() local
429 DE_TEST_ASSERT(semaphore); in deSemaphore_selfTest()
431 deSemaphore_increment(semaphore); in deSemaphore_selfTest()
432 deSemaphore_decrement(semaphore); in deSemaphore_selfTest()
433 deSemaphore_decrement(semaphore); in deSemaphore_selfTest()
435 deSemaphore_destroy(semaphore); in deSemaphore_selfTest()
|
| /external/skia/src/core/ |
| D | SkSemaphore.cpp | 79 static SkBaseSemaphore::OSSemaphore* semaphore(SkBaseSemaphore* semaphore) { in semaphore() argument
80 return semaphore->fOSSemaphore.get([](){ return new SkBaseSemaphore::OSSemaphore(); }); in semaphore()
83 void SkBaseSemaphore::osSignal(int n) { semaphore(this)->signal(n); } in osSignal()
85 void SkBaseSemaphore::osWait() { semaphore(this)->wait(); } in osWait()
|
| /external/v8/test/cctest/ |
| D | test-threads.cc | 39 v8::base::Semaphore* semaphore) in ThreadIdValidationThread() argument
44 semaphore_(semaphore) {} in ThreadIdValidationThread()
71 v8::base::Semaphore semaphore(0); in TEST() local
75 new ThreadIdValidationThread(prev, &refs, i, &semaphore); in TEST()
82 semaphore.Wait(); in TEST()
|
| D | test-circular-queue.cc | 144 v8::base::Semaphore semaphore(0); in TEST() local
146 ProducerThread producer1(&scq, kRecordsPerChunk, 1, &semaphore); in TEST()
147 ProducerThread producer2(&scq, kRecordsPerChunk, 10, &semaphore); in TEST()
148 ProducerThread producer3(&scq, kRecordsPerChunk, 20, &semaphore); in TEST()
152 semaphore.Wait(); in TEST()
164 semaphore.Wait(); in TEST()
176 semaphore.Wait(); in TEST()
|
| D | test-thread-termination.cc | 34 v8::base::Semaphore* semaphore = NULL; variable
38 semaphore->Signal(); in Signal()
173 semaphore->Wait(); in Run()
186 semaphore = new v8::base::Semaphore(0); in TEST()
203 delete semaphore; in TEST()
204 semaphore = NULL; in TEST()
209 semaphore = new v8::base::Semaphore(0); in TEST()
229 delete semaphore; in TEST()
230 semaphore = NULL; in TEST()
426 semaphore = new v8::base::Semaphore(0); in TEST()
[all …]
|
| /external/valgrind/drd/tests/ |
| D | tc18_semabuse.stderr.exp | 2 Semaphore reinitialization: semaphore 0x........
5 semaphore 0x........ was first observed at:
9 Invalid semaphore: semaphore 0x........
12 semaphore 0x........ was first observed at:
|
| D | tc18_semabuse.stderr.exp-solaris | 2 Semaphore reinitialization: semaphore 0x........
5 semaphore 0x........ was first observed at:
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidRenderActivity.hpp | 64 de::Semaphore* semaphore; member
99 Message (MessageType type_, de::Semaphore* semaphore) in Message()
103 DE_ASSERT(semaphore); in Message()
104 payload.semaphore = semaphore; in Message()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 296 Semaphore semaphore, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly() argument
297 return tryAcquireUninterruptibly(semaphore, 1, timeout, unit); in tryAcquireUninterruptibly()
307 Semaphore semaphore, int permits, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly() argument
316 return semaphore.tryAcquire(permits, remainingNanos, NANOSECONDS); in tryAcquireUninterruptibly()
|
| /external/jetty/src/resources/org/eclipse/jetty/servlets/jmx/ |
| D | QoSFilter-mbean.properties | 3 waitMs: (short) amount of time (in milliseconds) that the filter would wait for the semaphore to be…
4 …onds) that the filter would suspend a request for while waiting for the semaphore to become availa…
|