| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/base/ |
| H A D | prioritized_dispatcher_unittest.cc | 218 ASSERT_TRUE(job_b->running()); in TEST_F()
219 job_b->Finish(); in TEST_F()
244 ASSERT_TRUE(job_b->running()); in TEST_F()
245 job_b->Finish(); in TEST_F()
272 job_b->Finish(); in TEST_F()
351 job_b->Finish(); in TEST_F()
370 job_b->Cancel(); in TEST_F()
429 job_b->Finish(); in TEST_F()
467 job_b->Finish(); in TEST_F()
502 job_b->Cancel(); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/base/ |
| H A D | prioritized_dispatcher_unittest.cc | 218 ASSERT_TRUE(job_b->running()); in TEST_F()
219 job_b->Finish(); in TEST_F()
244 ASSERT_TRUE(job_b->running()); in TEST_F()
245 job_b->Finish(); in TEST_F()
272 job_b->Finish(); in TEST_F()
351 job_b->Finish(); in TEST_F()
370 job_b->Cancel(); in TEST_F()
429 job_b->Finish(); in TEST_F()
467 job_b->Finish(); in TEST_F()
502 job_b->Cancel(); in TEST_F()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/rust/rayon-core/src/join/ |
| H A D | mod.rs | 122 let job_b = StackJob::new(|migrated| oper_b(FnContext::new(migrated)), in join_context() localVariable
124 let job_b_ref = job_b.as_job_ref(); in join_context()
131 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
139 while !job_b.latch.probe() { in join_context()
146 let result_b = job_b.run_inline(injected); in join_context()
156 worker_thread.wait_until(&job_b.latch); in join_context()
157 debug_assert!(job_b.latch.probe()); in join_context()
162 return (result_a, job_b.into_result()); in join_context()
|
| /dports/shells/ion/ion-a8872014dbce730ccd00aaa722397dc394a52bf4/cargo-crates/rayon-core-1.5.0/src/join/ |
| H A D | mod.rs | 126 let job_b = StackJob::new( in join_context() localVariable
130 let job_b_ref = job_b.as_job_ref(); in join_context()
137 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
145 while !job_b.latch.probe() { in join_context()
154 let result_b = job_b.run_inline(injected); in join_context()
168 worker_thread.wait_until(&job_b.latch); in join_context()
169 debug_assert!(job_b.latch.probe()); in join_context()
174 (result_a, job_b.into_result()) in join_context()
|
| /dports/games/dose-response/dose-response-179c326/cargo-crates/rayon-core-1.4.1/src/join/ |
| H A D | mod.rs | 122 let job_b = StackJob::new(|migrated| oper_b(FnContext::new(migrated)), in join_context() localVariable
124 let job_b_ref = job_b.as_job_ref(); in join_context()
131 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
139 while !job_b.latch.probe() { in join_context()
146 let result_b = job_b.run_inline(injected); in join_context()
156 worker_thread.wait_until(&job_b.latch); in join_context()
157 debug_assert!(job_b.latch.probe()); in join_context()
162 return (result_a, job_b.into_result()); in join_context()
|
| /dports/devel/stylua/StyLua-0.11.0/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/multimedia/librav1e/rav1e-0.5.1/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/multimedia/rav1e/rav1e-0.5.1/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/misc/broot/broot-1.7.0/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/games/jaggedalliance2/ja2-stracciatella-0.18.0/cargo-crates/rayon-core-1.8.0/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/devel/rust-analyzer/rust-analyzer-2021-12-20/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/devel/grcov/grcov-0.8.2/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/net-im/zkgroup/zkgroup-0.7.4/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/graphics/librsvg2-rust/librsvg-2.52.8/vendor/rayon-core/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/sysutils/czkawka/czkawka-3.3.1/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/devel/tokei/tokei-12.1.2/cargo-crates/rayon-core-1.9.0/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/rayon-core/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/graphics/viu/viu-1.1/cargo-crates/rayon-core-1.8.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/rayon-core-1.8.0/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/rayon-core/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/rayon-core-1.9.0/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/devel/texlab/texlab-3.3.0/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|
| /dports/misc/xplr/xplr-0.17.0/cargo-crates/rayon-core-1.9.1/src/join/ |
| H A D | mod.rs | 136 let job_b = StackJob::new(call_b(oper_b), SpinLatch::new(worker_thread)); in join_context() localVariable
137 let job_b_ref = job_b.as_job_ref(); in join_context()
144 Err(err) => join_recover_from_panic(worker_thread, &job_b.latch, err), in join_context()
152 while !job_b.latch.probe() { in join_context()
158 let result_b = job_b.run_inline(injected); in join_context()
166 worker_thread.wait_until(&job_b.latch); in join_context()
167 debug_assert!(job_b.latch.probe()); in join_context()
172 (result_a, job_b.into_result()) in join_context()
|