xref: /unit/src/nxt_http_proxy.c (revision 1924)
11270Sigor@sysoev.ru 
21270Sigor@sysoev.ru /*
31270Sigor@sysoev.ru  * Copyright (C) Igor Sysoev
41270Sigor@sysoev.ru  * Copyright (C) NGINX, Inc.
51270Sigor@sysoev.ru  */
61270Sigor@sysoev.ru 
71270Sigor@sysoev.ru #include <nxt_router.h>
81270Sigor@sysoev.ru #include <nxt_http.h>
91394Sigor@sysoev.ru #include <nxt_upstream.h>
101270Sigor@sysoev.ru 
111270Sigor@sysoev.ru 
121394Sigor@sysoev.ru struct nxt_upstream_proxy_s {
131394Sigor@sysoev.ru     nxt_sockaddr_t  *sockaddr;
141394Sigor@sysoev.ru     uint8_t         protocol;
151270Sigor@sysoev.ru };
161270Sigor@sysoev.ru 
171270Sigor@sysoev.ru 
181394Sigor@sysoev.ru static void nxt_http_proxy_server_get(nxt_task_t *task,
191394Sigor@sysoev.ru     nxt_upstream_server_t *us);
201394Sigor@sysoev.ru static void nxt_http_proxy_upstream_ready(nxt_task_t *task,
211394Sigor@sysoev.ru     nxt_upstream_server_t *us);
221394Sigor@sysoev.ru static void nxt_http_proxy_upstream_error(nxt_task_t *task,
231394Sigor@sysoev.ru     nxt_upstream_server_t *us);
24*1924Sz.hong@f5.com static nxt_http_action_t *nxt_http_proxy(nxt_task_t *task,
251270Sigor@sysoev.ru     nxt_http_request_t *r, nxt_http_action_t *action);
261270Sigor@sysoev.ru static void nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data);
271270Sigor@sysoev.ru static void nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data);
281270Sigor@sysoev.ru static void nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data);
291270Sigor@sysoev.ru static void nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data);
301270Sigor@sysoev.ru static void nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj,
311270Sigor@sysoev.ru     void *data);
321270Sigor@sysoev.ru static void nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data);
331270Sigor@sysoev.ru 
341270Sigor@sysoev.ru 
351270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_send_state;
361270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_sent_state;
371270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_read_state;
381270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_read_state;
391270Sigor@sysoev.ru 
401270Sigor@sysoev.ru 
411394Sigor@sysoev.ru static const nxt_upstream_server_proto_t  nxt_upstream_simple_proto = {
421394Sigor@sysoev.ru     .get = nxt_http_proxy_server_get,
431394Sigor@sysoev.ru };
441394Sigor@sysoev.ru 
451394Sigor@sysoev.ru 
461394Sigor@sysoev.ru static const nxt_upstream_peer_state_t  nxt_upstream_proxy_state = {
471394Sigor@sysoev.ru     .ready = nxt_http_proxy_upstream_ready,
481394Sigor@sysoev.ru     .error = nxt_http_proxy_upstream_error,
491394Sigor@sysoev.ru };
501394Sigor@sysoev.ru 
511394Sigor@sysoev.ru 
521270Sigor@sysoev.ru nxt_int_t
53*1924Sz.hong@f5.com nxt_http_proxy_init(nxt_mp_t *mp, nxt_http_action_t *action,
54*1924Sz.hong@f5.com     nxt_http_action_conf_t *acf)
551270Sigor@sysoev.ru {
561394Sigor@sysoev.ru     nxt_str_t             name;
571394Sigor@sysoev.ru     nxt_sockaddr_t        *sa;
581394Sigor@sysoev.ru     nxt_upstream_t        *up;
591394Sigor@sysoev.ru     nxt_upstream_proxy_t  *proxy;
601270Sigor@sysoev.ru 
611270Sigor@sysoev.ru     sa = NULL;
62*1924Sz.hong@f5.com     nxt_conf_get_string(acf->proxy, &name);
631270Sigor@sysoev.ru 
641270Sigor@sysoev.ru     if (nxt_str_start(&name, "http://", 7)) {
651270Sigor@sysoev.ru         name.length -= 7;
661270Sigor@sysoev.ru         name.start += 7;
671270Sigor@sysoev.ru 
681270Sigor@sysoev.ru         sa = nxt_sockaddr_parse(mp, &name);
691270Sigor@sysoev.ru         if (nxt_slow_path(sa == NULL)) {
701270Sigor@sysoev.ru             return NXT_ERROR;
711270Sigor@sysoev.ru         }
721270Sigor@sysoev.ru 
731270Sigor@sysoev.ru         sa->type = SOCK_STREAM;
741270Sigor@sysoev.ru     }
751270Sigor@sysoev.ru 
761270Sigor@sysoev.ru     if (sa != NULL) {
771394Sigor@sysoev.ru         up = nxt_mp_alloc(mp, sizeof(nxt_upstream_t));
781394Sigor@sysoev.ru         if (nxt_slow_path(up == NULL)) {
791270Sigor@sysoev.ru             return NXT_ERROR;
801270Sigor@sysoev.ru         }
811270Sigor@sysoev.ru 
821394Sigor@sysoev.ru         up->name.length = sa->length;
831394Sigor@sysoev.ru         up->name.start = nxt_sockaddr_start(sa);
841394Sigor@sysoev.ru         up->proto = &nxt_upstream_simple_proto;
851270Sigor@sysoev.ru 
861394Sigor@sysoev.ru         proxy = nxt_mp_alloc(mp, sizeof(nxt_upstream_proxy_t));
871394Sigor@sysoev.ru         if (nxt_slow_path(proxy == NULL)) {
881394Sigor@sysoev.ru             return NXT_ERROR;
891394Sigor@sysoev.ru         }
901394Sigor@sysoev.ru 
911394Sigor@sysoev.ru         proxy->sockaddr = sa;
921394Sigor@sysoev.ru         proxy->protocol = NXT_HTTP_PROTO_H1;
931394Sigor@sysoev.ru         up->type.proxy = proxy;
941394Sigor@sysoev.ru 
951394Sigor@sysoev.ru         action->u.upstream = up;
96*1924Sz.hong@f5.com         action->handler = nxt_http_proxy;
971270Sigor@sysoev.ru     }
981270Sigor@sysoev.ru 
991270Sigor@sysoev.ru     return NXT_OK;
1001270Sigor@sysoev.ru }
1011270Sigor@sysoev.ru 
1021270Sigor@sysoev.ru 
1031270Sigor@sysoev.ru static nxt_http_action_t *
104*1924Sz.hong@f5.com nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r,
1051270Sigor@sysoev.ru     nxt_http_action_t *action)
1061270Sigor@sysoev.ru {
107*1924Sz.hong@f5.com     nxt_upstream_t  *u;
108*1924Sz.hong@f5.com 
109*1924Sz.hong@f5.com     u = action->u.upstream;
110*1924Sz.hong@f5.com 
111*1924Sz.hong@f5.com     nxt_debug(task, "http proxy: \"%V\"", &u->name);
112*1924Sz.hong@f5.com 
113*1924Sz.hong@f5.com     return nxt_upstream_proxy_handler(task, r, u);
1141394Sigor@sysoev.ru }
1151394Sigor@sysoev.ru 
1161394Sigor@sysoev.ru 
1171394Sigor@sysoev.ru nxt_http_action_t *
1181394Sigor@sysoev.ru nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r,
1191394Sigor@sysoev.ru     nxt_upstream_t *upstream)
1201394Sigor@sysoev.ru {
1211394Sigor@sysoev.ru     nxt_http_peer_t        *peer;
1221394Sigor@sysoev.ru     nxt_upstream_server_t  *us;
1231394Sigor@sysoev.ru 
1241394Sigor@sysoev.ru     us = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_upstream_server_t));
1251394Sigor@sysoev.ru     if (nxt_slow_path(us == NULL)) {
1261394Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
1271394Sigor@sysoev.ru         return NULL;
1281394Sigor@sysoev.ru     }
1291270Sigor@sysoev.ru 
1301270Sigor@sysoev.ru     peer = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_http_peer_t));
1311270Sigor@sysoev.ru     if (nxt_slow_path(peer == NULL)) {
1321270Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
1331270Sigor@sysoev.ru         return NULL;
1341270Sigor@sysoev.ru     }
1351270Sigor@sysoev.ru 
1361270Sigor@sysoev.ru     peer->request = r;
1371270Sigor@sysoev.ru     r->peer = peer;
1381270Sigor@sysoev.ru 
1391270Sigor@sysoev.ru     nxt_mp_retain(r->mem_pool);
1401270Sigor@sysoev.ru 
1411394Sigor@sysoev.ru     us->state = &nxt_upstream_proxy_state;
1421394Sigor@sysoev.ru     us->peer.http = peer;
1431394Sigor@sysoev.ru     peer->server = us;
1441394Sigor@sysoev.ru 
1451394Sigor@sysoev.ru     us->upstream = upstream;
1461394Sigor@sysoev.ru     upstream->proto->get(task, us);
1471270Sigor@sysoev.ru 
1481270Sigor@sysoev.ru     return NULL;
1491270Sigor@sysoev.ru }
1501270Sigor@sysoev.ru 
1511270Sigor@sysoev.ru 
1521270Sigor@sysoev.ru static void
1531394Sigor@sysoev.ru nxt_http_proxy_server_get(nxt_task_t *task, nxt_upstream_server_t *us)
1541270Sigor@sysoev.ru {
1551394Sigor@sysoev.ru     nxt_upstream_proxy_t  *proxy;
1561394Sigor@sysoev.ru 
1571394Sigor@sysoev.ru     proxy = us->upstream->type.proxy;
1581394Sigor@sysoev.ru 
1591394Sigor@sysoev.ru     us->sockaddr = proxy->sockaddr;
1601394Sigor@sysoev.ru     us->protocol = proxy->protocol;
1611394Sigor@sysoev.ru 
1621394Sigor@sysoev.ru     us->state->ready(task, us);
1631394Sigor@sysoev.ru }
1641394Sigor@sysoev.ru 
1651394Sigor@sysoev.ru 
1661394Sigor@sysoev.ru static void
1671394Sigor@sysoev.ru nxt_http_proxy_upstream_ready(nxt_task_t *task, nxt_upstream_server_t *us)
1681394Sigor@sysoev.ru {
1691394Sigor@sysoev.ru     nxt_http_peer_t  *peer;
1701394Sigor@sysoev.ru 
1711394Sigor@sysoev.ru     peer = us->peer.http;
1721394Sigor@sysoev.ru 
1731394Sigor@sysoev.ru     peer->protocol = us->protocol;
1741270Sigor@sysoev.ru 
1751270Sigor@sysoev.ru     peer->request->state = &nxt_http_proxy_header_send_state;
1761270Sigor@sysoev.ru 
1771270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_connect(task, peer);
1781270Sigor@sysoev.ru }
1791270Sigor@sysoev.ru 
1801270Sigor@sysoev.ru 
1811394Sigor@sysoev.ru static void
1821394Sigor@sysoev.ru nxt_http_proxy_upstream_error(nxt_task_t *task, nxt_upstream_server_t *us)
1831394Sigor@sysoev.ru {
1841394Sigor@sysoev.ru     nxt_http_request_t  *r;
1851394Sigor@sysoev.ru 
1861394Sigor@sysoev.ru     r = us->peer.http->request;
1871394Sigor@sysoev.ru 
1881394Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
1891394Sigor@sysoev.ru 
1901394Sigor@sysoev.ru     nxt_http_request_error(task, r, NXT_HTTP_BAD_GATEWAY);
1911394Sigor@sysoev.ru }
1921394Sigor@sysoev.ru 
1931394Sigor@sysoev.ru 
1941270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_send_state
1951270Sigor@sysoev.ru     nxt_aligned(64) =
1961270Sigor@sysoev.ru {
1971270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_send,
1981270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
1991270Sigor@sysoev.ru };
2001270Sigor@sysoev.ru 
2011270Sigor@sysoev.ru 
2021270Sigor@sysoev.ru static void
2031270Sigor@sysoev.ru nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data)
2041270Sigor@sysoev.ru {
2051270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2061270Sigor@sysoev.ru     nxt_http_request_t  *r;
2071270Sigor@sysoev.ru 
2081270Sigor@sysoev.ru     r = obj;
2091270Sigor@sysoev.ru     peer = data;
2101270Sigor@sysoev.ru     r->state = &nxt_http_proxy_header_sent_state;
2111270Sigor@sysoev.ru 
2121270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_header_send(task, peer);
2131270Sigor@sysoev.ru }
2141270Sigor@sysoev.ru 
2151270Sigor@sysoev.ru 
2161270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_sent_state
2171270Sigor@sysoev.ru     nxt_aligned(64) =
2181270Sigor@sysoev.ru {
2191270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_sent,
2201270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
2211270Sigor@sysoev.ru };
2221270Sigor@sysoev.ru 
2231270Sigor@sysoev.ru 
2241270Sigor@sysoev.ru static void
2251270Sigor@sysoev.ru nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data)
2261270Sigor@sysoev.ru {
2271270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2281270Sigor@sysoev.ru     nxt_http_request_t  *r;
2291270Sigor@sysoev.ru 
2301270Sigor@sysoev.ru     r = obj;
2311270Sigor@sysoev.ru     peer = data;
2321270Sigor@sysoev.ru     r->state = &nxt_http_proxy_header_read_state;
2331270Sigor@sysoev.ru 
2341270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_header_read(task, peer);
2351270Sigor@sysoev.ru }
2361270Sigor@sysoev.ru 
2371270Sigor@sysoev.ru 
2381270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_read_state
2391270Sigor@sysoev.ru     nxt_aligned(64) =
2401270Sigor@sysoev.ru {
2411270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_read,
2421270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
2431270Sigor@sysoev.ru };
2441270Sigor@sysoev.ru 
2451270Sigor@sysoev.ru 
2461270Sigor@sysoev.ru static void
2471270Sigor@sysoev.ru nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data)
2481270Sigor@sysoev.ru {
2491270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2501270Sigor@sysoev.ru     nxt_http_field_t    *f, *field;
2511270Sigor@sysoev.ru     nxt_http_request_t  *r;
2521270Sigor@sysoev.ru 
2531270Sigor@sysoev.ru     r = obj;
2541270Sigor@sysoev.ru     peer = data;
2551270Sigor@sysoev.ru 
2561270Sigor@sysoev.ru     r->status = peer->status;
2571270Sigor@sysoev.ru 
2581270Sigor@sysoev.ru     nxt_debug(task, "http proxy status: %d", peer->status);
2591270Sigor@sysoev.ru 
2601270Sigor@sysoev.ru     nxt_list_each(field, peer->fields) {
2611270Sigor@sysoev.ru 
2621270Sigor@sysoev.ru         nxt_debug(task, "http proxy header: \"%*s: %*s\"",
2631270Sigor@sysoev.ru                   (size_t) field->name_length, field->name,
2641270Sigor@sysoev.ru                   (size_t) field->value_length, field->value);
2651270Sigor@sysoev.ru 
2661270Sigor@sysoev.ru         if (!field->skip) {
2671270Sigor@sysoev.ru             f = nxt_list_add(r->resp.fields);
2681270Sigor@sysoev.ru             if (nxt_slow_path(f == NULL)) {
2691270Sigor@sysoev.ru                 nxt_http_proxy_error(task, r, peer);
2701270Sigor@sysoev.ru                 return;
2711270Sigor@sysoev.ru             }
2721270Sigor@sysoev.ru 
2731270Sigor@sysoev.ru             *f = *field;
2741270Sigor@sysoev.ru         }
2751270Sigor@sysoev.ru 
2761270Sigor@sysoev.ru     } nxt_list_loop;
2771270Sigor@sysoev.ru 
2781505Sigor@sysoev.ru     r->state = &nxt_http_proxy_read_state;
2791505Sigor@sysoev.ru 
2801270Sigor@sysoev.ru     nxt_http_request_header_send(task, r, nxt_http_proxy_send_body, peer);
2811270Sigor@sysoev.ru }
2821270Sigor@sysoev.ru 
2831270Sigor@sysoev.ru 
2841589Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_read_state
2851589Sigor@sysoev.ru     nxt_aligned(64) =
2861589Sigor@sysoev.ru {
2871589Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_send_body,
2881589Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
2891589Sigor@sysoev.ru };
2901589Sigor@sysoev.ru 
2911589Sigor@sysoev.ru 
2921270Sigor@sysoev.ru static void
2931270Sigor@sysoev.ru nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data)
2941270Sigor@sysoev.ru {
2951270Sigor@sysoev.ru     nxt_buf_t           *out;
2961270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2971270Sigor@sysoev.ru     nxt_http_request_t  *r;
2981270Sigor@sysoev.ru 
2991270Sigor@sysoev.ru     r = obj;
3001270Sigor@sysoev.ru     peer = data;
3011270Sigor@sysoev.ru     out = peer->body;
3021270Sigor@sysoev.ru 
3031270Sigor@sysoev.ru     if (out != NULL) {
3041270Sigor@sysoev.ru         peer->body = NULL;
3051505Sigor@sysoev.ru         nxt_http_request_send(task, r, out);
3061505Sigor@sysoev.ru     }
3071270Sigor@sysoev.ru 
3081505Sigor@sysoev.ru     if (!peer->closed) {
3091270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_read(task, peer);
3101270Sigor@sysoev.ru 
3111270Sigor@sysoev.ru     } else {
3121270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_close(task, peer);
3131270Sigor@sysoev.ru 
3141270Sigor@sysoev.ru         nxt_mp_release(r->mem_pool);
3151270Sigor@sysoev.ru     }
3161270Sigor@sysoev.ru }
3171270Sigor@sysoev.ru 
3181270Sigor@sysoev.ru 
3191270Sigor@sysoev.ru nxt_buf_t *
3201270Sigor@sysoev.ru nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r,
3211270Sigor@sysoev.ru     size_t size)
3221270Sigor@sysoev.ru {
3231270Sigor@sysoev.ru     nxt_buf_t  *b;
3241270Sigor@sysoev.ru 
3251270Sigor@sysoev.ru     b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size);
3261270Sigor@sysoev.ru     if (nxt_fast_path(b != NULL)) {
3271270Sigor@sysoev.ru         b->completion_handler = nxt_http_proxy_buf_mem_completion;
3281270Sigor@sysoev.ru         b->parent = r;
3291270Sigor@sysoev.ru         nxt_mp_retain(r->mem_pool);
3301270Sigor@sysoev.ru 
3311270Sigor@sysoev.ru     } else {
3321270Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
3331270Sigor@sysoev.ru     }
3341270Sigor@sysoev.ru 
3351270Sigor@sysoev.ru     return b;
3361270Sigor@sysoev.ru }
3371270Sigor@sysoev.ru 
3381270Sigor@sysoev.ru 
3391270Sigor@sysoev.ru static void
3401270Sigor@sysoev.ru nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj, void *data)
3411270Sigor@sysoev.ru {
3421270Sigor@sysoev.ru     nxt_buf_t           *b, *next;
3431270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
3441270Sigor@sysoev.ru     nxt_http_request_t  *r;
3451270Sigor@sysoev.ru 
3461270Sigor@sysoev.ru     b = obj;
3471270Sigor@sysoev.ru     r = data;
3481270Sigor@sysoev.ru 
3491270Sigor@sysoev.ru     peer = r->peer;
3501270Sigor@sysoev.ru 
3511270Sigor@sysoev.ru     do {
3521270Sigor@sysoev.ru         next = b->next;
3531270Sigor@sysoev.ru 
3541270Sigor@sysoev.ru         nxt_http_proxy_buf_mem_free(task, r, b);
3551270Sigor@sysoev.ru 
3561270Sigor@sysoev.ru         b = next;
3571270Sigor@sysoev.ru     } while (b != NULL);
3581270Sigor@sysoev.ru 
3591270Sigor@sysoev.ru     if (!peer->closed) {
3601270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_read(task, peer);
3611270Sigor@sysoev.ru     }
3621270Sigor@sysoev.ru }
3631270Sigor@sysoev.ru 
3641270Sigor@sysoev.ru 
3651270Sigor@sysoev.ru void
3661270Sigor@sysoev.ru nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r,
3671270Sigor@sysoev.ru     nxt_buf_t *b)
3681270Sigor@sysoev.ru {
3691270Sigor@sysoev.ru     nxt_event_engine_buf_mem_free(task->thread->engine, b);
3701270Sigor@sysoev.ru 
3711270Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
3721270Sigor@sysoev.ru }
3731270Sigor@sysoev.ru 
3741270Sigor@sysoev.ru 
3751270Sigor@sysoev.ru static void
3761270Sigor@sysoev.ru nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data)
3771270Sigor@sysoev.ru {
3781270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
3791270Sigor@sysoev.ru     nxt_http_request_t  *r;
3801270Sigor@sysoev.ru 
3811270Sigor@sysoev.ru     r = obj;
3821270Sigor@sysoev.ru     peer = r->peer;
3831270Sigor@sysoev.ru 
3841270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_close(task, peer);
3851270Sigor@sysoev.ru 
3861270Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
3871270Sigor@sysoev.ru 
3881505Sigor@sysoev.ru     nxt_http_request_error(&r->task, r, peer->status);
3891270Sigor@sysoev.ru }
3901270Sigor@sysoev.ru 
3911270Sigor@sysoev.ru 
3921270Sigor@sysoev.ru nxt_int_t
3931270Sigor@sysoev.ru nxt_http_proxy_date(void *ctx, nxt_http_field_t *field, uintptr_t data)
3941270Sigor@sysoev.ru {
3951270Sigor@sysoev.ru     nxt_http_request_t  *r;
3961270Sigor@sysoev.ru 
3971270Sigor@sysoev.ru     r = ctx;
3981270Sigor@sysoev.ru 
3991270Sigor@sysoev.ru     r->resp.date = field;
4001270Sigor@sysoev.ru 
4011270Sigor@sysoev.ru     return NXT_OK;
4021270Sigor@sysoev.ru }
4031270Sigor@sysoev.ru 
4041270Sigor@sysoev.ru 
4051270Sigor@sysoev.ru nxt_int_t
4061270Sigor@sysoev.ru nxt_http_proxy_content_length(void *ctx, nxt_http_field_t *field,
4071270Sigor@sysoev.ru     uintptr_t data)
4081270Sigor@sysoev.ru {
4091270Sigor@sysoev.ru     nxt_off_t           n;
4101270Sigor@sysoev.ru     nxt_http_request_t  *r;
4111270Sigor@sysoev.ru 
4121270Sigor@sysoev.ru     r = ctx;
4131270Sigor@sysoev.ru 
4141270Sigor@sysoev.ru     r->resp.content_length = field;
4151270Sigor@sysoev.ru 
4161270Sigor@sysoev.ru     n = nxt_off_t_parse(field->value, field->value_length);
4171270Sigor@sysoev.ru 
4181270Sigor@sysoev.ru     if (nxt_fast_path(n >= 0)) {
4191270Sigor@sysoev.ru         r->resp.content_length_n = n;
4201270Sigor@sysoev.ru     }
4211270Sigor@sysoev.ru 
4221270Sigor@sysoev.ru     return NXT_OK;
4231270Sigor@sysoev.ru }
4241270Sigor@sysoev.ru 
4251270Sigor@sysoev.ru 
4261270Sigor@sysoev.ru nxt_int_t
4271270Sigor@sysoev.ru nxt_http_proxy_skip(void *ctx, nxt_http_field_t *field, uintptr_t data)
4281270Sigor@sysoev.ru {
4291270Sigor@sysoev.ru     field->skip = 1;
4301270Sigor@sysoev.ru 
4311270Sigor@sysoev.ru     return NXT_OK;
4321270Sigor@sysoev.ru }
433