| /external/autotest/client/common_lib/ |
| base_barrier.py | 5 # default barrier port
25 Manages a listening socket for barrier.
27 Can be used to run multiple barrier instances with the same listening
67 class barrier(object): class in inherits:object
68 """Multi-machine barrier support.
70 Provides multi-machine barrier mechanism.
71 Execution stops until all members arrive at the barrier.
76 When a barrier is forming the master node (first in sort order) in the
78 they indicate the barrier they are joining and their identifier (their
82 successful then everyone has checked in at the barrier. We then tel
[all...] |
| barrier_unittest.disabled | 9 barrier = base_barrier variable
22 server = barrier.listen_server()
27 server = barrier.listen_server()
30 self.assertRaises(socket.error, barrier.listen_server)
34 server = barrier.listen_server()
52 b = barrier.barrier('127.0.0.1#', 'testtag', 100, 11921)
60 hostname = barrier.get_host_from_id('my_host')
63 hostname = barrier.get_host_from_id('my_host#')
66 self.assertRaises(error.BarrierError, barrier.get_host_from_id, '#my_host'
[all...] |
| base_barrier_unittest.py | 8 from autotest_lib.client.common_lib import error, barrier, base_barrier namespace
15 server = barrier.listen_server()
20 server = barrier.listen_server()
22 self.assertRaises(socket.error, barrier.listen_server)
25 server = barrier.listen_server()
41 b = barrier.barrier('127.0.0.1#', 'testtag', 100, 11921)
60 b = barrier.barrier('127.0.0.1#', 'update', 100)
66 b = barrier.barrier('127.0.0.1#', 'remain', 100
[all...] |
| /external/autotest/server/ |
| base_utils.py | 13 from autotest_lib.client.common_lib import barrier, utils namespace
335 sc_bar is a server barrier and s_bar, c_bar are the normal barriers
354 @param port_base: Port number that is used to derive the actual barrier
370 # The barrier code snippet is prepended into the conrol file
385 # Do the setup and wait at the server barrier
393 'b0 = job.barrier("%s", "sc_bar", %d, port=%d)'
400 # Wait at the server barrier to wait for instance=0
402 b0 = barrier.barrier("PARALLEL_MASTER", "sc_bar", sc_bar_timeout,
407 b1 = barrier.barrier(jobid, "s_bar", s_bar_timeout
[all...] |
| /external/deqp/framework/delibs/decpp/ |
| deAppendList.cpp | 59 SpinBarrier barrier; member in struct:de::__anon9954::SharedState
64 , barrier (numThreads)
84 m_shared->barrier.sync(SpinBarrier::WAIT_MODE_AUTO);
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| ThreadUtils.java | 132 public static boolean awaitUninterruptibly(CountDownLatch barrier, long timeoutMs) {
139 result = barrier.await(timeRemainingMs, TimeUnit.MILLISECONDS);
164 final CountDownLatch barrier = new CountDownLatch(1); local
172 barrier.countDown();
175 awaitUninterruptibly(barrier);
183 final CountDownLatch barrier = new CountDownLatch(1); local
187 barrier.countDown();
190 awaitUninterruptibly(barrier);
|
| VideoCapturerAndroid.java | 571 final CountDownLatch barrier = new CountDownLatch(1); local
575 barrier.countDown();
578 barrier.await();
|
| /external/jsilver/src/com/google/clearsilver/jsilver/syntax/ |
| DataCommandConsolidator.java | 63 * Data consolidation barrier: consolidates all data contents into the last data command in the
66 private void barrier() { method in class:DataCommandConsolidator
92 * Block exit: acts as a conditional barrier only to data contained within the block.
97 barrier(); method
109 barrier(); method
119 barrier(); method
124 barrier(); method
129 barrier(); method
134 barrier(); method
139 barrier(); method
210 barrier(); method
245 barrier(); method
250 barrier(); method
255 barrier(); method
260 barrier(); method
267 barrier(); method
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| DoubleAdderTest.java | 141 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); local
143 pool.execute(new AdderTask(a, barrier, incs));
144 barrier.await();
145 barrier.await();
154 final CyclicBarrier barrier; field in class:DoubleAdderTest.AdderTask
157 AdderTask(DoubleAdder adder, CyclicBarrier barrier, int incs) {
159 this.barrier = barrier;
165 barrier.await();
170 barrier.await()
[all...] |
| LongAdderTest.java | 164 CyclicBarrier barrier = new CyclicBarrier(nthreads + 1); local
166 pool.execute(new AdderTask(a, barrier, incs));
167 barrier.await();
168 barrier.await();
177 final CyclicBarrier barrier; field in class:LongAdderTest.AdderTask
180 AdderTask(LongAdder adder, CyclicBarrier barrier, int incs) {
182 this.barrier = barrier;
188 barrier.await();
193 barrier.await()
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/compute/ |
| vktComputeTestsUtil.cpp | 238 const VkBufferMemoryBarrier barrier = local
250 return barrier;
260 const VkImageMemoryBarrier barrier = local
273 return barrier;
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| lp_rast_priv.h | 129 pipe_barrier barrier; member in struct:lp_rasterizer
|
| /hardware/qcom/display/msm8084/liboverlay/pipes/ |
| overlay3DPipe.h | 373 ALOGE("S3DExtPipe close failed enable barrier");
431 uint32_t barrier=0; local
435 barrier = utils::BARRIER_LAND;
438 barrier = utils::BARRIER_PORT;
441 if(!utils::enableBarrier(barrier)) {
442 ALOGE("S3DPrimaryPipe setTransform failed to enable barrier");
|
| /hardware/qcom/display/msm8960/liboverlay/pipes/ |
| overlay3DPipe.h | 373 ALOGE("S3DExtPipe close failed enable barrier");
431 uint32_t barrier=0; local
435 barrier = utils::BARRIER_LAND;
438 barrier = utils::BARRIER_PORT;
441 if(!utils::enableBarrier(barrier)) {
442 ALOGE("S3DPrimaryPipe setTransform failed to enable barrier");
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/sysroot/usr/include/X11/extensions/ |
| Xfixes.h | 285 PointerBarrier barrier; member in struct:__anon38812
|
| /external/autotest/client/tests/tsc/src/ |
| checktsc.c | 133 #define barrier() __asm__ __volatile__("" : : : "memory") macro
143 barrier();
|
| /external/deqp/external/vulkancts/modules/vulkan/draw/ |
| vktDrawImageObjectUtil.cpp | 327 vk::VkImageMemoryBarrier barrier; local
328 barrier.sType = vk::VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER;
329 barrier.pNext = DE_NULL;
330 barrier.srcAccessMask = 0;
331 barrier.dstAccessMask = 0;
332 barrier.oldLayout = vk::VK_IMAGE_LAYOUT_UNDEFINED;
333 barrier.newLayout = vk::VK_IMAGE_LAYOUT_GENERAL;
334 barrier.srcQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
335 barrier.dstQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
336 barrier.image = object()
613 vk::VkImageMemoryBarrier barrier; local
734 vk::VkImageMemoryBarrier barrier; local
885 vk::VkImageMemoryBarrier barrier; local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/dynamic_state/ |
| vktDynamicStateImageObjectUtil.cpp | 327 vk::VkImageMemoryBarrier barrier; local
328 barrier.sType = vk::VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER;
329 barrier.pNext = DE_NULL;
330 barrier.srcAccessMask = 0;
331 barrier.dstAccessMask = 0;
332 barrier.oldLayout = vk::VK_IMAGE_LAYOUT_UNDEFINED;
333 barrier.newLayout = vk::VK_IMAGE_LAYOUT_GENERAL;
334 barrier.srcQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
335 barrier.dstQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
336 barrier.image = object()
613 vk::VkImageMemoryBarrier barrier; local
734 vk::VkImageMemoryBarrier barrier; local
887 vk::VkImageMemoryBarrier barrier; local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/image/ |
| vktImageTestsUtil.cpp | 358 const VkBufferMemoryBarrier barrier = local
370 return barrier;
380 const VkImageMemoryBarrier barrier = local
393 return barrier;
|
| /external/deqp/external/vulkancts/modules/vulkan/query_pool/ |
| vktQueryPoolImageObjectUtil.cpp | 304 vk::VkImageMemoryBarrier barrier; local
305 barrier.sType = vk::VK_STRUCTURE_TYPE_IMAGE_MEMORY_BARRIER;
306 barrier.pNext = DE_NULL;
307 barrier.srcAccessMask = 0;
308 barrier.dstAccessMask = 0;
309 barrier.oldLayout = vk::VK_IMAGE_LAYOUT_UNDEFINED;
310 barrier.newLayout = vk::VK_IMAGE_LAYOUT_GENERAL;
311 barrier.srcQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
312 barrier.dstQueueFamilyIndex = vk::VK_QUEUE_FAMILY_IGNORED;
313 barrier.image = object()
590 vk::VkImageMemoryBarrier barrier; local
711 vk::VkImageMemoryBarrier barrier; local
866 vk::VkImageMemoryBarrier barrier; local
[all...] |
| /external/google-breakpad/src/common/linux/tests/ |
| crash_generator.cc | 58 pthread_barrier_t* barrier; member in struct:__anon12233::ThreadData
85 int result = pthread_barrier_wait(thread_data->barrier);
87 perror("Failed to wait for sync barrier");
297 fprintf(stderr, "CrashGenerator: Failed to initialize thread barrier\n");
302 thread_data[i].barrier = &thread_barrier;
313 fprintf(stderr, "CrashGenerator: Failed to wait for thread barrier\n");
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| SerializingExecutorTest.java | 176 final CyclicBarrier barrier = new CyclicBarrier(2); local
191 barrier.await();
199 // the barrier task runs after the error task so we know that the error has been observed by
200 // SerializingExecutor by the time the barrier is satified
201 barrier.await(10, TimeUnit.SECONDS);
204 barrier.await(10, TimeUnit.SECONDS);
|
| /external/valgrind/drd/ |
| drd_clientobj.h | 123 Word count; // Participant count in a barrier wait.
124 Word pre_iteration; // pre barrier completion count modulo two.
125 Word post_iteration; // post barrier completion count modulo two.
126 Word pre_waiters_left; // number of waiters left for a complete barrier.
127 Word post_waiters_left; // number of waiters left for a complete barrier.
128 OSet* oset[2]; // Per-thread barrier information for the latest
129 // two barrier iterations.
152 struct barrier_info barrier; member in union:drd_clientobj
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/org/apache/harmony/kernel/dalvik/ |
| ThreadsTest.java | 52 CyclicBarrier barrier = new CyclicBarrier(2); local
53 Parker parker = new Parker(barrier, false, 500);
56 new Thread(new WaitAndUnpark(barrier, 1000, parkerThread));
67 CyclicBarrier barrier = new CyclicBarrier(2); local
68 Parker parker = new Parker(barrier, false, 1000);
71 new Thread(new WaitAndUnpark(barrier, 300, parkerThread));
82 CyclicBarrier barrier = new CyclicBarrier(1); local
83 Parker parker = new Parker(barrier, false, 1000);
94 CyclicBarrier barrier = new CyclicBarrier(2); local
95 Parker parker = new Parker(barrier, true, 500)
109 CyclicBarrier barrier = new CyclicBarrier(2); local
124 CyclicBarrier barrier = new CyclicBarrier(1); local
142 private final CyclicBarrier barrier; field in class:ThreadsTest.Parker
260 private final CyclicBarrier barrier; field in class:ThreadsTest.WaitAndUnpark
[all...] |
| /external/webrtc/talk/app/webrtc/androidtests/src/org/webrtc/ |
| VideoCapturerAndroidTestFixtures.java | 270 final CountDownLatch barrier = new CountDownLatch(1); local
275 barrier.countDown();
280 barrier.countDown();
284 barrier.await();
409 final CountDownLatch barrier = new CountDownLatch(1); local
412 barrier.countDown();
415 barrier.await();
|
