/third_party/ffmpeg/libavcodec/ |
H A D | pthread_slice.c | 60 int thread_count; member 89 for (i = 0; i < c->thread_count; i++) { in ff_slice_thread_free() 104 if (!(avctx->active_thread_type&FF_THREAD_SLICE) || avctx->thread_count <= 1) in thread_execute() 137 int thread_count = avctx->thread_count; in ff_slice_thread_init() local 144 thread_count = avctx->thread_count = 1; in ff_slice_thread_init() 146 if (!thread_count) { in ff_slice_thread_init() 152 thread_count = avctx->thread_count in ff_slice_thread_init() 182 int err, i = 0, thread_count = avctx->thread_count; ff_slice_thread_init_progress() local [all...] |
H A D | frame_thread_encoder.c | 145 if( !avctx->thread_count in ff_frame_thread_encoder_init() 151 avctx->thread_count = 1; in ff_frame_thread_encoder_init() 153 if( avctx->thread_count > 1 in ff_frame_thread_encoder_init() 176 avctx->thread_count = 1; in ff_frame_thread_encoder_init() 180 if(!avctx->thread_count) { in ff_frame_thread_encoder_init() 181 avctx->thread_count = av_cpu_count(); in ff_frame_thread_encoder_init() 182 avctx->thread_count = FFMIN(avctx->thread_count, MAX_THREADS); in ff_frame_thread_encoder_init() 185 if(avctx->thread_count <= 1) in ff_frame_thread_encoder_init() 188 if(avctx->thread_count > MAX_THREAD in ff_frame_thread_encoder_init() [all...] |
H A D | v410dec.c | 57 int thread_count = av_clip(avctx->thread_count, 1, avctx->height/4); in v410_decode_slice() local 58 int slice_start = (avctx->height * jobnr) / thread_count; in v410_decode_slice() 59 int slice_end = (avctx->height * (jobnr+1)) / thread_count; in v410_decode_slice() 94 int thread_count = av_clip(avctx->thread_count, 1, avctx->height/4); in v410_decode_frame() local 110 avctx->execute2(avctx, v410_decode_slice, &td, NULL, thread_count); in v410_decode_frame()
|
H A D | pthread.c | 56 if (avctx->thread_count == 1) { in validate_thread_parameters() 64 avctx->thread_count = 1; in validate_thread_parameters() 68 if (avctx->thread_count > MAX_AUTO_THREADS) in validate_thread_parameters() 71 avctx->thread_count, MAX_AUTO_THREADS); in validate_thread_parameters() 89 ff_frame_thread_free(avctx, avctx->thread_count); in ff_thread_free()
|
H A D | pthread_frame.c | 551 if (fctx->next_decoding > (avctx->thread_count-1-(avctx->codec_id == AV_CODEC_ID_FFV1))) in ff_thread_decode_frame() 593 if (finished >= avctx->thread_count) finished = 0; in ff_thread_decode_frame() 598 if (fctx->next_decoding >= avctx->thread_count) fctx->next_decoding = 0; in ff_thread_decode_frame() 692 static void park_frame_worker_threads(FrameThreadContext *fctx, int thread_count) in park_frame_worker_threads() argument 698 for (i = 0; i < thread_count; i++) { in park_frame_worker_threads() 725 void ff_frame_thread_free(AVCodecContext *avctx, int thread_count) in ff_frame_thread_free() argument 731 park_frame_worker_threads(fctx, thread_count); in ff_frame_thread_free() 733 for (i = 0; i < thread_count; i++) { in ff_frame_thread_free() 867 int thread_count = avctx->thread_count; in ff_frame_thread_init() local [all...] |
H A D | v210dec.c | 47 s->thread_count = av_clip(avctx->thread_count, 1, avctx->height/4); in decode_init() 112 int slice_start = (avctx->height * jobnr) / s->thread_count; in v210_decode_slice() 113 int slice_end = (avctx->height * (jobnr+1)) / s->thread_count; in v210_decode_slice() 196 avctx->execute2(avctx, v210_decode_slice, &td, NULL, s->thread_count); in decode_frame()
|
H A D | v210dec.h | 30 int thread_count; member
|
H A D | pthread_internal.h | 32 void ff_frame_thread_free(AVCodecContext *avctx, int thread_count);
|
H A D | libuavs3d.c | 109 cdsc.frm_threads = avctx->thread_count > 0 ? avctx->thread_count : av_cpu_count(); in libuavs3d_init()
|
H A D | libaomdec.c | 47 .threads = FFMIN(avctx->thread_count ? avctx->thread_count : av_cpu_count(), 16) in aom_init()
|
H A D | imm5.c | 63 ctx->h264_avctx->thread_count = 1; in imm5_init() 76 ctx->hevc_avctx->thread_count = 1; in imm5_init()
|
/third_party/astc-encoder/Source/ |
H A D | astcenccli_platform_dependents.cpp | 178 int thread_count; member 199 ltd->func(ltd->thread_count, ltd->thread_id, ltd->payload); in launch_threads_helper() 206 int thread_count, in launch_threads() 211 if (thread_count <= 1) in launch_threads() 218 launch_desc *thread_descs = new launch_desc[thread_count]; in launch_threads() 221 for (int i = 0; i < thread_count; i++) in launch_threads() 223 thread_descs[actual_thread_count].thread_count = thread_count; in launch_threads() 249 // If we did not create thread_count threads then emit a warning in launch_threads() 250 if (actual_thread_count != thread_count) in launch_threads() 204 launch_threads( const char* operation, int thread_count, void (*func)(int, int, void*), void *payload ) launch_threads() argument [all...] |
H A D | astcenccli_internal.h | 69 unsigned int thread_count; member 389 * @param thread_count The number of threads to spawn. 391 * void (int thread_count, int thread_id, void* payload) 396 int thread_count,
|
H A D | astcenc_entry.cpp | 659 unsigned int thread_count, in astcenc_context_alloc() 671 if (thread_count == 0) in astcenc_context_alloc() 678 if (thread_count != 1) in astcenc_context_alloc() 693 ctx->thread_count = thread_count; in astcenc_context_alloc() 750 size_t worksize = sizeof(compression_working_buffers) * thread_count; in astcenc_context_alloc() 1096 if (thread_index >= ctx->thread_count) in astcenc_compress_image() 1117 if (ctx->thread_count == 1) in astcenc_compress_image() 1199 if (thread_index >= ctx->thread_count) in astcenc_decompress_image() 1236 if (ctx->thread_count in astcenc_decompress_image() 657 astcenc_context_alloc( const astcenc_config* configp, unsigned int thread_count, astcenc_context** context ) astcenc_context_alloc() argument [all...] |
H A D | astcenccli_toplevel.cpp | 228 * @param thread_count The number of threads in the worker pool. 233 int thread_count, in compression_workload_runner() 237 (void)thread_count; in compression_workload_runner() 259 * @param thread_count The number of threads in the worker pool. 264 int thread_count, in decompression_workload_runner() 268 (void)thread_count; in decompression_workload_runner() 1096 cli_config.thread_count = atoi(argv[argidx - 1]); in edit_astcenc_config() 1198 if (cli_config.thread_count <= 0) in edit_astcenc_config() 1200 cli_config.thread_count = get_cpu_count(); in edit_astcenc_config() 1205 cli_config.thread_count in edit_astcenc_config() 232 compression_workload_runner( int thread_count, int thread_id, void* payload ) compression_workload_runner() argument 263 decompression_workload_runner( int thread_count, int thread_id, void* payload ) decompression_workload_runner() argument [all...] |
/third_party/gn/src/util/ |
H A D | worker_pool.cc | 15 std::string thread_count = in GetThreadCount() local 21 if (!thread_count.empty() && base::StringToInt(thread_count, &result) && in GetThreadCount() 48 WorkerPool::WorkerPool(size_t thread_count) : should_stop_processing_(false) { in WorkerPool() argument 49 threads_.reserve(thread_count); in WorkerPool() 50 for (size_t i = 0; i < thread_count; ++i) in WorkerPool()
|
H A D | worker_pool.h | 19 WorkerPool(size_t thread_count);
|
/third_party/libunwind/libunwind/src/coredump/ |
H A D | _UCD_get_threadinfo_prstatus.c | 43 size_t *thread_count = (size_t *)arg; in _count_thread_notes() local 46 ++*thread_count; in _count_thread_notes() 96 size_t thread_count = 0; in _UCD_get_threadinfo() local 102 _UCD_elf_visit_notes(segment, segment_size, _count_thread_notes, &thread_count); in _UCD_get_threadinfo() 103 Debug(2, "found %zu threads\n", thread_count); in _UCD_get_threadinfo() 105 size_t new_size = sizeof(struct PRSTATUS_STRUCT) * (ui->n_threads + thread_count); in _UCD_get_threadinfo()
|
/third_party/vulkan-loader/tests/live_verification/ |
H A D | macos_static_loader_build.cpp | 75 uint32_t thread_count = 4; in main() local 78 for (uint32_t i = 0; i < thread_count; i++) { in main()
|
/third_party/astc-encoder/Utils/Example/ |
H A D | astc_api_example.cpp | 55 static const unsigned int thread_count = 1; in main() local 100 status = astcenc_context_alloc(&config, thread_count, &context); in main()
|
/third_party/benchmark/src/ |
H A D | benchmark_api_internal.cc | 13 int thread_count) in BenchmarkInstance() 30 threads_(thread_count) { in BenchmarkInstance() 10 BenchmarkInstance(Benchmark* benchmark, int family_idx, int per_family_instance_idx, const std::vector<int64_t>& args, int thread_count) BenchmarkInstance() argument
|
/third_party/node/src/ |
H A D | node_api.cc | 215 thread_count(thread_count_), in ThreadSafeFunction() 249 if (thread_count == 0) { in Push() 252 thread_count--; in Push() 269 thread_count++; in Acquire() 277 if (thread_count == 0) { in Release() 281 thread_count--; in Release() 283 if (thread_count == 0 || mode == jsvm_tsfn_abort) { in Release() 394 if (thread_count == 0) { in DispatchOne() 512 size_t thread_count; member in v8impl::__anon15407::ThreadSafeFunction
|
/third_party/googletest/googletest/src/ |
H A D | gtest-death-test.cc | 241 // caller not to pass a thread_count of 1. 242 static std::string DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument 246 if (thread_count == 0) { in DeathTestThreadWarning() 249 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning() local 1106 const size_t thread_count = GetThreadCount(); in AssumeRole() local 1107 if (thread_count != 1) { in AssumeRole() 1108 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
|
/third_party/node/deps/googletest/src/ |
H A D | gtest-death-test.cc | 245 // caller not to pass a thread_count of 1. 246 static std::string DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument 250 if (thread_count == 0) { in DeathTestThreadWarning() 253 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning() local 1100 const size_t thread_count = GetThreadCount(); in AssumeRole() local 1101 if (thread_count != 1) { in AssumeRole() 1102 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
|
/third_party/mesa3d/src/gtest/src/ |
H A D | gtest-death-test.cc | 239 // caller not to pass a thread_count of 1. 240 static std::string DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument 244 if (thread_count == 0) { in DeathTestThreadWarning() 247 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning() local 1120 const size_t thread_count = GetThreadCount(); in AssumeRole() local 1121 if (thread_count != 1) { in AssumeRole() 1122 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
|