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