Lines Matching refs:r

25     nxt_http_request_t *r, nxt_http_action_t *action);
104 nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy() argument
113 return nxt_upstream_proxy_handler(task, r, u); in nxt_http_proxy()
118 nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_proxy_handler() argument
124 us = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_upstream_server_t)); in nxt_upstream_proxy_handler()
126 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_upstream_proxy_handler()
130 peer = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_http_peer_t)); in nxt_upstream_proxy_handler()
132 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_upstream_proxy_handler()
136 peer->request = r; in nxt_upstream_proxy_handler()
137 r->peer = peer; in nxt_upstream_proxy_handler()
139 nxt_mp_retain(r->mem_pool); in nxt_upstream_proxy_handler()
184 nxt_http_request_t *r; in nxt_http_proxy_upstream_error() local
186 r = us->peer.http->request; in nxt_http_proxy_upstream_error()
188 nxt_mp_release(r->mem_pool); in nxt_http_proxy_upstream_error()
190 nxt_http_request_error(task, r, NXT_HTTP_BAD_GATEWAY); in nxt_http_proxy_upstream_error()
206 nxt_http_request_t *r; in nxt_http_proxy_header_send() local
208 r = obj; in nxt_http_proxy_header_send()
210 r->state = &nxt_http_proxy_header_sent_state; in nxt_http_proxy_header_send()
228 nxt_http_request_t *r; in nxt_http_proxy_header_sent() local
230 r = obj; in nxt_http_proxy_header_sent()
232 r->state = &nxt_http_proxy_header_read_state; in nxt_http_proxy_header_sent()
251 nxt_http_request_t *r; in nxt_http_proxy_header_read() local
253 r = obj; in nxt_http_proxy_header_read()
256 r->status = peer->status; in nxt_http_proxy_header_read()
267 f = nxt_list_add(r->resp.fields); in nxt_http_proxy_header_read()
269 nxt_http_proxy_error(task, r, peer); in nxt_http_proxy_header_read()
278 r->state = &nxt_http_proxy_read_state; in nxt_http_proxy_header_read()
280 nxt_http_request_header_send(task, r, nxt_http_proxy_send_body, peer); in nxt_http_proxy_header_read()
297 nxt_http_request_t *r; in nxt_http_proxy_send_body() local
299 r = obj; in nxt_http_proxy_send_body()
305 nxt_http_request_send(task, r, out); in nxt_http_proxy_send_body()
314 nxt_mp_release(r->mem_pool); in nxt_http_proxy_send_body()
320 nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_alloc() argument
328 b->parent = r; in nxt_http_proxy_buf_mem_alloc()
329 nxt_mp_retain(r->mem_pool); in nxt_http_proxy_buf_mem_alloc()
332 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_http_proxy_buf_mem_alloc()
344 nxt_http_request_t *r; in nxt_http_proxy_buf_mem_completion() local
347 r = data; in nxt_http_proxy_buf_mem_completion()
349 peer = r->peer; in nxt_http_proxy_buf_mem_completion()
354 nxt_http_proxy_buf_mem_free(task, r, b); in nxt_http_proxy_buf_mem_completion()
366 nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_free() argument
371 nxt_mp_release(r->mem_pool); in nxt_http_proxy_buf_mem_free()
379 nxt_http_request_t *r; in nxt_http_proxy_error() local
381 r = obj; in nxt_http_proxy_error()
382 peer = r->peer; in nxt_http_proxy_error()
386 nxt_mp_release(r->mem_pool); in nxt_http_proxy_error()
388 nxt_http_request_error(&r->task, r, peer->status); in nxt_http_proxy_error()
395 nxt_http_request_t *r; in nxt_http_proxy_date() local
397 r = ctx; in nxt_http_proxy_date()
399 r->resp.date = field; in nxt_http_proxy_date()
410 nxt_http_request_t *r; in nxt_http_proxy_content_length() local
412 r = ctx; in nxt_http_proxy_content_length()
414 r->resp.content_length = field; in nxt_http_proxy_content_length()
419 r->resp.content_length_n = n; in nxt_http_proxy_content_length()