3 * Copyright (C) Igor Sysoev
7 #ifndef _NGX_EVENT_PIPE_H_INCLUDED_
8 #define _NGX_EVENT_PIPE_H_INCLUDED_
11 #include <ngx_config.h>
13 #include <ngx_event.h>
16 typedef struct ngx_event_pipe_s ngx_event_pipe_t;
18 typedef ngx_int_t (*ngx_event_pipe_input_filter_pt)(ngx_event_pipe_t *p,
20 typedef ngx_int_t (*ngx_event_pipe_output_filter_pt)(void *data,
24 struct ngx_event_pipe_s {
25 ngx_connection_t *upstream;
26 ngx_connection_t *downstream;
28 ngx_chain_t *free_raw_bufs;
30 ngx_chain_t **last_in;
33 ngx_chain_t **last_out;
39 * the input filter i.e. that moves HTTP/1.1 chunks
40 * from the raw bufs to an incoming chain
43 ngx_event_pipe_input_filter_pt input_filter;
46 ngx_event_pipe_output_filter_pt output_filter;
51 unsigned single_buf:1;
53 unsigned upstream_done:1;
54 unsigned upstream_error:1;
55 unsigned upstream_eof:1;
56 unsigned upstream_blocked:1;
57 unsigned downstream_done:1;
58 unsigned downstream_error:1;
59 unsigned cyclic_temp_file:1;
69 off_t max_temp_file_size;
70 ssize_t temp_file_write_size;
72 ngx_msec_t read_timeout;
73 ngx_msec_t send_timeout;
79 ngx_chain_t *preread_bufs;
81 ngx_buf_t *buf_to_file;
83 ngx_temp_file_t *temp_file;
89 ngx_int_t ngx_event_pipe(ngx_event_pipe_t *p, ngx_int_t do_write);
90 ngx_int_t ngx_event_pipe_copy_input_filter(ngx_event_pipe_t *p, ngx_buf_t *buf);
91 ngx_int_t ngx_event_pipe_add_free_buf(ngx_event_pipe_t *p, ngx_buf_t *b);
94 #endif /* _NGX_EVENT_PIPE_H_INCLUDED_ */