/unit/src/ |
H A D | nxt_mem_map.h | 46 #define nxt_mem_map_file_ctx_t(ctx) argument 49 #define nxt_mem_map(addr, ctx, len, protection, flags, fd, offset) \ argument 53 #define nxt_mem_unmap(addr, ctx, len) \ argument
|
H A D | nxt_router_access_log.c | 171 nxt_router_access_log_ctx_t *ctx; in nxt_router_access_log_writer() local 173 ctx = nxt_mp_get(r->mem_pool, sizeof(nxt_router_access_log_ctx_t)); in nxt_router_access_log_writer() 174 if (nxt_slow_path(ctx == NULL)) { in nxt_router_access_log_writer() 178 ctx->access_log = access_log; in nxt_router_access_log_writer() 181 nxt_tstr_str(format, &ctx->text); in nxt_router_access_log_writer() 183 nxt_router_access_log_write_ready(task, r, ctx); in nxt_router_access_log_writer() 194 nxt_tstr_query(task, r->tstr_query, format, &ctx->text); in nxt_router_access_log_writer() 195 nxt_tstr_query_resolve(task, r->tstr_query, ctx, in nxt_router_access_log_writer() 206 nxt_router_access_log_ctx_t *ctx; in nxt_router_access_log_write_ready() local 209 ctx = data; in nxt_router_access_log_write_ready() [all …]
|
H A D | nxt_gnutls.c | 149 nxt_gnutls_ctx_t *ctx; in nxt_gnutls_server_init() local 158 ctx = nxt_zalloc(sizeof(nxt_gnutls_ctx_t)); in nxt_gnutls_server_init() 159 if (ctx == NULL) { in nxt_gnutls_server_init() 163 conf->ctx = ctx; in nxt_gnutls_server_init() 209 gnutls_priority_deinit(ctx->ciphers); in nxt_gnutls_server_init() 227 nxt_gnutls_ctx_t *ctx; in nxt_gnutls_set_ciphers() local 230 ctx = conf->ctx; in nxt_gnutls_set_ciphers() 259 nxt_gnutls_ctx_t *ctx; in nxt_gnutls_conn_init() local 289 ctx = conf->ctx; in nxt_gnutls_conn_init() 291 ret = gnutls_priority_set(sess, ctx->ciphers); in nxt_gnutls_conn_init() [all …]
|
H A D | nxt_log.c | 47 nxt_log_set_ctx(nxt_log_t *log, nxt_log_ctx_handler_t handler, void *ctx) in nxt_log_set_ctx() argument 58 log->ctx = ctx; in nxt_log_set_ctx() 97 p = log->ctx_handler(log->ctx, p, end); in nxt_log_handler()
|
H A D | nxt_tstr.c | 42 void *ctx; member 225 nxt_tstr_cache_t *cache, void *ctx, nxt_mp_t *mp) in nxt_tstr_query_init() argument 241 query->ctx = ctx; in nxt_tstr_query_init() 266 tstr->u.var, val, query->ctx, in nxt_tstr_query() 277 tstr->u.js, val, query->ctx); in nxt_tstr_query() 318 task, query->ctx, query->data); in nxt_tstr_query_resolve() 332 task, query->ctx, query->data); in nxt_tstr_query_handle()
|
H A D | nxt_var.h | 16 void *ctx, void *data); 60 nxt_var_cache_t *cache, nxt_var_t *var, nxt_str_t *str, void *ctx, 63 nxt_var_cache_t *cache, nxt_str_t *name, void *ctx);
|
H A D | nxt_cyassl.c | 110 CYASSL_CTX *ctx; in nxt_cyassl_server_init() local 119 ctx = CyaSSL_CTX_new(CyaSSLv23_server_method()); in nxt_cyassl_server_init() 120 if (ctx == NULL) { in nxt_cyassl_server_init() 126 conf->ctx = ctx; in nxt_cyassl_server_init() 150 err = CyaSSL_CTX_set_cipher_list(ctx, conf->ciphers); in nxt_cyassl_server_init() 161 CyaSSL_SetIORecv(ctx, nxt_cyassl_io_recv); in nxt_cyassl_server_init() 162 CyaSSL_SetIOSend(ctx, nxt_cyassl_io_send); in nxt_cyassl_server_init() 168 CyaSSL_CTX_free(ctx); in nxt_cyassl_server_init() 179 CYASSL_CTX *ctx; in nxt_cyassl_conn_init() local 198 ctx = conf->ctx; in nxt_cyassl_conn_init() [all …]
|
H A D | nxt_thread_pool.c | 12 static void nxt_thread_pool_start(void *ctx); 13 static void nxt_thread_pool_loop(void *ctx); 115 nxt_thread_pool_start(void *ctx) in nxt_thread_pool_start() argument 120 tp = ctx; in nxt_thread_pool_start() 126 nxt_thread_pool_loop(ctx); in nxt_thread_pool_start() 131 nxt_thread_pool_loop(void *ctx) in nxt_thread_pool_loop() argument 139 tp = ctx; in nxt_thread_pool_loop()
|
H A D | nxt_pcre2.c | 114 pcre2_general_context *ctx; in nxt_regex_match_create() local 116 ctx = pcre2_general_context_create(nxt_pcre2_malloc, nxt_pcre2_free, mp); in nxt_regex_match_create() 117 if (nxt_slow_path(ctx == NULL)) { in nxt_regex_match_create() 122 match = pcre2_match_data_create(size, ctx); in nxt_regex_match_create()
|
H A D | nxt_http_parse.h | 75 typedef nxt_int_t (*nxt_http_field_handler_t)(void *ctx, 128 void *ctx); 138 nxt_http_field_process(nxt_http_field_t *field, nxt_lvlhsh_t *hash, void *ctx) in nxt_http_field_process() argument 155 return proc->handler(ctx, field, proc->data); in nxt_http_field_process()
|
H A D | nxt_log.h | 24 typedef u_char *(*nxt_log_ctx_handler_t)(void *ctx, u_char *pos, u_char *end); 32 void *ctx; member 38 nxt_log_ctx_handler_t handler, void *ctx);
|
H A D | nxt_conf_validation.c | 1617 vldt->ctx = &ctx; in nxt_conf_vldt_mtypes() 1622 vldt->ctx = NULL; in nxt_conf_vldt_mtypes() 1643 ctx = vldt->ctx; in nxt_conf_vldt_mtypes_type() 1645 ctx->type = nxt_mp_get(ctx->pool, sizeof(nxt_str_t)); in nxt_conf_vldt_mtypes_type() 1670 ctx = vldt->ctx; in nxt_conf_vldt_mtypes_extension() 2165 vldt->ctx = data; in nxt_conf_vldt_match_patterns() 2176 vldt->ctx = NULL; in nxt_conf_vldt_match_patterns() 2304 vldt->ctx = data; in nxt_conf_vldt_match_encoded_patterns() 2315 vldt->ctx = NULL; in nxt_conf_vldt_match_encoded_patterns() 2446 vldt->ctx = data; in nxt_conf_vldt_match_patterns_sets() [all …]
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 34 nxt_wasm_do_response_end(nxt_wasm_ctx_t *ctx) in nxt_wasm_do_response_end() argument 36 nxt_unit_request_done(ctx->req, NXT_UNIT_OK); in nxt_wasm_do_response_end() 43 nxt_wasm_do_send_headers(nxt_wasm_ctx_t *ctx, uint32_t offset) in nxt_wasm_do_send_headers() argument 49 rh = (nxt_wasm_response_fields_t *)(ctx->baddr + offset); in nxt_wasm_do_send_headers() 56 nxt_unit_response_init(ctx->req, ctx->status, rh->nfields, fields_len); in nxt_wasm_do_send_headers() 65 nxt_unit_response_add_field(ctx->req, name, rh->fields[i].name_len, in nxt_wasm_do_send_headers() 69 nxt_unit_response_send(ctx->req); in nxt_wasm_do_send_headers() 74 nxt_wasm_do_send_response(nxt_wasm_ctx_t *ctx, uint32_t offset) in nxt_wasm_do_send_response() argument 77 nxt_unit_request_info_t *req = ctx->req; in nxt_wasm_do_send_response() 80 nxt_unit_response_init(req, ctx->status, 0, 0); in nxt_wasm_do_send_response()
|
/unit/test/ |
H A D | test_reconfigure_tls.py | 37 ctx = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT) 38 ctx.check_hostname = False 39 ctx.verify_mode = ssl.CERT_NONE 42 ssl_sock = ctx.wrap_socket(
|
/unit/src/python/ |
H A D | nxt_python.c | 20 nxt_unit_ctx_t *ctx; member 37 static int nxt_python_ready_handler(nxt_unit_ctx_t *ctx); 39 static void nxt_python_join_threads(nxt_unit_ctx_t *ctx, 637 nxt_python_ready_handler(nxt_unit_ctx_t *ctx) in nxt_python_ready_handler() argument 644 c = ctx->unit->data; in nxt_python_ready_handler() 653 ti->ctx = ctx; in nxt_python_ready_handler() 674 nxt_unit_ctx_t *ctx; in nxt_python_thread_func() local 691 ctx = nxt_unit_ctx_alloc(ti->ctx, ti->ctx_data); in nxt_python_thread_func() 692 if (nxt_slow_path(ctx == NULL)) { in nxt_python_thread_func() 696 (void) nxt_py_proto.run(ctx); in nxt_python_thread_func() [all …]
|
H A D | nxt_python_asgi.h | 10 typedef PyObject * (*nxt_py_asgi_enum_header_cb)(void *ctx, int i, 68 int nxt_py_asgi_lifespan_shutdown(nxt_unit_ctx_t *ctx);
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 51 static void nxt_ruby_ubf(void *ctx); 291 ruby_ctx.ctx = NULL; in nxt_ruby_start() 645 rctx = req->ctx->data; in nxt_ruby_request_handler_gvl() 676 rctx = req->ctx->data; in nxt_ruby_rack_app_run() 1339 c = ctx->unit->data; in nxt_ruby_ready_handler() 1348 rctx->ctx = ctx; in nxt_ruby_ready_handler() 1383 nxt_unit_ctx_t *ctx; in nxt_ruby_thread_func() local 1390 ctx = nxt_unit_ctx_alloc(rctx->ctx, rctx); in nxt_ruby_thread_func() 1414 nxt_unit_done(ctx); in nxt_ruby_thread_func() 1425 nxt_ruby_unit_run(void *ctx) in nxt_ruby_unit_run() argument [all …]
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 32 nxt_clone_creds_ctx_t *ctx, nxt_clone_creds_testcase_t *tc); 392 nxt_clone_creds_ctx_t *ctx; in nxt_clone_test_log_handler() local 399 ctx = log->ctx; in nxt_clone_test_log_handler() 400 tc = ctx->tc; in nxt_clone_test_log_handler() 434 nxt_clone_creds_ctx_t ctx; in nxt_clone_creds_test() local 441 &ctx in nxt_clone_creds_test() 464 ret = nxt_clone_test_mappings(task, mp, &ctx, &testcases[i]); in nxt_clone_creds_test() 485 nxt_clone_creds_ctx_t *ctx, nxt_clone_creds_testcase_t *tc) in nxt_clone_test_mappings() argument 507 ctx->tc = tc; in nxt_clone_test_mappings()
|
H A D | nxt_unit_websocket_chat.c | 206 nxt_unit_ctx_t *ctx; in main() local 224 ctx = nxt_unit_init(&init); in main() 225 if (ctx == NULL) { in main() 229 nxt_unit_run(ctx); in main() 231 nxt_unit_done(ctx); in main()
|
/unit/go/ |
H A D | port.go | 97 func nxt_go_add_port(ctx *C.nxt_unit_ctx_t, p *C.nxt_unit_port_t) C.int { 117 func nxt_go_ready(ctx *C.nxt_unit_ctx_t) C.int { 118 go func(ctx *C.nxt_unit_ctx_t) { 119 C.nxt_unit_run_shared(ctx) 120 }(ctx) 126 func nxt_go_remove_port(unit *C.nxt_unit_t, ctx *C.nxt_unit_ctx_t,
|
H A D | request.go | 111 ctx := c_req.ctx 129 c_req = C.nxt_unit_dequeue_request(ctx)
|
/unit/src/java/ |
H A D | nxt_jni_Context.h | 18 void nxt_java_service(JNIEnv *env, jobject ctx, jobject jreq, jobject jresp); 20 void nxt_java_stopContext(JNIEnv *env, jobject ctx);
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 27 nxt_unit_ctx_t *ctx; member 605 pctx = req->ctx->data; in nxt_perl_psgi_env_create() 1008 ctx = read_info->data; in nxt_perl_psgi_io_read() 1010 dTHXa(ctx->my_perl); in nxt_perl_psgi_io_read() 1103 pctx = req->ctx->data; in nxt_perl_psgi_result_cb() 1210 pctx = req->ctx->data; in nxt_perl_psgi_request_handler() 1271 c = ctx->unit->data; in nxt_perl_psgi_ready_handler() 1280 pctx->ctx = ctx; in nxt_perl_psgi_ready_handler() 1310 ctx = nxt_unit_ctx_alloc(pctx->ctx, pctx); in nxt_perl_psgi_thread_func() 1315 pctx->ctx = ctx; in nxt_perl_psgi_thread_func() [all …]
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 32 nxt_unit_ctx_t *ctx; member 62 rc = nxt_unit_process_port_msg(ctx, port); in process_port_msg() 437 Unit::shm_ack_handler_cb(nxt_unit_ctx_t *ctx) in shm_ack_handler_cb() argument 443 obj->shm_ack_handler(ctx); in shm_ack_handler_cb() 448 Unit::shm_ack_handler(nxt_unit_ctx_t *ctx) in shm_ack_handler() argument 494 data = new port_data_t(ctx, port); in add_port() 526 if (port->data != NULL && ctx != NULL) { in remove_port() 535 Unit::quit_cb(nxt_unit_ctx_t *ctx) in quit_cb() argument 541 obj->quit(ctx); in quit_cb() 546 Unit::quit(nxt_unit_ctx_t *ctx) in quit() argument [all …]
|
H A D | nxt_napi.h | 441 make_callback(napi_async_context ctx, napi_value val, napi_value func, in make_callback() 470 make_callback(napi_async_context ctx, napi_value val, napi_value func) in make_callback() 472 return make_callback(ctx, val, func, 0, NULL); in make_callback() 477 make_callback(napi_async_context ctx, napi_value val, napi_value func, in make_callback() 480 return make_callback(ctx, val, func, 1, &arg1); in make_callback() 485 make_callback(napi_async_context ctx, napi_value val, napi_value func, in make_callback() 490 return make_callback(ctx, val, func, 2, args); in make_callback() 500 return make_callback(ctx, val, func, 3, args); in make_callback() 810 nxt_callback_scope(nxt_async_context& ctx) : in nxt_callback_scope() 811 nxt_napi(ctx.env()) in nxt_callback_scope() [all …]
|