| /external/bluetooth/bluedroid/osi/src/ |
| D | semaphore.c | 51 void semaphore_free(semaphore_t *semaphore) { in semaphore_free() argument
52 if (semaphore->fd != -1) in semaphore_free()
53 close(semaphore->fd); in semaphore_free()
54 free(semaphore); in semaphore_free()
57 void semaphore_wait(semaphore_t *semaphore) { in semaphore_wait() argument
58 assert(semaphore != NULL); in semaphore_wait()
59 assert(semaphore->fd != -1); in semaphore_wait()
62 if (eventfd_read(semaphore->fd, &value) == -1) in semaphore_wait()
66 bool semaphore_try_wait(semaphore_t *semaphore) { in semaphore_try_wait() argument
67 assert(semaphore != NULL); in semaphore_try_wait()
[all …]
|
| /external/valgrind/main/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 | 52 void deSemaphore_destroy (deSemaphore semaphore) in deSemaphore_destroy() argument
54 sem_t* sem = (sem_t*)semaphore; in deSemaphore_destroy()
60 void deSemaphore_increment (deSemaphore semaphore) in deSemaphore_increment() argument
62 sem_t* sem = (sem_t*)semaphore; in deSemaphore_increment()
68 void deSemaphore_decrement (deSemaphore semaphore) in deSemaphore_decrement() argument
70 sem_t* sem = (sem_t*)semaphore; in deSemaphore_decrement()
76 deBool deSemaphore_tryDecrement (deSemaphore semaphore) in deSemaphore_tryDecrement() argument
78 sem_t* sem = (sem_t*)semaphore; in deSemaphore_tryDecrement()
|
| /external/chromium_org/v8/src/base/platform/ |
| D | semaphore-unittest.cc | 74 explicit WaitAndSignalThread(Semaphore* semaphore) in WaitAndSignalThread() argument
75 : Thread(Options("WaitAndSignalThread")), semaphore_(semaphore) {} in WaitAndSignalThread()
108 Semaphore semaphore(0); in TEST() local
109 WaitAndSignalThread t1(&semaphore); in TEST()
110 WaitAndSignalThread t2(&semaphore); in TEST()
116 semaphore.Signal(); in TEST()
121 semaphore.Wait(); in TEST()
123 EXPECT_FALSE(semaphore.WaitFor(TimeDelta::FromMicroseconds(1))); in TEST()
128 Semaphore semaphore(0); in TEST() local
131 ASSERT_FALSE(semaphore.WaitFor(TimeDelta::FromMicroseconds(0))); in TEST()
[all …]
|
| /external/bluetooth/bluedroid/test/suite/support/ |
| D | callbacks.h | 27 sem_t *semaphore = callbacks_get_semaphore(#callback); \
28 sem_wait(semaphore); \
33 sem_t *semaphore = callbacks_get_semaphore(#callback); \
34 while (!sem_trywait(semaphore)); \
36 sem_wait(semaphore); \
42 sem_t *semaphore = callbacks_get_semaphore(__func__); \
43 sem_post(semaphore); \
|
| D | callbacks.c | 44 sem_t semaphore; member
90 sem_init(&callback_data[i].semaphore, 0, 0); in callbacks_init()
96 sem_destroy(&callback_data[i].semaphore); in callbacks_cleanup()
111 return &callback_data[i].semaphore; in callbacks_get_semaphore()
|
| /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()
64 void deSemaphore_decrement (deSemaphore semaphore) in deSemaphore_decrement() argument
66 HANDLE handle = (HANDLE)semaphore; in deSemaphore_decrement()
71 deBool deSemaphore_tryDecrement (deSemaphore semaphore) in deSemaphore_tryDecrement() argument
73 HANDLE handle = (HANDLE)semaphore; in deSemaphore_tryDecrement()
|
| /external/bluetooth/bluedroid/osi/include/ |
| D | semaphore.h | 33 void semaphore_free(semaphore_t *semaphore);
37 void semaphore_wait(semaphore_t *semaphore);
42 bool semaphore_try_wait(semaphore_t *semaphore);
45 void semaphore_post(semaphore_t *semaphore);
57 int semaphore_get_fd(const semaphore_t *semaphore);
|
| /external/bluetooth/bluedroid/osi/test/ |
| D | alarm_test.cpp | 13 static semaphore_t *semaphore; variable
37 semaphore = semaphore_new(0); in SetUp()
54 semaphore_post(semaphore); in cb()
138 semaphore_wait(semaphore); in TEST_F()
153 semaphore_wait(semaphore); in TEST_F()
173 semaphore_wait(semaphore); in TEST_F()
178 semaphore_wait(semaphore); in TEST_F()
199 semaphore_wait(semaphore); in TEST_F()
204 semaphore_wait(semaphore); in TEST_F()
225 semaphore_wait(semaphore); in TEST_F()
[all …]
|
| /external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/sync/ |
| D | ChromiumSyncAdapter.java | 64 Semaphore semaphore = new Semaphore(0); in onPerformSync() local
68 getStartupCallback(mApplication, account, extras, syncResult, semaphore); in onPerformSync()
69 startBrowserProcess(callback, syncResult, semaphore); in onPerformSync()
73 semaphore.acquire(); in onPerformSync()
83 final SyncResult syncResult, Semaphore semaphore) { in startBrowserProcess() argument
107 semaphore.release(); in startBrowserProcess()
129 final SyncResult syncResult, final Semaphore semaphore) { in getStartupCallback() argument
154 semaphore.release(); in getStartupCallback()
163 semaphore.release(); in getStartupCallback()
|
| /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/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/valgrind/main/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 | sem_open_traced.vgtest | 2 vgopts: --check-stack-var=yes --read-var-info=yes --trace-semaphore=yes
|
| /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/chromium_org/v8/test/cctest/ |
| 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-threads.cc | 129 v8::base::Semaphore* semaphore) in ThreadIdValidationThread() argument
134 semaphore_(semaphore) {} in ThreadIdValidationThread()
161 v8::base::Semaphore semaphore(0); in TEST() local
165 new ThreadIdValidationThread(prev, &refs, i, &semaphore); in TEST()
172 semaphore.Wait(); in TEST()
|
| D | test-thread-termination.cc | 34 v8::base::Semaphore* semaphore = NULL; variable
38 semaphore->Signal(); in Signal()
168 semaphore->Wait(); in Run()
181 semaphore = new v8::base::Semaphore(0); in TEST()
198 delete semaphore; in TEST()
199 semaphore = NULL; in TEST()
381 semaphore = new v8::base::Semaphore(0); in TEST()
403 delete semaphore; in TEST()
404 semaphore = NULL; in TEST()
|
| /external/srec/portable/include/ |
| D | ptrd.h | 312 PtrdSemaphore **semaphore);
322 PORTABLE_API ESR_ReturnCode PtrdSemaphoreDestroy(PtrdSemaphore *semaphore);
333 PORTABLE_API ESR_ReturnCode PtrdSemaphoreAcquire(PtrdSemaphore *semaphore);
347 PORTABLE_API ESR_ReturnCode PtrdSemaphoreAcquireTimeout(PtrdSemaphore *semaphore,
359 PORTABLE_API ESR_ReturnCode PtrdSemaphoreRelease(PtrdSemaphore *semaphore);
|
| /external/chromium_org/third_party/libusb/src/libusb/os/ |
| D | wince_usb.c | 172 HANDLE semaphore; in wince_init() local
176 semaphore = CreateSemaphore(NULL, 1, 1, sem_name); in wince_init()
177 if (semaphore == NULL) { in wince_init()
184 if (WaitForSingleObject(semaphore, INFINITE) != WAIT_OBJECT_0) { in wince_init()
186 CloseHandle(semaphore); in wince_init()
282 ReleaseSemaphore(semaphore, 1, NULL); // increase count back to 1 in wince_init()
283 CloseHandle(semaphore); in wince_init()
290 HANDLE semaphore; in wince_exit() local
294 semaphore = CreateSemaphore(NULL, 1, 1, sem_name); in wince_exit()
295 if (semaphore == NULL) { in wince_exit()
[all …]
|
| /external/chromium_org/sandbox/mac/ |
| D | dispatch_source_mach_unittest.cc | 32 void WaitForSemaphore(dispatch_semaphore_t semaphore) { in WaitForSemaphore() argument
33 dispatch_semaphore_wait(semaphore, dispatch_time( in WaitForSemaphore()
|
| /external/chromium_org/chrome/android/java/src/org/chromium/chrome/browser/signin/ |
| D | OAuth2TokenService.java | 183 final Semaphore semaphore = new Semaphore(0); in getOAuth2AccessTokenWithTimeout() local
190 semaphore.release(); in getOAuth2AccessTokenWithTimeout()
194 if (semaphore.tryAcquire(timeout, unit)) { in getOAuth2AccessTokenWithTimeout()
|