Home
last modified time | relevance | path

Searched refs:ctx_data (Results 1 – 11 of 11) sorted by last modified time

/unit/src/
H A Dnxt_unit.h166 void *ctx_data; /* Opaque pointer to user-defined data. */ member
H A Dnxt_unit.c632 rc = nxt_unit_ctx_init(lib, &lib->main_ctx, init->ctx_data); in nxt_unit_create()
H A Dnxt_java.c439 java_init.ctx_data = env; in nxt_java_start()
/unit/src/python/
H A Dnxt_python_asgi_lifespan.c20 nxt_py_asgi_ctx_data_t *ctx_data; member
98 nxt_py_asgi_lifespan_startup(nxt_py_asgi_ctx_data_t *ctx_data) in nxt_py_asgi_lifespan_startup() argument
127 ctx_data->target_lifespans = target_lifespans; in nxt_py_asgi_lifespan_startup()
182 lifespan->ctx_data = ctx_data; in nxt_py_asgi_lifespan_target_startup()
326 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_shutdown() local
328 ctx_data = ctx->data; in nxt_py_asgi_lifespan_shutdown()
339 nxt_unit_free(NULL, ctx_data->target_lifespans); in nxt_py_asgi_lifespan_shutdown()
349 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_target_shutdown() local
351 ctx_data = lifespan->ctx_data; in nxt_py_asgi_lifespan_target_shutdown()
407 nxt_py_asgi_ctx_data_t *ctx_data; in nxt_py_asgi_lifespan_receive() local
[all …]
H A Dnxt_python_asgi.c329 ctx_data->quit_future = obj; in nxt_python_asgi_ctx_data_alloc()
347 *pdata = ctx_data; in nxt_python_asgi_ctx_data_alloc()
367 ctx_data = data; in nxt_python_asgi_ctx_data_free()
395 ctx_data = ctx->data; in nxt_python_asgi_run()
424 ctx_data = ctx->data; in nxt_py_asgi_remove_reader()
497 ctx_data = req->ctx->data; in nxt_py_asgi_request_handler()
1034 ctx_data = ctx->data; in nxt_py_asgi_add_reader()
1111 ctx_data = ctx->data; in nxt_py_asgi_quit()
1141 ctx_data = ctx->data; in nxt_py_asgi_shm_ack_handler()
1202 ctx_data = ctx->data; in nxt_py_asgi_port_read()
[all …]
H A Dnxt_python.c21 void *ctx_data; member
242 python_init.ctx_data = NULL; in nxt_python_start()
348 rc = nxt_py_proto.ctx_data_alloc(&python_init.ctx_data, 1); in nxt_python_start()
375 nxt_py_proto.ctx_data_free(python_init.ctx_data); in nxt_python_start()
387 if (python_init.ctx_data != NULL) { in nxt_python_start()
388 nxt_py_proto.ctx_data_free(python_init.ctx_data); in nxt_python_start()
626 res = nxt_py_proto.ctx_data_alloc(&ti->ctx_data, 0); in nxt_python_init_threads()
686 if (nxt_py_proto.startup(ti->ctx_data) != NXT_UNIT_OK) { in nxt_python_thread_func()
691 ctx = nxt_unit_ctx_alloc(ti->ctx, ti->ctx_data); in nxt_python_thread_func()
748 if (ti->ctx_data != NULL) { in nxt_python_join_threads()
[all …]
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()
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()
/unit/src/perl/
H A Dnxt_perl_psgi.c1169 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()