Searched defs:semaphore (Results 1 - 25 of 42) sorted by relevance

12

/external/deqp/framework/delibs/dethread/unix/
H A DdeSemaphoreUnix.c21 * \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...]
H A DdeNamedSemaphoreUnix.c21 * \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...]
/external/deqp/framework/delibs/dethread/win32/
H A DdeSemaphoreWin32.c21 * \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/skia/src/core/
H A DSkSemaphore.cpp43 #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/v8/test/cctest/
H A Dtest-threads.cc39 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 Dtest-thread-termination.cc34 v8::base::Semaphore* semaphore = NULL; variable
38 semaphore->Signal();
173 semaphore->Wait();
186 semaphore = new v8::base::Semaphore(0);
203 delete semaphore;
204 semaphore = NULL;
401 semaphore = new v8::base::Semaphore(0);
427 delete semaphore;
428 semaphore = NULL;
/external/v8/test/unittests/base/platform/
H A Dsemaphore-unittest.cc8 #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/guava/guava/src/com/google/common/util/concurrent/
H A DUninterruptibles.java290 * Invokes {@code semaphore.}{@link Semaphore#tryAcquire(int, long, TimeUnit)
296 Semaphore semaphore, long timeout, TimeUnit unit) {
297 return tryAcquireUninterruptibly(semaphore, 1, timeout, unit);
301 * Invokes {@code semaphore.}{@link Semaphore#tryAcquire(int, long, TimeUnit)
307 Semaphore semaphore, int permits, long timeout, TimeUnit unit) {
316 return semaphore.tryAcquire(permits, remainingNanos, NANOSECONDS);
295 tryAcquireUninterruptibly( Semaphore semaphore, long timeout, TimeUnit unit) argument
306 tryAcquireUninterruptibly( Semaphore semaphore, int permits, long timeout, TimeUnit unit) argument
H A DStriped.java53 * <p>The guarantee provided by this class is that equal keys lead to the same lock (or semaphore),
64 * {@code Striped<Lock>}, {@linkplain #semaphore(int, int) strong} and {@linkplain
232 * @param permits the number of permits in each semaphore
235 public static Striped<Semaphore> semaphore(int stripes, final int permits) { method in class:Striped
248 * @param permits the number of permits in each semaphore
/external/valgrind/drd/
H A Ddrd_semaphore.c85 /** 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...]
H A Ddrd_clientobj.h151 struct semaphore_info semaphore; member in union:drd_clientobj
H A Ddrd_error.h142 Addr semaphore; member in struct:__anon19735
/external/deqp/framework/platform/android/
H A DtcuAndroidRenderActivity.hpp64 de::Semaphore* semaphore; member in union:tcu::Android::Message::__anon3893
99 Message (MessageType type_, de::Semaphore* semaphore) argument
103 DE_ASSERT(semaphore);
104 payload.semaphore = semaphore;
/external/deqp/framework/delibs/dethread/
H A DdeThreadTest.c428 deSemaphore semaphore = deSemaphore_create(1, DE_NULL); local
429 DE_TEST_ASSERT(semaphore);
431 deSemaphore_increment(semaphore);
432 deSemaphore_decrement(semaphore);
433 deSemaphore_decrement(semaphore);
435 deSemaphore_destroy(semaphore);
/external/dng_sdk/source/
H A Ddng_pthread.h83 long semaphore; member in struct:_dng_pthread_once_t
H A Ddng_pthread.cpp62 HANDLE semaphore; member in struct:__anon4669::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:__anon4671::rw_waiter
848 HANDLE semaphore = head_waiter->semaphore; local
909 HANDLE semaphore=NULL; local
1035 HANDLE semaphore=NULL; local
[all...]
/external/vulkan-validation-layers/loader/
H A Dwsi.c441 uint64_t timeout, VkSemaphore semaphore, VkFence fence,
446 semaphore, fence, pImageIndex);
440 vkAcquireNextImageKHR(VkDevice device, VkSwapchainKHR swapchain, uint64_t timeout, VkSemaphore semaphore, VkFence fence, uint32_t *pImageIndex) argument
H A Dtrampoline.c1113 vkDestroySemaphore(VkDevice device, VkSemaphore semaphore, argument
1119 disp->DestroySemaphore(device, semaphore, pAllocator);
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DJSR166TestCase.java937 public void await(Semaphore semaphore) { argument
939 assertTrue(semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS));
/external/nist-sip/java/gov/nist/javax/sip/stack/
H A DSIPTransaction.java131 private Semaphore semaphore; field in class:SIPTransaction
332 this.semaphore = new Semaphore(1,true);
1130 * semaphore gaurds re-entrancy to the transaction.
1140 retval = this.semaphore.tryAcquire(1000, TimeUnit.MILLISECONDS);
1157 * Release the transaction semaphore.
1181 this.semaphore.release();
/external/vulkan-validation-layers/layers/
H A Dswapchain.cpp1721 VkSemaphore semaphore, VkFence fence, uint32_t *pImageIndex) {
1726 // - Implement a check for validity language that reads: If pname:semaphore is
1746 if ((semaphore == VK_NULL_HANDLE) && (fence == VK_NULL_HANDLE)) {
1748 "%s() called with both the semaphore and fence parameters set to "
1783 result = my_data->device_dispatch_table->AcquireNextImageKHR(device, swapchain, timeout, semaphore, fence, pImageIndex);
1805 // semaphore
1720 vkAcquireNextImageKHR(VkDevice device, VkSwapchainKHR swapchain, uint64_t timeout, VkSemaphore semaphore, VkFence fence, uint32_t *pImageIndex) argument
/external/deqp/external/vulkancts/modules/vulkan/
H A DvktSynchronization.cpp1105 VkSemaphore semaphore; local
1110 VK_CHECK(deviceInterface.createSemaphore(device, &semaCreateInfo, allocationCallbacks, &semaphore));
1112 return vk::check<VkSemaphore>(semaphore);
1130 Unique<VkSemaphore> semaphore (createSemaphore(deviceInterface, device.get(), (VkAllocationCallbacks*)DE_NULL), Deleter<VkSemaphore>(deviceInterface, device.get(), DE_NULL));
1172 // and one will signal a semaphore but not wait on a semaphore, the other will wait on the
1173 // semaphore but not signal a semaphore
1178 submitInfo[0].pSignalSemaphores = &semaphore.get();
1180 submitInfo[1].pWaitSemaphores = &semaphore
[all...]
/external/deqp/external/vulkancts/modules/vulkan/api/
H A DvktApiObjectManagementTests.cpp2409 CaseDescription<Semaphore> semaphore; member in struct:vkt::CaseDescriptions
2453 addCases (group, cases.semaphore);
2537 { "semaphore", Semaphore::Parameters(0u), }
/external/valgrind/coregrind/m_syswrap/
H A Dsyswrap-darwin.c69 #include <semaphore.h>
6024 mach_msg_port_descriptor_t semaphore; member in struct:__anon19558
6032 assign_port_name(reply->semaphore.name, "semaphore-%p");
6033 PRINT("%s", name_for_port(reply->semaphore.name));
6044 mach_msg_port_descriptor_t semaphore; member in struct:__anon19559
6053 name_for_port(MACH_REMOTE), name_for_port(req->semaphore.name));
6055 record_port_destroy(req->semaphore.name);
7676 // Create a semaphore that pthread_hijack will signal once it starts
7698 // GrP fixme semaphore destro
[all...]
/external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/
H A Dorg.eclipse.core.jobs_3.5.1.R36x_v20100824.jarMETA-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ...

Completed in 1218 milliseconds

12