Home
last modified time | relevance | path

Searched refs:ctx_data (Results 1 – 11 of 11) sorted by relevance

/unit/src/python/
H A Dnxt_python_asgi_lifespan.c18 nxt_py_asgi_ctx_data_t *ctx_data; member
73 nxt_py_asgi_lifespan_startup(nxt_py_asgi_ctx_data_t *ctx_data) in nxt_py_asgi_lifespan_startup() argument
102 ctx_data->target_lifespans = target_lifespans; in nxt_py_asgi_lifespan_startup()
157 lifespan->ctx_data = ctx_data; in nxt_py_asgi_lifespan_target_startup()
284 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_shutdown() local
286 ctx_data = ctx->data; in nxt_py_asgi_lifespan_shutdown()
297 nxt_unit_free(NULL, ctx_data->target_lifespans); in nxt_py_asgi_lifespan_shutdown()
307 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_target_shutdown() local
309 ctx_data = lifespan->ctx_data; in nxt_py_asgi_lifespan_target_shutdown()
365 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_receive() local
[all …]
H A Dnxt_python_asgi.c292 ctx_data->quit_future = obj; in nxt_python_asgi_ctx_data_alloc()
310 *pdata = ctx_data; in nxt_python_asgi_ctx_data_alloc()
330 ctx_data = data; in nxt_python_asgi_ctx_data_free()
358 ctx_data = ctx->data; in nxt_python_asgi_run()
387 ctx_data = ctx->data; in nxt_py_asgi_remove_reader()
521 ctx_data = req->ctx->data; in nxt_py_asgi_request_handler()
968 ctx_data = ctx->data; in nxt_py_asgi_add_reader()
1045 ctx_data = ctx->data; in nxt_py_asgi_quit()
1075 ctx_data = ctx->data; in nxt_py_asgi_shm_ack_handler()
1136 ctx_data = ctx->data; in nxt_py_asgi_port_read()
[all …]
H A Dnxt_python.c21 void *ctx_data; member
160 python_init.ctx_data = NULL; in nxt_python_start()
266 rc = nxt_py_proto.ctx_data_alloc(&python_init.ctx_data, 1); in nxt_python_start()
293 nxt_py_proto.ctx_data_free(python_init.ctx_data); in nxt_python_start()
305 if (python_init.ctx_data != NULL) { in nxt_python_start()
306 nxt_py_proto.ctx_data_free(python_init.ctx_data); in nxt_python_start()
497 res = nxt_py_proto.ctx_data_alloc(&ti->ctx_data, 0); in nxt_python_init_threads()
557 if (nxt_py_proto.startup(ti->ctx_data) != NXT_UNIT_OK) { in nxt_python_thread_func()
562 ctx = nxt_unit_ctx_alloc(ti->ctx, ti->ctx_data); in nxt_python_thread_func()
619 if (ti->ctx_data != NULL) { in nxt_python_join_threads()
[all …]
H A Dnxt_python_asgi.h46 nxt_py_asgi_ctx_data_t *ctx_data, PyObject *future, PyObject *result);
67 int nxt_py_asgi_lifespan_startup(nxt_py_asgi_ctx_data_t *ctx_data);
H A Dnxt_python_asgi_http.c117 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_http_receive() local
136 ctx_data = req->ctx->data; in nxt_py_asgi_http_receive()
138 future = PyObject_CallObject(ctx_data->loop_create_future, NULL); in nxt_py_asgi_http_receive()
150 return nxt_py_asgi_set_result_soon(req, ctx_data, future, msg); in nxt_py_asgi_http_receive()
363 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_http_response_body() local
401 ctx_data = http->req->ctx->data; in nxt_py_asgi_http_response_body()
414 future = PyObject_CallObject(ctx_data->loop_create_future, in nxt_py_asgi_http_response_body()
H A Dnxt_python_asgi_websocket.c140 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_websocket_receive() local
164 ctx_data = ws->req->ctx->data; in nxt_py_asgi_websocket_receive()
166 future = PyObject_CallObject(ctx_data->loop_create_future, NULL); in nxt_py_asgi_websocket_receive()
180 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
186 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
192 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
/unit/src/
H A Dnxt_unit.h166 void *ctx_data; /* Opaque pointer to user-defined data. */ member
H A Dnxt_java.c439 java_init.ctx_data = env; in nxt_java_start()
H A Dnxt_unit.c632 rc = nxt_unit_ctx_init(lib, &lib->main_ctx, init->ctx_data); in nxt_unit_create()
/unit/src/perl/
H A Dnxt_perl_psgi.c1168 perl_init.ctx_data = &pctx; in nxt_perl_psgi_start()
/unit/src/ruby/
H A Dnxt_ruby.c367 ruby_unit_init.ctx_data = &ruby_ctx; in nxt_ruby_start()