Lines Matching refs:task
18 static void nxt_http_proxy_server_get(nxt_task_t *task,
20 static void nxt_http_proxy_upstream_ready(nxt_task_t *task,
22 static void nxt_http_proxy_upstream_error(nxt_task_t *task,
24 static nxt_http_action_t *nxt_http_proxy(nxt_task_t *task,
26 static void nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data);
27 static void nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data);
28 static void nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data);
29 static void nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data);
30 static void nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj,
32 static void nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data);
104 nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy() argument
111 nxt_debug(task, "http proxy: \"%V\"", &u->name); in nxt_http_proxy()
113 return nxt_upstream_proxy_handler(task, r, u); in nxt_http_proxy()
118 nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_proxy_handler() argument
126 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_upstream_proxy_handler()
132 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_upstream_proxy_handler()
146 upstream->proto->get(task, us); in nxt_upstream_proxy_handler()
153 nxt_http_proxy_server_get(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_server_get() argument
162 us->state->ready(task, us); in nxt_http_proxy_server_get()
167 nxt_http_proxy_upstream_ready(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_upstream_ready() argument
177 nxt_http_proto[peer->protocol].peer_connect(task, peer); in nxt_http_proxy_upstream_ready()
182 nxt_http_proxy_upstream_error(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_upstream_error() argument
190 nxt_http_request_error(task, r, NXT_HTTP_BAD_GATEWAY); in nxt_http_proxy_upstream_error()
203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_send() argument
212 nxt_http_proto[peer->protocol].peer_header_send(task, peer); in nxt_http_proxy_header_send()
225 nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_sent() argument
234 nxt_http_proto[peer->protocol].peer_header_read(task, peer); in nxt_http_proxy_header_sent()
247 nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_read() argument
258 nxt_debug(task, "http proxy status: %d", peer->status); in nxt_http_proxy_header_read()
262 nxt_debug(task, "http proxy header: \"%*s: %*s\"", in nxt_http_proxy_header_read()
269 nxt_http_proxy_error(task, r, peer); in nxt_http_proxy_header_read()
280 nxt_http_request_header_send(task, r, nxt_http_proxy_send_body, peer); in nxt_http_proxy_header_read()
293 nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_send_body() argument
305 nxt_http_request_send(task, r, out); in nxt_http_proxy_send_body()
309 nxt_http_proto[peer->protocol].peer_read(task, peer); in nxt_http_proxy_send_body()
312 nxt_http_proto[peer->protocol].peer_close(task, peer); in nxt_http_proxy_send_body()
320 nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_alloc() argument
325 b = nxt_event_engine_buf_mem_alloc(task->thread->engine, size); in nxt_http_proxy_buf_mem_alloc()
332 nxt_http_request_error(task, r, NXT_HTTP_INTERNAL_SERVER_ERROR); in nxt_http_proxy_buf_mem_alloc()
340 nxt_http_proxy_buf_mem_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_buf_mem_completion() argument
354 nxt_http_proxy_buf_mem_free(task, r, b); in nxt_http_proxy_buf_mem_completion()
360 nxt_http_proto[peer->protocol].peer_read(task, peer); in nxt_http_proxy_buf_mem_completion()
366 nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_free() argument
369 nxt_event_engine_buf_mem_free(task->thread->engine, b); in nxt_http_proxy_buf_mem_free()
376 nxt_http_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_error() argument
384 nxt_http_proto[peer->protocol].peer_close(task, peer); in nxt_http_proxy_error()
388 nxt_http_request_error(&r->task, r, peer->status); in nxt_http_proxy_error()