Home
last modified time | relevance | path

Searched refs:req (Results 1 – 25 of 77) sorted by relevance

1234

/unit/src/java/
H A Dnxt_jni_Response.c273 if (req == NULL) { in nxt_java_Response_addHeader()
319 data = req->data; in nxt_java_get_response_info()
347 rc = nxt_unit_response_realloc(req, 2 * req->response_max_fields, in nxt_java_get_response_info()
356 return req; in nxt_java_get_response_info()
371 if (req == NULL) { in nxt_java_Response_addIntHeader()
600 data = req->data; in nxt_java_Response_getRequest()
641 if (req == NULL) { in nxt_java_Response_sendRedirect()
928 data = req->data; in nxt_java_Response_reset()
953 data = req->data; in nxt_java_Response_resetBuffer()
969 data = req->data; in nxt_java_Response_setBufferSize()
[all …]
H A Dnxt_jni_InputStream.c95 nxt_unit_request_info_t *req; in nxt_java_InputStream_readLine() local
118 nxt_unit_request_info_t *req; in nxt_java_InputStream_isFinished() local
122 return req->content_length == 0; in nxt_java_InputStream_isFinished()
131 nxt_unit_request_info_t *req; in nxt_java_InputStream_readByte() local
147 nxt_unit_request_info_t *req; in nxt_java_InputStream_read() local
168 nxt_unit_request_info_t *req; in nxt_java_InputStream_skip() local
174 buf = req->content_buf; in nxt_java_InputStream_skip()
194 n = n < (jlong) req->content_length ? n : (jlong) req->content_length; in nxt_java_InputStream_skip()
196 req->content_length -= n; in nxt_java_InputStream_skip()
205 nxt_unit_request_info_t *req; in nxt_java_InputStream_available() local
[all …]
H A Dnxt_jni_OutputStream.c19 nxt_unit_request_info_t *req);
85 nxt_unit_request_info_t *req; in nxt_java_OutputStream_writeByte() local
88 req = nxt_jlong2ptr(req_info_ptr); in nxt_java_OutputStream_writeByte()
89 data = req->data; in nxt_java_OutputStream_writeByte()
110 data = req->data; in nxt_java_OutputStream_flush_buf()
154 data = req->data; in nxt_java_OutputStream_req_buf()
182 nxt_unit_request_info_t *req; in nxt_java_OutputStream_write() local
185 req = nxt_jlong2ptr(req_info_ptr); in nxt_java_OutputStream_write()
186 data = req->data; in nxt_java_OutputStream_write()
220 nxt_unit_request_info_t *req; in nxt_java_OutputStream_flush() local
[all …]
H A Dnxt_jni_Request.c268 nxt_ptr2jlong(req->request)); in nxt_java_newRequest()
674 nxt_unit_request_info_t *req; in nxt_java_Request_upgrade() local
689 nxt_unit_request_info_t *req; in nxt_java_Request_isUpgrade() local
702 nxt_unit_request_info_t *req; in nxt_java_Request_log() local
723 nxt_unit_request_info_t *req; in nxt_java_Request_trace() local
742 nxt_unit_request_info_t *req; in nxt_java_Request_getResponse() local
746 data = req->data; in nxt_java_Request_getResponse()
756 nxt_unit_request_info_t *req; in nxt_java_Request_sendWsFrameBuf() local
774 nxt_unit_request_info_t *req; in nxt_java_Request_sendWsFrameArr() local
797 nxt_unit_request_info_t *req; in nxt_java_Request_closeWs() local
[all …]
/unit/go/
H A Drequest.go22 req http.Request member
42 req := c_req.request
44 uri := GoStringN(&req.target, C.int(req.target_length))
51 proto := GoStringN(&req.version, C.int(req.version_length))
54 req: http.Request {
58 Method: GoStringN(&req.method, C.int(req.method_length)),
63 Host: GoStringN(&req.server_name, C.int(req.server_name_length)),
64 RemoteAddr: GoStringN(&req.remote, C.int(req.remote_length)),
70 r.req.Body = r
72 if req.tls != 0 {
[all …]
/unit/src/test/
H A Dnxt_unit_websocket_chat.c55 r = req->request; in ws_chat_request_handler()
60 rc = ws_chat_root(req); in ws_chat_request_handler()
74 data = req->data; in ws_chat_request_handler()
79 nxt_unit_response_upgrade(req); in ws_chat_request_handler()
80 nxt_unit_response_send(req); in ws_chat_request_handler()
96 nxt_unit_request_done(req, rc); in ws_chat_request_handler()
116 rc = nxt_unit_response_add_field(req, in ws_chat_root()
137 return nxt_unit_response_send(req); in ws_chat_root()
145 nxt_unit_request_info_t *req; in ws_chat_broadcast() local
171 data = ws->req->data; in ws_chat_websocket_handler()
[all …]
H A Dnxt_unit_websocket_echo.c17 ws_echo_request_handler(nxt_unit_request_info_t *req) in ws_echo_request_handler() argument
23 target = nxt_unit_sptr_get(&req->request->target); in ws_echo_request_handler()
26 if (!nxt_unit_request_is_websocket_handshake(req)) { in ws_echo_request_handler()
30 rc = nxt_unit_response_init(req, 101, 0, 0); in ws_echo_request_handler()
35 nxt_unit_response_upgrade(req); in ws_echo_request_handler()
36 nxt_unit_response_send(req); in ws_echo_request_handler()
43 rc = nxt_unit_response_init(req, 404, 0, 0); in ws_echo_request_handler()
47 nxt_unit_request_done(req, rc); in ws_echo_request_handler()
56 nxt_unit_request_info_t *req; in ws_echo_websocket_handler() local
66 req = ws->req; in ws_echo_websocket_handler()
[all …]
/unit/test/node/variables/
H A Dapp.js2 require('http').createServer(function (req, res) { argument
4 req.on('data', chunk => {
7 req.on('end', () => {
8 res.setHeader('Request-Method', req.method);
9 res.setHeader('Request-Uri', req.url);
10 res.setHeader('Server-Protocol', req.httpVersion);
11 res.setHeader('Request-Raw-Headers', req.rawHeaders.join());
13 res.setHeader('Content-Type', req.headers['content-type']);
14 res.setHeader('Custom-Header', req.headers['custom-header']);
15 res.setHeader('Http-Host', req.headers['host']);
/unit/src/
H A Dnxt_unit.h127 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,
279 int nxt_unit_response_send(nxt_unit_request_info_t *req);
369 #define nxt_unit_req_debug(req, fmt, ARGS...) \ argument
376 #define nxt_unit_req_debug(req, fmt, ARGS...) argument
384 #define nxt_unit_req_warn(req, fmt, ARGS...) \ argument
385 nxt_unit_req_log(req, NXT_UNIT_LOG_WARN, fmt, ##ARGS)
390 #define nxt_unit_req_error(req, fmt, ARGS...) \ argument
391 nxt_unit_req_log(req, NXT_UNIT_LOG_ERR, fmt, ##ARGS)
[all …]
H A Dnxt_unit.c1318 req = &req_impl->req; in nxt_unit_process_req_headers()
1340 b->req = req; in nxt_unit_process_req_headers()
1429 b->req = req; in nxt_unit_process_req_body()
1650 ws_impl->ws.req = req; in nxt_unit_process_websocket()
1656 b->req = req; in nxt_unit_process_websocket()
1677 b->req = req; in nxt_unit_process_websocket()
2427 mmap_buf->req = req; in nxt_unit_response_buf_alloc()
2574 req = mmap_buf->req; in nxt_unit_buf_send()
2614 req = mmap_buf->req; in nxt_unit_buf_send_done()
4814 req = &req_impl->req; in nxt_unit_process_ready_req()
[all …]
H A Dnxt_php_sapi.c63 nxt_unit_request_info_t *req; member
267 ctx->req = NULL; in PHP_FUNCTION()
939 r = req->request; in nxt_php_do_301()
1013 r = req->request; in nxt_php_request_handler()
1018 ctx.req = req; in nxt_php_request_handler()
1256 if (ctx->req != NULL) {
1320 nxt_unit_request_info_t *req; local
1323 req = ctx->req;
1423 nxt_unit_request_info_t *req; local
1427 req = ctx->req;
[all …]
H A Dnxt_controller.c1091 c = req->conn; in nxt_controller_process_request()
1285 c = req->conn; in nxt_controller_process_config()
1633 req = data; in nxt_controller_status_handler()
1720 c = req->conn; in nxt_controller_process_cert()
1879 req = data; in nxt_controller_process_cert_save()
1891 c = req->conn; in nxt_controller_process_cert_save()
1981 c = req->conn; in nxt_controller_process_script()
2145 req = data; in nxt_controller_process_script_save()
2157 c = req->conn; in nxt_controller_process_script_save()
2243 req = data; in nxt_controller_conf_handler()
[all …]
/unit/src/python/
H A Dnxt_python_asgi_http.c20 nxt_unit_request_info_t *req; member
96 http->req = req; in nxt_py_asgi_http_create()
118 nxt_unit_request_info_t *req; in nxt_py_asgi_http_receive() local
121 req = http->req; in nxt_py_asgi_http_receive()
136 ctx_data = req->ctx->data; in nxt_py_asgi_http_receive()
169 nxt_unit_request_info_t *req; in nxt_py_asgi_http_read_msg() local
171 req = http->req; in nxt_py_asgi_http_read_msg()
173 size = req->content_length; in nxt_py_asgi_http_read_msg()
335 add_field_ctx.req = http->req; in nxt_py_asgi_http_response_start()
530 http = req->data; in nxt_py_asgi_http_data_handler()
[all …]
H A Dnxt_python_asgi_websocket.c37 nxt_unit_request_info_t *req; member
122 ws->req = req; in nxt_py_asgi_websocket_create()
157 nxt_unit_req_error(ws->req, in nxt_py_asgi_websocket_receive()
164 ctx_data = ws->req->ctx->data; in nxt_py_asgi_websocket_receive()
323 add_field_ctx.req = ws->req; in nxt_py_asgi_websocket_accept()
497 ws = frame->req->data; in nxt_py_asgi_websocket_handler()
509 nxt_unit_req_debug(ws->req, in nxt_py_asgi_websocket_handler()
682 ws = frame->req->data; in nxt_py_asgi_websocket_suspend_frame()
698 nxt_unit_req_alert(ws->req, in nxt_py_asgi_websocket_suspend_frame()
766 nxt_unit_req_alert(ws->req, in nxt_py_asgi_websocket_pop_msg()
[all …]
H A Dnxt_python_asgi.h13 void nxt_py_asgi_drain_wait(nxt_unit_request_info_t *req,
22 nxt_unit_request_info_t *req; member
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 Dnxt_python_asgi.c458 if (req->request->websocket_handshake) { in nxt_py_asgi_request_handler()
462 asgi = nxt_py_asgi_http_create(req); in nxt_py_asgi_request_handler()
496 req->data = asgi; in nxt_py_asgi_request_handler()
497 ctx_data = req->ctx->data; in nxt_py_asgi_request_handler()
552 nxt_unit_req_error(req, in nxt_py_asgi_request_handler()
602 nxt_unit_req_error(req, in nxt_py_asgi_request_handler()
664 r = req->request; in nxt_py_asgi_create_http_scope()
1311 nxt_unit_request_info_t *req; in nxt_py_asgi_add_field() local
1321 req = ctx->req; in nxt_py_asgi_add_field()
1487 nxt_unit_req_alert(req, in nxt_py_asgi_new_scope()
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp308 obj->request_handler(req); in request_handler_cb()
394 obj->close_handler(req); in close_handler_cb()
589 r = req->request; in create_headers()
650 r = req->request; in create_socket()
669 nxt_unit_request_info_t *req) in create_request() argument
687 nxt_unit_request_info_t *req) in create_response() argument
747 nxt_unit_request_info_t *req; in request_read() local
796 nxt_unit_request_info_t *req; in response_send_headers() local
867 f = req->response->fields + req->response->fields_count; in response_send_headers()
893 f = req->response->fields + req->response->fields_count; in response_send_headers()
[all …]
H A Dunit.h31 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);
/unit/src/perl/
H A Dnxt_perl_psgi.c25 nxt_unit_request_info_t *req; member
232 if (pctx->req != NULL) { in nxt_perl_psgi_cb_request_done()
234 pctx->req = NULL; in nxt_perl_psgi_cb_request_done()
468 arg->req = req; in nxt_perl_psgi_io_init()
605 pctx = req->ctx->data; in nxt_perl_psgi_env_create()
620 r = req->request; in nxt_perl_psgi_env_create()
1103 pctx = req->ctx->data; in nxt_perl_psgi_result_cb()
1210 pctx = req->ctx->data; in nxt_perl_psgi_request_handler()
1213 pctx->req = req; in nxt_perl_psgi_request_handler()
1225 pctx->req = NULL; in nxt_perl_psgi_request_handler()
[all …]
/unit/test/
H A Dtest_upstreams_rr.py50 def get_resps(req=100, port=8080): argument
53 for _ in range(req):
72 req - 1
102 resps = get_resps(req=50)
121 resps = get_resps_sc(req=30)
139 resps = get_resps_sc(req=10)
210 resps = get_resps_sc(req=20)
228 resps = get_resps_sc(req=30)
298 req = 50
301 for i in range(req):
[all …]
H A Dtest_settings.py107 def req(): function
193 def req(): function
263 def req(addr, data_len): function
267 req = f"""GET / HTTP/1.1
274 sock.sendall(req.encode())
300 data = req(addr, data_len)
306 data = req(addr, data_len)
314 def req(): function
328 assert req()['status'] == 408, 'status idle timeout'
337 def req(): function
[all …]
/unit/src/ruby/
H A Dnxt_ruby.c292 ruby_ctx.req = NULL; in nxt_ruby_start()
643 req = data; in nxt_ruby_request_handler_gvl()
645 rctx = req->ctx->data; in nxt_ruby_request_handler_gvl()
646 rctx->req = req; in nxt_ruby_request_handler_gvl()
659 rctx->req = NULL; in nxt_ruby_request_handler_gvl()
676 rctx = req->ctx->data; in nxt_ruby_rack_app_run()
682 nxt_unit_req_alert(req, in nxt_ruby_rack_app_run()
690 nxt_unit_req_error(req, in nxt_ruby_rack_app_run()
742 r = req->request; in nxt_ruby_read_request()
856 headers_info.req = req; in nxt_ruby_rack_result_headers()
[all …]
/unit/src/wasm/
H A Dnxt_wasm.c36 nxt_unit_request_done(ctx->req, NXT_UNIT_OK); in nxt_wasm_do_response_end()
69 nxt_unit_response_send(ctx->req); in nxt_wasm_do_send_headers()
77 nxt_unit_request_info_t *req = ctx->req; in nxt_wasm_do_send_response() local
79 if (!nxt_unit_response_is_init(req)) { in nxt_wasm_do_send_response()
80 nxt_unit_response_init(req, ctx->status, 0, 0); in nxt_wasm_do_send_response()
85 nxt_unit_response_write(req, (const char *)resp->data, resp->size); in nxt_wasm_do_send_response()
90 nxt_wasm_request_handler(nxt_unit_request_info_t *req) in nxt_wasm_request_handler() argument
113 r = req->request; in nxt_wasm_request_handler()
159 nxt_wasm_ctx.req = req; in nxt_wasm_request_handler()
190 nxt_unit_response_init(req, NXT_WASM_HTTP_ERROR, 0, 0); in nxt_wasm_request_handler()
[all …]
/unit/test/node/mirror/
H A Dapp.js2 require('http').createServer(function (req, res) { argument
4 req.on('data', chunk => {
7 req.on('end', () => {
/unit/src/java/nginx/unit/websocket/server/
H A DWsFilter.java58 HttpServletRequest req = (HttpServletRequest) request; in doFilter() local
63 String pathInfo = req.getPathInfo(); in doFilter()
65 path = req.getServletPath(); in doFilter()
67 path = req.getServletPath() + pathInfo; in doFilter()
78 UpgradeUtil.doUpgrade(sc, req, resp, mappingResult.getConfig(), in doFilter()

1234