Home
last modified time | relevance | path

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

/unit/test/
H A Dtest_ruby_hooks.py53 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 Dtest_perl_application.py302 threads = set()
313 threads.add(resp['headers']['X-Thread'])
319 assert len(socks) == len(threads), 'threads differs'
H A Dtest_asgi_application.py424 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 Dtest_ruby_application.py454 threads = set()
465 threads.add(resp['headers']['X-Thread'])
471 assert len(socks) == len(threads), 'threads differs'
H A Dtest_python_application.py901 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 Dtest_java_application.py1019 threads = set()
1030 threads.add(resp['headers']['X-Thread'])
1034 assert len(socks) == len(threads), 'threads differs'
/unit/src/
H A Dnxt_thread_pool.c82 (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 Dnxt_application.h55 uint32_t threads; member
69 uint32_t threads; member
76 uint32_t threads; member
86 uint32_t threads; member
H A Dnxt_thread_pool.h17 nxt_atomic_t threads; member
H A Dnxt_java.c621 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 Dnxt_router.h43 uint32_t threads; member
H A Dnxt_main_process.c219 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 Dnxt_router.c1415 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 Dnxt_conf_validation.c2072 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 Dnxt_unit_app_test.c41 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 Dnxt_python.c235 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 Dnxt_python_wsgi.c515 c->threads > 1 ? Py_True : Py_False) in nxt_python_create_environ()
/unit/src/ruby/
H A Dnxt_ruby.c278 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 DAsyncChannelGroupUtil.java30 import org.apache.tomcat.util.threads.ThreadPoolExecutor;
/unit/src/perl/
H A Dnxt_perl_psgi.c1273 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 Dconfigure122 . auto/threads
H A DCHANGES694 *) Bugfix: threads in Python applications might not work correctly.
/unit/docs/
H A Dunit-openapi.yaml5568 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."