| /third_party/iowow/src/utils/ |
| D | iwth.c | 38 pthread_barrier_init(pthread_barrier_t *restrict barrier, in pthread_barrier_init() argument
46 if (pthread_mutex_init(&barrier->mutex, 0) < 0) { in pthread_barrier_init()
49 if (pthread_cond_init(&barrier->cond, 0) < 0) { in pthread_barrier_init()
51 pthread_mutex_destroy(&barrier->mutex); in pthread_barrier_init()
56 barrier->limit = count; in pthread_barrier_init()
57 barrier->count = 0; in pthread_barrier_init()
58 barrier->phase = 0; in pthread_barrier_init()
64 pthread_barrier_destroy(pthread_barrier_t *barrier) { in pthread_barrier_destroy() argument
65 pthread_mutex_destroy(&barrier->mutex); in pthread_barrier_destroy()
66 pthread_cond_destroy(&barrier->cond); in pthread_barrier_destroy()
[all …]
|
| /third_party/libuv/test/ |
| D | test-barrier.c | 29 uv_barrier_t barrier; member
43 c->worker_barrier_wait_rval = uv_barrier_wait(&c->barrier); in worker()
53 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
57 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
60 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
75 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
78 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
81 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
95 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
98 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
[all …]
|
| /third_party/mesa3d/src/util/ |
| D | u_thread.h | 289 static inline void util_barrier_init(util_barrier *barrier, unsigned count) in util_barrier_init() argument
291 pthread_barrier_init(barrier, NULL, count); in util_barrier_init()
294 static inline void util_barrier_destroy(util_barrier *barrier) in util_barrier_destroy() argument
296 pthread_barrier_destroy(barrier); in util_barrier_destroy()
299 static inline void util_barrier_wait(util_barrier *barrier) in util_barrier_wait() argument
301 pthread_barrier_wait(barrier); in util_barrier_wait()
315 static inline void util_barrier_init(util_barrier *barrier, unsigned count) in util_barrier_init() argument
317 barrier->count = count; in util_barrier_init()
318 barrier->waiters = 0; in util_barrier_init()
319 barrier->sequence = 0; in util_barrier_init()
[all …]
|
| /third_party/boost/libs/fiber/doc/ |
| D | barrier.qbk | 11 A barrier is a concept also known as a __rendezvous__, it is a synchronization
12 point between multiple contexts of execution (fibers). The barrier is
14 barrier they must wait until all `n` fibers have arrived. Once the `n`-th
15 fiber has reached the barrier, all the waiting fibers can proceed, and the
16 barrier is reset.
18 The fact that the barrier automatically resets is significant. Consider a case
20 first of them has completed. You might be tempted to use a `barrier(2)` as the
22 barrier..wait] method, then calling `wait()` in the launching fiber to wait
30 # Fiber ["main] launches fibers A, B, C and D, then calls `barrier::wait()`.
31 # Fiber C finishes first and likewise calls `barrier::wait()`.
[all …]
|
| /third_party/boost/libs/thread/doc/ |
| D | barrier.qbk | 11 A barrier is a simple concept. Also known as a ['rendezvous], it is a synchronization point between…
12 configured for a particular number of threads (`n`), and as threads reach the barrier they must wai…
13 …rived. Once the `n`-th thread has reached the barrier, all the waiting threads can proceed, and th…
15 [section:barrier Class `barrier`]
17 #include <boost/thread/barrier.hpp>
19 class barrier
22 barrier(barrier const&) = delete;
23 barrier& operator=(barrier const&) = delete;
25 barrier(unsigned int count);
27 barrier(unsigned int count, F&&);
[all …]
|
| /third_party/boost/libs/log/test/run/ |
| D | util_once_block.cpp | 53 void once_block_flag_thread(boost::barrier& barrier) in once_block_flag_thread() argument
56 barrier.wait(); in once_block_flag_thread()
78 boost::barrier barrier(static_cast< unsigned int >(THREAD_COUNT)); in BOOST_AUTO_TEST_CASE()
84 group.create_thread(boost::bind(&once_block_flag_thread, boost::ref(barrier))); in BOOST_AUTO_TEST_CASE()
100 void once_block_thread(boost::barrier& barrier) in once_block_thread() argument
103 barrier.wait(); in once_block_thread()
127 boost::barrier barrier(static_cast< unsigned int >(THREAD_COUNT)); in BOOST_AUTO_TEST_CASE()
133 group.create_thread(boost::bind(&once_block_thread, boost::ref(barrier))); in BOOST_AUTO_TEST_CASE()
155 void once_block_with_exception_thread(boost::barrier& barrier) in once_block_with_exception_thread() argument
157 barrier.wait(); in once_block_with_exception_thread()
[all …]
|
| /third_party/libuv/src/win/ |
| 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->turnstile2); in uv_barrier_destroy()
[all …]
|
| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| D | deSpinBarrier.cpp | 165 SpinBarrier barrier(1); in singleThreadTest() local
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 (numThreads); in multiThreadTest() local
242 threads[ndx] = new TestThread(barrier, &sharedVar, numThreads, ndx); in multiThreadTest()
258 SpinBarrier barrier(3); in singleThreadRemoveTest() local
260 barrier.removeThread(mode); in singleThreadRemoveTest()
[all …]
|
| /third_party/glib/glib/tests/ |
| D | cond.c | 143 barrier_init (Barrier *barrier, in barrier_init() argument
146 g_mutex_init (&barrier->mutex); in barrier_init()
147 g_cond_init (&barrier->cond); in barrier_init()
148 barrier->limit = limit; in barrier_init()
149 barrier->count = limit; in barrier_init()
153 barrier_wait (Barrier *barrier) in barrier_wait() argument
157 g_mutex_lock (&barrier->mutex); in barrier_wait()
158 barrier->count--; in barrier_wait()
159 if (barrier->count == 0) in barrier_wait()
162 barrier->count = barrier->limit; in barrier_wait()
[all …]
|
| /third_party/boost/libs/fiber/examples/ |
| D | priority.cpp | 240 void barrier_fn( boost::fibers::barrier & barrier) { in barrier_fn() argument
244 barrier.wait(); in barrier_fn()
252 boost::fibers::barrier& barrier) { in change_fn() argument
259 barrier.wait(); in change_fn()
322 boost::fibers::barrier barrier( 3); in main() local
323 boost::fibers::fiber low( launch( [&barrier](){ barrier_fn( barrier); }, "low", 1) ); in main()
324 boost::fibers::fiber med( launch( [&barrier](){ barrier_fn( barrier); }, "medium", 2) ); in main()
325 boost::fibers::fiber hi( launch( [&barrier](){ barrier_fn( barrier); }, "high", 3) ); in main()
337 boost::fibers::barrier barrier( 3); in main() local
338 boost::fibers::fiber c( launch( [&barrier](){ barrier_fn( barrier); }, "c", 1) ); in main()
[all …]
|
| /third_party/vk-gl-cts/external/vulkancts/modules/vulkan/draw/ |
| D | vktDrawBufferObjectUtil.cpp | 79 vk::VkBufferMemoryBarrier barrier; in bufferBarrier() local
80 barrier.sType = vk::VK_STRUCTURE_TYPE_BUFFER_MEMORY_BARRIER; in bufferBarrier()
81 barrier.pNext = DE_NULL; in bufferBarrier()
82 barrier.srcAccessMask = srcAccessMask; in bufferBarrier()
83 barrier.dstAccessMask = dstAccessMask; in bufferBarrier()
84 barrier.srcQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier()
85 barrier.dstQueueFamilyIndex = VK_QUEUE_FAMILY_IGNORED; in bufferBarrier()
86 barrier.buffer = buffer; in bufferBarrier()
87 barrier.offset = 0; in bufferBarrier()
88 barrier.size = VK_WHOLE_SIZE; in bufferBarrier()
[all …]
|
| 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.image = object(); in readUsingBuffer()
[all …]
|
| /third_party/flutter/flutter/packages/flutter/test/widgets/ |
| D | modal_barrier_test.dart | 100 // Initially the barrier is not visible
101 expect(find.byKey(const ValueKey<String>('barrier')), findsNothing);
103 // Tapping on X routes to the barrier
108 // Tap on the barrier to dismiss it
109 await tester.tap(find.byKey(const ValueKey<String>('barrier')));
113 expect(find.byKey(const ValueKey<String>('barrier')), findsNothing,
114 reason: 'The route should have been dismissed by tapping the barrier.');
125 // Initially the barrier is not visible
126 expect(find.byKey(const ValueKey<String>('barrier')), findsNothing);
128 // Tapping on X routes to the barrier
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | win_fenced_block.hpp | 47 LONG barrier = 0; in win_fenced_block() local
48 ::InterlockedExchange(&barrier, 1); in win_fenced_block()
54 LONG barrier; in win_fenced_block()
55 __asm { xchg barrier, eax } in win_fenced_block()
67 LONG barrier = 0; in ~win_fenced_block() local
68 ::InterlockedExchange(&barrier, 1); in ~win_fenced_block()
74 LONG barrier; in ~win_fenced_block()
75 __asm { xchg barrier, eax } in ~win_fenced_block()
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | win_fenced_block.hpp | 47 LONG barrier = 0; in win_fenced_block() local
48 ::InterlockedExchange(&barrier, 1); in win_fenced_block()
54 LONG barrier; in win_fenced_block()
55 __asm { xchg barrier, eax } in win_fenced_block()
67 LONG barrier = 0; in ~win_fenced_block() local
68 ::InterlockedExchange(&barrier, 1); in ~win_fenced_block()
74 LONG barrier; in ~win_fenced_block()
75 __asm { xchg barrier, eax } in ~win_fenced_block()
|
| /third_party/skia/third_party/externals/swiftshader/tests/VulkanWrapper/ |
| D | Util.cpp | 76 vk::ImageMemoryBarrier barrier{}; in transitionImageLayout() local
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.subresourceRange.baseArrayLayer = 0; in transitionImageLayout()
[all …]
|
| /third_party/flutter/skia/third_party/externals/dawn/src/dawn_native/vulkan/ |
| D | NativeSwapChainImplVk.cpp | 130 VkImageMemoryBarrier barrier; in Configure() local
131 barrier.sType = VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER; in Configure()
132 barrier.pNext = nullptr; in Configure()
133 barrier.srcAccessMask = 0; in Configure()
134 barrier.dstAccessMask = 0; in Configure()
135 barrier.oldLayout = VK_IMAGE_LAYOUT_UNDEFINED; in Configure()
136 barrier.newLayout = VK_IMAGE_LAYOUT_PRESENT_SRC_KHR; in Configure()
137 barrier.srcQueueFamilyIndex = 0; in Configure()
138 barrier.dstQueueFamilyIndex = 0; in Configure()
139 barrier.image = image; in Configure()
[all …]
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_bounded_queue/ |
| D | multi_thread_pass.cpp | 28 boost::barrier& go_;
30 call_push(boost::sync_bounded_queue<int> &q, boost::barrier &go) : in call_push()
46 boost::barrier& go_;
47 boost::barrier& end_;
49 call_push_2(boost::sync_bounded_queue<int> &q, boost::barrier &go, boost::barrier &end) : in call_push_2()
66 boost::barrier& go_;
68 call_pull(boost::sync_bounded_queue<int> &q, boost::barrier &go) : in call_pull()
84 boost::barrier go(2); in test_concurrent_push_and_pull_on_empty_queue()
128 boost::barrier go(n); in test_concurrent_push_on_empty_queue()
166 boost::barrier go(n); in test_concurrent_push_on_full_queue()
[all …]
|
| /third_party/skia/third_party/externals/spirv-cross/reference/opt/shaders/comp/ |
| D | barriers.comp | 11 barrier();
13 barrier();
15 barrier();
17 barrier();
19 barrier();
20 barrier();
|
| /third_party/python/Include/ |
| D | dynamic_annotations.h | 292 #define _Py_ANNOTATE_BARRIER_INIT(barrier, count, reinitialization_allowed) \ argument
293 AnnotateBarrierInit(__FILE__, __LINE__, barrier, count, \
297 #define _Py_ANNOTATE_BARRIER_WAIT_BEFORE(barrier) \ argument
298 AnnotateBarrierWaitBefore(__FILE__, __LINE__, barrier)
301 #define _Py_ANNOTATE_BARRIER_WAIT_AFTER(barrier) \ argument
302 AnnotateBarrierWaitAfter(__FILE__, __LINE__, barrier)
305 #define _Py_ANNOTATE_BARRIER_DESTROY(barrier) \ argument
306 AnnotateBarrierDestroy(__FILE__, __LINE__, barrier)
332 #define _Py_ANNOTATE_BARRIER_INIT(barrier, count, reinitialization_allowed) /* */ argument
333 #define _Py_ANNOTATE_BARRIER_WAIT_BEFORE(barrier) /* empty */ argument
[all …]
|
| /third_party/boost/boost/fiber/ |
| D | barrier.hpp | 25 class BOOST_FIBERS_DECL barrier { class
34 explicit barrier( std::size_t);
36 barrier( barrier const&) = delete;
37 barrier & operator=( barrier const&) = delete;
|
| /third_party/skia/third_party/externals/opengl-registry/extensions/SGIX/ |
| D | GLX_SGIX_swap_barrier.txt | 29 swap group using that barrier will wait until every swap group using
30 that barrier is ready to swap (where readiness is defined below), after
31 which time all buffer swaps of all groups using that barrier will
45 int barrier);
60 <barrier>. Subsequent buffer swaps for that group will be subject to
61 this binding, until the group is unbound from <barrier>. If <barrier>
62 is zero, the group is unbound from its current barrier, if any.
96 barrier, all groups using that barrier are ready.
101 Buffer swaps for all groups using a barrier will take place concurrently
103 the barrier, if and only if the vertical retraces of the screens of all
[all …]
|
| /third_party/openGLES/extensions/SGIX/ |
| D | GLX_SGIX_swap_barrier.txt | 29 swap group using that barrier will wait until every swap group using
30 that barrier is ready to swap (where readiness is defined below), after
31 which time all buffer swaps of all groups using that barrier will
45 int barrier);
60 <barrier>. Subsequent buffer swaps for that group will be subject to
61 this binding, until the group is unbound from <barrier>. If <barrier>
62 is zero, the group is unbound from its current barrier, if any.
96 barrier, all groups using that barrier are ready.
101 Buffer swaps for all groups using a barrier will take place concurrently
103 the barrier, if and only if the vertical retraces of the screens of all
[all …]
|
| /third_party/boost/libs/atomic/test/ |
| D | wait_fuzz.cpp | 30 void thread_func(boost::barrier* barrier) in thread_func() argument
32 barrier->wait(); in thread_func()
48 boost::barrier barrier(thread_count + 1u); in main() local
52 boost::thread(boost::bind(&thread_func, &barrier)).swap(threads[i]); in main()
54 barrier.wait(); in main()
|
| /third_party/glslang/Test/ |
| D | 400.tesc | 15 barrier();
39 barrier(); // ERROR
41 barrier(); // ERROR
43 barrier();
46 barrier(); // ERROR
51 barrier(); // ERROR
54 a < 12 ? a : (barrier(), a); // ERROR
56 barrier();
61 barrier(); // ERROR
71 barrier(); // ERROR
|