Home
last modified time | relevance | path

Searched refs:thr (Results 1 – 25 of 59) sorted by last modified time

123

/unit/src/
H A Dnxt_runtime.c21 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 Dnxt_main.h139 typedef void (*nxt_event_conn_handler_t)(nxt_thread_t *thr, nxt_conn_t *c);
H A Dnxt_work_queue.h123 NXT_EXPORT void nxt_locked_work_queue_move(nxt_thread_t *thr,
H A Dnxt_thread_id.h168 NXT_EXPORT nxt_tid_t nxt_thread_tid(nxt_thread_t *thr);
H A Dnxt_thread_time.h64 NXT_EXPORT void nxt_thread_time_update(nxt_thread_t *thr);
65 void nxt_thread_time_free(nxt_thread_t *thr);
66 NXT_EXPORT nxt_time_t nxt_thread_time(nxt_thread_t *thr);
67 NXT_EXPORT nxt_realtime_t *nxt_thread_realtime(nxt_thread_t *thr);
68 NXT_EXPORT u_char *nxt_thread_time_string(nxt_thread_t *thr,
73 #define nxt_thread_monotonic_time(thr) \ argument
74 (thr)->time.now.monotonic
79 #define nxt_thread_time_debug_update(thr) \ argument
80 nxt_thread_time_update(thr)
84 #define nxt_thread_time_debug_update(thr) argument
H A Dnxt_thread.h92 NXT_EXPORT void nxt_thread_exit(nxt_thread_t *thr);
H A Dnxt_source.h25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
27 if (thr->engine->batch != 0) { \
28 nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \
H A Dnxt_fiber.c47 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 Dnxt_cache.c12 (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 Dnxt_event_engine.h520 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 Dnxt_main_process.c82 nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task, in nxt_main_process_start() argument
H A Dnxt_gnutls.c126 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 Dnxt_malloc.c18 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 Dnxt_runtime.h86 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,
H A Dnxt_main_process.h22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
H A Dnxt_event_engine.c514 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 Dnxt_file.c107 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 Dnxt_app_log.c27 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 Dnxt_log.c50 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()
/unit/src/test/
H A Dnxt_rbtree1_test.c64 nxt_thread_time_update(thr); in nxt_rbtree1_test()
92 nxt_thread_time_update(thr); in nxt_rbtree1_test()
93 start = nxt_thread_monotonic_time(thr); in nxt_rbtree1_test()
132 nxt_thread_time_update(thr); in nxt_rbtree1_test()
133 end = nxt_thread_monotonic_time(thr); in nxt_rbtree1_test()
265 nxt_rbtree1_mb_start(nxt_thread_t *thr) in nxt_rbtree1_mb_start() argument
297 nxt_log_error(NXT_LOG_NOTICE, thr->log, in nxt_rbtree1_mb_start()
305 nxt_rbtree1_mb_insert(nxt_thread_t *thr) in nxt_rbtree1_mb_insert() argument
317 nxt_log_error(NXT_LOG_NOTICE, thr->log, in nxt_rbtree1_mb_insert()
323 nxt_rbtree1_mb_delete(nxt_thread_t *thr) in nxt_rbtree1_mb_delete() argument
[all …]
H A Dnxt_tests.c29 nxt_thread_t *thr; in main() local
38 thr = nxt_thread(); in main()
39 thr->task = &task; in main()
58 nxt_rbtree1_mb_insert(thr); in main()
59 nxt_rbtree_mb_insert(thr); in main()
65 nxt_rbtree1_mb_delete(thr); in main()
66 nxt_rbtree_mb_delete(thr); in main()
73 if (nxt_random_test(thr) != NXT_OK) { in main()
141 if (nxt_gmtime_test(thr) != NXT_OK) { in main()
149 if (nxt_malloc_test(thr) != NXT_OK) { in main()
[all …]
H A Dnxt_tests.h36 nxt_int_t nxt_term_parse_test(nxt_thread_t *thr);
44 nxt_int_t nxt_rbtree_mb_start(nxt_thread_t *thr);
45 void nxt_rbtree_mb_insert(nxt_thread_t *thr);
46 void nxt_rbtree_mb_delete(nxt_thread_t *thr);
49 void nxt_rbtree1_mb_insert(nxt_thread_t *thr);
50 void nxt_rbtree1_mb_delete(nxt_thread_t *thr);
61 nxt_int_t nxt_gmtime_test(nxt_thread_t *thr);
62 nxt_int_t nxt_sprintf_test(nxt_thread_t *thr);
63 nxt_int_t nxt_malloc_test(nxt_thread_t *thr);
64 nxt_int_t nxt_utf8_test(nxt_thread_t *thr);
[all …]
H A Dnxt_base64_test.c11 nxt_base64_test(nxt_thread_t *thr) in nxt_base64_test() argument
70 nxt_thread_time_update(thr); in nxt_base64_test()
80 nxt_log_alert(thr->log, in nxt_base64_test()
90 nxt_log_alert(thr->log, "nxt_base64_decode() test \"%V\" failed"); in nxt_base64_test()
95 nxt_log_error(NXT_LOG_NOTICE, thr->log, "nxt_base64_decode() test passed"); in nxt_base64_test()
H A Dnxt_mem_zone_test.c12 nxt_mem_zone_test(nxt_thread_t *thr, nxt_uint_t runs, nxt_uint_t nblocks, in nxt_mem_zone_test() argument
22 nxt_thread_time_update(thr); in nxt_mem_zone_test()
23 nxt_log_error(NXT_LOG_NOTICE, thr->log, in nxt_mem_zone_test()
56 nxt_log_error(NXT_LOG_NOTICE, thr->log, in nxt_mem_zone_test()
70 nxt_thread_time_update(thr); in nxt_mem_zone_test()
71 nxt_log_error(NXT_LOG_NOTICE, thr->log, "mem zone test passed"); in nxt_mem_zone_test()
H A Dnxt_strverscmp_test.c19 nxt_strverscmp_test(nxt_thread_t *thr) in nxt_strverscmp_test() argument
53 nxt_thread_time_update(thr); in nxt_strverscmp_test()
83 nxt_log_alert(thr->log, in nxt_strverscmp_test()
90 nxt_log_error(NXT_LOG_NOTICE, thr->log, in nxt_strverscmp_test()

123