Deleted
Added
nxt_h1proto.c (1148:f93deb2432da) | nxt_h1proto.c (1155:8f70f87d0254) |
---|---|
1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_router.h> 8#include <nxt_http.h> --- 816 unchanged lines hidden (view full) --- 825 c->read_state = &nxt_h1p_read_body_state; 826 827 nxt_conn_read(task->thread->engine, c); 828 return; 829 } 830 831ready: 832 | 1 2/* 3 * Copyright (C) Igor Sysoev 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#include <nxt_router.h> 8#include <nxt_http.h> --- 816 unchanged lines hidden (view full) --- 825 c->read_state = &nxt_h1p_read_body_state; 826 827 nxt_conn_read(task->thread->engine, c); 828 return; 829 } 830 831ready: 832 |
833 nxt_work_queue_add(&task->thread->engine->fast_work_queue, 834 r->state->ready_handler, task, r, NULL); | 833 r->state->ready_handler(task, r, NULL); |
835 836 return; 837 838error: 839 840 h1p->keepalive = 0; 841 842 nxt_http_request_error(task, r, status); --- 36 unchanged lines hidden (view full) --- 879 880 if (size != 0) { 881 nxt_conn_read(engine, c); 882 883 } else { 884 c->read = NULL; 885 r = h1p->request; 886 | 834 835 return; 836 837error: 838 839 h1p->keepalive = 0; 840 841 nxt_http_request_error(task, r, status); --- 36 unchanged lines hidden (view full) --- 878 879 if (size != 0) { 880 nxt_conn_read(engine, c); 881 882 } else { 883 c->read = NULL; 884 r = h1p->request; 885 |
887 nxt_work_queue_add(&engine->fast_work_queue, r->state->ready_handler, 888 task, r, NULL); | 886 r->state->ready_handler(task, r, NULL); |
889 } 890} 891 892 893static void 894nxt_h1p_request_local_addr(nxt_task_t *task, nxt_http_request_t *r) 895{ 896 r->local = nxt_conn_local_addr(task, r->proto.h1->conn); --- 976 unchanged lines hidden --- | 887 } 888} 889 890 891static void 892nxt_h1p_request_local_addr(nxt_task_t *task, nxt_http_request_t *r) 893{ 894 r->local = nxt_conn_local_addr(task, r->proto.h1->conn); --- 976 unchanged lines hidden --- |