Home
last modified time | relevance | path

Searched refs:wg (Results 1 - 25 of 29) sorted by relevance

12

/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
H A Dwaitgroup_test.cpp20 marl::WaitGroup wg(2); // Should not require a scheduler. in TEST_F()
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()
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()
37 marl::schedule([&counter, wg] { in TEST_P()
39 wg in TEST_P()
[all...]
H A Dscheduler_test.cpp71 marl::WaitGroup wg(1); in TEST_P()
74 wg.wait(); in TEST_P()
83 wg.done(); // Ready, steady, go... in TEST_P()
99 marl::WaitGroup wg(1); in TEST_P()
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()
119 wg.done(); in TEST_P()
125 wg in TEST_P()
169 marl::WaitGroup wg; TEST_F() local
191 marl::WaitGroup wg; TEST_F() local
[all...]
H A Dblockingcall_test.cpp27 marl::WaitGroup wg(100); in TEST_P()
30 defer(wg.done()); in TEST_P()
39 wg.wait(); in TEST_P()
46 marl::WaitGroup wg(100); in TEST_P()
50 defer(wg.done()); in TEST_P()
60 wg.wait(); in TEST_P()
66 marl::WaitGroup wg(1); in TEST_P()
68 marl::blocking_call([=] { marl::schedule([=] { wg.done(); }); }); in TEST_P()
70 wg.wait(); in TEST_P()
H A Dscheduler_bench.cpp36 marl::WaitGroup wg; in BENCHMARK_DEFINE_F()
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()
58 wg.add(numTasks); in BENCHMARK_DEFINE_F()
62 wg.done(); in BENCHMARK_DEFINE_F()
65 wg.wait(); in BENCHMARK_DEFINE_F()
H A 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 in TEST_P() local
178 auto wg = marl::WaitGroup(1000); TEST_P() local
202 auto wg = marl::WaitGroup(100); TEST_P() local
[all...]
H A Dwaitgroup_bench.cpp22 marl::WaitGroup wg; in BENCHMARK_DEFINE_F()
23 wg.add(numTasks); in BENCHMARK_DEFINE_F()
25 marl::schedule([=] { wg.done(); }); in BENCHMARK_DEFINE_F()
27 wg.wait(); in BENCHMARK_DEFINE_F()
H A Dpool_test.cpp49 marl::WaitGroup wg(iterations); in TEST_P()
53 wg.done(); in TEST_P()
56 wg.wait(); in TEST_P()
69 marl::WaitGroup wg(iterations); in TEST_P()
73 wg.done(); in TEST_P()
76 wg.wait(); in TEST_P()
H A Dconditionvariable_test.cpp118 auto wg = marl::WaitGroup(100); in TEST_P() local
129 // Ensure the mutex unlock happens *before* the wg.done() call, in TEST_P()
131 wg.done(); in TEST_P()
140 wg.wait(); in TEST_P()
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
H A 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()
H A 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()
H A Ddag.h164 void DAGBase<T>::invoke(RunContext* ctx, NodeIndex nodeIdx, WaitGroup* wg) { in invoke() argument
182 wg->add(1); in invoke()
187 [=](WaitGroup wg) { in invoke()
188 invoke(ctx, toInvoke, &wg); in invoke()
189 wg.done(); in invoke()
191 *wg); in invoke()
197 invoke(ctx, toInvoke, wg); in invoke()
376 WaitGroup wg; in run() local
377 this->invoke(&ctx, this->RootIndex, &wg); in run()
378 wg in run()
399 WaitGroup wg; run() local
[all...]
/third_party/skia/third_party/externals/swiftshader/tests/regres/cov/
H A 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/
H A Dshrpx_worker.cc213 WeightGroup *wg, DownstreamAddr *addr) { in ensure_enqueue_addr()
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 in ensure_enqueue_addr()
210 ensure_enqueue_addr( std::priority_queue<WeightGroupEntry, std::vector<WeightGroupEntry>, WeightGroupEntryGreater> &wgpq, WeightGroup *wg, DownstreamAddr *addr) ensure_enqueue_addr() argument
381 auto &wg = wgs[addr.group]; replace_downstream_config() local
[all...]
H A Dshrpx_client_handler.cc842 WeightGroup *wg) { in reschedule_wg()
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 in reschedule_wg()
839 reschedule_wg( std::priority_queue<WeightGroupEntry, std::vector<WeightGroupEntry>, WeightGroupEntryGreater> &pq, WeightGroup *wg) reschedule_wg() argument
935 auto wg = wgpq.top().wg; get_downstream_addr() local
[all...]
/third_party/skia/third_party/externals/tint/tools/src/cmd/run-parallel/
H A Dmain.go84 wg := sync.WaitGroup{}
85 wg.Add(numCPU)
88 defer wg.Done()
107 wg.Wait()
/third_party/skia/third_party/externals/swiftshader/src/System/
H A DSynchronization.hpp56 wg.add(); in add()
65 if(wg.done()) in done()
102 const marl::WaitGroup wg; member in sw::CountedEvent
/third_party/skia/tools/fm/fm_bot/
H A 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/dawn/src/dawn_node/tools/src/cmd/run-cts/
H A 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)
642 // sequential order. Once the WaitGroup 'wg' is complete, streamResults() will
646 func (r *runner) streamResults(wg *syn
[all...]
/third_party/ltp/testcases/network/virt/
H A Dwireguard_lib.sh7 TST_NEEDS_CMDS="$TST_NEEDS_CMDS wg"
21 local pub_key0="$(wg genkey | tee wg0.key | wg pubkey)"
22 local pub_key1="$(wg genkey | tee wg1.key | wg pubkey)"
46 pub_key0="$(wg genkey | wg pubkey)"
51 ROD wg set ltp_v0 listen-port $port_loc private-key wg0.key
52 ROD wg set ltp_v0 peer $pub_key1 endpoint \
57 "wg se
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/marl/examples/
H A Dfractal.cpp165 marl::WaitGroup wg(imageHeight); in main()
174 defer(wg.done()); in main()
201 wg.wait(); in main()
/third_party/skia/third_party/externals/tint/tools/src/cmd/trim-includes/
H A Dmain.go243 wg := sync.WaitGroup{}
244 wg.Add(len(paths))
250 defer wg.Done()
261 wg.Wait()
/third_party/skia/third_party/externals/swiftshader/src/Vulkan/
H A DVkQueryPool.cpp42 wg.add(); in start()
47 if(wg.done()) in finish()
/third_party/skia/third_party/externals/swiftshader/src/Pipeline/
H A DComputeProgram.cpp242 marl::WaitGroup wg; in run() local
249 wg.add(1); in run()
251 defer(wg.done()); in run()
304 wg.wait(); in run()
/third_party/skia/third_party/externals/swiftshader/tests/regres/deqp/
H A Ddeqp.go152 wg := sync.WaitGroup{}
196 wg.Add(numParallelTests)
200 wg.Done()
259 wg.Wait() // Block until all the deqpTestRoutines have finished.
/third_party/ffmpeg/libavfilter/
H A Dvf_paletteuse.c631 int wa, wr, wg, wb; in get_next_color() local
682 wg = ranges.max[2] - ranges.min[2]; in get_next_color()
686 if (wa >= wr && wa >= wb && wa >= wg) longest = 0; in get_next_color()
687 if (wr >= wg && wr >= wb && wr >= wa) longest = 1; in get_next_color()
688 if (wg >= wr && wg >= wb && wg >= wa) longest = 2; in get_next_color()
689 if (wb >= wr && wb >= wg && wb >= wa) longest = 3; in get_next_color()
691 if (wr >= wg && wr >= wb) longest = 1; in get_next_color()
692 if (wg > in get_next_color()
[all...]

Completed in 12 milliseconds

12