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 ---