/unit/test/ |
H A D | test_ruby_hooks.py | 53 threads = 2 58 threads=threads, 62 hooked = wait_cookie('thread_boot.*', processes * threads) 69 threads = 2 74 threads=threads, 82 hooked = wait_cookie('thread_shutdown.*', processes * threads) 89 threads = 1 94 threads=threads, 101 hooked = wait_cookie('thread_boot.*', threads)
|
H A D | test_perl_application.py | 302 threads = set() 313 threads.add(resp['headers']['X-Thread']) 319 assert len(socks) == len(threads), 'threads differs'
|
H A D | test_asgi_application.py | 424 client.load('threads', threads=2) 442 threads = set() 453 threads.add(resp['headers']['x-thread']) 457 assert len(socks) == len(threads), 'threads differs'
|
H A D | test_ruby_application.py | 454 threads = set() 465 threads.add(resp['headers']['X-Thread']) 471 assert len(socks) == len(threads), 'threads differs'
|
H A D | test_python_application.py | 901 client.load('threads', threads=4) 917 threads = set() 928 threads.add(resp['headers']['X-Thread']) 934 assert len(socks) == len(threads), 'threads differs'
|
H A D | test_java_application.py | 1019 threads = set() 1030 threads.add(resp['headers']['X-Thread']) 1034 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 | 55 uint32_t threads; member 69 uint32_t threads; member 76 uint32_t threads; member 86 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 | 219 offsetof(nxt_common_app_conf_t, u.python.threads), 261 offsetof(nxt_common_app_conf_t, u.perl.threads), 281 offsetof(nxt_common_app_conf_t, u.ruby.threads), 315 offsetof(nxt_common_app_conf_t, u.java.threads),
|
H A D | nxt_router.c | 1415 offsetof(nxt_router_conf_t, threads), 1671 if (rtcf->threads == 0) { in nxt_router_conf_create() 1672 rtcf->threads = nxt_ncpu; in nxt_router_conf_create() 3193 nxt_uint_t n, threads; in nxt_router_engines_create() local 3197 threads = tmcf->router_conf->threads; in nxt_router_engines_create() 3199 tmcf->engines = nxt_array_create(tmcf->mem_pool, threads, in nxt_router_engines_create() 3218 if (n < threads) { in nxt_router_engines_create() 3236 while (n < threads) { in nxt_router_engines_create() 3450 nxt_uint_t i, threads; in nxt_router_threads_create() local 3454 threads = tmcf->router_conf->threads; in nxt_router_threads_create() [all …]
|
H A D | nxt_conf_validation.c | 2072 int64_t threads; in nxt_conf_vldt_threads() local 2074 threads = nxt_conf_get_number(value); in nxt_conf_vldt_threads() 2076 if (threads < 1) { in nxt_conf_vldt_threads() 2081 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 | 235 if (c->threads > 1) { in nxt_python_start() 589 if (c->threads <= 1) { in nxt_python_init_threads() 614 * (c->threads - 1)); in nxt_python_init_threads() 621 memset(nxt_py_threads, 0, sizeof(nxt_py_thread_info_t) * (c->threads - 1)); in nxt_python_init_threads() 623 for (i = 0; i < c->threads - 1; i++) { in nxt_python_init_threads() 646 if (c->threads <= 1) { in nxt_python_ready_handler() 650 for (i = 0; i < c->threads - 1; i++) { in nxt_python_ready_handler() 725 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads() 745 for (i = 0; i < c->threads - 1; i++) { in nxt_python_join_threads()
|
H A D | nxt_python_wsgi.c | 515 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() 1341 if (c->threads <= 1) { in nxt_ruby_ready_handler() 1345 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_ready_handler() 1445 if (c->threads <= 1) { in nxt_ruby_init_threads() 1450 * (c->threads - 1)); in nxt_ruby_init_threads() 1457 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1466 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_init_threads() 1492 for (i = 0; i < c->threads - 1; i++) { in nxt_ruby_join_threads() 1505 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/src/perl/ |
H A D | nxt_perl_psgi.c | 1273 if (c->threads <= 1) { in nxt_perl_psgi_ready_handler() 1277 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_ready_handler() 1336 if (c->threads <= 1) { in nxt_perl_psgi_init_threads() 1361 * (c->threads - 1)); in nxt_perl_psgi_init_threads() 1367 * (c->threads - 1)); in nxt_perl_psgi_init_threads() 1369 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_init_threads() 1392 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_join_threads() 1406 for (i = 0; i < c->threads - 1; i++) { in nxt_perl_psgi_join_threads()
|
/unit/ |
H A D | configure | 122 . auto/threads
|
H A D | CHANGES | 694 *) Bugfix: threads in Python applications might not work correctly.
|
/unit/docs/ |
H A D | unit-openapi.yaml | 5568 threads: 5570 description: "Number of worker threads per app process." 5590 threads: 5592 description: "Number of worker threads per app process." 5742 threads: 5744 description: "Number of worker threads per app process." 5765 threads: 5767 description: "Number of worker threads per app process."
|