| /unit/src/ |
| H A D | nxt_app_log.c | 27 nxt_thread_t *thr; in nxt_log_time_handler() local
31 thr = nxt_thread(); in nxt_log_time_handler()
38 p = nxt_thread_time_string(thr, time_cache, msg); in nxt_log_time_handler()
49 fib = nxt_fiber_self(thr); in nxt_log_time_handler()
61 nxt_thread_tid(thr), fid); in nxt_log_time_handler()
64 nxt_thread_tid(thr)); in nxt_log_time_handler()
|
| H A D | nxt_cache.c | 12 (uint64_t) (nxt_thread_time(thr) * 100)
132 nxt_thread_t *thr; in nxt_cache_query() local
136 thr = nxt_thread(); in nxt_cache_query()
146 q->now = nxt_cache_time(thr); in nxt_cache_query()
158 handler(thr, q, NULL); in nxt_cache_query()
374 cq->state->timeout_handler(thr, cq, NULL); in nxt_cache_timeout_handler()
405 handler(thr, q, NULL); in nxt_cache_wake_handler()
467 nxt_thread_t *thr; in nxt_cache_release() local
470 thr = nxt_thread(); in nxt_cache_release()
471 q->now = nxt_cache_time(thr); in nxt_cache_release()
[all …]
|
| H A D | nxt_conn.c | 46 nxt_thread_t *thr; in nxt_conn_create() local
66 thr = nxt_thread(); in nxt_conn_create()
67 thr->engine->connections++; in nxt_conn_create()
69 c->task.thread = thr; in nxt_conn_create()
76 c->io = thr->engine->event.io; in nxt_conn_create()
80 c->socket.read_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
81 c->socket.write_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
86 nxt_log_debug(&c->log, "connections: %uD", thr->engine->connections); in nxt_conn_create()
|
| H A D | nxt_conn_proxy.c | 63 nxt_thread_t *thr; in nxt_conn_proxy_create() local
76 thr = nxt_thread(); in nxt_conn_proxy_create()
78 client->read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
79 client->write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
80 client->socket.read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
81 client->socket.write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
82 peer->socket.read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
83 peer->socket.write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
|
| H A D | nxt_cyassl.c | 75 nxt_thread_t *thr; in nxt_cyassl_start() local
84 thr = nxt_thread(); in nxt_cyassl_start()
111 nxt_thread_t *thr; in nxt_cyassl_server_init() local
113 thr = nxt_thread(); in nxt_cyassl_server_init()
246 nxt_thread_t *thr; in nxt_cyassl_io_recv() local
250 thr = nxt_thread(); in nxt_cyassl_io_recv()
274 nxt_thread_t *thr; in nxt_cyassl_io_send() local
278 thr = nxt_thread(); in nxt_cyassl_io_send()
314 nxt_thread_time_debug_update(thr); in nxt_cyassl_conn_handshake()
319 nxt_cyassl_conn_io_read(thr, c, data); in nxt_cyassl_conn_handshake()
[all …]
|
| H A D | nxt_event_engine.c | 514 nxt_thread_t *thr; in nxt_event_engine_start() local
517 thr = nxt_thread(); in nxt_event_engine_start()
529 thr->log = engine->task.log; in nxt_event_engine_start()
540 thr->task = task; in nxt_event_engine_start()
551 now = nxt_thread_monotonic_time(thr) / 1000000; in nxt_event_engine_start()
|
| H A D | nxt_event_engine.h | 520 nxt_thread_t *thr; in nxt_thread_event_engine() local
522 thr = nxt_thread(); in nxt_thread_event_engine()
523 return thr->engine; in nxt_thread_event_engine()
|
| H A D | nxt_fiber.c | 47 nxt_thread_t *thr; in nxt_fiber_create() local
50 thr = nxt_thread(); in nxt_fiber_create()
51 fm = thr->engine->fibers; in nxt_fiber_create()
68 fib->task.thread = thr; in nxt_fiber_create()
69 fib->task.log = thr->log; in nxt_fiber_create()
74 nxt_fiber_enqueue(thr, &fm->engine->task, fib); in nxt_fiber_create()
79 nxt_log_debug(thr->log, "fiber create"); in nxt_fiber_create()
92 fib->task.thread = thr; in nxt_fiber_create()
93 fib->task.log = thr->log; in nxt_fiber_create()
356 nxt_fiber_self(nxt_thread_t *thr) in nxt_fiber_self() argument
[all …]
|
| H A D | nxt_fiber.h | 54 NXT_EXPORT nxt_fiber_t *nxt_fiber_self(nxt_thread_t *thr);
|
| H A D | nxt_file.c | 107 nxt_thread_debug(thr); in nxt_file_write()
113 nxt_thread_time_debug_update(thr); in nxt_file_write()
115 nxt_log_debug(thr->log, "pwrite(%FD, %p, %uz, %O): %z", in nxt_file_write()
135 nxt_thread_debug(thr); in nxt_file_read()
141 nxt_thread_time_debug_update(thr); in nxt_file_read()
143 nxt_log_debug(thr->log, "pread(%FD, %p, %uz, %O): %z", in nxt_file_read()
|
| H A D | nxt_file_cache.c | 239 nxt_thread_t *thr; in nxt_cache_wait_handler() local
252 thr = nxt_thread(); in nxt_cache_wait_handler()
253 ev->log = thr->log; in nxt_cache_wait_handler()
258 nxt_event_timer_add(thr->engine, ev, q->timeout); in nxt_cache_wait_handler()
|
| H A D | nxt_gnutls.c | 126 nxt_thread_t *thr; in nxt_gnutls_time() local
128 thr = nxt_thread(); in nxt_gnutls_time()
131 t = (time_t) nxt_thread_time(thr); in nxt_gnutls_time()
148 nxt_thread_t *thr; in nxt_gnutls_server_init() local
166 thr = nxt_thread(); in nxt_gnutls_server_init()
355 nxt_thread_t *thr; in nxt_gnutls_pull() local
359 thr = nxt_thread(); in nxt_gnutls_pull()
376 nxt_thread_t *thr; in nxt_gnutls_push() local
380 thr = nxt_thread(); in nxt_gnutls_push()
402 nxt_thread_t *thr; in nxt_gnutls_vec_push() local
[all …]
|
| H A D | nxt_listen_socket.c | 50 thr = nxt_thread(); in nxt_listen_socket_create()
51 old = thr->log; in nxt_listen_socket_create()
52 log = *thr->log; in nxt_listen_socket_create()
55 thr->log = &log; in nxt_listen_socket_create()
190 thr->log = old; in nxt_listen_socket_create()
212 thr->log = old; in nxt_listen_socket_create()
228 old = thr->log; in nxt_listen_socket_update()
229 log = *thr->log; in nxt_listen_socket_update()
232 thr->log = &log; in nxt_listen_socket_update()
242 thr->log = old; in nxt_listen_socket_update()
[all …]
|
| H A D | nxt_log.c | 50 nxt_thread_t *thr; in nxt_log_set_ctx() local
52 thr = nxt_thread(); in nxt_log_set_ctx()
53 old = thr->log; in nxt_log_set_ctx()
60 thr->log = log; in nxt_log_set_ctx()
|
| H A D | nxt_log_moderation.c | 20 nxt_thread_t *thr; in nxt_log_moderate_allow() local
22 thr = nxt_thread(); in nxt_log_moderate_allow()
23 now = nxt_thread_time(thr); in nxt_log_moderate_allow()
61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
66 nxt_timer_add(thr->engine, &mod->timer, 1000); in nxt_log_moderate_allow()
|
| H A D | nxt_main.h | 139 typedef void (*nxt_event_conn_handler_t)(nxt_thread_t *thr, nxt_conn_t *c);
|
| H A D | nxt_main_process.c | 82 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start() argument
|
| H A D | nxt_main_process.h | 22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
|
| H A D | nxt_malloc.c | 18 nxt_thread_t *thr; in nxt_malloc_log() local
20 thr = nxt_thread(); in nxt_malloc_log()
22 if (thr != NULL && thr->log != NULL) { in nxt_malloc_log()
23 return thr->log; in nxt_malloc_log()
|
| H A D | nxt_pcre.c | 65 nxt_log_warn(thr->log, "pcre_study(%V) failed: %s", source, err->msg); in nxt_regex_compile()
|
| H A D | nxt_polarssl.c | 22 static void nxt_polarssl_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf,
38 nxt_thread_t *thr; in nxt_polarssl_server_init() local
41 thr = nxt_thread(); in nxt_polarssl_server_init()
52 nxt_polarssl_log_error(NXT_LOG_ALERT, thr->log, n, "ssl_init() failed"); in nxt_polarssl_server_init()
63 nxt_polarssl_log_error(NXT_LOG_ALERT, thr->log, n, in nxt_polarssl_server_init()
73 nxt_polarssl_log_error(NXT_LOG_ALERT, thr->log, n, in nxt_polarssl_server_init()
94 nxt_polarssl_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf, in nxt_polarssl_conn_init() argument
|
| H A D | nxt_random.c | 182 nxt_random_test(nxt_thread_t *thr) in nxt_random_test() argument
205 nxt_log_error(NXT_LOG_NOTICE, thr->log, "arc4random test passed"); in nxt_random_test()
211 nxt_log_error(NXT_LOG_NOTICE, thr->log, "arc4random test failed"); in nxt_random_test()
|
| H A D | nxt_random.h | 23 nxt_int_t nxt_random_test(nxt_thread_t *thr);
|
| H A D | nxt_runtime.c | 21 static nxt_int_t nxt_runtime_thread_pools(nxt_thread_t *thr, nxt_runtime_t *rt);
316 nxt_runtime_thread_pools(nxt_thread_t *thr, nxt_runtime_t *rt) in nxt_runtime_thread_pools() argument
329 ret = nxt_runtime_thread_pool_create(thr, rt, 2, 60000 * 1000000LL); in nxt_runtime_thread_pools()
378 nxt_thread_t *thr; in nxt_runtime_initial_start() local
382 thr = task->thread; in nxt_runtime_initial_start()
383 rt = thr->runtime; in nxt_runtime_initial_start()
418 thr->engine->max_connections = rt->engine_connections; in nxt_runtime_initial_start()
420 if (nxt_main_process_start(thr, task, rt) != NXT_ERROR) { in nxt_runtime_initial_start()
656 nxt_runtime_thread_pool_create(nxt_thread_t *thr, nxt_runtime_t *rt, in nxt_runtime_thread_pool_create() argument
668 thr->engine, in nxt_runtime_thread_pool_create()
|
| H A D | nxt_runtime.h | 86 typedef nxt_int_t (*nxt_module_init_t)(nxt_thread_t *thr, nxt_runtime_t *rt);
94 nxt_int_t nxt_runtime_thread_pool_create(nxt_thread_t *thr, nxt_runtime_t *rt,
|