Home
last modified time | relevance | path

Searched refs:ctx (Results 26 – 50 of 86) sorted by relevance

1234

/unit/src/
H A Dnxt_mem_map.h46 #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 Dnxt_router_access_log.c171 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 Dnxt_gnutls.c149 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 Dnxt_log.c47 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 Dnxt_tstr.c42 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 Dnxt_var.h16 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 Dnxt_cyassl.c110 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 Dnxt_thread_pool.c12 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 Dnxt_pcre2.c114 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 Dnxt_http_parse.h75 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 Dnxt_log.h24 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 Dnxt_conf_validation.c1617 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 Dnxt_wasm.c34 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 Dtest_reconfigure_tls.py37 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 Dnxt_python.c20 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 Dnxt_python_asgi.h10 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 Dnxt_ruby.c51 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 Dnxt_clone_test.c32 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 Dnxt_unit_websocket_chat.c206 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 Dport.go97 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 Drequest.go111 ctx := c_req.ctx
129 c_req = C.nxt_unit_dequeue_request(ctx)
/unit/src/java/
H A Dnxt_jni_Context.h18 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 Dnxt_perl_psgi.c27 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 Dunit.cpp32 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 Dnxt_napi.h441 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 …]

1234