| /system/bt/osi/test/ |
| semaphore_test.cc | 11 #include "osi/include/semaphore.h"
15 semaphore_t* semaphore; member in struct:SemaphoreTestSequenceHelper
24 CHECK(helper->semaphore);
27 semaphore_post(helper->semaphore);
34 semaphore_t* semaphore = semaphore_new(0); local
35 ASSERT_TRUE(semaphore != NULL);
36 semaphore_free(semaphore);
40 semaphore_t* semaphore = semaphore_new(3); local
41 ASSERT_TRUE(semaphore != NULL);
43 EXPECT_TRUE(semaphore_try_wait(semaphore));
52 semaphore_t* semaphore = semaphore_new(0); local
64 semaphore_t* semaphore = semaphore_new(0); local
72 semaphore_t* semaphore = semaphore_new(0); local
[all...] |
| /system/bt/osi/include/ |
| semaphore.h | 26 // Creates a new semaphore with an initial value of |value|.
31 // Frees a semaphore allocated with |semaphore_new|. |semaphore| may
33 void semaphore_free(semaphore_t* semaphore);
35 // Decrements the value of |semaphore|. If it is 0, this call blocks until
36 // it becomes non-zero. |semaphore| may not be NULL.
37 void semaphore_wait(semaphore_t* semaphore);
39 // Tries to decrement the value of |semaphore|. Returns true if the value was
41 // |semaphore| may not be NULL.
42 bool semaphore_try_wait(semaphore_t* semaphore);
[all...] |
| /system/bt/osi/src/ |
| semaphore.cc | 21 #include "osi/include/semaphore.h"
47 LOG_ERROR(LOG_TAG, "%s unable to allocate semaphore: %s", __func__,
55 void semaphore_free(semaphore_t* semaphore) {
56 if (!semaphore) return;
58 if (semaphore->fd != INVALID_FD) close(semaphore->fd);
59 osi_free(semaphore);
62 void semaphore_wait(semaphore_t* semaphore) {
63 CHECK(semaphore != NULL);
64 CHECK(semaphore->fd != INVALID_FD)
[all...] |
| future.cc | 28 #include "osi/include/semaphore.h"
32 semaphore_t* semaphore; // NULL semaphore means immediate future member in struct:future_t
41 ret->semaphore = semaphore_new(0);
42 if (!ret->semaphore) {
43 LOG_ERROR(LOG_TAG, "%s unable to allocate memory for the semaphore.",
69 semaphore_post(future->semaphore);
75 // If the future is immediate, it will not have a semaphore
76 if (future->semaphore) semaphore_wait(future->semaphore);
[all...] |
| /external/deqp/framework/delibs/dethread/ |
| deSemaphore.h | 23 * \brief Semaphore class.
30 /* Semaphore type. */
34 * \brief Semaphore attributes.
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/ |
| drd_semaphore.h | 25 // Semaphore state information: owner thread and recursion count.
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,
|
| 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)
147 tl_assert(offsetof(DrdClientobj, semaphore) == 0)
[all...] |
| /bionic/benchmarks/ |
| semaphore_benchmark.cpp | 18 #include <semaphore.h>
26 sem_t semaphore; local
27 sem_init(&semaphore, 1, 1);
31 sem_getvalue(&semaphore, &dummy);
37 sem_t semaphore; local
38 sem_init(&semaphore, 1, 1);
41 sem_wait(&semaphore);
42 sem_post(&semaphore);
73 sem_t* semaphore = reinterpret_cast<sem_t*>(arg); local
74 while ((BM_semaphore_sem_post_running > 0) && !sem_wait(semaphore)) {
117 sem_t semaphore; member in class:SemaphoreFixture
[all...] |
| /external/deqp/framework/delibs/dethread/unix/ |
| 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)
72 NamedSemaphore* sem = (NamedSemaphore*)semaphore;
78 res = sem_close(sem->semaphore);
86 void deSemaphore_increment (deSemaphore semaphore)
88 sem_t* sem = ((NamedSemaphore*)semaphore)->semaphore
[all...] |
| deSemaphoreUnix.c | 21 * \brief Unix implementation of semaphore.
30 #include <semaphore.h>
53 void deSemaphore_destroy (deSemaphore semaphore)
55 sem_t* sem = (sem_t*)semaphore;
61 void deSemaphore_increment (deSemaphore semaphore)
63 sem_t* sem = (sem_t*)semaphore;
69 void deSemaphore_decrement (deSemaphore semaphore)
71 sem_t* sem = (sem_t*)semaphore;
77 deBool deSemaphore_tryDecrement (deSemaphore semaphore)
79 sem_t* sem = (sem_t*)semaphore;
[all...] |
| /external/skia/src/gpu/ops/ |
| GrSemaphoreOp.cpp | 17 static std::unique_ptr<GrSignalSemaphoreOp> Make(sk_sp<GrSemaphore> semaphore) {
18 return std::unique_ptr<GrSignalSemaphoreOp>(new GrSignalSemaphoreOp(std::move(semaphore)));
24 explicit GrSignalSemaphoreOp(sk_sp<GrSemaphore> semaphore)
25 : INHERITED(ClassID(), std::move(semaphore)) {}
38 static std::unique_ptr<GrWaitSemaphoreOp> Make(sk_sp<GrSemaphore> semaphore) {
39 return std::unique_ptr<GrWaitSemaphoreOp>(new GrWaitSemaphoreOp(std::move(semaphore)));
45 explicit GrWaitSemaphoreOp(sk_sp<GrSemaphore> semaphore)
46 : INHERITED(ClassID(), std::move(semaphore)) {}
57 std::unique_ptr<GrSemaphoreOp> GrSemaphoreOp::MakeSignal(sk_sp<GrSemaphore> semaphore) {
58 return GrSignalSemaphoreOp::Make(std::move(semaphore));
[all...] |
| GrSemaphoreOp.h | 18 static std::unique_ptr<GrSemaphoreOp> MakeSignal(sk_sp<GrSemaphore> semaphore);
20 static std::unique_ptr<GrSemaphoreOp> MakeWait(sk_sp<GrSemaphore> semaphore);
23 GrSemaphoreOp(uint32_t classId, sk_sp<GrSemaphore> semaphore)
24 : INHERITED(classId), fSemaphore(std::move(semaphore)) {}
|
| /external/syslinux/core/include/ |
| thread.h | 17 struct semaphore;
36 struct semaphore *semaphore; member in struct:thread_block
68 struct semaphore { struct
74 struct semaphore sem = { \
82 mstime_t sem_down(struct semaphore *, mstime_t);
83 void sem_up(struct semaphore *);
84 void sem_init(struct semaphore *, int);
87 * This marks a semaphore object as unusable; it will remain unusable
89 * list of blocked processes on this semaphore!
[all...] |
| mbox.h | 19 struct semaphore prod_sem; /* Producer semaphore (empty slots) */
20 struct semaphore cons_sem; /* Consumer semaphore (data slots) */
21 struct semaphore head_sem; /* Head pointer semaphore */
22 struct semaphore tail_sem; /* Tail pointer semaphore */
|
| /external/skia/src/gpu/vk/ |
| GrVkSemaphore.h | 26 Resource(VkSemaphore semaphore) : INHERITED(), fSemaphore(semaphore) {}
30 VkSemaphore semaphore() const { return fSemaphore; } function in class:GrVkSemaphore::Resource
48 GrVkSemaphore(const GrVkGpu* gpu, VkSemaphore semaphore);
|
| GrVkSemaphore.cpp | 24 VkSemaphore semaphore = VK_NULL_HANDLE; local
26 CreateSemaphore(gpu->device(), &createInfo, nullptr, &semaphore));
28 return sk_sp<GrVkSemaphore>(new GrVkSemaphore(gpu, semaphore));
31 GrVkSemaphore::GrVkSemaphore(const GrVkGpu* gpu, VkSemaphore semaphore) : INHERITED(gpu) {
32 fResource = new Resource(semaphore);
|
| /external/deqp/framework/delibs/dethread/win32/ |
| deSemaphoreWin32.c | 21 * \brief Win32 implementation of semaphore.
51 void deSemaphore_destroy (deSemaphore semaphore)
53 HANDLE handle = (HANDLE)semaphore;
57 void deSemaphore_increment (deSemaphore semaphore)
59 HANDLE handle = (HANDLE)semaphore;
65 void deSemaphore_decrement (deSemaphore semaphore)
67 HANDLE handle = (HANDLE)semaphore;
73 deBool deSemaphore_tryDecrement (deSemaphore semaphore)
75 HANDLE handle = (HANDLE)semaphore;
|
| /external/squashfs-tools/kernel-2.4/include/linux/ |
| 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;
|
| /cts/suite/audio_quality/lib/include/ |
| Semaphore.h | 21 #include <semaphore.h>
26 * Simple semaphore interface for synchronization between client and server
28 class Semaphore {
30 explicit Semaphore(int count = 0);
32 ~Semaphore();
34 /// down semaphore if it is already positive.
|
| /external/valgrind/none/tests/ |
| semlimit.c | 1 #include <semaphore.h>
|
| /external/skia/src/gpu/gl/ |
| GrGLExternalTextureData.cpp | 16 sk_sp<GrSemaphore> semaphore,
19 , fSemaphore(std::move(semaphore)) {
27 // semaphore will live on a GrTexture object and the wait will be called from there. At that
|
| /external/valgrind/drd/tests/ |
| 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:
|
| /system/bt/btif/src/ |
| stack_manager.cc | 32 #include "osi/include/semaphore.h"
69 semaphore_t* semaphore = semaphore_new(0); local
70 thread_post(management_thread, event_init_stack, semaphore);
71 semaphore_wait(semaphore);
72 semaphore_free(semaphore);
86 semaphore_t* semaphore = semaphore_new(0); local
87 thread_post(management_thread, event_clean_up_stack, semaphore);
88 semaphore_wait(semaphore);
89 semaphore_free(semaphore);
98 semaphore_t* semaphore = (semaphore_t*)context local
219 semaphore_t* semaphore = (semaphore_t*)context; local
[all...] |
| /frameworks/data-binding/integration-tests/TestApp/app/src/androidTestApi7/java/android/databinding/testapp/ |
| InvalidateAllTest.java | 8 import java.util.concurrent.Semaphore;
18 final Semaphore semaphore = new Semaphore(1); local
19 semaphore.acquire();
29 semaphore.release();
34 assertTrue(semaphore.tryAcquire(2, TimeUnit.SECONDS));
40 assertTrue(semaphore.tryAcquire(2, TimeUnit.SECONDS));
|
| /development/ndk/platforms/android-9/arch-arm/include/asm/ |
| semaphore.h | 23 struct semaphore { struct
31 #define __DECLARE_SEMAPHORE_GENERIC(name,count) struct semaphore name = __SEMAPHORE_INIT(name,count)
|
