Home
last modified time | relevance | path

Searched defs:r (Results 1 – 25 of 45) sorted by path

12

/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelGroupUtil.java117 public Thread newThread(final Runnable r) { in newThread()
131 private final Runnable r; field in AsyncChannelGroupUtil.AsyncIOThreadFactory.NewThreadPrivilegedAction
133 public NewThreadPrivilegedAction(Runnable r) { in NewThreadPrivilegedAction()
H A DAsyncChannelWrapperSecure.java195 SSLEngineResult r = sslEngine.wrap(src, socketWriteBuffer); in run() local
279 SSLEngineResult r = sslEngine.unwrap(socketReadBuffer, dest); in run() local
372 SSLEngineResult r = in run() local
390 SSLEngineResult r = in run() local
396 Runnable r = null; in run() local
569 public Thread newThread(Runnable r) { in newThread()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeText.java111 StringReader r = new StringReader(message); in decode() local
/unit/src/java/nginx/unit/websocket/server/
H A DUpgradeUtil.java79 Request r = (Request) request.getAttribute(Request.BARE); in isWebSocketUpgradeRequest() local
H A DWsHttpUpgradeHandler.java112 Request r = (Request) handshakeRequest.getAttribute(Request.BARE); in init() local
H A DWsRemoteEndpointImplServer.java127 OnResultRunnable r = new OnResultRunnable(sh, t); in clearHandler() local
/unit/src/java/
H A Dnxt_jni_Request.c278 nxt_unit_request_t *r; in nxt_java_Request_getHeader() local
303 nxt_unit_request_t *r; in nxt_java_Request_getHeaderNames() local
317 nxt_unit_request_t *r; in nxt_java_Request_getHeaders() local
348 nxt_unit_request_t *r; in nxt_java_Request_getIntHeader() local
384 nxt_unit_request_t *r; in nxt_java_Request_getMethod() local
396 nxt_unit_request_t *r; in nxt_java_Request_getQueryString() local
413 nxt_unit_request_t *r; in nxt_java_Request_getRequestURI() local
431 nxt_unit_request_t *r; in nxt_java_Request_getContentLength() local
443 nxt_unit_request_t *r; in nxt_java_Request_getContentType() local
460 nxt_unit_request_t *r; in nxt_java_Request_getLocalAddr() local
[all …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp588 nxt_unit_request_t *r; in create_headers() local
654 nxt_unit_request_t *r; in create_socket() local
1144 Unit::conn_destroy(napi_env env, void *r, void *finalize_hint) in conn_destroy()
1151 Unit::sock_destroy(napi_env env, void *r, void *finalize_hint) in sock_destroy()
1158 Unit::req_destroy(napi_env env, void *r, void *finalize_hint) in req_destroy()
1165 Unit::resp_destroy(napi_env env, void *r, void *finalize_hint) in resp_destroy()
/unit/src/
H A Dnxt_controller.c718 nxt_controller_request_t *r; in nxt_controller_conn_init() local
780 nxt_controller_request_t *r; in nxt_controller_conn_read() local
910 nxt_controller_request_t *r; in nxt_controller_conn_body_read() local
1041 nxt_controller_request_t *r; in nxt_controller_request_content_length() local
H A Dnxt_h1proto.c553 nxt_http_request_t *r; in nxt_h1p_conn_request_header_parse() local
649 nxt_http_request_t *r) in nxt_h1p_header_process()
751 nxt_http_request_t *r; in nxt_h1p_connection() local
779 nxt_http_request_t *r; in nxt_h1p_upgrade() local
796 nxt_http_request_t *r; in nxt_h1p_websocket_key() local
811 nxt_http_request_t *r; in nxt_h1p_websocket_version() local
829 nxt_http_request_t *r; in nxt_h1p_transfer_encoding() local
1032 nxt_http_request_t *r; in nxt_h1p_conn_request_body_read() local
1596 nxt_http_request_t *r; in nxt_h1p_conn_request_error() local
1627 nxt_http_request_t *r; in nxt_h1p_conn_request_timeout() local
[all …]
H A Dnxt_h1proto_websocket.c73 nxt_h1p_websocket_first_frame_start(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_websocket_first_frame_start()
117 nxt_h1p_websocket_frame_start(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_websocket_frame_start()
166 nxt_http_request_t *r; in nxt_h1p_conn_ws_keepalive() local
223 nxt_http_request_t *r; in nxt_h1p_conn_ws_frame_header_read() local
405 nxt_http_request_t *r; in nxt_h1p_conn_ws_frame_process() local
445 nxt_http_request_t *r; in nxt_h1p_conn_ws_error() local
501 nxt_http_request_t *r; in nxt_h1p_conn_ws_timeout() local
546 nxt_http_request_t *r; in nxt_h1p_conn_ws_frame_payload_read() local
578 hxt_h1p_send_ws_error(nxt_task_t *task, nxt_http_request_t *r, in hxt_h1p_send_ws_error()
635 nxt_http_request_t *r; in nxt_h1p_conn_ws_error_sent() local
[all …]
H A Dnxt_http_error.c28 nxt_http_request_error(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_error()
81 nxt_http_request_t *r; in nxt_http_request_send_error_body() local
H A Dnxt_http_js.c115 nxt_http_request_t *r; in nxt_http_js_ext_uri() local
131 nxt_http_request_t *r; in nxt_http_js_ext_host() local
147 nxt_http_request_t *r; in nxt_http_js_ext_remote_addr() local
168 nxt_http_request_t *r; in nxt_http_js_ext_get_args() local
198 nxt_http_request_t *r; in nxt_http_js_ext_get_header() local
234 nxt_http_request_t *r; in nxt_http_js_ext_keys_header() local
271 nxt_http_request_t *r; in nxt_http_js_ext_get_cookie() local
315 nxt_http_request_t *r; in nxt_http_js_ext_keys_cookie() local
361 nxt_http_request_t *r; in nxt_http_js_ext_get_var() local
H A Dnxt_http_proxy.c104 nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy()
118 nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_proxy_handler()
184 nxt_http_request_t *r; in nxt_http_proxy_upstream_error() local
206 nxt_http_request_t *r; in nxt_http_proxy_header_send() local
228 nxt_http_request_t *r; in nxt_http_proxy_header_sent() local
251 nxt_http_request_t *r; in nxt_http_proxy_header_read() local
297 nxt_http_request_t *r; in nxt_http_proxy_send_body() local
344 nxt_http_request_t *r; in nxt_http_proxy_buf_mem_completion() local
379 nxt_http_request_t *r; in nxt_http_proxy_error() local
395 nxt_http_request_t *r; in nxt_http_proxy_date() local
[all …]
H A Dnxt_http_request.c87 nxt_http_request_t *r; in nxt_http_request_host() local
204 nxt_http_request_t *r; in nxt_http_request_field() local
219 nxt_http_request_t *r; in nxt_http_request_content_length() local
250 nxt_http_request_t *r; in nxt_http_request_create() local
312 nxt_http_request_t *r; in nxt_http_request_start() local
547 nxt_http_request_t *r; in nxt_http_request_ready() local
758 nxt_http_request_t *r; in nxt_http_request_mem_buf_completion() local
775 nxt_http_buf_last(nxt_http_request_t *r) in nxt_http_buf_last()
789 nxt_http_request_t *r; in nxt_http_request_done() local
803 nxt_http_request_t *r; in nxt_http_request_error_handler() local
[all …]
H A Dnxt_http_response.c49 nxt_http_request_t *r; in nxt_http_response_status() local
80 nxt_http_request_t *r; in nxt_http_response_field() local
H A Dnxt_http_return.c75 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return()
181 nxt_http_request_t *r; in nxt_http_return_send_ready() local
222 nxt_http_request_t *r; in nxt_http_return_send_error() local
H A Dnxt_http_rewrite.c29 nxt_http_rewrite(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_rewrite()
H A Dnxt_http_route.c1317 nxt_http_pass_var(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_pass_var()
1367 nxt_http_request_t *r; in nxt_http_pass_query_ready() local
1392 nxt_http_request_t *r; in nxt_http_pass_query_error() local
1564 nxt_http_route_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_route_handler()
1604 nxt_http_route_match(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_route_match()
1693 nxt_http_route_rule(nxt_http_request_t *r, nxt_http_route_rule_t *rule) in nxt_http_route_rule()
1879 nxt_http_route_addr_rule(nxt_http_request_t *r, in nxt_http_route_addr_rule()
1919 nxt_http_route_header(nxt_http_request_t *r, nxt_http_route_rule_t *rule) in nxt_http_route_header()
1966 nxt_http_route_test_argument(nxt_http_request_t *r, in nxt_http_route_test_argument()
2015 nxt_http_route_query(nxt_http_request_t *r, nxt_http_route_rule_t *rule) in nxt_http_route_query()
[all …]
H A Dnxt_http_set_headers.c72 nxt_http_resp_header_find(nxt_http_request_t *r, u_char *name, size_t length) in nxt_http_resp_header_find()
95 nxt_http_set_headers(nxt_http_request_t *r) in nxt_http_set_headers()
H A Dnxt_http_static.c187 nxt_http_static(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static()
229 nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_iterate()
317 nxt_http_request_t *r; in nxt_http_static_send_ready() local
668 nxt_http_request_t *r; in nxt_http_static_send_error() local
677 nxt_http_static_next(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_next()
800 nxt_http_request_t *r; in nxt_http_static_body_handler() local
860 nxt_http_request_t *r; in nxt_http_static_buf_completion() local
H A Dnxt_http_variables.c243 nxt_http_request_t *r; in nxt_http_var_request_time() local
267 nxt_http_request_t *r; in nxt_http_var_method() local
281 nxt_http_request_t *r; in nxt_http_var_request_uri() local
294 nxt_http_request_t *r; in nxt_http_var_uri() local
307 nxt_http_request_t *r; in nxt_http_var_host() local
321 nxt_http_request_t *r; in nxt_http_var_remote_addr() local
335 nxt_http_request_t *r; in nxt_http_var_time_local() local
393 nxt_http_request_t *r; in nxt_http_var_request_line() local
408 nxt_http_request_t *r; in nxt_http_var_request_id() local
435 nxt_http_request_t *r; in nxt_http_var_body_bytes_sent() local
[all …]
H A Dnxt_http_websocket.c35 nxt_http_request_t *r; in nxt_http_websocket_client() local
129 nxt_http_request_t *r; in nxt_http_websocket_error_handler() local
H A Dnxt_php_sapi.c937 nxt_unit_request_t *r; in nxt_php_do_301() local
1011 nxt_unit_request_t *r; in nxt_php_request_handler() local
1040 nxt_php_dynamic_request(nxt_php_run_ctx_t *ctx, nxt_unit_request_t *r) in nxt_php_dynamic_request()
1153 nxt_php_execute(nxt_php_run_ctx_t *ctx, nxt_unit_request_t *r)
1422 nxt_unit_request_t *r; local
H A Dnxt_port_rpc.c260 nxt_port_rpc_reg_t *r; in nxt_port_rpc_remove_from_peers() local

12