| /external/swiftshader/third_party/marl/src/ |
| D | waitgroup_test.cpp | 20 marl::WaitGroup wg(2); // Should not require a scheduler. in TEST_F() local
21 wg.done(); in TEST_F()
22 wg.done(); in TEST_F()
27 marl::WaitGroup wg(2); // Should not require a scheduler. in TEST_F() local
28 wg.done(); in TEST_F()
29 wg.done(); in TEST_F()
30 EXPECT_DEATH(wg.done(), "done\\(\\) called too many times"); in TEST_F()
35 marl::WaitGroup wg(1); in TEST_P() local
37 marl::schedule([&counter, wg] { in TEST_P()
39 wg.done(); in TEST_P()
[all …]
|
| D | scheduler_test.cpp | 71 marl::WaitGroup wg(1); in TEST_P() local
74 wg.wait(); in TEST_P()
83 wg.done(); // Ready, steady, go... in TEST_P()
99 marl::WaitGroup wg(1); in TEST_P() local
101 [wg, &got](std::string s, int i, bool b) { in TEST_P()
104 wg.done(); in TEST_P()
107 wg.wait(); in TEST_P()
113 marl::WaitGroup wg(1000); in TEST_P() local
119 wg.done(); in TEST_P()
125 wg.wait(); in TEST_P()
[all …]
|
| D | blockingcall_test.cpp | 27 marl::WaitGroup wg(100); in TEST_P() local
30 defer(wg.done()); in TEST_P()
39 wg.wait(); in TEST_P()
46 marl::WaitGroup wg(100); in TEST_P() local
50 defer(wg.done()); in TEST_P()
60 wg.wait(); in TEST_P()
66 marl::WaitGroup wg(1); in TEST_P() local
68 marl::blocking_call([=] { marl::schedule([=] { wg.done(); }); }); in TEST_P()
70 wg.wait(); in TEST_P()
|
| D | event_test.cpp | 88 auto wg = marl::WaitGroup(3); in TEST_P() local
93 wg.done(); in TEST_P()
97 wg.wait(); in TEST_P()
132 auto wg = marl::WaitGroup(1000); in TEST_P() local
135 defer(wg.done()); in TEST_P()
141 wg.wait(); in TEST_P()
146 auto wg = marl::WaitGroup(1000); in TEST_P() local
149 defer(wg.done()); in TEST_P()
158 wg.wait(); in TEST_P()
163 auto wg = marl::WaitGroup(1000); in TEST_P() local
[all …]
|
| D | scheduler_bench.cpp | 36 marl::WaitGroup wg; in BENCHMARK_DEFINE_F() local
37 wg.add(numTasks); in BENCHMARK_DEFINE_F()
41 wg.done(); in BENCHMARK_DEFINE_F()
44 wg.wait(); in BENCHMARK_DEFINE_F()
57 marl::WaitGroup wg; in BENCHMARK_DEFINE_F() local
58 wg.add(numTasks); in BENCHMARK_DEFINE_F()
62 wg.done(); in BENCHMARK_DEFINE_F()
65 wg.wait(); in BENCHMARK_DEFINE_F()
|
| D | waitgroup_bench.cpp | 22 marl::WaitGroup wg; in BENCHMARK_DEFINE_F() local
23 wg.add(numTasks); in BENCHMARK_DEFINE_F()
25 marl::schedule([=] { wg.done(); }); in BENCHMARK_DEFINE_F()
27 wg.wait(); in BENCHMARK_DEFINE_F()
|
| D | pool_test.cpp | 49 marl::WaitGroup wg(iterations); in TEST_P() local
53 wg.done(); in TEST_P()
56 wg.wait(); in TEST_P()
69 marl::WaitGroup wg(iterations); in TEST_P() local
73 wg.done(); in TEST_P()
76 wg.wait(); in TEST_P()
|
| D | conditionvariable_test.cpp | 118 auto wg = marl::WaitGroup(100); in TEST_P() local
131 wg.done(); in TEST_P()
140 wg.wait(); in TEST_P()
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/gl/workgroups/ |
| D | calculator.cc | 31 void MaybeShrinkWorkgroup(const GpuInfo& gpu_info, uint3* wg) { in MaybeShrinkWorkgroup() argument
32 while (wg->x > gpu_info.GetMaxWorkGroupSizeForX()) { in MaybeShrinkWorkgroup()
33 wg->x /= 2; in MaybeShrinkWorkgroup()
36 while (wg->y > gpu_info.GetMaxWorkGroupSizeForY()) { in MaybeShrinkWorkgroup()
37 wg->y /= 2; in MaybeShrinkWorkgroup()
40 while (wg->z > gpu_info.GetMaxWorkGroupSizeForZ()) { in MaybeShrinkWorkgroup()
41 wg->z /= 2; in MaybeShrinkWorkgroup()
51 while (CalculateProduct(*wg) > gpu_info.GetMaxWorkGroupTotalSize()) { in MaybeShrinkWorkgroup()
52 unsigned int* max = &wg->x; in MaybeShrinkWorkgroup()
53 if (wg->y > *max) max = &wg->y; in MaybeShrinkWorkgroup()
[all …]
|
| /external/rust/crates/crossbeam-utils/tests/ |
| D | wait_group.rs | 11 let wg = WaitGroup::new(); in wait() localVariable
15 let wg = wg.clone(); in wait() localVariable
19 wg.wait(); in wait()
30 wg.wait(); in wait()
40 let wg = WaitGroup::new(); in wait_and_drop() localVariable
44 let wg = wg.clone(); in wait_and_drop() localVariable
50 drop(wg); in wait_and_drop()
58 wg.wait(); in wait_and_drop()
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | blockingcall.h | 35 WaitGroup wg(1); in call()
38 [&, wg](Args&&... args) { in call()
46 wg.done(); in call()
49 wg.wait(); in call()
60 WaitGroup wg(1); in call()
63 [&, wg](Args&&... args) { in call()
71 wg.done(); in call()
74 wg.wait(); in call()
|
| D | parallelize.h | 28 MARL_NO_EXPORT inline void parallelizeChain(WaitGroup& wg, F&& f, L&&... l) { in parallelizeChain() argument
31 wg.done(); in parallelizeChain()
33 parallelizeChain(wg, std::forward<L>(l)...); in parallelizeChain()
53 WaitGroup wg(sizeof...(FN)); in parallelize()
55 detail::parallelizeChain(wg, std::forward<FN>(fn)...); in parallelize()
58 wg.wait(); in parallelize()
|
| D | dag.h | 164 void DAGBase<T>::invoke(RunContext* ctx, NodeIndex nodeIdx, WaitGroup* wg) {
182 wg->add(1);
187 [=](WaitGroup wg) {
188 invoke(ctx, toInvoke, &wg);
189 wg.done();
191 *wg);
197 invoke(ctx, toInvoke, wg);
376 WaitGroup wg;
377 this->invoke(&ctx, this->RootIndex, &wg);
378 wg.wait();
[all …]
|
| /external/swiftshader/tests/regres/cov/ |
| D | optimization.go | 29 wg := sync.WaitGroup{}
30 wg.Add(len(t.files))
34 defer wg.Done()
42 wg.Wait()
141 wg := sync.WaitGroup{}
142 wg.Add(len(tc.Children))
146 defer wg.Done()
150 wg.Wait()
|
| /external/boringssl/src/util/fipstools/acvp/acvptool/test/ |
| D | check_expected.go | 92 var wg sync.WaitGroup
94 wg.Add(1)
95 go worker(&wg, work, &numFailed)
112 wg.Wait()
123 func worker(wg *sync.WaitGroup, work <-chan invocation, numFailed *uint32) {
124 defer wg.Done()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | golang.rs | 1146 let wg = WaitGroup::new(); in test_self_select() localVariable
1147 wg.add(2); in test_self_select()
1152 go!(wg, p, c, { in test_self_select()
1153 defer! { wg.done() } in test_self_select()
1177 wg.wait(); in test_self_select()
1198 let wg = WaitGroup::new(); in test_select_stress() localVariable
1199 wg.add(10); in test_select_stress()
1202 go!(k, c, wg, { in test_select_stress()
1206 wg.done(); in test_select_stress()
1208 go!(k, c, wg, { in test_select_stress()
[all …]
|
| /external/llvm-project/compiler-rt/test/tsan/ |
| D | java_finalizer2.cpp | 14 uint64_t wg; member
23 __atomic_fetch_add(&heap->wg, 1, __ATOMIC_RELEASE); in Thread1()
43 __atomic_fetch_add(&heap->wg, 1, __ATOMIC_RELEASE); in Thread3()
72 while (__atomic_load_n(&heap->wg, __ATOMIC_ACQUIRE) != 2) in main()
|
| /external/tensorflow/tensorflow/go/ |
| D | session.go | 46 wg sync.WaitGroup member
140 s.wg.Add(1)
142 defer s.wg.Done()
194 s.wg.Add(1)
196 defer s.wg.Done()
251 s.wg.Add(1)
253 defer s.wg.Done()
275 s.wg.Wait()
|
| /external/swiftshader/src/System/ |
| D | Synchronization.hpp | 56 wg.add(); in add()
65 if(wg.done()) in done()
102 const marl::WaitGroup wg; member in sw::CountedEvent
|
| /external/boringssl/src/util/fipstools/cavp/ |
| D | run_cavp.go | 372 func worker(wg *sync.WaitGroup, work <-chan testInstance) {
373 defer wg.Done()
418 var wg sync.WaitGroup
426 wg.Add(1)
427 go worker(&wg, work)
437 wg.Wait()
|
| /external/skia/tools/fm/fm_bot/ |
| D | fm_bot.go | 196 wg := &sync.WaitGroup{}
220 wg.Add(1)
231 wg.Done()
289 wg.Add(1)
294 wg.Wait()
|
| /external/deqp/external/vulkancts/data/vulkan/amber/compute/workgroup_memory_explicit_layout/ |
| D | copy_memory_basic.amber | 25 OpEntryPoint GLCompute %main "main" %input_buffer_0 %input_buffer_1 %output_buffer %wg %half_wg_0 %…
42 OpDecorate %wg Aliased
71 %wg = OpVariable %wg_ptr Workgroup
|
| /external/skqp/tools/skqp/ |
| D | make_gmkb.go | 180 var wg sync.WaitGroup
190 wg.Add(1)
192 defer wg.Done()
203 wg.Wait()
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/common/task/ |
| D | work_group_picking.cc | 322 for (const auto& wg : wgs) { in GetFirstSuitableWorkGroup() local
323 const int wg_size = wg.x * wg.y * wg.z; in GetFirstSuitableWorkGroup()
325 return wg; in GetFirstSuitableWorkGroup()
|
| /external/swiftshader/third_party/marl/examples/ |
| D | fractal.cpp | 163 marl::WaitGroup wg(imageHeight); in main() local
172 defer(wg.done()); in main()
199 wg.wait(); in main()
|