/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 | 62 nxt_unit_request_info_t *req; 103 static void nxt_php_request_handler(nxt_unit_request_info_t *req); 114 static void nxt_php_set_sptr(nxt_unit_request_info_t *req, const char *name, 118 static void nxt_php_set_cstr(nxt_unit_request_info_t *req, const char *name, 924 nxt_php_request_handler(nxt_unit_request_info_t *req) in nxt_php_request_handler() 1141 nxt_php_vcwd_chdir(nxt_unit_request_info_t *req, u_char *dir) 1190 nxt_unit_request_info_t *req; 1293 nxt_unit_request_info_t *req; 1404 nxt_php_set_sptr(nxt_unit_request_info_t *req, const char *name, 1419 nxt_php_set_str(nxt_unit_request_info_t *req, const char *name, [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; 960 nxt_unit_request_info_t **preq) in nxt_unit_process_msg() 1405 nxt_unit_request_info_t *req; in nxt_unit_process_req_body() 2538 nxt_unit_request_info_t * 2595 nxt_unit_request_info_t *req; in nxt_unit_buf_send_done() 4981 nxt_unit_request_info_t * 6477 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() 525 nxt_py_asgi_http_data_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_http_data_handler() 631 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 | 27 static void nxt_py_asgi_request_handler(nxt_unit_request_info_t *req); 28 static void nxt_py_asgi_close_handler(nxt_unit_request_info_t *req); 30 static PyObject *nxt_py_asgi_create_http_scope(nxt_unit_request_info_t *req); 411 nxt_py_asgi_request_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_request_handler() 562 nxt_py_asgi_close_handler(nxt_unit_request_info_t *req) in nxt_py_asgi_close_handler() 574 nxt_py_asgi_create_http_scope(nxt_unit_request_info_t *req) in nxt_py_asgi_create_http_scope() 1201 nxt_unit_request_info_t *req; in nxt_py_asgi_add_field() 1239 nxt_py_asgi_set_result_soon(nxt_unit_request_info_t *req, in nxt_py_asgi_set_result_soon() 1291 nxt_py_asgi_new_msg(nxt_unit_request_info_t *req, PyObject *type) in nxt_py_asgi_new_msg() 1318 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() 668 nxt_unit_request_info_t *req) in create_request() 686 nxt_unit_request_info_t *req) in create_response() 746 nxt_unit_request_info_t *req; in request_read() 795 nxt_unit_request_info_t *req; in response_send_headers() 939 nxt_unit_request_info_t *req; in response_write() 1012 nxt_unit_request_info_t *req; in response_end() 1046 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() 365 nxt_unit_request_info_t *req; in nxt_java_Response_addIntHeader() 425 nxt_unit_request_info_t *req; in nxt_java_Response_containsHeader() 466 nxt_unit_request_info_t *req; in nxt_java_Response_getHeader() 506 nxt_unit_request_info_t *req; in nxt_java_Response_getHeaderNames() 533 nxt_unit_request_info_t *req; in nxt_java_Response_getHeaders() 574 nxt_unit_request_info_t *req; in nxt_java_Response_getStatus() 595 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); 369 nxt_unit_request_info_t *req) in nxt_perl_psgi_call_method() 595 nxt_unit_request_info_t *req) in nxt_perl_psgi_env_create() 858 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body() 909 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body_ref() 977 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_body_fh() 1021 nxt_unit_request_info_t *req) in nxt_perl_psgi_result_array() [all …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 46 static void nxt_ruby_request_handler(nxt_unit_request_info_t *req); 63 static int nxt_ruby_rack_result_headers(nxt_unit_request_info_t *req, 67 static int nxt_ruby_rack_result_body(nxt_unit_request_info_t *req, 76 static void nxt_ruby_exception_log(nxt_unit_request_info_t *req, 657 nxt_ruby_request_handler(nxt_unit_request_info_t *req) in nxt_ruby_request_handler() 669 nxt_unit_request_info_t *req; in nxt_ruby_request_handler_gvl() 700 nxt_unit_request_info_t *req; in nxt_ruby_rack_app_run() 702 req = (nxt_unit_request_info_t *) arg; in nxt_ruby_rack_app_run() 858 nxt_unit_request_info_t *req; 1096 nxt_unit_request_info_t *req; [all …]
|
H A D | nxt_ruby.h | 30 nxt_unit_request_info_t *req;
|