Home
last modified time | relevance | path

Searched refs:nxt_unit_ctx_t (Results 1 – 23 of 23) sorted by relevance

/unit/src/
H A Dnxt_unit.h97 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 Dnxt_unit.c79 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()
4533 nxt_unit_run(nxt_unit_ctx_t *ctx) in nxt_unit_run()
4850 nxt_unit_run_ctx(nxt_unit_ctx_t *ctx) in nxt_unit_run_ctx()
5096 nxt_unit_done(nxt_unit_ctx_t *ctx) in nxt_unit_done()
[all …]
H A Dnxt_unit_typedefs.h11 typedef struct nxt_unit_ctx_s nxt_unit_ctx_t; typedef
H A Dnxt_java.c39 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 Dnxt_php_sapi.c360 static nxt_unit_ctx_t *nxt_php_unit_ctx;
456 nxt_unit_ctx_t *unit_ctx; in nxt_php_start()
/unit/src/nodejs/unit-http/
H A Dunit.h40 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 Dunit.cpp20 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 Dnxt_cgo_lib.c13 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 Dport.go97 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 Dresponse.go105 func nxt_go_shm_ack_handler(ctx *C.nxt_unit_ctx_t) { argument
/unit/src/ruby/
H A Dnxt_ruby.h28 nxt_unit_ctx_t *ctx;
H A Dnxt_ruby.c47 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()
1261 nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx) in nxt_ruby_ready_handler()
1312 nxt_unit_ctx_t *ctx; in nxt_ruby_thread_func()
1412 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 Dnxt_unit_app_test.c34 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 Dnxt_unit_websocket_echo.c88 nxt_unit_ctx_t *ctx; in main()
H A Dnxt_unit_websocket_chat.c206 nxt_unit_ctx_t *ctx; in main()
/unit/src/python/
H A Dnxt_python_asgi.c23 static int nxt_python_asgi_run(nxt_unit_ctx_t *ctx);
25 static void nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx,
42 static void nxt_py_asgi_quit(nxt_unit_ctx_t *ctx);
43 static void nxt_py_asgi_shm_ack_handler(nxt_unit_ctx_t *ctx);
353 nxt_python_asgi_run(nxt_unit_ctx_t *ctx) in nxt_python_asgi_run()
934 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port()
958 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader()
1022 nxt_py_asgi_remove_port(nxt_unit_t *lib, nxt_unit_ctx_t *ctx, in nxt_py_asgi_remove_port()
1036 nxt_py_asgi_quit(nxt_unit_ctx_t *ctx) in nxt_py_asgi_quit()
1067 nxt_py_asgi_shm_ack_handler(nxt_unit_ctx_t *ctx) in nxt_py_asgi_shm_ack_handler()
[all …]
H A Dnxt_python.c20 nxt_unit_ctx_t *ctx;
35 static int nxt_python_ready_handler(nxt_unit_ctx_t *ctx);
37 static void nxt_python_join_threads(nxt_unit_ctx_t *ctx,
137 nxt_unit_ctx_t *unit_ctx; in nxt_python_start()
571 nxt_python_ready_handler(nxt_unit_ctx_t *ctx) in nxt_python_ready_handler()
608 nxt_unit_ctx_t *ctx; in nxt_python_thread_func()
646 nxt_python_join_threads(nxt_unit_ctx_t *ctx, nxt_python_app_conf_t *c) in nxt_python_join_threads()
H A Dnxt_python.h66 int (*run)(nxt_unit_ctx_t *ctx);
H A Dnxt_python_asgi.h68 int nxt_py_asgi_lifespan_shutdown(nxt_unit_ctx_t *ctx);
H A Dnxt_python_asgi_lifespan.c280 nxt_py_asgi_lifespan_shutdown(nxt_unit_ctx_t *ctx) in nxt_py_asgi_lifespan_shutdown()
H A Dnxt_python_wsgi.c56 static int nxt_python_wsgi_run(nxt_unit_ctx_t *ctx);
278 nxt_python_wsgi_run(nxt_unit_ctx_t *ctx) in nxt_python_wsgi_run()
/unit/src/java/
H A Dnxt_jni_Context.c130 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 Dnxt_perl_psgi.c27 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()