/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() 712 nxt_unit_ctx_use(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_use() 1230 nxt_unit_ctx_ready(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_ready() 4519 nxt_unit_run(nxt_unit_ctx_t *ctx) in nxt_unit_run() 4836 nxt_unit_run_ctx(nxt_unit_ctx_t *ctx) in nxt_unit_run_ctx() 5082 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 | 357 static nxt_unit_ctx_t *nxt_php_unit_ctx; 453 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 | 29 nxt_unit_ctx_t *ctx;
|
H A D | nxt_ruby.c | 48 static int nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx); 54 static void nxt_ruby_join_threads(nxt_unit_ctx_t *ctx, 266 nxt_unit_ctx_t *unit_ctx; in nxt_ruby_start() 1289 nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx) in nxt_ruby_ready_handler() 1340 nxt_unit_ctx_t *ctx; in nxt_ruby_thread_func() 1441 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 | 23 static int nxt_python_asgi_run(nxt_unit_ctx_t *ctx); 25 static void nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, 40 static void nxt_py_asgi_quit(nxt_unit_ctx_t *ctx); 41 static void nxt_py_asgi_shm_ack_handler(nxt_unit_ctx_t *ctx); 351 nxt_python_asgi_run(nxt_unit_ctx_t *ctx) in nxt_python_asgi_run() 892 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port() 916 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader() 980 nxt_py_asgi_remove_port(nxt_unit_t *lib, nxt_unit_ctx_t *ctx, in nxt_py_asgi_remove_port() 994 nxt_py_asgi_quit(nxt_unit_ctx_t *ctx) in nxt_py_asgi_quit() 1025 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; 31 static int nxt_python_ready_handler(nxt_unit_ctx_t *ctx); 33 static void nxt_python_join_threads(nxt_unit_ctx_t *ctx, 76 nxt_unit_ctx_t *unit_ctx; in nxt_python_start() 508 nxt_python_ready_handler(nxt_unit_ctx_t *ctx) in nxt_python_ready_handler() 545 nxt_unit_ctx_t *ctx; in nxt_python_thread_func() 583 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 | 66 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); 274 nxt_python_wsgi_run(nxt_unit_ctx_t *ctx) in nxt_python_wsgi_run()
|
H A D | nxt_python_asgi_lifespan.c | 280 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, 1133 nxt_unit_ctx_t *unit_ctx; in nxt_perl_psgi_start() 1263 nxt_perl_psgi_ready_handler(nxt_unit_ctx_t *ctx) in nxt_perl_psgi_ready_handler() 1302 nxt_unit_ctx_t *ctx; in nxt_perl_psgi_thread_func() 1381 nxt_perl_psgi_join_threads(nxt_unit_ctx_t *ctx, nxt_perl_app_conf_t *c) in nxt_perl_psgi_join_threads()
|