Home
last modified time | relevance | path

Searched refs:max_concurrency (Results 1 – 9 of 9) sorted by relevance

/aosp_15_r20/external/cronet/base/task/thread_pool/
H A Djob_task_source.cc185 size_t max_concurrency = GetMaxConcurrency(state.worker_count() - 1); in WaitForParticipationOpportunity() local
191 while (!((state.worker_count() <= max_concurrency && !state.is_canceled()) || in WaitForParticipationOpportunity()
204 max_concurrency = GetMaxConcurrency(state.worker_count() - 1); in WaitForParticipationOpportunity()
211 if (state.worker_count() <= max_concurrency && !state.is_canceled()) { in WaitForParticipationOpportunity()
217 DCHECK(state.is_canceled() || max_concurrency == 0U); in WaitForParticipationOpportunity()
237 const size_t max_concurrency = in WillRunTask() local
239 if (state_before_add.worker_count() < max_concurrency) { in WillRunTask()
244 if (worker_count_before_add >= max_concurrency) { in WillRunTask()
248 DCHECK_LT(worker_count_before_add, max_concurrency); in WillRunTask()
249 return max_concurrency == worker_count_before_add + 1 in WillRunTask()
[all …]
H A Djob_task_source_unittest.cc266 size_t max_concurrency = 1; in TEST_F() local
271 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()
273 return max_concurrency + worker_count; in TEST_F()
287 EXPECT_EQ(0U, max_concurrency); in TEST_F()
293 size_t max_concurrency = 1; in TEST_F() local
298 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()
300 return max_concurrency + worker_count; in TEST_F()
308 EXPECT_EQ(0U, max_concurrency); in TEST_F()
H A Dthread_group_unittest.cc756 std::atomic_size_t max_concurrency(1); in TEST_F() local
761 [&](size_t /*worker_count*/) -> size_t { return max_concurrency; }), in TEST_F()
770 max_concurrency = 0; in TEST_F()
/aosp_15_r20/external/executorch/backends/vulkan/tools/gpuinfo/include/
H A Dtextures.h95 auto max_concurrency = nthread - 1; in tex_cacheline_concurr() local
97 << max_concurrency * TEXEL_SIZE << std::endl; in tex_cacheline_concurr()
/aosp_15_r20/external/cronet/third_party/libc++/src/include/__pstl/internal/
H A Dparallel_backend_tbb.h365 _Index __p = tbb::this_task_arena::max_concurrency(); in __parallel_strict_scan()
/aosp_15_r20/frameworks/base/core/proto/android/server/
H A Djobscheduler.proto866 optional int32 max_concurrency = 5; field
/aosp_15_r20/out/soong/.intermediates/frameworks/base/libplatformprotos/android_arm64_armv8-2a_cortex-a55_static/gen/proto/frameworks/base/core/proto/android/server/
Djobscheduler.pb.h11865 ::int32_t max_concurrency() const; in Swap()
27570 inline ::int32_t DataSetProto::max_concurrency() const { in max_concurrency() function
/aosp_15_r20/out/soong/.intermediates/frameworks/base/libplatformprotos/linux_glibc_x86_64_static/gen/proto/frameworks/base/core/proto/android/server/
Djobscheduler.pb.h12804 ::int32_t max_concurrency() const; in Swap()
28795 inline ::int32_t DataSetProto::max_concurrency() const { in max_concurrency() function
/aosp_15_r20/out/soong/.intermediates/frameworks/base/libplatformprotos/android_arm64_armv8-2a_cortex-a55_static_cfi/gen/proto/frameworks/base/core/proto/android/server/
Djobscheduler.pb.h11865 ::int32_t max_concurrency() const; in Swap()
27570 inline ::int32_t DataSetProto::max_concurrency() const { in max_concurrency() function