/external/deqp/framework/delibs/dethread/ |
H A 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);
|
/external/valgrind/drd/ |
H A 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,
|
H A D | drd_semaphore.c | 85 /** Enable or disable tracing of semaphore actions. */ 93 * client semaphore at client address 'semaphore'. 97 const Addr semaphore) 99 tl_assert(semaphore != 0); 100 tl_assert(p->a1 == semaphore); 127 "Destruction of semaphore that is being waited" 138 * client semaphore. Allocate a new structure if such a structure did not 143 drd_semaphore_get_or_allocate(const Addr semaphore) argument 147 tl_assert(offsetof(DrdClientobj, semaphore) 96 drd_semaphore_initialize(struct semaphore_info* const p, const Addr semaphore) argument 162 semaphore_get(const Addr semaphore) argument 169 semaphore_init(const Addr semaphore, const Word pshared, const UInt value) argument 218 semaphore_destroy(const Addr semaphore) argument 247 semaphore_open(const Addr semaphore, const HChar* name, const Word oflag, const Word mode, const UInt value) argument 291 semaphore_close(const Addr semaphore) argument 320 semaphore_pre_wait(const Addr semaphore) argument 344 semaphore_post_wait(const DrdThreadId tid, const Addr semaphore, const Bool waited) argument 403 semaphore_pre_post(const DrdThreadId tid, const Addr semaphore) argument 426 semaphore_post_post(const DrdThreadId tid, const Addr semaphore, const Bool succeeded) argument [all...] |
/external/deqp/framework/delibs/dethread/unix/ |
H A D | deNamedSemaphoreUnix.c | 21 * \brief Unix implementation of semaphore using named semaphores. 31 #include <semaphore.h> 36 sem_t* semaphore; member in struct:NamedSemaphore_s 59 sem->semaphore = sem_open(name, O_CREAT|O_EXCL, mode, initialValue); 61 if (sem->semaphore == SEM_FAILED) 70 void deSemaphore_destroy (deSemaphore semaphore) argument 72 NamedSemaphore* sem = (NamedSemaphore*)semaphore; 78 res = sem_close(sem->semaphore); 86 void deSemaphore_increment (deSemaphore semaphore) argument 88 sem_t* sem = ((NamedSemaphore*)semaphore) 94 deSemaphore_decrement(deSemaphore semaphore) argument 102 deSemaphore_tryDecrement(deSemaphore semaphore) argument [all...] |
H A D | deSemaphoreUnix.c | 21 * \brief Unix implementation of semaphore. 30 #include <semaphore.h> 53 void deSemaphore_destroy (deSemaphore semaphore) argument 55 sem_t* sem = (sem_t*)semaphore; 61 void deSemaphore_increment (deSemaphore semaphore) argument 63 sem_t* sem = (sem_t*)semaphore; 69 void deSemaphore_decrement (deSemaphore semaphore) argument 71 sem_t* sem = (sem_t*)semaphore; 77 deBool deSemaphore_tryDecrement (deSemaphore semaphore) argument 79 sem_t* sem = (sem_t*)semaphore; [all...] |
/external/v8/test/unittests/base/platform/ |
H A D | semaphore-unittest.cc | 8 #include "src/base/platform/semaphore.h" 72 explicit WaitAndSignalThread(Semaphore* semaphore) argument 73 : Thread(Options("WaitAndSignalThread")), semaphore_(semaphore) {} 105 Semaphore semaphore(0); 106 WaitAndSignalThread t1(&semaphore); 107 WaitAndSignalThread t2(&semaphore); 113 semaphore.Signal(); 118 semaphore.Wait(); 120 EXPECT_FALSE(semaphore.WaitFor(TimeDelta::FromMicroseconds(1))); 125 Semaphore semaphore( [all...] |
/external/deqp/framework/delibs/dethread/win32/ |
H A D | deSemaphoreWin32.c | 21 * \brief Win32 implementation of semaphore. 51 void deSemaphore_destroy (deSemaphore semaphore) argument 53 HANDLE handle = (HANDLE)semaphore; 57 void deSemaphore_increment (deSemaphore semaphore) argument 59 HANDLE handle = (HANDLE)semaphore; 65 void deSemaphore_decrement (deSemaphore semaphore) argument 67 HANDLE handle = (HANDLE)semaphore; 73 deBool deSemaphore_tryDecrement (deSemaphore semaphore) argument 75 HANDLE handle = (HANDLE)semaphore;
|
/external/squashfs-tools/kernel-2.4/include/linux/ |
H A 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/valgrind/none/tests/ |
H A D | semlimit.c | 1 #include <semaphore.h>
|
/external/valgrind/drd/tests/ |
H A 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:
|
H A D | linuxthreads_det.c | 7 #include <semaphore.h>
|
/external/v8/test/cctest/ |
H A D | test-threads.cc | 39 v8::base::Semaphore* semaphore) 44 semaphore_(semaphore) {} 71 v8::base::Semaphore semaphore(0); 75 new ThreadIdValidationThread(prev, &refs, i, &semaphore); 82 semaphore.Wait(); 37 ThreadIdValidationThread(v8::base::Thread* thread_to_start, i::List<i::ThreadId>* refs, unsigned int thread_no, v8::base::Semaphore* semaphore) argument
|
H A D | test-circular-queue.cc | 144 v8::base::Semaphore semaphore(0); 146 ProducerThread producer1(&scq, kRecordsPerChunk, 1, &semaphore); 147 ProducerThread producer2(&scq, kRecordsPerChunk, 10, &semaphore); 148 ProducerThread producer3(&scq, kRecordsPerChunk, 20, &semaphore); 152 semaphore.Wait(); 164 semaphore.Wait(); 176 semaphore.Wait();
|
/external/skia/src/core/ |
H A D | SkSemaphore.cpp | 43 #include <semaphore.h> 63 // We only want to call the OS semaphore when our logical count crosses 68 // SkTMin(-(-3), 5) == 3 times on the OS semaphore, leaving the count at 2. 71 // so we don't call the OS semaphore, leaving the count at (prev + n). 79 static SkBaseSemaphore::OSSemaphore* semaphore(SkBaseSemaphore* semaphore) { argument 80 return semaphore->fOSSemaphore.get([](){ return new SkBaseSemaphore::OSSemaphore(); }); 83 void SkBaseSemaphore::osSignal(int n) { semaphore(this)->signal(n); } 85 void SkBaseSemaphore::osWait() { semaphore(this)->wait(); }
|
/external/compiler-rt/test/msan/ |
H A D | sem_getvalue.cc | 5 #include <semaphore.h>
|
/external/ImageMagick/MagickCore/ |
H A D | linked-list.c | 52 #include "MagickCore/semaphore.h"
81 *semaphore;
128 LockSemaphoreInfo(list_info->semaphore);
137 UnlockSemaphoreInfo(list_info->semaphore);
179 LockSemaphoreInfo(list_info->semaphore);
193 UnlockSemaphoreInfo(list_info->semaphore);
233 LockSemaphoreInfo(list_info->semaphore);
243 UnlockSemaphoreInfo(list_info->semaphore);
244 RelinquishSemaphoreInfo(&list_info->semaphore);
281 LockSemaphoreInfo(list_info->semaphore);
79 *semaphore; member in struct:_LinkedListInfo [all...] |
H A D | exception.c | 170 LockSemaphoreInfo(exception->semaphore); 176 UnlockSemaphoreInfo(exception->semaphore); 216 LockSemaphoreInfo(exception->semaphore); 239 UnlockSemaphoreInfo(exception->semaphore); 439 if (exception->semaphore == (SemaphoreInfo *) NULL) 440 ActivateSemaphoreInfo(&exception->semaphore); 441 LockSemaphoreInfo(exception->semaphore); 454 UnlockSemaphoreInfo(exception->semaphore); 457 RelinquishSemaphoreInfo(&exception->semaphore); 664 LockSemaphoreInfo(relative->semaphore); [all...] |
H A D | splay-tree.c | 59 #include "MagickCore/semaphore.h" 111 *semaphore; 167 LockSemaphoreInfo(splay_tree->semaphore); 189 UnlockSemaphoreInfo(splay_tree->semaphore); 196 UnlockSemaphoreInfo(splay_tree->semaphore); 222 UnlockSemaphoreInfo(splay_tree->semaphore); 368 LockSemaphoreInfo(splay_tree->semaphore); 371 UnlockSemaphoreInfo(splay_tree->semaphore); 389 UnlockSemaphoreInfo(splay_tree->semaphore); 506 LockSemaphoreInfo(splay_tree->semaphore); 108 *semaphore; member in struct:_SplayTreeInfo [all...] |
H A D | delegate.h | 26 #include "MagickCore/semaphore.h" 45 *semaphore; member in struct:_DelegateInfo
|
/external/v8/src/base/platform/ |
H A D | semaphore.h | 14 #include <mach/semaphore.h> // NOLINT 16 #include <semaphore.h> // NOLINT 28 // A semaphore object is a synchronization object that maintains a count. The 29 // count is decremented each time a thread completes a wait for the semaphore 30 // object and incremented each time a thread signals the semaphore. When the 31 // count reaches zero, threads waiting for the semaphore blocks until the 39 // Increments the semaphore counter. 42 // Suspends the calling thread until the semaphore counter is non zero 43 // and then decrements the semaphore counter. 48 // counter is unchanged. Otherwise the semaphore counte [all...] |
/external/dng_sdk/source/ |
H A D | dng_pthread.cpp | 62 HANDLE semaphore; member in struct:__anon4841::waiter 184 HANDLE semaphore = ::TlsGetValue(thread_wait_sema_TLS_index); local 185 if (semaphore == NULL) 187 semaphore = ::CreateSemaphore(NULL, 0, 1, NULL); 188 ::TlsSetValue(thread_wait_sema_TLS_index, semaphore); 191 return semaphore; 198 HANDLE semaphore = (HANDLE)::TlsGetValue(thread_wait_sema_TLS_index); local 200 if (semaphore != NULL) 203 ::CloseHandle(semaphore); 577 HANDLE semaphore local 811 HANDLE semaphore; member in struct:__anon4843::rw_waiter 848 HANDLE semaphore = head_waiter->semaphore; local 909 HANDLE semaphore=NULL; local 1035 HANDLE semaphore=NULL; local [all...] |
/external/deqp/framework/platform/android/ |
H A D | tcuAndroidRenderActivity.hpp | 64 de::Semaphore* semaphore; member in union:tcu::Android::Message::__anon4065 99 Message (MessageType type_, de::Semaphore* semaphore) argument 103 DE_ASSERT(semaphore); 104 payload.semaphore = semaphore;
|
/external/jmdns/src/javax/jmdns/impl/ |
H A D | DNSStatefulObject.java | 25 * This class define a semaphore. On this multiple threads can wait the arrival of one event. Thread wait for a maximum defined by the timeout. 57 Semaphore semaphore = _semaphores.get(thread); 58 if (semaphore == null) { 59 semaphore = new Semaphore(1, true); 60 semaphore.drainPermits(); 61 _semaphores.putIfAbsent(thread, semaphore); 63 semaphore = _semaphores.get(thread); 65 semaphore.tryAcquire(timeout, TimeUnit.MILLISECONDS); 72 * Signals the semaphore when the event arrives. 76 for (Semaphore semaphore [all...] |
/external/compiler-rt/test/sanitizer_common/TestCases/Linux/ |
H A D | sem_init_glibc.cc | 6 #include <semaphore.h>
|
/external/compiler-rt/test/tsan/ |
H A D | signal_cond.cc | 6 #include <semaphore.h>
|