/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelGroupUtil.java | 117 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 D | AsyncChannelWrapperSecure.java | 195 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 D | PojoMessageHandlerWholeText.java | 111 StringReader r = new StringReader(message); in decode() local
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | UpgradeUtil.java | 79 Request r = (Request) request.getAttribute(Request.BARE); in isWebSocketUpgradeRequest() local
|
H A D | WsHttpUpgradeHandler.java | 112 Request r = (Request) handshakeRequest.getAttribute(Request.BARE); in init() local
|
H A D | WsRemoteEndpointImplServer.java | 127 OnResultRunnable r = new OnResultRunnable(sh, t); in clearHandler() local
|
/unit/src/java/ |
H A D | nxt_jni_Request.c | 278 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 D | unit.cpp | 588 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 D | nxt_controller.c | 718 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 D | nxt_h1proto.c | 553 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 D | nxt_h1proto_websocket.c | 73 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 D | nxt_http_error.c | 28 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 D | nxt_http_js.c | 115 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 D | nxt_http_proxy.c | 104 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 D | nxt_http_request.c | 87 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 D | nxt_http_response.c | 49 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 D | nxt_http_return.c | 75 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 D | nxt_http_rewrite.c | 29 nxt_http_rewrite(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_rewrite()
|
H A D | nxt_http_route.c | 1317 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 D | nxt_http_set_headers.c | 72 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 D | nxt_http_static.c | 187 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 D | nxt_http_variables.c | 243 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 D | nxt_http_websocket.c | 35 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 D | nxt_php_sapi.c | 937 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 D | nxt_port_rpc.c | 260 nxt_port_rpc_reg_t *r; in nxt_port_rpc_remove_from_peers() local
|