Searched refs:threads (Results 1 – 22 of 22) sorted by relevance

/unit/test/
H A D	test_ruby_hooks.py	47 threads = 2 52 threads=threads, 56 hooked = self._wait_cookie('thread_boot.*', processes * threads) 62 threads = 2 67 threads=threads, 75 hooked = self._wait_cookie('thread_shutdown.*', processes * threads) 81 threads = 1 86 threads=threads, 93 hooked = self._wait_cookie('thread_boot.*', threads)
H A D	test_asgi_application.py	355 self.load('threads', threads=2) 373 threads = set() 384 threads.add(resp['headers']['x-thread']) 388 assert len(socks) == len(threads), 'threads differs'
H A D	test_perl_application.py	273 threads = set() 284 threads.add(resp['headers']['X-Thread']) 290 assert len(socks) == len(threads), 'threads differs'
H A D	test_ruby_application.py	402 threads = set() 413 threads.add(resp['headers']['X-Thread']) 419 assert len(socks) == len(threads), 'threads differs'
H A D	test_python_application.py	763 self.load('threads', threads=4) 779 threads = set() 790 threads.add(resp['headers']['X-Thread']) 796 assert len(socks) == len(threads), 'threads differs'
H A D	test_java_application.py	1017 threads = set() 1028 threads.add(resp['headers']['X-Thread']) 1032 assert len(socks) == len(threads), 'threads differs'
/unit/src/
H A D	nxt_thread_pool.c	82 (void) nxt_atomic_fetch_add(&tp->threads, 1); in nxt_thread_pool_init() 101 (void) nxt_atomic_fetch_add(&tp->threads, -1); in nxt_thread_pool_init() 170 nxt_atomic_uint_t waiting, threads; in nxt_thread_pool_wait() local 195 (void) nxt_atomic_fetch_add(&tp->threads, -1); in nxt_thread_pool_wait() 208 threads = tp->threads; in nxt_thread_pool_wait() 210 if (threads >= tp->max_threads) { in nxt_thread_pool_wait() 214 } while (!nxt_atomic_cmp_set(&tp->threads, threads, threads + 1)); in nxt_thread_pool_wait() 271 nxt_atomic_uint_t threads; in nxt_thread_pool_exit() local 284 threads = nxt_atomic_fetch_add(&tp->threads, -1); in nxt_thread_pool_exit() 286 nxt_debug(task, "thread pool threads: %A", threads); in nxt_thread_pool_exit() [all …]
H A D	nxt_application.h	54 uint32_t threads; member 68 uint32_t threads; member 75 uint32_t threads; member 85 uint32_t threads; member
H A D	nxt_thread_pool.h	17 nxt_atomic_t threads; member
H A D	nxt_java.c	621 if (c->threads <= 1) { in nxt_java_ready_handler() 625 for (i = 0; i < c->threads - 1; i++) { in nxt_java_ready_handler() 693 if (c->threads <= 1) { in nxt_java_init_threads() 718 sizeof(pthread_t) * (c->threads - 1)); in nxt_java_init_threads() 725 memset(nxt_java_threads, 0, sizeof(pthread_t) * (c->threads - 1)); in nxt_java_init_threads() 741 for (i = 0; i < c->threads - 1; i++) { in nxt_java_join_threads()
H A D	nxt_router.h	43 uint32_t threads; member
H A D	nxt_main_process.c	202 offsetof(nxt_common_app_conf_t, u.python.threads), 244 offsetof(nxt_common_app_conf_t, u.perl.threads), 264 offsetof(nxt_common_app_conf_t, u.ruby.threads), 298 offsetof(nxt_common_app_conf_t, u.java.threads),
H A D	nxt_router.c	1363 offsetof(nxt_router_conf_t, threads), 1601 if (rtcf->threads == 0) { in nxt_router_conf_create() 1602 rtcf->threads = nxt_ncpu; in nxt_router_conf_create() 3030 nxt_uint_t n, threads; in nxt_router_engines_create() local 3034 threads = tmcf->router_conf->threads; in nxt_router_engines_create() 3036 tmcf->engines = nxt_array_create(tmcf->mem_pool, threads, in nxt_router_engines_create() 3055 if (n < threads) { in nxt_router_engines_create() 3073 while (n < threads) { in nxt_router_engines_create() 3287 nxt_uint_t i, threads; in nxt_router_threads_create() local 3291 threads = tmcf->router_conf->threads; in nxt_router_threads_create() [all …]
H A D	nxt_conf_validation.c	1838 int64_t threads; in nxt_conf_vldt_threads() local 1840 threads = nxt_conf_get_number(value); in nxt_conf_vldt_threads() 1842 if (threads < 1) { in nxt_conf_vldt_threads() 1847 if (threads > NXT_INT32_T_MAX) { in nxt_conf_vldt_threads()
/unit/src/test/
H A D	nxt_unit_app_test.c	41 static pthread_t *threads; variable 71 err = pthread_join(threads[i], NULL); in main() 82 nxt_unit_free(ctx, threads); in main() 104 threads = nxt_unit_malloc(ctx, sizeof(pthread_t) * (thread_count - 1)); in ready_handler() 105 if (threads == NULL) { in ready_handler() 110 err = pthread_create(&threads[i], NULL, worker, ctx); in ready_handler()
/unit/src/python/
H A D	nxt_python.c	217 if (c->threads > 1) { in nxt_python_start() 523 if (c->threads <= 1) { in nxt_python_init_threads() 548 * (c->threads - 1)); in nxt_python_init_threads() 555 memset(nxt_py_threads, 0, sizeof(nxt_py_thread_info_t) * (c->threads - 1)); in nxt_python_init_threads() 557 for (i = 0; i < c->threads - 1; i++) { in nxt_python_init_threads() 580 if (c->threads <= 1) { in nxt_python_ready_handler() 584 for (i = 0; i < c->threads - 1; i++) { in nxt_python_ready_handler() 659 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads() 679 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads()
H A D	nxt_python_wsgi.c	510 c->threads > 1 ? Py_True : Py_False) in nxt_python_create_environ()
/unit/src/ruby/
H A D	nxt_ruby.c	278 nxt_ruby_threads = c->threads; in nxt_ruby_start() 1270 if (c->threads <= 1) { in nxt_ruby_ready_handler() 1274 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_ready_handler() 1374 if (c->threads <= 1) { in nxt_ruby_init_threads() 1379 * (c->threads - 1)); in nxt_ruby_init_threads() 1386 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1395 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1421 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_join_threads() 1434 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_join_threads()
/unit/src/java/nginx/unit/websocket/
H A D	AsyncChannelGroupUtil.java	30 import org.apache.tomcat.util.threads.ThreadPoolExecutor;
/unit/
H A D	configure	119 . auto/threads
H A D	CHANGES	505 *) Bugfix: threads in Python applications might not work correctly.
/unit/src/perl/
H A D	nxt_perl_psgi.c	1272 if (c->threads <= 1) { in nxt_perl_psgi_ready_handler() 1276 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_ready_handler() 1335 if (c->threads <= 1) { in nxt_perl_psgi_init_threads() 1360 * (c->threads - 1)); in nxt_perl_psgi_init_threads() 1366 * (c->threads - 1)); in nxt_perl_psgi_init_threads() 1368 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_init_threads() 1391 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_join_threads() 1405 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_join_threads()

Last Index update Thu Dec 08 05:55:15 UTC 2022