/unit/src/ |
H A D | nxt_unit.h | 97 nxt_unit_ctx_t *ctx; 146 void (*quit)(nxt_unit_ctx_t *); 149 void (*shm_ack_handler)(nxt_unit_ctx_t *); 160 int (*ready_handler)(nxt_unit_ctx_t *); 201 nxt_unit_ctx_t *nxt_unit_init(nxt_unit_init_t *); 214 int nxt_unit_run(nxt_unit_ctx_t *); 216 int nxt_unit_run_ctx(nxt_unit_ctx_t *ctx); 218 int nxt_unit_run_shared(nxt_unit_ctx_t *ctx); 229 int nxt_unit_run_once(nxt_unit_ctx_t *ctx); 234 void nxt_unit_done(nxt_unit_ctx_t *); [all …]
|
H A D | nxt_unit.c | 79 nxt_unit_ctx_t *ctx); 83 nxt_unit_ctx_t *ctx); 288 nxt_unit_ctx_t ctx; 426 nxt_unit_ctx_t * 432 nxt_unit_ctx_t *ctx; in nxt_unit_init() 726 nxt_unit_ctx_use(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_use() 1244 nxt_unit_ctx_ready(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_ready() 4534 nxt_unit_run(nxt_unit_ctx_t *ctx) in nxt_unit_run() 4851 nxt_unit_run_ctx(nxt_unit_ctx_t *ctx) in nxt_unit_run_ctx() 5097 nxt_unit_done(nxt_unit_ctx_t *ctx) in nxt_unit_done() [all …]
|
H A D | nxt_unit_typedefs.h | 11 typedef struct nxt_unit_ctx_s nxt_unit_ctx_t; typedef
|
H A D | nxt_java.c | 39 static int nxt_java_ready_handler(nxt_unit_ctx_t *ctx); 42 static void nxt_java_join_threads(nxt_unit_ctx_t *ctx, 203 nxt_unit_ctx_t *ctx; in nxt_java_start() 611 nxt_java_ready_handler(nxt_unit_ctx_t *ctx) in nxt_java_ready_handler() 650 nxt_unit_ctx_t *main_ctx, *ctx; in nxt_java_thread_func() 732 nxt_java_join_threads(nxt_unit_ctx_t *ctx, nxt_java_app_conf_t *c) in nxt_java_join_threads()
|
H A D | nxt_php_sapi.c | 365 static nxt_unit_ctx_t *nxt_php_unit_ctx; 461 nxt_unit_ctx_t *unit_ctx; in nxt_php_start()
|
/unit/src/nodejs/unit-http/ |
H A D | unit.h | 40 static void shm_ack_handler_cb(nxt_unit_ctx_t *ctx); 41 void shm_ack_handler(nxt_unit_ctx_t *ctx); 43 static int add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port); 44 static void remove_port(nxt_unit_t *unit, nxt_unit_ctx_t *ctx, 47 static void quit_cb(nxt_unit_ctx_t *ctx); 48 void quit(nxt_unit_ctx_t *ctx); 83 nxt_unit_ctx_t *unit_ctx_;
|
H A D | unit.cpp | 20 port_data_t(nxt_unit_ctx_t *c, nxt_unit_port_t *p); 32 nxt_unit_ctx_t *ctx; 50 port_data_t::port_data_t(nxt_unit_ctx_t *c, nxt_unit_port_t *p) : in port_data_t() 437 Unit::shm_ack_handler_cb(nxt_unit_ctx_t *ctx) in shm_ack_handler_cb() 448 Unit::shm_ack_handler(nxt_unit_ctx_t *ctx) in shm_ack_handler() 471 Unit::add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in add_port() 522 Unit::remove_port(nxt_unit_t *unit, nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in remove_port() 535 Unit::quit_cb(nxt_unit_ctx_t *ctx) in quit_cb() 546 Unit::quit(nxt_unit_ctx_t *ctx) in quit()
|
/unit/go/ |
H A D | nxt_cgo_lib.c | 13 static ssize_t nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, 15 static ssize_t nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, 22 nxt_unit_ctx_t *ctx; in nxt_cgo_run() 51 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_send() 60 nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_recv()
|
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 { argument 117 func nxt_go_ready(ctx *C.nxt_unit_ctx_t) C.int { argument 118 go func(ctx *C.nxt_unit_ctx_t) { 126 func nxt_go_remove_port(unit *C.nxt_unit_t, ctx *C.nxt_unit_ctx_t, argument
|
H A D | response.go | 105 func nxt_go_shm_ack_handler(ctx *C.nxt_unit_ctx_t) { argument
|
/unit/src/ruby/ |
H A D | nxt_ruby.h | 28 nxt_unit_ctx_t *ctx;
|
H A D | nxt_ruby.c | 47 static int nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx); 53 static void nxt_ruby_join_threads(nxt_unit_ctx_t *ctx, 265 nxt_unit_ctx_t *unit_ctx; in nxt_ruby_start() 1332 nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx) in nxt_ruby_ready_handler() 1383 nxt_unit_ctx_t *ctx; in nxt_ruby_thread_func() 1483 nxt_ruby_join_threads(nxt_unit_ctx_t *ctx, nxt_ruby_app_conf_t *c) in nxt_ruby_join_threads()
|
/unit/src/test/ |
H A D | nxt_unit_app_test.c | 34 static int ready_handler(nxt_unit_ctx_t *ctx); 48 nxt_unit_ctx_t *ctx; in main() 94 ready_handler(nxt_unit_ctx_t *ctx) in ready_handler() 124 nxt_unit_ctx_t *ctx; in worker()
|
H A D | nxt_unit_websocket_echo.c | 88 nxt_unit_ctx_t *ctx; in main()
|
H A D | nxt_unit_websocket_chat.c | 206 nxt_unit_ctx_t *ctx; in main()
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 25 static int nxt_python_asgi_run(nxt_unit_ctx_t *ctx); 27 static void nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, 45 static void nxt_py_asgi_quit(nxt_unit_ctx_t *ctx); 46 static void nxt_py_asgi_shm_ack_handler(nxt_unit_ctx_t *ctx); 390 nxt_python_asgi_run(nxt_unit_ctx_t *ctx) in nxt_python_asgi_run() 1002 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port() 1026 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader() 1090 nxt_py_asgi_remove_port(nxt_unit_t *lib, nxt_unit_ctx_t *ctx, in nxt_py_asgi_remove_port() 1104 nxt_py_asgi_quit(nxt_unit_ctx_t *ctx) in nxt_py_asgi_quit() 1135 nxt_py_asgi_shm_ack_handler(nxt_unit_ctx_t *ctx) in nxt_py_asgi_shm_ack_handler() [all …]
|
H A D | nxt_python.c | 20 nxt_unit_ctx_t *ctx; 37 static int nxt_python_ready_handler(nxt_unit_ctx_t *ctx); 39 static void nxt_python_join_threads(nxt_unit_ctx_t *ctx, 155 nxt_unit_ctx_t *unit_ctx; in nxt_python_start() 637 nxt_python_ready_handler(nxt_unit_ctx_t *ctx) in nxt_python_ready_handler() 674 nxt_unit_ctx_t *ctx; in nxt_python_thread_func() 712 nxt_python_join_threads(nxt_unit_ctx_t *ctx, nxt_python_app_conf_t *c) in nxt_python_join_threads()
|
H A D | nxt_python.h | 68 int (*run)(nxt_unit_ctx_t *ctx);
|
H A D | nxt_python_asgi.h | 68 int nxt_py_asgi_lifespan_shutdown(nxt_unit_ctx_t *ctx);
|
H A D | nxt_python_wsgi.c | 56 static int nxt_python_wsgi_run(nxt_unit_ctx_t *ctx); 281 nxt_python_wsgi_run(nxt_unit_ctx_t *ctx) in nxt_python_wsgi_run()
|
H A D | nxt_python_asgi_lifespan.c | 322 nxt_py_asgi_lifespan_shutdown(nxt_unit_ctx_t *ctx) in nxt_py_asgi_lifespan_shutdown()
|
/unit/src/java/ |
H A D | nxt_jni_Context.c | 130 nxt_unit_ctx_t *ctx; in nxt_java_Context_log() 151 nxt_unit_ctx_t *ctx; in nxt_java_Context_trace()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 27 nxt_unit_ctx_t *ctx; 94 static int nxt_perl_psgi_ready_handler(nxt_unit_ctx_t *ctx); 97 static void nxt_perl_psgi_join_threads(nxt_unit_ctx_t *ctx, 1134 nxt_unit_ctx_t *unit_ctx; in nxt_perl_psgi_start() 1264 nxt_perl_psgi_ready_handler(nxt_unit_ctx_t *ctx) in nxt_perl_psgi_ready_handler() 1303 nxt_unit_ctx_t *ctx; in nxt_perl_psgi_thread_func() 1382 nxt_perl_psgi_join_threads(nxt_unit_ctx_t *ctx, nxt_perl_app_conf_t *c) in nxt_perl_psgi_join_threads()
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 202 nxt_unit_ctx_t *unit_ctx; in nxt_wasm_start()
|