/unit/src/ |
H A D | nxt_unit.h | 125 void (*request_handler)(nxt_unit_request_info_t *req); 127 void (*data_handler)(nxt_unit_request_info_t *req); 133 void (*close_handler)(nxt_unit_request_info_t *req); 260 int nxt_unit_response_init(nxt_unit_request_info_t *req, 263 int nxt_unit_response_realloc(nxt_unit_request_info_t *req, 266 int nxt_unit_response_is_init(nxt_unit_request_info_t *req); 268 int nxt_unit_response_add_field(nxt_unit_request_info_t *req, 279 int nxt_unit_response_send(nxt_unit_request_info_t *req); 281 int nxt_unit_response_is_sent(nxt_unit_request_info_t *req); 288 int nxt_unit_response_upgrade(nxt_unit_request_info_t *req); [all …]
|
H A D | nxt_unit_websocket.h | 16 nxt_unit_request_info_t *req;
|
H A D | nxt_unit_typedefs.h | 15 typedef struct nxt_unit_request_info_s nxt_unit_request_info_t; typedef
|
H A D | nxt_php_sapi.c | 63 nxt_unit_request_info_t *req; 104 static nxt_int_t nxt_php_do_301(nxt_unit_request_info_t *req); 105 static nxt_int_t nxt_php_handle_fs_err(nxt_unit_request_info_t *req); 107 static void nxt_php_request_handler(nxt_unit_request_info_t *req); 932 nxt_php_do_301(nxt_unit_request_info_t *req) in nxt_php_do_301() 989 nxt_php_handle_fs_err(nxt_unit_request_info_t *req) in nxt_php_handle_fs_err() 1007 nxt_php_request_handler(nxt_unit_request_info_t *req) in nxt_php_request_handler() 1267 nxt_php_vcwd_chdir(nxt_unit_request_info_t *req, u_char *dir) 1320 nxt_unit_request_info_t *req; 1423 nxt_unit_request_info_t *req; [all …]
|
H A D | nxt_unit.c | 64 nxt_unit_request_info_t **preq); 195 nxt_unit_request_info_t *req); 213 nxt_unit_request_info_t *req; 247 nxt_unit_request_info_t req; 974 nxt_unit_request_info_t **preq) in nxt_unit_process_msg() 1419 nxt_unit_request_info_t *req; in nxt_unit_process_req_body() 2553 nxt_unit_request_info_t * 2610 nxt_unit_request_info_t *req; in nxt_unit_buf_send_done() 4996 nxt_unit_request_info_t * 6492 nxt_unit_request_info_t *req) in nxt_unit_request_hash_add() [all …]
|
/unit/src/python/ |
H A D | nxt_python_asgi.h | 13 void nxt_py_asgi_drain_wait(nxt_unit_request_info_t *req, 22 nxt_unit_request_info_t *req; 45 PyObject *nxt_py_asgi_set_result_soon(nxt_unit_request_info_t *req, 47 PyObject *nxt_py_asgi_new_msg(nxt_unit_request_info_t *req, PyObject *type); 48 PyObject *nxt_py_asgi_new_scope(nxt_unit_request_info_t *req, PyObject *type, 57 PyObject *nxt_py_asgi_http_create(nxt_unit_request_info_t *req); 58 void nxt_py_asgi_http_data_handler(nxt_unit_request_info_t *req); 60 void nxt_py_asgi_http_close_handler(nxt_unit_request_info_t *req); 63 PyObject *nxt_py_asgi_websocket_create(nxt_unit_request_info_t *req); 65 void nxt_py_asgi_websocket_close_handler(nxt_unit_request_info_t *req);
|
H A D | nxt_python_asgi_http.c | 20 nxt_unit_request_info_t *req; 89 nxt_py_asgi_http_create(nxt_unit_request_info_t *req) in nxt_py_asgi_http_create() 118 nxt_unit_request_info_t *req; in nxt_py_asgi_http_receive() 169 nxt_unit_request_info_t *req; in nxt_py_asgi_http_read_msg() 532 nxt_py_asgi_http_data_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_http_data_handler() 638 nxt_py_asgi_http_close_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_http_close_handler()
|
H A D | nxt_python_asgi.c | 29 static void nxt_py_asgi_request_handler(nxt_unit_request_info_t *req); 30 static void nxt_py_asgi_close_handler(nxt_unit_request_info_t *req); 32 static PyObject *nxt_py_asgi_create_http_scope(nxt_unit_request_info_t *req, 450 nxt_py_asgi_request_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_request_handler() 627 nxt_py_asgi_close_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_close_handler() 639 nxt_py_asgi_create_http_scope(nxt_unit_request_info_t *req, in nxt_py_asgi_create_http_scope() 1311 nxt_unit_request_info_t *req; in nxt_py_asgi_add_field() 1349 nxt_py_asgi_set_result_soon(nxt_unit_request_info_t *req, in nxt_py_asgi_set_result_soon() 1401 nxt_py_asgi_new_msg(nxt_unit_request_info_t *req, PyObject *type) in nxt_py_asgi_new_msg() 1428 nxt_py_asgi_new_scope(nxt_unit_request_info_t *req, PyObject *type, in nxt_py_asgi_new_scope() [all …]
|
/unit/src/nodejs/unit-http/ |
H A D | unit.h | 31 static void request_handler_cb(nxt_unit_request_info_t *req); 32 void request_handler(nxt_unit_request_info_t *req); 37 static void close_handler_cb(nxt_unit_request_info_t *req); 38 void close_handler(nxt_unit_request_info_t *req); 53 nxt_unit_request_info_t *req); 56 nxt_unit_request_info_t *req); 59 nxt_unit_request_info_t *req); 75 void create_headers(nxt_unit_request_info_t *req, napi_value request);
|
H A D | unit.cpp | 313 Unit::request_handler(nxt_unit_request_info_t *req) in request_handler() 388 Unit::close_handler_cb(nxt_unit_request_info_t *req) in close_handler_cb() 399 Unit::close_handler(nxt_unit_request_info_t *req) in close_handler() 675 nxt_unit_request_info_t *req) in create_request() 693 nxt_unit_request_info_t *req) in create_response() 753 nxt_unit_request_info_t *req; in request_read() 802 nxt_unit_request_info_t *req; in response_send_headers() 946 nxt_unit_request_info_t *req; in response_write() 1019 nxt_unit_request_info_t *req; in response_end() 1053 nxt_unit_request_info_t *req; in websocket_send_frame() [all …]
|
/unit/src/java/ |
H A D | nxt_jni_Response.c | 267 nxt_unit_request_info_t *req; in nxt_java_Response_addHeader() 302 static nxt_unit_request_info_t * 310 nxt_unit_request_info_t *req; in nxt_java_get_response_info() 366 nxt_unit_request_info_t *req; in nxt_java_Response_addIntHeader() 426 nxt_unit_request_info_t *req; in nxt_java_Response_containsHeader() 467 nxt_unit_request_info_t *req; in nxt_java_Response_getHeader() 507 nxt_unit_request_info_t *req; in nxt_java_Response_getHeaderNames() 534 nxt_unit_request_info_t *req; in nxt_java_Response_getHeaders() 575 nxt_unit_request_info_t *req; in nxt_java_Response_getStatus() 596 nxt_unit_request_info_t *req; in nxt_java_Response_getRequest() [all …]
|
H A D | nxt_jni_InputStream.c | 95 nxt_unit_request_info_t *req; in nxt_java_InputStream_readLine() 118 nxt_unit_request_info_t *req; in nxt_java_InputStream_isFinished() 131 nxt_unit_request_info_t *req; in nxt_java_InputStream_readByte() 147 nxt_unit_request_info_t *req; in nxt_java_InputStream_read() 168 nxt_unit_request_info_t *req; in nxt_java_InputStream_skip() 205 nxt_unit_request_info_t *req; in nxt_java_InputStream_available()
|
H A D | nxt_jni_OutputStream.c | 19 nxt_unit_request_info_t *req); 85 nxt_unit_request_info_t *req; in nxt_java_OutputStream_writeByte() 105 nxt_java_OutputStream_flush_buf(JNIEnv *env, nxt_unit_request_info_t *req) in nxt_java_OutputStream_flush_buf() 148 nxt_java_OutputStream_req_buf(JNIEnv *env, nxt_unit_request_info_t *req) in nxt_java_OutputStream_req_buf() 182 nxt_unit_request_info_t *req; in nxt_java_OutputStream_write() 220 nxt_unit_request_info_t *req; in nxt_java_OutputStream_flush()
|
H A D | nxt_jni_OutputStream.h | 15 int nxt_java_OutputStream_flush_buf(JNIEnv *env, nxt_unit_request_info_t *req);
|
H A D | nxt_jni_Response.h | 16 jobject nxt_java_newResponse(JNIEnv *env, nxt_unit_request_info_t *req);
|
H A D | nxt_jni_Request.h | 16 jobject nxt_java_newRequest(JNIEnv *env, jobject ctx, nxt_unit_request_info_t *req);
|
H A D | nxt_jni_Request.c | 264 nxt_java_newRequest(JNIEnv *env, jobject ctx, nxt_unit_request_info_t *req) in nxt_java_newRequest() 674 nxt_unit_request_info_t *req; in nxt_java_Request_upgrade() 689 nxt_unit_request_info_t *req; in nxt_java_Request_isUpgrade() 702 nxt_unit_request_info_t *req; in nxt_java_Request_log() 723 nxt_unit_request_info_t *req; in nxt_java_Request_trace() 742 nxt_unit_request_info_t *req; in nxt_java_Request_getResponse() 756 nxt_unit_request_info_t *req; in nxt_java_Request_sendWsFrameBuf() 774 nxt_unit_request_info_t *req; in nxt_java_Request_sendWsFrameArr() 797 nxt_unit_request_info_t *req; in nxt_java_Request_closeWs()
|
/unit/go/ |
H A D | nxt_cgo_lib.h | 23 ssize_t nxt_cgo_response_write(nxt_unit_request_info_t *req, 26 ssize_t nxt_cgo_request_read(nxt_unit_request_info_t *req,
|
H A D | request.go | 24 c_req *C.nxt_unit_request_info_t 41 func new_request(c_req *C.nxt_unit_request_info_t) (r *request, err error) { argument 107 func nxt_go_request_handler(c_req *C.nxt_unit_request_info_t) { argument 109 go func(c_req *C.nxt_unit_request_info_t, handler http.Handler) {
|
H A D | nxt_cgo_lib.c | 69 nxt_cgo_response_write(nxt_unit_request_info_t *req, uintptr_t start, in nxt_cgo_response_write() 77 nxt_cgo_request_read(nxt_unit_request_info_t *req, uintptr_t dst, in nxt_cgo_request_read()
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 32 static int ws_chat_root(nxt_unit_request_info_t *req); 47 ws_chat_request_handler(nxt_unit_request_info_t *req) in ws_chat_request_handler() 101 ws_chat_root(nxt_unit_request_info_t *req) in ws_chat_root() 145 nxt_unit_request_info_t *req; in ws_chat_broadcast() 186 ws_chat_close_handler(nxt_unit_request_info_t *req) in ws_chat_close_handler()
|
H A D | nxt_unit_websocket_echo.c | 17 ws_echo_request_handler(nxt_unit_request_info_t *req) in ws_echo_request_handler() 56 nxt_unit_request_info_t *req; in ws_echo_websocket_handler()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 25 nxt_unit_request_info_t *req; 63 nxt_unit_request_info_t *req); 83 nxt_unit_request_info_t *req); 89 nxt_unit_request_info_t *req); 370 nxt_unit_request_info_t *req) in nxt_perl_psgi_call_method() 596 nxt_unit_request_info_t *req) in nxt_perl_psgi_env_create() 859 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body() 910 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body_ref() 978 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body_fh() 1022 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_array() [all …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 45 static void nxt_ruby_request_handler(nxt_unit_request_info_t *req); 62 static int nxt_ruby_rack_result_headers(nxt_unit_request_info_t *req, 66 static int nxt_ruby_rack_result_body(nxt_unit_request_info_t *req, 75 static void nxt_ruby_exception_log(nxt_unit_request_info_t *req, 629 nxt_ruby_request_handler(nxt_unit_request_info_t *req) in nxt_ruby_request_handler() 641 nxt_unit_request_info_t *req; in nxt_ruby_request_handler_gvl() 672 nxt_unit_request_info_t *req; in nxt_ruby_rack_app_run() 674 req = (nxt_unit_request_info_t *) arg; in nxt_ruby_rack_app_run() 830 nxt_unit_request_info_t *req; 1139 nxt_unit_request_info_t *req; [all …]
|
H A D | nxt_ruby.h | 29 nxt_unit_request_info_t *req;
|