nxt_application.h (421:b57f61ecf2ec) nxt_application.h (431:5817734dd9b9)
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#ifndef _NXT_APPLICATION_H_INCLUDED_

--- 101 unchanged lines hidden (view full) ---

110 nxt_app_request_header_t header;
111 nxt_app_request_body_t body;
112
113 nxt_str_t remote;
114 nxt_str_t local;
115} nxt_app_request_t;
116
117
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#ifndef _NXT_APPLICATION_H_INCLUDED_

--- 101 unchanged lines hidden (view full) ---

110 nxt_app_request_header_t header;
111 nxt_app_request_body_t body;
112
113 nxt_str_t remote;
114 nxt_str_t local;
115} nxt_app_request_t;
116
117
118typedef struct nxt_app_parse_ctx_s nxt_app_parse_ctx_t;
118typedef struct nxt_http_request_s nxt_http_request_t;
119
119
120typedef struct nxt_app_parse_ctx_s nxt_app_parse_ctx_t;
121
120struct nxt_app_parse_ctx_s {
121 nxt_app_request_t r;
122struct nxt_app_parse_ctx_s {
123 nxt_app_request_t r;
124 nxt_http_request_t *request;
125 nxt_timer_t timer;
122 nxt_http_request_parse_t parser;
126 nxt_http_request_parse_t parser;
127 nxt_http_request_parse_t resp_parser;
123 nxt_mp_t *mem_pool;
124};
125
126
128 nxt_mp_t *mem_pool;
129};
130
131
127nxt_app_parse_ctx_t *nxt_app_http_req_init(nxt_task_t *task);
128
129nxt_int_t nxt_app_http_req_header_parse(nxt_task_t *task,
130 nxt_app_parse_ctx_t *ctx, nxt_buf_t *buf);
131
132nxt_int_t nxt_app_http_req_body_read(nxt_task_t *task,
133 nxt_app_parse_ctx_t *ctx, nxt_buf_t *buf);
134
135
136nxt_int_t nxt_app_http_req_done(nxt_task_t *task, nxt_app_parse_ctx_t *ctx);
137
132nxt_int_t nxt_app_http_req_done(nxt_task_t *task, nxt_app_parse_ctx_t *ctx);
133
138nxt_int_t nxt_app_http_init(nxt_task_t *task, nxt_runtime_t *rt);
139
134
140
141typedef struct nxt_app_wmsg_s nxt_app_wmsg_t;
142typedef struct nxt_app_rmsg_s nxt_app_rmsg_t;
143
144struct nxt_app_wmsg_s {
145 nxt_port_t *port; /* where prepared buf will be sent */
146 nxt_buf_t *write;
147 nxt_buf_t **buf;
148 uint32_t stream;

--- 159 unchanged lines hidden ---
135typedef struct nxt_app_wmsg_s nxt_app_wmsg_t;
136typedef struct nxt_app_rmsg_s nxt_app_rmsg_t;
137
138struct nxt_app_wmsg_s {
139 nxt_port_t *port; /* where prepared buf will be sent */
140 nxt_buf_t *write;
141 nxt_buf_t **buf;
142 uint32_t stream;

--- 159 unchanged lines hidden ---