/unit/src/ |
H A D | nxt_random.c | 41 r->i = 0; in nxt_random_start_schedule() 42 r->j = 0; in nxt_random_start_schedule() 124 val = r->s[r->i]; in nxt_random_add() 127 r->s[r->i] = r->s[r->j]; in nxt_random_add() 128 r->s[r->j] = val; in nxt_random_add() 134 r->i--; in nxt_random_add() 136 r->j = r->i; in nxt_random_add() 166 si = r->s[r->i]; in nxt_random_byte() 169 sj = r->s[r->j]; in nxt_random_byte() 170 r->s[r->i] = sj; in nxt_random_byte() [all …]
|
H A D | nxt_http_error.c | 35 if (r->header_sent || r->error) { in nxt_http_request_error() 41 r->status = status; in nxt_http_request_error() 43 r->resp.fields = nxt_list_create(r->mem_pool, 8, sizeof(nxt_http_field_t)); in nxt_http_request_error() 55 r->resp.content_length = NULL; in nxt_http_request_error() 60 nxt_http_request_header_send(task, r, in nxt_http_request_error() 66 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_http_request_error() 81 nxt_http_request_t *r; in nxt_http_request_send_error_body() local 83 r = obj; in nxt_http_request_send_error_body() 93 r->status, r->status); in nxt_http_request_send_error_body() 95 out->next = nxt_http_buf_last(r); in nxt_http_request_send_error_body() [all …]
|
H A D | nxt_http_request.c | 89 r = ctx; in nxt_http_request_host() 206 r = ctx; in nxt_http_request_field() 221 r = ctx; in nxt_http_request_content_length() 289 return r; in nxt_http_request_create() 314 r = obj; in nxt_http_request_start() 549 r = obj; in nxt_http_request_ready() 600 r->server_name = r->host; in nxt_http_application_handler() 805 r = obj; in nxt_http_request_error_handler() 813 nxt_http_proto[r->protocol].discard(task, r, nxt_http_buf_last(r)); in nxt_http_request_error_handler() 849 if (r->body != NULL && nxt_buf_is_file(r->body) in nxt_http_request_close_handler() [all …]
|
H A D | nxt_http_rewrite.c | 38 action = r->action; in nxt_http_rewrite() 51 &r->tstr_cache, r, r->mem_pool); in nxt_http_rewrite() 65 rp.mem_pool = r->mem_pool; in nxt_http_rewrite() 80 if (r->args->length == 0) { in nxt_http_rewrite() 81 r->target = encoded_path; in nxt_http_rewrite() 93 nxt_memcpy(p, r->args->start, r->args->length); in nxt_http_rewrite() 95 r->target = target; in nxt_http_rewrite() 96 r->args->start = p; in nxt_http_rewrite() 99 r->path = nxt_mp_alloc(r->mem_pool, sizeof(nxt_str_t)); in nxt_http_rewrite() 104 *r->path = rp.path; in nxt_http_rewrite() [all …]
|
H A D | nxt_http_proxy.c | 137 r->peer = peer; in nxt_upstream_proxy_handler() 208 r = obj; in nxt_http_proxy_header_send() 230 r = obj; in nxt_http_proxy_header_sent() 253 r = obj; in nxt_http_proxy_header_read() 299 r = obj; in nxt_http_proxy_send_body() 347 r = data; in nxt_http_proxy_buf_mem_completion() 349 peer = r->peer; in nxt_http_proxy_buf_mem_completion() 381 r = obj; in nxt_http_proxy_error() 388 nxt_http_request_error(&r->task, r, peer->status); in nxt_http_proxy_error() 397 r = ctx; in nxt_http_proxy_date() [all …]
|
H A D | nxt_http_variables.c | 245 r = ctx; in nxt_http_var_request_time() 269 r = ctx; in nxt_http_var_method() 283 r = ctx; in nxt_http_var_request_uri() 296 r = ctx; in nxt_http_var_uri() 309 r = ctx; in nxt_http_var_host() 323 r = ctx; in nxt_http_var_remote_addr() 346 r = ctx; in nxt_http_var_time_local() 395 r = ctx; in nxt_http_var_request_line() 410 r = ctx; in nxt_http_var_request_id() 437 r = ctx; in nxt_http_var_body_bytes_sent() [all …]
|
H A D | nxt_http_js.c | 118 if (r == NULL) { in nxt_http_js_ext_uri() 134 if (r == NULL) { in nxt_http_js_ext_host() 150 if (r == NULL) { in nxt_http_js_ext_remote_addr() 171 if (r == NULL) { in nxt_http_js_ext_get_args() 179 r->args->start + r->args->length, args); in nxt_http_js_ext_get_args() 201 if (r == NULL) { in nxt_http_js_ext_get_header() 242 if (r == NULL) { in nxt_http_js_ext_keys_header() 275 if (r == NULL) { in nxt_http_js_ext_get_cookie() 324 if (r == NULL) { in nxt_http_js_ext_keys_cookie() 364 if (r == NULL) { in nxt_http_js_ext_get_var() [all …]
|
H A D | nxt_http_return.c | 24 nxt_http_request_t *r, nxt_http_action_t *action); 115 r->status = conf->status; in nxt_http_return() 116 r->resp.content_length_n = 0; in nxt_http_return() 123 nxt_http_return_send_ready(task, r, ctx); in nxt_http_return() 126 rtcf = r->conf->socket_conf->router_conf; in nxt_http_return() 129 &r->tstr_cache, r, r->mem_pool); in nxt_http_return() 181 nxt_http_request_t *r; in nxt_http_return_send_ready() local 184 r = obj; in nxt_http_return_send_ready() 207 r->state = &nxt_http_return_send_state; in nxt_http_return_send_ready() 222 nxt_http_request_t *r; in nxt_http_return_send_error() local [all …]
|
H A D | nxt_h1proto_websocket.c | 83 h1p = r->proto.h1; in nxt_h1p_websocket_first_frame_start() 176 r = h1p->request; in nxt_h1p_conn_ws_keepalive() 183 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_keepalive() 437 r->state->ready_handler(task, r, NULL); in nxt_h1p_conn_ws_frame_process() 456 r->state->error_handler(task, r, h1p); in nxt_h1p_conn_ws_error() 605 nxt_http_request_error_handler(task, r, r->proto.any); in hxt_h1p_send_ws_error() 637 r = data; in nxt_h1p_conn_ws_error_sent() 641 r->state->error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_error_sent() 656 r = obj; in nxt_h1p_conn_ws_pong() 670 nxt_http_request_error_handler(task, r, r->proto.any); in nxt_h1p_conn_ws_pong() [all …]
|
H A D | nxt_http_static.c | 280 &r->tstr_cache, r, r->mem_pool); in nxt_http_static_iterate() 322 r = obj; in nxt_http_static_send_ready() 618 encode = nxt_encode_uri(NULL, r->path->start, r->path->length); in nxt_http_static_send_ready() 637 p = nxt_cpymem(p, r->path->start, r->path->length); in nxt_http_static_send_ready() 644 nxt_memcpy(p, r->args->start, r->args->length); in nxt_http_static_send_ready() 670 r = obj; in nxt_http_static_send_error() 802 r = obj; in nxt_http_static_body_handler() 803 fb = r->out; in nxt_http_static_body_handler() 863 r = data; in nxt_http_static_buf_completion() 867 fb = r->out; in nxt_http_static_buf_completion() [all …]
|
H A D | nxt_h1proto.c | 998 r->state->ready_handler(task, r, NULL); in nxt_h1p_request_body_read() 1689 r->state->error_handler(task, r, h1p); in nxt_h1p_request_error() 2211 r->state->error_handler(task, r, peer); in nxt_h1p_peer_connect() 2239 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_connected() 2257 r->state->error_handler(task, r, peer); in nxt_h1p_peer_refused() 2407 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_header_sent() 2587 r->state->error_handler(task, r, peer); in nxt_h1p_peer_header_read_done() 2718 r->state->ready_handler(task, r, peer); in nxt_h1p_peer_body_process() 2762 r->state->error_handler(task, r, peer); in nxt_h1p_peer_error() 2786 r->state->error_handler(task, r, peer); in nxt_h1p_peer_send_timeout() [all …]
|
H A D | nxt_http_set_headers.c | 76 nxt_list_each(f, r->resp.fields) { in nxt_http_resp_header_find() 95 nxt_http_set_headers(nxt_http_request_t *r) in nxt_http_set_headers() argument 105 action = r->action; in nxt_http_set_headers() 111 if ((r->status < NXT_HTTP_OK || r->status >= NXT_HTTP_BAD_REQUEST)) { in nxt_http_set_headers() 115 rtcf = r->conf->socket_conf->router_conf; in nxt_http_set_headers() 120 value = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_str_t) * n); in nxt_http_set_headers() 136 ret = nxt_tstr_query_init(&r->tstr_query, rtcf->tstr_state, in nxt_http_set_headers() 137 &r->tstr_cache, r, r->mem_pool); in nxt_http_set_headers() 142 nxt_tstr_query(&r->task, r->tstr_query, hv->value, &value[i]); in nxt_http_set_headers() 144 if (nxt_slow_path(nxt_tstr_query_failed(r->tstr_query))) { in nxt_http_set_headers() [all …]
|
H A D | nxt_http_websocket.c | 35 nxt_http_request_t *r; in nxt_http_websocket_client() local 39 r = obj; in nxt_http_websocket_client() 40 req_rpc_data = r->req_rpc_data; in nxt_http_websocket_client() 50 wsh = (nxt_websocket_header_t *) r->ws_frame->mem.pos; in nxt_http_websocket_client() 60 b = r->ws_frame; in nxt_http_websocket_client() 95 r->ws_frame = next; in nxt_http_websocket_client() 109 b = r->ws_frame; in nxt_http_websocket_client() 122 nxt_http_request_ws_frame_start(task, r, r->ws_frame); in nxt_http_websocket_client() 129 nxt_http_request_t *r; in nxt_http_websocket_error_handler() local 134 r = obj; in nxt_http_websocket_error_handler() [all …]
|
H A D | nxt_php_sapi.c | 965 p = nxt_cpymem(p, nxt_unit_sptr_get(&r->path), r->path_length); in nxt_php_do_301() 1190 f = r->fields + r->content_type_field; 1196 f = r->fields + r->cookie_field; 1202 f = r->fields + r->authorization_field; 1451 nxt_php_set_sptr(req, "PHP_SELF", &r->path, r->path_length, 1491 nxt_php_set_sptr(req, "REQUEST_URI", &r->target, r->target_length, 1493 nxt_php_set_sptr(req, "QUERY_STRING", &r->query, r->query_length, 1505 if (r->tls) { 1509 f_end = r->fields + r->fields_count; 1518 f = r->fields + r->content_length_field; [all …]
|
H A D | nxt_http.h | 248 nxt_http_request_t *r, 266 void (*body_read)(nxt_task_t *task, nxt_http_request_t *r); 337 nxt_buf_t *nxt_http_buf_last(nxt_http_request_t *r); 348 nxt_array_t *nxt_http_arguments_parse(nxt_http_request_t *r); 349 nxt_array_t *nxt_http_cookies_parse(nxt_http_request_t *r); 369 nxt_int_t nxt_http_route_addr_rule(nxt_http_request_t *r, 373 nxt_int_t nxt_http_route_test_rule(nxt_http_request_t *r, 392 nxt_int_t nxt_http_set_headers(nxt_http_request_t *r); 406 nxt_http_request_t *r, nxt_http_action_t *action); 410 nxt_http_request_t *r, nxt_upstream_t *upstream); [all …]
|
/unit/go/ |
H A D | response.go | 25 return r.header 29 if !r.header_sent { 30 r.WriteHeader(http.StatusOK) 44 if r.ch == nil { 45 r.ch = make(chan int, 2) 48 wait_shm_ack(r.ch) 56 if r.header_sent { 60 r.header_sent = true 70 for k, vv := range r.header { 90 func (r *response) Flush() { [all …]
|
H A D | request.go | 37 func (r *request) Close() error { 53 r = &request{ 70 r.req.Body = r 73 r.req.TLS = &tls.ConnectionState{ } 74 r.req.URL.Scheme = "https" 77 r.req.URL.Scheme = "http" 88 r.req.Header.Add(n, v) 91 return r, nil 114 r, err := new_request(c_req) 117 handler.ServeHTTP(&r.resp, &r.req) [all …]
|
/unit/test/ |
H A D | test_access_log.py | 342 assert wait_for_record(r'^/foo$', 'access.log') is not None 344 assert search_in_file(r'^/$', 'access.log') is None 345 assert search_in_file(r'^/0$', 'access.log') is None 346 assert search_in_file(r'^/false$', 'access.log') is None 347 assert search_in_file(r'^/undefined$', 'access.log') is None 348 assert search_in_file(r'^/!$', 'access.log') is not None 349 assert search_in_file(r'^/!null$', 'access.log') is not None 350 assert search_in_file(r'^/1$', 'access.log') is not None 352 assert search_in_file(r'^/bar$', 'access.log') is None 368 assert search_in_file(r'^/foo_2$', 'access.log') is None [all …]
|
H A D | test_variables.py | 85 reg = r'^GET$' 90 reg = r'^POST$' 181 reg = r'^::1$' 192 assert search_in_file(r'/time_local', 'access.log') is None 208 reg = r'^GET \/r_line HTTP\/1\.1$' 217 assert search_in_file(r'/request_id', 'access.log') is None 239 reg = r'^418$' 338 assert search_in_file(r'^0$', 'access.log') is None 376 assert search_in_file(r'^0$', 'access.log') is None 403 assert search_in_file(r'^0$', 'access.log') is None [all …]
|
H A D | test_php_application.py | 92 r = check_opcache() 93 assert r['headers']['X-OPcache'] == val, 'opcache value' 217 errs = findall(r'Error in fastcgi_finish_request') 236 errs = findall(r'Error in fastcgi_finish_request') 638 r'012345', client.get()['body'] 653 r'012345', client.get()['body'] 861 r = check_opcache() 862 pid = r['headers']['X-Pid'] 865 r = client.get() 867 assert r['headers']['X-Pid'] != pid, 'new instance' [all …]
|
/unit/src/java/ |
H A D | nxt_jni_Request.c | 278 nxt_unit_request_t *r; in nxt_java_Request_getHeader() local 287 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeader() 307 return nxt_java_newHeaderNamesEnumeration(env, r->fields, r->fields_count); in nxt_java_Request_getHeaderNames() 326 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getHeaders() 332 f = r->fields + r->fields_count; in nxt_java_Request_getHeaders() 335 return nxt_java_newHeadersEnumeration(env, r->fields, r->fields_count, in nxt_java_Request_getHeaders() 359 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getIntHeader() 448 f = r->fields + r->content_type_field; in nxt_java_Request_getContentType() 606 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerName() 634 f = nxt_java_findHeader(r->fields, r->fields + r->fields_count, in nxt_java_Request_getServerPort() [all …]
|
/unit/test/go/variables/ |
H A D | app.go | 10 func handler(w http.ResponseWriter, r *http.Request) { 12 len, _ := r.Body.Read(buf[:]) 14 w.Header().Set("Request-Method", r.Method) 15 w.Header().Set("Request-Uri", r.RequestURI) 16 w.Header().Set("Server-Protocol", r.Proto) 17 w.Header().Set("Server-Protocol-Major", fmt.Sprintf("%v", r.ProtoMajor)) 18 w.Header().Set("Server-Protocol-Minor", fmt.Sprintf("%v", r.ProtoMinor)) 20 w.Header().Set("Content-Type", r.Header.Get("Content-Type")) 21 w.Header().Set("Custom-Header", r.Header.Get("Custom-Header")) 22 w.Header().Set("Http-Host", r.Header.Get("Host"))
|
/unit/src/test/ |
H A D | nxt_unit_app_test.c | 152 nxt_unit_request_t *r; in greeting_app_request_handler() local 181 r = req->request; in greeting_app_request_handler() 216 p = copy(p, nxt_unit_sptr_get(&r->method), r->method_length); in greeting_app_request_handler() 220 p = copy(p, nxt_unit_sptr_get(&r->version), r->version_length); in greeting_app_request_handler() 224 p = copy(p, nxt_unit_sptr_get(&r->remote), r->remote_length); in greeting_app_request_handler() 228 p = copy(p, nxt_unit_sptr_get(&r->local_addr), r->local_addr_length); in greeting_app_request_handler() 232 p = copy(p, nxt_unit_sptr_get(&r->target), r->target_length); in greeting_app_request_handler() 236 p = copy(p, nxt_unit_sptr_get(&r->path), r->path_length); in greeting_app_request_handler() 239 if (r->query.offset) { in greeting_app_request_handler() 241 p = copy(p, nxt_unit_sptr_get(&r->query), r->query_length); in greeting_app_request_handler() [all …]
|
/unit/test/go/post_variables/ |
H A D | app.go | 8 func handler(w http.ResponseWriter, r *http.Request) { 9 r.ParseForm() 11 w.Header().Set("X-Var-1", r.Form.Get("var1")) 12 w.Header().Set("X-Var-2", r.Form.Get("var2")) 13 w.Header().Set("X-Var-3", r.Form.Get("var3"))
|
/unit/test/go/get_variables/ |
H A D | app.go | 8 func handler(w http.ResponseWriter, r *http.Request) { 9 w.Header().Set("X-Var-1", r.URL.Query().Get("var1")) 10 w.Header().Set("X-Var-2", r.URL.Query().Get("var2")) 11 w.Header().Set("X-Var-3", r.URL.Query().Get("var3"))
|