| /third_party/glib/glib/ |
| D | gthreadpool.c | 94 gint max_threads; member
252 if (pool->max_threads != -1 && pool->num_threads > (guint) pool->max_threads) in g_thread_pool_wait_for_new_task()
435 if (pool->max_threads != -1 && pool->num_threads >= (guint) pool->max_threads) in g_thread_pool_start_thread()
558 gint max_threads, in g_thread_pool_new() argument
566 g_return_val_if_fail (!exclusive || max_threads != -1, NULL); in g_thread_pool_new()
567 g_return_val_if_fail (max_threads >= -1, NULL); in g_thread_pool_new()
576 retval->max_threads = max_threads; in g_thread_pool_new()
629 while (retval->num_threads < (guint) retval->max_threads) in g_thread_pool_new()
736 gint max_threads, in g_thread_pool_set_max_threads() argument
747 g_return_val_if_fail (!real->pool.exclusive || max_threads != -1, FALSE); in g_thread_pool_set_max_threads()
[all …]
|
| D | gthreadpool.h | 51 gint max_threads,
74 gint max_threads,
82 void g_thread_pool_set_max_unused_threads (gint max_threads);
|
| /third_party/glib/gio/ |
| D | gthreadedsocketservice.c | 56 int max_threads; member
100 if (data->service->priv->job_count-- == data->service->priv->max_threads) in g_threaded_socket_service_func()
124 if (++threaded->priv->job_count == threaded->priv->max_threads) in g_threaded_socket_service_incoming()
143 service->priv->max_threads = 10; in g_threaded_socket_service_init()
154 service->priv->max_threads, in g_threaded_socket_service_constructed()
184 g_value_set_int (value, service->priv->max_threads); in g_threaded_socket_service_get_property()
203 service->priv->max_threads = g_value_get_int (value); in g_threaded_socket_service_set_property()
272 g_threaded_socket_service_new (int max_threads) in g_threaded_socket_service_new() argument
275 "max-threads", max_threads, in g_threaded_socket_service_new()
|
| D | gthreadedsocketservice.h | 77 GSocketService * g_threaded_socket_service_new (int max_threads);
|
| /third_party/gstreamer/gstplugins_bad/gst/dvbsubenc/libimagequant/ |
| D | viter.c | 20 viter_init (const colormap * map, const unsigned int max_threads, in viter_init() argument
25 map->colors) * max_threads); in viter_init()
42 viter_finalize (colormap * map, const unsigned int max_threads, in viter_finalize() argument
49 for (unsigned int t = 0; t < max_threads; t++) { in viter_finalize()
75 const unsigned int max_threads = omp_get_max_threads (); in viter_do_iteration() local
80 map->colors) * max_threads); in viter_do_iteration()
82 viter_init (map, max_threads, average_color); in viter_do_iteration()
108 viter_finalize (map, max_threads, average_color); in viter_do_iteration()
|
| D | viter.h | 14 LIQ_PRIVATE void viter_init(const colormap *map, const unsigned int max_threads, viter_state state[…
16 LIQ_PRIVATE void viter_finalize(colormap *map, const unsigned int max_threads, const viter_state st…
|
| /third_party/gstreamer/gstreamer/gst/ |
| D | gsttaskpool.c | 358 guint max_threads; member
450 shared_pool->priv->max_threads, FALSE, error); in shared_prepare()
471 priv->max_threads = 1; in gst_shared_task_pool_init()
489 guint max_threads) in gst_shared_task_pool_set_max_threads() argument
499 g_thread_pool_set_max_threads (taskpool->pool, max_threads, NULL); in gst_shared_task_pool_set_max_threads()
500 pool->priv->max_threads = max_threads; in gst_shared_task_pool_set_max_threads()
519 ret = pool->priv->max_threads; in gst_shared_task_pool_get_max_threads()
|
| D | gsttaskpool.h | 167 void gst_shared_task_pool_set_max_threads (GstSharedTaskPool *pool, guint max_threads);
|
| /third_party/glib/tests/ |
| D | asyncqueue-test.c | 181 gint max_threads = MAX_THREADS; in main() local
195 max_threads, max_unused_threads)); in main()
198 max_threads, in main()
207 for (i = 1; i <= max_threads; i++) { in main()
|
| D | threadpool-test.c | 250 guint max_threads; in test_thread_sort() local
256 max_threads = 1; in test_thread_sort()
258 max_threads = MAX_THREADS; in test_thread_sort()
271 max_threads, in test_thread_sort()
296 g_assert (g_thread_pool_get_max_threads (pool) == max_threads); in test_thread_sort()
|
| /third_party/benchmark/src/ |
| D | benchmark_register.cc | 429 Benchmark* Benchmark::ThreadRange(int min_threads, int max_threads) { in ThreadRange() argument
431 BM_CHECK_GE(max_threads, min_threads); in ThreadRange()
433 AddRange(&thread_counts_, min_threads, max_threads, 2); in ThreadRange()
437 Benchmark* Benchmark::DenseThreadRange(int min_threads, int max_threads, in DenseThreadRange() argument
440 BM_CHECK_GE(max_threads, min_threads); in DenseThreadRange()
443 for (auto i = min_threads; i < max_threads; i += stride) { in DenseThreadRange()
446 thread_counts_.push_back(max_threads); in DenseThreadRange()
|
| /third_party/json/benchmarks/thirdparty/benchmark/src/ |
| D | benchmark_register.cc | 413 Benchmark* Benchmark::ThreadRange(int min_threads, int max_threads) { in ThreadRange() argument
415 CHECK_GE(max_threads, min_threads); in ThreadRange()
417 AddRange(&thread_counts_, min_threads, max_threads, 2); in ThreadRange()
421 Benchmark* Benchmark::DenseThreadRange(int min_threads, int max_threads, in DenseThreadRange() argument
424 CHECK_GE(max_threads, min_threads); in DenseThreadRange()
427 for (auto i = min_threads; i < max_threads; i += stride) { in DenseThreadRange()
430 thread_counts_.push_back(max_threads); in DenseThreadRange()
|
| /third_party/python/Tools/ccbench/ |
| D | ccbench.py | 240 def run_throughput_tests(max_threads): argument
247 while nthreads <= max_threads:
375 def run_latency_tests(max_threads): argument
381 while nthreads <= max_threads:
502 def run_bandwidth_tests(max_threads): argument
509 while nthreads <= max_threads:
|
| /third_party/gstreamer/gstplugins_bad/ext/libde265/ |
| D | libde265-dec.c | 147 dec->max_threads = DEFAULT_MAX_THREADS; in gst_libde265_dec_init()
190 dec->max_threads = g_value_get_int (value); in gst_libde265_dec_set_property()
191 if (dec->max_threads) { in gst_libde265_dec_set_property()
192 GST_DEBUG_OBJECT (dec, "Max. threads set to %d", dec->max_threads); in gst_libde265_dec_set_property()
210 g_value_set_int (value, dec->max_threads); in gst_libde265_dec_get_property()
367 int threads = dec->max_threads; in gst_libde265_dec_start()
|
| D | libde265-dec.h | 52 int max_threads; member
|
| /third_party/mesa3d/src/util/ |
| D | u_queue.c | 374 num_threads = MIN2(num_threads, queue->max_threads); in util_queue_adjust_num_threads()
443 queue->max_threads = num_threads; in util_queue_init()
460 queue->threads = (thrd_t*) calloc(queue->max_threads, sizeof(thrd_t)); in util_queue_init()
578 queue->num_threads < queue->max_threads) { in util_queue_add_job()
|
| D | u_queue.h | 215 unsigned max_threads; member
|
| /third_party/gstreamer/gstplugins_base/gst/compositor/ |
| D | compositor.h | 138 guint max_threads; member
|
| D | compositor.c | 732 g_value_set_uint (value, self->max_threads); in gst_compositor_get_property()
758 self->max_threads = g_value_get_uint (value); in gst_compositor_set_property()
1193 if (compositor->max_threads == 0) in _negotiated_caps()
1196 n_threads = compositor->max_threads; in _negotiated_caps()
1668 self->max_threads = DEFAULT_MAX_THREADS; in gst_compositor_init()
|
| /third_party/gstreamer/gst_libav/ext/libav/ |
| D | gstavviddec.h | 69 int max_threads; member
|
| /third_party/gstreamer/gstplugins_bad/ext/openjpeg/ |
| D | gstopenjpegdec.h | 60 gint max_threads; /* atomic */ member
|
| D | gstopenjpegdec.c | 329 g_atomic_int_set (&dec->max_threads, g_value_get_int (value)); in gst_openjpeg_dec_set_property()
348 g_value_set_int (value, g_atomic_int_get (&dec->max_threads)); in gst_openjpeg_dec_get_property()
1403 gint max_threads; in gst_openjpeg_dec_decode_stripe() local
1432 max_threads = g_atomic_int_get (&self->max_threads); in gst_openjpeg_dec_decode_stripe()
1433 if (max_threads > self->num_procs) in gst_openjpeg_dec_decode_stripe()
1434 max_threads = self->num_procs; in gst_openjpeg_dec_decode_stripe()
1435 if (!opj_codec_set_threads (dec, max_threads)) in gst_openjpeg_dec_decode_stripe()
1437 max_threads); in gst_openjpeg_dec_decode_stripe()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 161 int max_threads; member
654 resource_quota->max_threads = INT_MAX; in grpc_resource_quota_create()
714 resource_quota->max_threads = new_max_threads; in grpc_resource_quota_set_max_threads()
858 if (rq->num_threads_allocated + thread_count <= rq->max_threads) { in grpc_resource_user_allocate_threads()
|
| /third_party/mesa3d/src/gallium/drivers/freedreno/ir3/ |
| D | ir3_gallium.c | 478 unsigned max_threads) in ir3_set_max_shader_compiler_threads() argument
485 util_queue_adjust_num_threads(&screen->compile_queue, max_threads); in ir3_set_max_shader_compiler_threads()
|
| /third_party/mesa3d/src/gallium/include/pipe/ |
| D | p_screen.h | 506 unsigned max_threads);
|