xref: /unit/src/nxt_http_proxy.c (revision 1589)
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);
241270Sigor@sysoev.ru static nxt_http_action_t *nxt_http_proxy_handler(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
531270Sigor@sysoev.ru nxt_http_proxy_create(nxt_mp_t *mp, nxt_http_action_t *action)
541270Sigor@sysoev.ru {
551394Sigor@sysoev.ru     nxt_str_t             name;
561394Sigor@sysoev.ru     nxt_sockaddr_t        *sa;
571394Sigor@sysoev.ru     nxt_upstream_t        *up;
581394Sigor@sysoev.ru     nxt_upstream_proxy_t  *proxy;
591270Sigor@sysoev.ru 
601270Sigor@sysoev.ru     sa = NULL;
611270Sigor@sysoev.ru     name = action->name;
621270Sigor@sysoev.ru 
631270Sigor@sysoev.ru     if (nxt_str_start(&name, "http://", 7)) {
641270Sigor@sysoev.ru         name.length -= 7;
651270Sigor@sysoev.ru         name.start += 7;
661270Sigor@sysoev.ru 
671270Sigor@sysoev.ru         sa = nxt_sockaddr_parse(mp, &name);
681270Sigor@sysoev.ru         if (nxt_slow_path(sa == NULL)) {
691270Sigor@sysoev.ru             return NXT_ERROR;
701270Sigor@sysoev.ru         }
711270Sigor@sysoev.ru 
721270Sigor@sysoev.ru         sa->type = SOCK_STREAM;
731270Sigor@sysoev.ru     }
741270Sigor@sysoev.ru 
751270Sigor@sysoev.ru     if (sa != NULL) {
761394Sigor@sysoev.ru         up = nxt_mp_alloc(mp, sizeof(nxt_upstream_t));
771394Sigor@sysoev.ru         if (nxt_slow_path(up == NULL)) {
781270Sigor@sysoev.ru             return NXT_ERROR;
791270Sigor@sysoev.ru         }
801270Sigor@sysoev.ru 
811394Sigor@sysoev.ru         up->name.length = sa->length;
821394Sigor@sysoev.ru         up->name.start = nxt_sockaddr_start(sa);
831394Sigor@sysoev.ru         up->proto = &nxt_upstream_simple_proto;
841270Sigor@sysoev.ru 
851394Sigor@sysoev.ru         proxy = nxt_mp_alloc(mp, sizeof(nxt_upstream_proxy_t));
861394Sigor@sysoev.ru         if (nxt_slow_path(proxy == NULL)) {
871394Sigor@sysoev.ru             return NXT_ERROR;
881394Sigor@sysoev.ru         }
891394Sigor@sysoev.ru 
901394Sigor@sysoev.ru         proxy->sockaddr = sa;
911394Sigor@sysoev.ru         proxy->protocol = NXT_HTTP_PROTO_H1;
921394Sigor@sysoev.ru         up->type.proxy = proxy;
931394Sigor@sysoev.ru 
941394Sigor@sysoev.ru         action->u.upstream = up;
951270Sigor@sysoev.ru         action->handler = nxt_http_proxy_handler;
961270Sigor@sysoev.ru     }
971270Sigor@sysoev.ru 
981270Sigor@sysoev.ru     return NXT_OK;
991270Sigor@sysoev.ru }
1001270Sigor@sysoev.ru 
1011270Sigor@sysoev.ru 
1021270Sigor@sysoev.ru static nxt_http_action_t *
1031270Sigor@sysoev.ru nxt_http_proxy_handler(nxt_task_t *task, nxt_http_request_t *r,
1041270Sigor@sysoev.ru     nxt_http_action_t *action)
1051270Sigor@sysoev.ru {
1061394Sigor@sysoev.ru     return nxt_upstream_proxy_handler(task, r, action->u.upstream);
1071394Sigor@sysoev.ru }
1081394Sigor@sysoev.ru 
1091394Sigor@sysoev.ru 
1101394Sigor@sysoev.ru nxt_http_action_t *
1111394Sigor@sysoev.ru nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r,
1121394Sigor@sysoev.ru     nxt_upstream_t *upstream)
1131394Sigor@sysoev.ru {
1141394Sigor@sysoev.ru     nxt_http_peer_t        *peer;
1151394Sigor@sysoev.ru     nxt_upstream_server_t  *us;
1161394Sigor@sysoev.ru 
1171394Sigor@sysoev.ru     us = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_upstream_server_t));
1181394Sigor@sysoev.ru     if (nxt_slow_path(us == NULL)) {
1191394Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
1201394Sigor@sysoev.ru         return NULL;
1211394Sigor@sysoev.ru     }
1221270Sigor@sysoev.ru 
1231270Sigor@sysoev.ru     peer = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_http_peer_t));
1241270Sigor@sysoev.ru     if (nxt_slow_path(peer == NULL)) {
1251270Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
1261270Sigor@sysoev.ru         return NULL;
1271270Sigor@sysoev.ru     }
1281270Sigor@sysoev.ru 
1291270Sigor@sysoev.ru     peer->request = r;
1301270Sigor@sysoev.ru     r->peer = peer;
1311270Sigor@sysoev.ru 
1321270Sigor@sysoev.ru     nxt_mp_retain(r->mem_pool);
1331270Sigor@sysoev.ru 
1341394Sigor@sysoev.ru     us->state = &nxt_upstream_proxy_state;
1351394Sigor@sysoev.ru     us->peer.http = peer;
1361394Sigor@sysoev.ru     peer->server = us;
1371394Sigor@sysoev.ru 
1381394Sigor@sysoev.ru     us->upstream = upstream;
1391394Sigor@sysoev.ru     upstream->proto->get(task, us);
1401270Sigor@sysoev.ru 
1411270Sigor@sysoev.ru     return NULL;
1421270Sigor@sysoev.ru }
1431270Sigor@sysoev.ru 
1441270Sigor@sysoev.ru 
1451270Sigor@sysoev.ru static void
1461394Sigor@sysoev.ru nxt_http_proxy_server_get(nxt_task_t *task, nxt_upstream_server_t *us)
1471270Sigor@sysoev.ru {
1481394Sigor@sysoev.ru     nxt_upstream_proxy_t  *proxy;
1491394Sigor@sysoev.ru 
1501394Sigor@sysoev.ru     proxy = us->upstream->type.proxy;
1511394Sigor@sysoev.ru 
1521394Sigor@sysoev.ru     us->sockaddr = proxy->sockaddr;
1531394Sigor@sysoev.ru     us->protocol = proxy->protocol;
1541394Sigor@sysoev.ru 
1551394Sigor@sysoev.ru     us->state->ready(task, us);
1561394Sigor@sysoev.ru }
1571394Sigor@sysoev.ru 
1581394Sigor@sysoev.ru 
1591394Sigor@sysoev.ru static void
1601394Sigor@sysoev.ru nxt_http_proxy_upstream_ready(nxt_task_t *task, nxt_upstream_server_t *us)
1611394Sigor@sysoev.ru {
1621394Sigor@sysoev.ru     nxt_http_peer_t  *peer;
1631394Sigor@sysoev.ru 
1641394Sigor@sysoev.ru     peer = us->peer.http;
1651394Sigor@sysoev.ru 
1661394Sigor@sysoev.ru     peer->protocol = us->protocol;
1671270Sigor@sysoev.ru 
1681270Sigor@sysoev.ru     peer->request->state = &nxt_http_proxy_header_send_state;
1691270Sigor@sysoev.ru 
1701270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_connect(task, peer);
1711270Sigor@sysoev.ru }
1721270Sigor@sysoev.ru 
1731270Sigor@sysoev.ru 
1741394Sigor@sysoev.ru static void
1751394Sigor@sysoev.ru nxt_http_proxy_upstream_error(nxt_task_t *task, nxt_upstream_server_t *us)
1761394Sigor@sysoev.ru {
1771394Sigor@sysoev.ru     nxt_http_request_t  *r;
1781394Sigor@sysoev.ru 
1791394Sigor@sysoev.ru     r = us->peer.http->request;
1801394Sigor@sysoev.ru 
1811394Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
1821394Sigor@sysoev.ru 
1831394Sigor@sysoev.ru     nxt_http_request_error(task, r, NXT_HTTP_BAD_GATEWAY);
1841394Sigor@sysoev.ru }
1851394Sigor@sysoev.ru 
1861394Sigor@sysoev.ru 
1871270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_send_state
1881270Sigor@sysoev.ru     nxt_aligned(64) =
1891270Sigor@sysoev.ru {
1901270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_send,
1911270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
1921270Sigor@sysoev.ru };
1931270Sigor@sysoev.ru 
1941270Sigor@sysoev.ru 
1951270Sigor@sysoev.ru static void
1961270Sigor@sysoev.ru nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data)
1971270Sigor@sysoev.ru {
1981270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
1991270Sigor@sysoev.ru     nxt_http_request_t  *r;
2001270Sigor@sysoev.ru 
2011270Sigor@sysoev.ru     r = obj;
2021270Sigor@sysoev.ru     peer = data;
2031270Sigor@sysoev.ru     r->state = &nxt_http_proxy_header_sent_state;
2041270Sigor@sysoev.ru 
2051270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_header_send(task, peer);
2061270Sigor@sysoev.ru }
2071270Sigor@sysoev.ru 
2081270Sigor@sysoev.ru 
2091270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_sent_state
2101270Sigor@sysoev.ru     nxt_aligned(64) =
2111270Sigor@sysoev.ru {
2121270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_sent,
2131270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
2141270Sigor@sysoev.ru };
2151270Sigor@sysoev.ru 
2161270Sigor@sysoev.ru 
2171270Sigor@sysoev.ru static void
2181270Sigor@sysoev.ru nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data)
2191270Sigor@sysoev.ru {
2201270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2211270Sigor@sysoev.ru     nxt_http_request_t  *r;
2221270Sigor@sysoev.ru 
2231270Sigor@sysoev.ru     r = obj;
2241270Sigor@sysoev.ru     peer = data;
2251270Sigor@sysoev.ru     r->state = &nxt_http_proxy_header_read_state;
2261270Sigor@sysoev.ru 
2271270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_header_read(task, peer);
2281270Sigor@sysoev.ru }
2291270Sigor@sysoev.ru 
2301270Sigor@sysoev.ru 
2311270Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_header_read_state
2321270Sigor@sysoev.ru     nxt_aligned(64) =
2331270Sigor@sysoev.ru {
2341270Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_header_read,
2351270Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
2361270Sigor@sysoev.ru };
2371270Sigor@sysoev.ru 
2381270Sigor@sysoev.ru 
2391270Sigor@sysoev.ru static void
2401270Sigor@sysoev.ru nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data)
2411270Sigor@sysoev.ru {
2421270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2431270Sigor@sysoev.ru     nxt_http_field_t    *f, *field;
2441270Sigor@sysoev.ru     nxt_http_request_t  *r;
2451270Sigor@sysoev.ru 
2461270Sigor@sysoev.ru     r = obj;
2471270Sigor@sysoev.ru     peer = data;
2481270Sigor@sysoev.ru 
2491270Sigor@sysoev.ru     r->status = peer->status;
2501270Sigor@sysoev.ru 
2511270Sigor@sysoev.ru     nxt_debug(task, "http proxy status: %d", peer->status);
2521270Sigor@sysoev.ru 
2531270Sigor@sysoev.ru     nxt_list_each(field, peer->fields) {
2541270Sigor@sysoev.ru 
2551270Sigor@sysoev.ru         nxt_debug(task, "http proxy header: \"%*s: %*s\"",
2561270Sigor@sysoev.ru                   (size_t) field->name_length, field->name,
2571270Sigor@sysoev.ru                   (size_t) field->value_length, field->value);
2581270Sigor@sysoev.ru 
2591270Sigor@sysoev.ru         if (!field->skip) {
2601270Sigor@sysoev.ru             f = nxt_list_add(r->resp.fields);
2611270Sigor@sysoev.ru             if (nxt_slow_path(f == NULL)) {
2621270Sigor@sysoev.ru                 nxt_http_proxy_error(task, r, peer);
2631270Sigor@sysoev.ru                 return;
2641270Sigor@sysoev.ru             }
2651270Sigor@sysoev.ru 
2661270Sigor@sysoev.ru             *f = *field;
2671270Sigor@sysoev.ru         }
2681270Sigor@sysoev.ru 
2691270Sigor@sysoev.ru     } nxt_list_loop;
2701270Sigor@sysoev.ru 
2711505Sigor@sysoev.ru     r->state = &nxt_http_proxy_read_state;
2721505Sigor@sysoev.ru 
2731270Sigor@sysoev.ru     nxt_http_request_header_send(task, r, nxt_http_proxy_send_body, peer);
2741270Sigor@sysoev.ru }
2751270Sigor@sysoev.ru 
2761270Sigor@sysoev.ru 
277*1589Sigor@sysoev.ru static const nxt_http_request_state_t  nxt_http_proxy_read_state
278*1589Sigor@sysoev.ru     nxt_aligned(64) =
279*1589Sigor@sysoev.ru {
280*1589Sigor@sysoev.ru     .ready_handler = nxt_http_proxy_send_body,
281*1589Sigor@sysoev.ru     .error_handler = nxt_http_proxy_error,
282*1589Sigor@sysoev.ru };
283*1589Sigor@sysoev.ru 
284*1589Sigor@sysoev.ru 
2851270Sigor@sysoev.ru static void
2861270Sigor@sysoev.ru nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data)
2871270Sigor@sysoev.ru {
2881270Sigor@sysoev.ru     nxt_buf_t           *out;
2891270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
2901270Sigor@sysoev.ru     nxt_http_request_t  *r;
2911270Sigor@sysoev.ru 
2921270Sigor@sysoev.ru     r = obj;
2931270Sigor@sysoev.ru     peer = data;
2941270Sigor@sysoev.ru     out = peer->body;
2951270Sigor@sysoev.ru 
2961270Sigor@sysoev.ru     if (out != NULL) {
2971270Sigor@sysoev.ru         peer->body = NULL;
2981505Sigor@sysoev.ru         nxt_http_request_send(task, r, out);
2991505Sigor@sysoev.ru     }
3001270Sigor@sysoev.ru 
3011505Sigor@sysoev.ru     if (!peer->closed) {
3021270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_read(task, peer);
3031270Sigor@sysoev.ru 
3041270Sigor@sysoev.ru     } else {
3051270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_close(task, peer);
3061270Sigor@sysoev.ru 
3071270Sigor@sysoev.ru         nxt_mp_release(r->mem_pool);
3081270Sigor@sysoev.ru     }
3091270Sigor@sysoev.ru }
3101270Sigor@sysoev.ru 
3111270Sigor@sysoev.ru 
3121270Sigor@sysoev.ru nxt_buf_t *
3131270Sigor@sysoev.ru nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r,
3141270Sigor@sysoev.ru     size_t size)
3151270Sigor@sysoev.ru {
3161270Sigor@sysoev.ru     nxt_buf_t  *b;
3171270Sigor@sysoev.ru 
3181270Sigor@sysoev.ru     b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size);
3191270Sigor@sysoev.ru     if (nxt_fast_path(b != NULL)) {
3201270Sigor@sysoev.ru         b->completion_handler = nxt_http_proxy_buf_mem_completion;
3211270Sigor@sysoev.ru         b->parent = r;
3221270Sigor@sysoev.ru         nxt_mp_retain(r->mem_pool);
3231270Sigor@sysoev.ru 
3241270Sigor@sysoev.ru     } else {
3251270Sigor@sysoev.ru         nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR);
3261270Sigor@sysoev.ru     }
3271270Sigor@sysoev.ru 
3281270Sigor@sysoev.ru     return b;
3291270Sigor@sysoev.ru }
3301270Sigor@sysoev.ru 
3311270Sigor@sysoev.ru 
3321270Sigor@sysoev.ru static void
3331270Sigor@sysoev.ru nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj, void *data)
3341270Sigor@sysoev.ru {
3351270Sigor@sysoev.ru     nxt_buf_t           *b, *next;
3361270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
3371270Sigor@sysoev.ru     nxt_http_request_t  *r;
3381270Sigor@sysoev.ru 
3391270Sigor@sysoev.ru     b = obj;
3401270Sigor@sysoev.ru     r = data;
3411270Sigor@sysoev.ru 
3421270Sigor@sysoev.ru     peer = r->peer;
3431270Sigor@sysoev.ru 
3441270Sigor@sysoev.ru     do {
3451270Sigor@sysoev.ru         next = b->next;
3461270Sigor@sysoev.ru 
3471270Sigor@sysoev.ru         nxt_http_proxy_buf_mem_free(task, r, b);
3481270Sigor@sysoev.ru 
3491270Sigor@sysoev.ru         b = next;
3501270Sigor@sysoev.ru     } while (b != NULL);
3511270Sigor@sysoev.ru 
3521270Sigor@sysoev.ru     if (!peer->closed) {
3531270Sigor@sysoev.ru         nxt_http_proto[peer->protocol].peer_read(task, peer);
3541270Sigor@sysoev.ru     }
3551270Sigor@sysoev.ru }
3561270Sigor@sysoev.ru 
3571270Sigor@sysoev.ru 
3581270Sigor@sysoev.ru void
3591270Sigor@sysoev.ru nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r,
3601270Sigor@sysoev.ru     nxt_buf_t *b)
3611270Sigor@sysoev.ru {
3621270Sigor@sysoev.ru     nxt_event_engine_buf_mem_free(task->thread->engine, b);
3631270Sigor@sysoev.ru 
3641270Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
3651270Sigor@sysoev.ru }
3661270Sigor@sysoev.ru 
3671270Sigor@sysoev.ru 
3681270Sigor@sysoev.ru static void
3691270Sigor@sysoev.ru nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data)
3701270Sigor@sysoev.ru {
3711270Sigor@sysoev.ru     nxt_http_peer_t     *peer;
3721270Sigor@sysoev.ru     nxt_http_request_t  *r;
3731270Sigor@sysoev.ru 
3741270Sigor@sysoev.ru     r = obj;
3751270Sigor@sysoev.ru     peer = r->peer;
3761270Sigor@sysoev.ru 
3771270Sigor@sysoev.ru     nxt_http_proto[peer->protocol].peer_close(task, peer);
3781270Sigor@sysoev.ru 
3791270Sigor@sysoev.ru     nxt_mp_release(r->mem_pool);
3801270Sigor@sysoev.ru 
3811505Sigor@sysoev.ru     nxt_http_request_error(&r->task, r, peer->status);
3821270Sigor@sysoev.ru }
3831270Sigor@sysoev.ru 
3841270Sigor@sysoev.ru 
3851270Sigor@sysoev.ru nxt_int_t
3861270Sigor@sysoev.ru nxt_http_proxy_date(void *ctx, nxt_http_field_t *field, uintptr_t data)
3871270Sigor@sysoev.ru {
3881270Sigor@sysoev.ru     nxt_http_request_t  *r;
3891270Sigor@sysoev.ru 
3901270Sigor@sysoev.ru     r = ctx;
3911270Sigor@sysoev.ru 
3921270Sigor@sysoev.ru     r->resp.date = field;
3931270Sigor@sysoev.ru 
3941270Sigor@sysoev.ru     return NXT_OK;
3951270Sigor@sysoev.ru }
3961270Sigor@sysoev.ru 
3971270Sigor@sysoev.ru 
3981270Sigor@sysoev.ru nxt_int_t
3991270Sigor@sysoev.ru nxt_http_proxy_content_length(void *ctx, nxt_http_field_t *field,
4001270Sigor@sysoev.ru     uintptr_t data)
4011270Sigor@sysoev.ru {
4021270Sigor@sysoev.ru     nxt_off_t           n;
4031270Sigor@sysoev.ru     nxt_http_request_t  *r;
4041270Sigor@sysoev.ru 
4051270Sigor@sysoev.ru     r = ctx;
4061270Sigor@sysoev.ru 
4071270Sigor@sysoev.ru     r->resp.content_length = field;
4081270Sigor@sysoev.ru 
4091270Sigor@sysoev.ru     n = nxt_off_t_parse(field->value, field->value_length);
4101270Sigor@sysoev.ru 
4111270Sigor@sysoev.ru     if (nxt_fast_path(n >= 0)) {
4121270Sigor@sysoev.ru         r->resp.content_length_n = n;
4131270Sigor@sysoev.ru     }
4141270Sigor@sysoev.ru 
4151270Sigor@sysoev.ru     return NXT_OK;
4161270Sigor@sysoev.ru }
4171270Sigor@sysoev.ru 
4181270Sigor@sysoev.ru 
4191270Sigor@sysoev.ru nxt_int_t
4201270Sigor@sysoev.ru nxt_http_proxy_skip(void *ctx, nxt_http_field_t *field, uintptr_t data)
4211270Sigor@sysoev.ru {
4221270Sigor@sysoev.ru     field->skip = 1;
4231270Sigor@sysoev.ru 
4241270Sigor@sysoev.ru     return NXT_OK;
4251270Sigor@sysoev.ru }
426