/third_party/libuv/test/ |
H A D | test-barrier.c | 29 uv_barrier_t barrier; member 45 c->worker_barrier_wait_rval += uv_barrier_wait(&c->barrier); in worker() 56 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL() 60 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL() 63 uv_barrier_destroy(&wc.barrier); in TEST_IMPL() 79 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL() 82 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL() 85 uv_barrier_destroy(&wc.barrier); in TEST_IMPL() 101 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL() 105 wc.main_barrier_wait_rval += uv_barrier_wait(&wc.barrier); in TEST_IMPL() 116 uv_barrier_t* barrier; serial_worker() local 133 uv_barrier_t barrier; TEST_IMPL() local 154 uv_barrier_t barrier; TEST_IMPL() local [all...] |
/third_party/mesa3d/src/util/ |
H A D | u_thread.h | 292 static inline void util_barrier_init(util_barrier *barrier, unsigned count) in util_barrier_init() argument 294 pthread_barrier_init(barrier, NULL, count); in util_barrier_init() 297 static inline void util_barrier_destroy(util_barrier *barrier) in util_barrier_destroy() argument 299 pthread_barrier_destroy(barrier); in util_barrier_destroy() 302 static inline bool util_barrier_wait(util_barrier *barrier) in util_barrier_wait() argument 304 return pthread_barrier_wait(barrier) == PTHREAD_BARRIER_SERIAL_THREAD; in util_barrier_wait() 318 static inline void util_barrier_init(util_barrier *barrier, unsigned count) in util_barrier_init() argument 320 barrier->count = count; in util_barrier_init() 321 barrier->waiters = 0; in util_barrier_init() 322 barrier in util_barrier_init() 327 util_barrier_destroy(util_barrier *barrier) util_barrier_destroy() argument 334 util_barrier_wait(util_barrier *barrier) util_barrier_wait() argument [all...] |
/third_party/libuv/src/ |
H A D | thread-common.c | 38 int uv_barrier_init(uv_barrier_t* barrier, unsigned int count) { in uv_barrier_init() argument 42 b = barrier; in uv_barrier_init() 44 if (barrier == NULL || count == 0) in uv_barrier_init() 49 if (barrier == NULL || count == 0) in uv_barrier_init() 71 barrier->b = b; in uv_barrier_init() 85 int uv_barrier_wait(uv_barrier_t* barrier) { in uv_barrier_wait() argument 89 b = barrier; in uv_barrier_wait() 93 if (barrier == NULL || barrier->b == NULL) in uv_barrier_wait() 96 b = barrier in uv_barrier_wait() 123 uv_barrier_destroy(uv_barrier_t* barrier) uv_barrier_destroy() argument 153 uv_barrier_init(uv_barrier_t* barrier, unsigned int count) uv_barrier_init() argument 158 uv_barrier_wait(uv_barrier_t* barrier) uv_barrier_wait() argument 170 uv_barrier_destroy(uv_barrier_t* barrier) uv_barrier_destroy() argument [all...] |
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_locks.py | 16 r'(, waiters:\d+\/\d+)?' # barrier 1064 barrier = asyncio.Barrier(self.N) 1065 self.assertIn("filling", repr(barrier)) 1070 await barrier 1072 self.assertIn("filling", repr(barrier)) 1075 barrier = asyncio.Barrier(self.N) 1077 self.assertTrue(RGX_REPR.match(repr(barrier))) 1078 self.assertIn("filling", repr(barrier)) 1081 async def wait(barrier): 1082 await barrier [all...] |
/third_party/node/deps/uv/src/win/ |
H A D | thread.c | 386 int uv_barrier_init(uv_barrier_t* barrier, unsigned int count) { in uv_barrier_init() argument 389 barrier->n = count; in uv_barrier_init() 390 barrier->count = 0; in uv_barrier_init() 392 err = uv_mutex_init(&barrier->mutex); in uv_barrier_init() 396 err = uv_sem_init(&barrier->turnstile1, 0); in uv_barrier_init() 400 err = uv_sem_init(&barrier->turnstile2, 1); in uv_barrier_init() 407 uv_sem_destroy(&barrier->turnstile1); in uv_barrier_init() 409 uv_mutex_destroy(&barrier->mutex); in uv_barrier_init() 415 void uv_barrier_destroy(uv_barrier_t* barrier) { in uv_barrier_destroy() argument 416 uv_sem_destroy(&barrier in uv_barrier_destroy() 422 uv_barrier_wait(uv_barrier_t* barrier) uv_barrier_wait() argument [all...] |
/third_party/vk-gl-cts/external/amber/src/src/vulkan/ |
H A D | transfer_image.cc | 314 VkImageMemoryBarrier barrier = VkImageMemoryBarrier(); in ImageBarrier() 315 barrier.sType = VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER; in ImageBarrier() 316 barrier.oldLayout = layout_; in ImageBarrier() 317 barrier.newLayout = to_layout; in ImageBarrier() 318 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in ImageBarrier() 319 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in ImageBarrier() 320 barrier.image = image_; in ImageBarrier() 321 barrier.subresourceRange = { in ImageBarrier() 331 barrier.srcAccessMask = VK_ACCESS_HOST_WRITE_BIT; in ImageBarrier() 334 barrier in ImageBarrier() [all...] |
/third_party/vk-gl-cts/framework/delibs/decpp/ |
H A D | deSpinBarrier.cpp | 21 * \brief Cross-thread barrier. 132 // Wait for other threads exiting previous barrier in removeThread() 144 // Ask for last thread entering barrier to adjust thread count in removeThread() 165 SpinBarrier barrier(1); in singleThreadTest() 167 barrier.sync(mode); in singleThreadTest() 168 barrier.sync(mode); in singleThreadTest() 169 barrier.sync(mode); in singleThreadTest() 175 TestThread (SpinBarrier& barrier, volatile deInt32* sharedVar, int numThreads, int threadNdx) in TestThread() argument 176 : m_barrier (barrier) in TestThread() 236 SpinBarrier barrier (numThread in multiThreadTest() 276 TestExitThread(SpinBarrier& barrier, int numThreads, int threadNdx, SpinBarrier::WaitMode waitMode) TestExitThread() argument [all...] |
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/draw/ |
H A D | vktDrawImageObjectUtil.cpp | 341 vk::VkImageMemoryBarrier barrier; in readUsingBuffer() local 342 barrier.sType = vk::VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER; in readUsingBuffer() 343 barrier.pNext = DE_NULL; in readUsingBuffer() 344 barrier.srcAccessMask = 0; in readUsingBuffer() 345 barrier.dstAccessMask = 0; in readUsingBuffer() 346 barrier.oldLayout = vk::VK_IMAGE_LAYOUT_UNDEFINED; in readUsingBuffer() 347 barrier.newLayout = vk::VK_IMAGE_LAYOUT_GENERAL; in readUsingBuffer() 348 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in readUsingBuffer() 349 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in readUsingBuffer() 350 barrier in readUsingBuffer() 642 vk::VkImageMemoryBarrier barrier; upload() local 738 vk::VkImageMemoryBarrier barrier; uploadUsingBuffer() local 849 vk::VkImageMemoryBarrier barrier; transition2DImage() local [all...] |
H A D | vktDrawBufferObjectUtil.cpp | 94 vk::VkBufferMemoryBarrier barrier; in bufferBarrier() local 95 barrier.sType = vk::VK_STRUCTURE_TYPE_BUFFER_MEMORY_BARRIER; in bufferBarrier() 96 barrier.pNext = DE_NULL; in bufferBarrier() 97 barrier.srcAccessMask = srcAccessMask; in bufferBarrier() 98 barrier.dstAccessMask = dstAccessMask; in bufferBarrier() 99 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier() 100 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier() 101 barrier.buffer = buffer; in bufferBarrier() 102 barrier.offset = 0; in bufferBarrier() 103 barrier in bufferBarrier() [all...] |
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/draw/ |
H A D | vktDrawImageObjectUtil.cpp | 341 vk::VkImageMemoryBarrier barrier; in readUsingBuffer() local 342 barrier.sType = vk::VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER; in readUsingBuffer() 343 barrier.pNext = DE_NULL; in readUsingBuffer() 344 barrier.srcAccessMask = 0; in readUsingBuffer() 345 barrier.dstAccessMask = 0; in readUsingBuffer() 346 barrier.oldLayout = vk::VK_IMAGE_LAYOUT_UNDEFINED; in readUsingBuffer() 347 barrier.newLayout = vk::VK_IMAGE_LAYOUT_GENERAL; in readUsingBuffer() 348 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in readUsingBuffer() 349 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in readUsingBuffer() 350 barrier in readUsingBuffer() 642 vk::VkImageMemoryBarrier barrier; upload() local 738 vk::VkImageMemoryBarrier barrier; uploadUsingBuffer() local 849 vk::VkImageMemoryBarrier barrier; transition2DImage() local [all...] |
H A D | vktDrawBufferObjectUtil.cpp | 94 vk::VkBufferMemoryBarrier barrier; in bufferBarrier() local 95 barrier.sType = vk::VK_STRUCTURE_TYPE_BUFFER_MEMORY_BARRIER; in bufferBarrier() 96 barrier.pNext = DE_NULL; in bufferBarrier() 97 barrier.srcAccessMask = srcAccessMask; in bufferBarrier() 98 barrier.dstAccessMask = dstAccessMask; in bufferBarrier() 99 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier() 100 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier() 101 barrier.buffer = buffer; in bufferBarrier() 102 barrier.offset = 0; in bufferBarrier() 103 barrier in bufferBarrier() [all...] |
/third_party/skia/third_party/externals/swiftshader/tests/VulkanWrapper/ |
H A D | Util.cpp | 76 vk::ImageMemoryBarrier barrier{}; in transitionImageLayout() 77 barrier.oldLayout = oldLayout; in transitionImageLayout() 78 barrier.newLayout = newLayout; in transitionImageLayout() 79 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in transitionImageLayout() 80 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in transitionImageLayout() 81 barrier.image = image; in transitionImageLayout() 82 barrier.subresourceRange.aspectMask = vk::ImageAspectFlagBits::eColor; in transitionImageLayout() 83 barrier.subresourceRange.baseMipLevel = 0; in transitionImageLayout() 84 barrier.subresourceRange.levelCount = 1; in transitionImageLayout() 85 barrier in transitionImageLayout() [all...] |
/third_party/musl/src/time/ |
H A D | timer_create.c | 20 * barrier val: 54 static void __child_sync(volatile int *barrier) in __child_sync() argument 56 if (a_swap(barrier, CHILD_ARRIVE) == INIT_STATE) { in __child_sync() 57 __wait(barrier, 0, CHILD_ARRIVE, 0); in __child_sync() 59 __wake(barrier, 1, 0); in __child_sync() 62 a_swap(barrier, CHILD_DONE); in __child_sync() 63 __wake(barrier, 1, 0); in __child_sync() 66 static void __parent_sync(volatile int *barrier) in __parent_sync() argument 68 if (a_swap(barrier, PARENT_ARRIVE) == CHILD_ARRIVE) { in __parent_sync() 69 __wake(barrier, in __parent_sync() [all...] |
/third_party/skia/third_party/externals/dawn/src/dawn_native/vulkan/ |
H A D | TextureVk.cpp | 171 VkImageMemoryBarrier barrier; in BuildMemoryBarrier() local 172 barrier.sType = VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER; in BuildMemoryBarrier() 173 barrier.pNext = nullptr; in BuildMemoryBarrier() 174 barrier.srcAccessMask = VulkanAccessFlags(lastUsage, texture->GetFormat()); in BuildMemoryBarrier() 175 barrier.dstAccessMask = VulkanAccessFlags(usage, texture->GetFormat()); in BuildMemoryBarrier() 176 barrier.oldLayout = VulkanImageLayout(texture, lastUsage); in BuildMemoryBarrier() 177 barrier.newLayout = VulkanImageLayout(texture, usage); in BuildMemoryBarrier() 178 barrier.image = texture->GetHandle(); in BuildMemoryBarrier() 179 barrier.subresourceRange.aspectMask = VulkanAspectMask(range.aspects); in BuildMemoryBarrier() 180 barrier in BuildMemoryBarrier() 774 VkImageMemoryBarrier barrier; ExportExternalTexture() local 905 VkImageMemoryBarrier* barrier = &(*barriers)[transitionBarrierStart]; TweakTransitionForExternalUsage() local [all...] |
H A D | BufferVk.cpp | 247 VkBufferMemoryBarrier barrier; in TransitionUsageNow() local 251 if (TransitionUsageAndGetResourceBarrier(usage, &barrier, &srcStages, &dstStages)) { in TransitionUsageNow() 255 nullptr, 1u, &barrier, 0, nullptr); in TransitionUsageNow() 260 VkBufferMemoryBarrier* barrier, in TransitionUsageAndGetResourceBarrier() 280 barrier->sType = VK_STRUCTURE_TYPE_BUFFER_MEMORY_BARRIER; in TransitionUsageAndGetResourceBarrier() 281 barrier->pNext = nullptr; in TransitionUsageAndGetResourceBarrier() 282 barrier->srcAccessMask = VulkanAccessFlags(mLastUsage); in TransitionUsageAndGetResourceBarrier() 283 barrier->dstAccessMask = VulkanAccessFlags(usage); in TransitionUsageAndGetResourceBarrier() 284 barrier->srcQueueFamilyIndex = 0; in TransitionUsageAndGetResourceBarrier() 285 barrier in TransitionUsageAndGetResourceBarrier() 259 TransitionUsageAndGetResourceBarrier(wgpu::BufferUsage usage, VkBufferMemoryBarrier* barrier, VkPipelineStageFlags* srcStages, VkPipelineStageFlags* dstStages) TransitionUsageAndGetResourceBarrier() argument [all...] |
/third_party/python/Include/ |
H A D | dynamic_annotations.h | 287 The "barrier" argument is a pointer to the barrier object. */ 289 /* Report that the "barrier" has been initialized with initial "count". 292 #define _Py_ANNOTATE_BARRIER_INIT(barrier, count, reinitialization_allowed) \ 293 AnnotateBarrierInit(__FILE__, __LINE__, barrier, count, \ 296 /* Report that we are about to enter barrier_wait("barrier"). */ 297 #define _Py_ANNOTATE_BARRIER_WAIT_BEFORE(barrier) \ 298 AnnotateBarrierWaitBefore(__FILE__, __LINE__, barrier) 300 /* Report that we just exited barrier_wait("barrier"). */ 301 #define _Py_ANNOTATE_BARRIER_WAIT_AFTER(barrier) \ [all...] |
/third_party/ltp/include/ |
H A D | tst_safe_pthread.h | 34 pthread_barrier_t *barrier); 35 #define SAFE_PTHREAD_BARRIER_WAIT(barrier) \ 36 safe_pthread_barrier_wait(__FILE__, __LINE__, barrier); 39 pthread_barrier_t *barrier); 40 #define SAFE_PTHREAD_BARRIER_DESTROY(barrier) \ 41 safe_pthread_barrier_destroy(__FILE__, __LINE__, barrier); 44 pthread_barrier_t *barrier, 47 #define SAFE_PTHREAD_BARRIER_INIT(barrier, attr, count) \ 48 safe_pthread_barrier_init(__FILE__, __LINE__, barrier, attr, count);
|
/third_party/mesa3d/src/vulkan/runtime/ |
H A D | vk_synchronization2.c | 49 upgrade_memory_barrier(const VkMemoryBarrier *barrier, in upgrade_memory_barrier() argument 56 .srcAccessMask = (VkAccessFlags2) barrier->srcAccessMask, in upgrade_memory_barrier() 58 .dstAccessMask = (VkAccessFlags2) barrier->dstAccessMask, in upgrade_memory_barrier() 63 upgrade_buffer_memory_barrier(const VkBufferMemoryBarrier *barrier, in upgrade_buffer_memory_barrier() argument 70 .srcAccessMask = (VkAccessFlags2) barrier->srcAccessMask, in upgrade_buffer_memory_barrier() 72 .dstAccessMask = (VkAccessFlags2) barrier->dstAccessMask, in upgrade_buffer_memory_barrier() 73 .srcQueueFamilyIndex = barrier->srcQueueFamilyIndex, in upgrade_buffer_memory_barrier() 74 .dstQueueFamilyIndex = barrier->dstQueueFamilyIndex, in upgrade_buffer_memory_barrier() 75 .buffer = barrier->buffer, in upgrade_buffer_memory_barrier() 76 .offset = barrier in upgrade_buffer_memory_barrier() 82 upgrade_image_memory_barrier(const VkImageMemoryBarrier *barrier, VkPipelineStageFlags2 src_stage_mask2, VkPipelineStageFlags2 dst_stage_mask2) upgrade_image_memory_barrier() argument [all...] |
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_barrierattr_getpshared/ |
H A D | 2-1.c | 10 * a barrier to be operated upon by any thread that has access to the memory 11 * where the barrier is allocated. If the process-shared attribute 12 * is PTHREAD_PROCESS_PRIVATE, the barrier shall only be operated 14 * that initialized the barrier; if threads of different processes attempt 15 * to operate on such a barrier, the behavior is undefined. 20 * 1. Create a piece of shared memory object, create pthread barrier object 'barrier' 22 * 2. Parent map the shared memory to its memory space, put 'barrier' into it; 24 * 4. Child process map the 'barrier' to its memory space; 60 static pthread_barrier_t *barrier; in main() local [all...] |
/third_party/ltp/lib/ |
H A D | safe_pthread.c | 46 pthread_barrier_t *barrier) in safe_pthread_barrier_wait() 50 rval = pthread_barrier_wait(barrier); in safe_pthread_barrier_wait() 55 barrier, tst_strerrno(rval)); in safe_pthread_barrier_wait() 62 pthread_barrier_t *barrier) in safe_pthread_barrier_destroy() 66 rval = pthread_barrier_destroy(barrier); in safe_pthread_barrier_destroy() 71 barrier, tst_strerrno(rval)); in safe_pthread_barrier_destroy() 93 pthread_barrier_t *barrier, in safe_pthread_barrier_init() 99 rval = pthread_barrier_init(barrier, attr, count); in safe_pthread_barrier_init() 104 barrier, attr, count, tst_strerrno(rval)); in safe_pthread_barrier_init() 45 safe_pthread_barrier_wait(const char *file, const int lineno, pthread_barrier_t *barrier) safe_pthread_barrier_wait() argument 61 safe_pthread_barrier_destroy(const char *file, const int lineno, pthread_barrier_t *barrier) safe_pthread_barrier_destroy() argument 92 safe_pthread_barrier_init(const char *file, const int lineno, pthread_barrier_t *barrier, const pthread_barrierattr_t *attr, unsigned count) safe_pthread_barrier_init() argument
|
/third_party/FreeBSD/sys/compat/linuxkpi/common/include/linux/ |
H A D | compiler.h | 38 #define barrier() __asm__ __volatile__("": : :"memory") macro 41 barrier(); \ 43 barrier(); \ 48 barrier(); \ 51 barrier(); \
|
/third_party/node/deps/uv/src/unix/ |
H A D | thread.c | 55 int uv_barrier_init(uv_barrier_t* barrier, unsigned int count) { in uv_barrier_init() argument 59 if (barrier == NULL || count == 0) in uv_barrier_init() 78 barrier->b = b; in uv_barrier_init() 89 int uv_barrier_wait(uv_barrier_t* barrier) { in uv_barrier_wait() argument 93 if (barrier == NULL || barrier->b == NULL) in uv_barrier_wait() 96 b = barrier->b; in uv_barrier_wait() 117 void uv_barrier_destroy(uv_barrier_t* barrier) { in uv_barrier_destroy() argument 120 b = barrier->b; in uv_barrier_destroy() 134 uv__free(barrier in uv_barrier_destroy() 140 uv_barrier_init(uv_barrier_t* barrier, unsigned int count) uv_barrier_init() argument 145 uv_barrier_wait(uv_barrier_t* barrier) uv_barrier_wait() argument 157 uv_barrier_destroy(uv_barrier_t* barrier) uv_barrier_destroy() argument [all...] |
/third_party/libbpf/include/linux/ |
H A D | compiler.h | 12 #define barrier() asm volatile("" ::: "memory") macro 16 # define smp_rmb() barrier() 17 # define smp_wmb() barrier() 22 barrier(); \ 29 barrier(); \
|
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_barrier_init/ |
H A D | 1-1.c | 11 * required to use the barrier referenced by barrier and shall initialize 12 * the barrier with attributes referenced by attr. If attr is NULL, 13 * the default barrier attributes shall be used; 14 * the effect is the same as passing the address of a default barrier attributes object. 29 static pthread_barrier_t barrier; variable 36 /* Intilized barrier with NULL attribute, check that this can be done. */ in main() 37 rc = pthread_barrier_init(&barrier, NULL, COUNT); in main() 46 if (pthread_barrier_destroy(&barrier) != 0) { in main() 52 /* Initialize a barrier attribut in main() [all...] |
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/ |
H A D | 12-1.c | 54 static pthread_barrier_t barrier; variable 95 ret = pthread_barrier_wait(&barrier); in a_thread_func() 127 ret = pthread_barrier_wait(&barrier); in a_thread_func() 138 ret = pthread_barrier_init(&barrier, NULL, 2); in main() 147 ret = pthread_barrier_wait(&barrier); in main() 162 ret = pthread_barrier_wait(&barrier); in main() 185 ret = pthread_barrier_destroy(&barrier); in main()
|