HomeSort by relevance Sort by last modified time
    Searched defs:semaphore (Results 1 - 25 of 79) sorted by null

1 2 3 4

  /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,

Completed in 1126 milliseconds

1 2 3 4