/external/deqp/framework/delibs/dethread/unix/ |
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...] |
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...] |
/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/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/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-thread-termination.cc | 34 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 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/guava/guava/src/com/google/common/util/concurrent/ |
H A D | Uninterruptibles.java | 290 * 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 D | Striped.java | 53 * <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 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...] |
H A D | drd_clientobj.h | 151 struct semaphore_info semaphore; member in union:drd_clientobj
|
H A D | drd_error.h | 142 Addr semaphore; member in struct:__anon19735
|
/external/deqp/framework/platform/android/ |
H A D | tcuAndroidRenderActivity.hpp | 64 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 D | deThreadTest.c | 428 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 D | dng_pthread.h | 83 long semaphore; member in struct:_dng_pthread_once_t
|
H A D | dng_pthread.cpp | 62 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 D | wsi.c | 441 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 D | trampoline.c | 1113 vkDestroySemaphore(VkDevice device, VkSemaphore semaphore, argument 1119 disp->DestroySemaphore(device, semaphore, pAllocator);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | JSR166TestCase.java | 937 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 D | SIPTransaction.java | 131 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 D | swapchain.cpp | 1721 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 D | vktSynchronization.cpp | 1105 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 D | vktApiObjectManagementTests.cpp | 2409 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 D | syswrap-darwin.c | 69 #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 D | org.eclipse.core.jobs_3.5.1.R36x_v20100824.jar | META-INF/MANIFEST.MF META-INF/ECLIPSEF.SF META-INF/ECLIPSEF.RSA META ... |