Home
last modified time | relevance | path

Searched refs:r (Results 1 – 25 of 114) sorted by relevance

12345

/unit/src/
H A Dnxt_random.c41 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 Dnxt_http_error.c35 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 Dnxt_http_request.c89 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 Dnxt_http_rewrite.c38 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 Dnxt_http_proxy.c137 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 Dnxt_http_variables.c245 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 Dnxt_http_js.c118 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 Dnxt_http_return.c24 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 Dnxt_h1proto_websocket.c83 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 Dnxt_http_static.c280 &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 Dnxt_h1proto.c998 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 Dnxt_http_set_headers.c76 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 Dnxt_http_websocket.c35 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 Dnxt_php_sapi.c965 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 Dnxt_http.h248 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 Dresponse.go25 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 Drequest.go37 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 Dtest_access_log.py342 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 Dtest_variables.py85 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 Dtest_php_application.py92 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 Dnxt_jni_Request.c278 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 Dapp.go10 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 Dnxt_unit_app_test.c152 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 Dapp.go8 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 Dapp.go8 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"))

12345