/cts/common/device-side/util/src/com/android/compatibility/common/util/ |
BlockedNumberUtil.java | 37 import java.util.concurrent.Semaphore; 70 final Semaphore semaphore = new Semaphore(0); local 77 semaphore.release(); 86 TestCase.assertTrue(semaphore.tryAcquire(TIMEOUT, TimeUnit.SECONDS));
|
/cts/common/device-side/util-axt/src/com/android/compatibility/common/util/ |
BlockedNumberUtil.java | 37 import java.util.concurrent.Semaphore; 70 final Semaphore semaphore = new Semaphore(0); local 77 semaphore.release(); 86 TestCase.assertTrue(semaphore.tryAcquire(TIMEOUT, TimeUnit.SECONDS));
|
/bionic/benchmarks/ |
semaphore_benchmark.cpp | 18 #include <semaphore.h> 27 sem_t semaphore; local 28 sem_init(&semaphore, 1, 1); 32 sem_getvalue(&semaphore, &dummy); 38 sem_t semaphore; local 39 sem_init(&semaphore, 1, 1); 42 sem_wait(&semaphore); 43 sem_post(&semaphore); 74 sem_t* semaphore = reinterpret_cast<sem_t*>(arg); local 75 while ((BM_semaphore_sem_post_running > 0) && !sem_wait(semaphore)) { 112 sem_post(&semaphore); variable 118 sem_t semaphore; member in class:SemaphoreFixture [all...] |
/external/ImageMagick/MagickCore/ |
delegate.h | 26 #include "MagickCore/semaphore.h" 45 *semaphore; member in struct:_DelegateInfo
|
linked-list.c | 53 #include "MagickCore/semaphore.h" 82 *semaphore; 129 LockSemaphoreInfo(list_info->semaphore); 138 UnlockSemaphoreInfo(list_info->semaphore); 180 LockSemaphoreInfo(list_info->semaphore); 194 UnlockSemaphoreInfo(list_info->semaphore); 234 LockSemaphoreInfo(list_info->semaphore); 244 UnlockSemaphoreInfo(list_info->semaphore); 245 RelinquishSemaphoreInfo(&list_info->semaphore); 282 LockSemaphoreInfo(list_info->semaphore); 80 *semaphore; member in struct:_LinkedListInfo [all...] |
magick.h | 26 #include "MagickCore/semaphore.h" 90 *semaphore; member in struct:_MagickInfo
|
/external/bcc/src/cc/ |
bcc_elf.h | 28 uint64_t semaphore; member in struct:bcc_elf_usdt
|
bcc_usdt.h | 33 uint64_t semaphore; member in struct:bcc_usdt
|
/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...] |
/external/skia/src/gpu/vk/ |
GrVkSemaphore.cpp | 25 VkSemaphore semaphore = VK_NULL_HANDLE; local 27 CreateSemaphore(gpu->device(), &createInfo, nullptr, &semaphore)); 29 return sk_sp<GrVkSemaphore>(new GrVkSemaphore(gpu, semaphore, false, false, isOwned)); 33 VkSemaphore semaphore, 36 if (VK_NULL_HANDLE == semaphore) { 41 return sk_sp<GrVkSemaphore>(new GrVkSemaphore(gpu, semaphore, prohibitSignal, prohibitWait, 45 GrVkSemaphore::GrVkSemaphore(GrVkGpu* gpu, VkSemaphore semaphore, bool prohibitSignal, 48 fResource = new Resource(semaphore, prohibitSignal, prohibitWait, isOwned); 78 backendSemaphore.initVulkan(fResource->semaphore());
|
GrVkSemaphore.h | 27 VkSemaphore semaphore, 35 Resource(VkSemaphore semaphore, bool prohibitSignal, bool prohibitWait, bool isOwned) 37 , fSemaphore(semaphore) 44 VkSemaphore semaphore() const { return fSemaphore; } function in class:GrVkSemaphore::Resource 89 GrVkSemaphore(GrVkGpu* gpu, VkSemaphore semaphore, bool prohibitSignal, bool prohibitWait,
|
/external/skqp/src/gpu/vk/ |
GrVkSemaphore.cpp | 25 VkSemaphore semaphore = VK_NULL_HANDLE; local 27 CreateSemaphore(gpu->device(), &createInfo, nullptr, &semaphore)); 29 return sk_sp<GrVkSemaphore>(new GrVkSemaphore(gpu, semaphore, false, false, isOwned)); 33 VkSemaphore semaphore, 36 if (VK_NULL_HANDLE == semaphore) { 41 return sk_sp<GrVkSemaphore>(new GrVkSemaphore(gpu, semaphore, prohibitSignal, prohibitWait, 45 GrVkSemaphore::GrVkSemaphore(GrVkGpu* gpu, VkSemaphore semaphore, bool prohibitSignal, 48 fResource = new Resource(semaphore, prohibitSignal, prohibitWait, isOwned); 78 backendSemaphore.initVulkan(fResource->semaphore());
|
GrVkSemaphore.h | 27 VkSemaphore semaphore, 35 Resource(VkSemaphore semaphore, bool prohibitSignal, bool prohibitWait, bool isOwned) 37 , fSemaphore(semaphore) 44 VkSemaphore semaphore() const { return fSemaphore; } function in class:GrVkSemaphore::Resource 89 GrVkSemaphore(GrVkGpu* gpu, VkSemaphore semaphore, bool prohibitSignal, bool prohibitWait,
|
/external/python/cpython2/Demo/threads/ |
sync.py | 7 # semaphore(n=1) # a semaphore object, with initial count n 197 # A semaphore object is created via 199 # your_semaphore = this_module.semaphore(count=1) 201 # A semaphore has an integer count associated with it. The initial value 203 # 1) passed to the semaphore constructor. 208 # If the semaphore's count is greater than 0, decrements the count 210 # Else if the semaphore's count is 0, blocks the calling thread 215 # Increments the semaphore's count by 1, and wakes up a thread (if 217 # increase the semaphore's count to a value larger than the initia 402 class semaphore: class in inherits: [all...] |
/external/skia/src/gpu/ |
GrBackendTextureImageGenerator.cpp | 38 sk_sp<GrSemaphore> semaphore, SkColorType colorType, 62 std::move(semaphore), backendTexture)); 69 sk_sp<GrSemaphore> semaphore, 73 , fSemaphore(std::move(semaphore)) 141 sk_sp<GrSemaphore> semaphore = fSemaphore; local 149 [refHelper, releaseProcHelper, semaphore, 151 if (semaphore) { 152 resourceProvider->priv().gpu()->waitSemaphore(semaphore);
|
/external/skia/tools/skqp/ |
jitter_gms.cpp | 112 SkSemaphore semaphore; local 117 &semaphore, &doNotRun, &testOnlyThese](){ 131 semaphore.signal(); 134 while (total-- > 0) { semaphore.wait(); }
|
/external/skqp/src/gpu/ |
GrBackendTextureImageGenerator.cpp | 36 sk_sp<GrSemaphore> semaphore, SkColorType colorType, 60 std::move(semaphore), backendTexture)); 67 sk_sp<GrSemaphore> semaphore, 71 , fSemaphore(std::move(semaphore)) 138 sk_sp<GrSemaphore> semaphore = fSemaphore; local 146 [refHelper, releaseProcHelper, semaphore, 152 if (semaphore) { 153 resourceProvider->priv().gpu()->waitSemaphore(semaphore);
|
GrGpu.cpp | 385 sk_sp<GrSemaphore> semaphore; local 387 semaphore = resourceProvider->wrapBackendSemaphore( 391 semaphore = resourceProvider->makeSemaphore(false); 393 this->insertSemaphore(semaphore); 396 backendSemaphores[i] = semaphore->backendSemaphore();
|
/external/skqp/tools/skqp/ |
jitter_gms.cpp | 112 SkSemaphore semaphore; local 117 &semaphore, &doNotRun, &testOnlyThese](){ 131 semaphore.signal(); 134 while (total-- > 0) { semaphore.wait(); }
|
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
TensorDeviceCuda.h | 33 // Return a semaphore. The semaphore is initially initialized to 0, and 35 // to maintain the invariant that the semaphore is always equal to 0 upon 37 virtual unsigned int* semaphore() const = 0; 165 virtual unsigned int* semaphore() const { 209 EIGEN_STRONG_INLINE unsigned int* semaphore() const { function 210 return stream_->semaphore();
|
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
ClientCallsTest.java | 50 import java.util.concurrent.Semaphore; 373 final Semaphore semaphore = new Semaphore(0); local 391 semaphore.release(); 438 semaphore.acquire(); 440 semaphore.acquire(); 451 final Semaphore semaphore = new Semaphore(0) local [all...] |
ServerCallsTest.java | 47 import java.util.concurrent.Semaphore; 375 final Semaphore semaphore = new Semaphore(1); local 393 semaphore.release(); 425 semaphore.acquire(); 427 semaphore.acquire(); 429 semaphore.acquire();
|
/art/test/004-ThreadStress/src-art/ |
Main.java | 28 import java.util.concurrent.Semaphore; 42 // -p X .............. number of permits granted by semaphore 287 // An operation requiring the acquisition of a permit from a semaphore 290 // implementation of java.util.concurrent.Semaphore. We use the latter, 295 private final Semaphore semaphore; field in class:Main.QueuedWait 297 public QueuedWait(Semaphore semaphore) { 298 this.semaphore = semaphore; 480 Semaphore semaphore = getSemaphore(permits); local 508 Semaphore semaphore = getSemaphore(permits); local 532 Semaphore semaphore = new Semaphore(permits, \/* fair *\/ true); local [all...] |
/art/test/testrunner/ |
testrunner.py | 100 # The semaphore object is used by the testrunner to limit the number of 102 semaphore = threading.Semaphore(1) variable 239 global semaphore 240 semaphore = threading.Semaphore(n_thread) 284 semaphore object to keep a count in control for the thread workers. When a new 285 worker is created, it acquires the semaphore object, and when the number of 287 existing thread worker to release the semaphore object. Worker releases the 288 semaphore object when they finish printing the output [all...] |
/cts/tests/tests/graphics/jni/ |
VulkanTestHelpers.h | 68 VkSemaphore semaphore() { return mSemaphore; } function in class:VkAHardwareBufferImage 91 VkImageView view, VkSemaphore semaphore, 95 VkImageView view, VkSemaphore semaphore,
|