Home
last modified time | relevance | path

Searched refs:wg (Results 1 – 25 of 82) sorted by relevance

1234

/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
Dwaitgroup_test.cpp20 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 …]
Dscheduler_test.cpp71 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 …]
Devent_test.cpp88 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 …]
Dblockingcall_test.cpp27 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()
Dscheduler_bench.cpp36 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()
Dwaitgroup_bench.cpp22 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()
Dpool_test.cpp49 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()
Dconditionvariable_test.cpp118 auto wg = marl::WaitGroup(100); in TEST_P() local
131 wg.done(); in TEST_P()
140 wg.wait(); in TEST_P()
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
Dblockingcall.h35 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()
Dparallelize.h28 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()
Ddag.h164 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 …]
/third_party/skia/third_party/externals/swiftshader/tests/regres/cov/
Doptimization.go29 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()
/third_party/nghttp2/src/
Dshrpx_worker.cc213 WeightGroup *wg, DownstreamAddr *addr) { in ensure_enqueue_addr() argument
215 if (!wg->pq.empty()) { in ensure_enqueue_addr()
216 auto &top = wg->pq.top(); in ensure_enqueue_addr()
224 wg->pq.push(DownstreamAddrEntry{addr, addr->seq, addr->cycle}); in ensure_enqueue_addr()
227 if (!wg->queued) { in ensure_enqueue_addr()
235 wg->cycle = cycle; in ensure_enqueue_addr()
236 wg->pending_penalty = 0; in ensure_enqueue_addr()
237 wgpq.push(WeightGroupEntry{wg, wg->seq, wg->cycle}); in ensure_enqueue_addr()
238 wg->queued = true; in ensure_enqueue_addr()
347 if (!addr.wg) { in replace_downstream_config()
[all …]
Dshrpx_client_handler.cc842 WeightGroup *wg) { in reschedule_wg() argument
843 auto penalty = MAX_DOWNSTREAM_ADDR_WEIGHT + wg->pending_penalty; in reschedule_wg()
844 wg->cycle += penalty / wg->weight; in reschedule_wg()
845 wg->pending_penalty = penalty % wg->weight; in reschedule_wg()
847 pq.push(WeightGroupEntry{wg, wg->seq, wg->cycle}); in reschedule_wg()
848 wg->queued = true; in reschedule_wg()
935 auto wg = wgpq.top().wg; in get_downstream_addr() local
937 wg->queued = false; in get_downstream_addr()
940 if (wg->pq.empty()) { in get_downstream_addr()
944 auto addr = wg->pq.top().addr; in get_downstream_addr()
[all …]
/third_party/skia/third_party/externals/tint/tools/src/cmd/run-parallel/
Dmain.go84 wg := sync.WaitGroup{}
85 wg.Add(numCPU)
88 defer wg.Done()
107 wg.Wait()
/third_party/skia/third_party/externals/spirv-cross/shaders-msl-no-opt/asm/comp/
Ddevice-constant-array-load-store.asm.comp30 %wg = OpVariable %arr_uvec2_2_ptr_workgroup Workgroup
61 %loaded_array_workgroup = OpLoad %arr_uvec2_2 %wg
66 OpStore %wg %loaded_array_2
74 OpStore %wg %loaded_array_const_2
Ddevice-constant-array-load-store.force-native-array.asm.comp30 %wg = OpVariable %arr_uvec2_2_ptr_workgroup Workgroup
61 %loaded_array_workgroup = OpLoad %arr_uvec2_2 %wg
66 OpStore %wg %loaded_array_2
74 OpStore %wg %loaded_array_const_2
/third_party/vk-gl-cts/external/vulkancts/data/vulkan/amber/compute/workgroup_memory_explicit_layout/
Dzero_ext_block.amber26 OpEntryPoint GLCompute %main "main" %index %push_constants %output_buffer %wg
35 OpDecorate %wg Aliased
58 %wg = OpVariable %wg_ptr Workgroup %null_buffer
79 OpCopyMemory %output_buffer %wg
Dzero_ext_block_with_offset.amber26 OpEntryPoint GLCompute %main "main" %index %push_constants %output_buffer %wg %offset_wg
37 OpDecorate %wg Aliased
63 %wg = OpVariable %wg_ptr Workgroup
88 OpCopyMemory %output_buffer %wg
Dzero_ext_other_block.amber26 OpEntryPoint GLCompute %main "main" %index %push_constants %output_buffer %wg %other_wg
35 OpDecorate %wg Aliased
59 %wg = OpVariable %wg_ptr Workgroup %null_buffer
Dcopy_memory_basic.amber25 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
/third_party/skia/tools/fm/fm_bot/
Dfm_bot.go196 wg := &sync.WaitGroup{}
220 wg.Add(1)
231 wg.Done()
289 wg.Add(1)
294 wg.Wait()
/third_party/skia/third_party/externals/swiftshader/src/System/
DSynchronization.hpp56 wg.add(); in add()
65 if(wg.done()) in done()
102 const marl::WaitGroup wg; member in sw::CountedEvent
/third_party/skia/third_party/externals/dawn/src/dawn_node/tools/src/cmd/run-cts/
Dmain.go458 wg := &sync.WaitGroup{}
460 wg.Add(1)
462 defer wg.Done()
472 r.streamResults(wg, results)
624 wg := &sync.WaitGroup{}
626 wg.Add(1)
628 defer wg.Done()
637 r.streamResults(wg, results)
646 func (r *runner) streamResults(wg *sync.WaitGroup, results chan result) {
652 wg.Wait()
/third_party/skia/third_party/externals/tint/tools/src/cmd/trim-includes/
Dmain.go243 wg := sync.WaitGroup{}
244 wg.Add(len(paths))
250 defer wg.Done()
261 wg.Wait()

1234