diff options
Diffstat (limited to 'src/event/ngx_event_pipe.h')
| -rw-r--r-- | src/event/ngx_event_pipe.h | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/src/event/ngx_event_pipe.h b/src/event/ngx_event_pipe.h new file mode 100644 index 000000000..aef80de03 --- /dev/null +++ b/src/event/ngx_event_pipe.h @@ -0,0 +1,75 @@ +#ifndef _NGX_EVENT_PIPE_H_INCLUDED_ +#define _NGX_EVENT_PIPE_H_INCLUDED_ + + +#include <ngx_config.h> +#include <ngx_core.h> +#include <ngx_event.h> + + +typedef struct ngx_event_pipe_s ngx_event_pipe_t; + +typedef int (*ngx_event_pipe_input_filter_pt)(ngx_event_pipe_t *p, + ngx_hunk_t *hunk); +typedef int (*ngx_event_pipe_output_filter_pt)(void *data, ngx_chain_t *chain); + + +struct ngx_event_pipe_s { + ngx_chain_t *free_raw_hunks; + ngx_chain_t *in; + ngx_chain_t **last_in; + + ngx_chain_t *out; + ngx_chain_t **last_out; + + ngx_chain_t *free; + ngx_chain_t *busy; + + /* + * the input filter i.e. that moves HTTP/1.1 chunks + * from the raw hunks to an incoming chain + */ + + ngx_event_pipe_input_filter_pt input_filter; + void *input_ctx; + + ngx_event_pipe_output_filter_pt output_filter; + void *output_ctx; + + unsigned read:1; + unsigned cachable:1; + unsigned upstream_done:1; + unsigned upstream_eof:1; + unsigned upstream_error:1; + unsigned downstream_done:1; + unsigned downstream_error:1; + + int hunks; + ngx_bufs_t bufs; + + size_t max_busy_len; + + off_t temp_offset; + off_t max_temp_file_size; + int temp_file_write_size; + + ngx_connection_t *upstream; + ngx_connection_t *downstream; + + ngx_pool_t *pool; + ngx_log_t *log; + + ngx_chain_t *preread_hunks; + int preread_size; + + ngx_file_t *temp_file; + ngx_path_t *temp_path; + char *temp_file_warn; +}; + + +int ngx_event_pipe(ngx_event_pipe_t *p, int do_write); +int ngx_event_pipe_copy_input_filter(ngx_event_pipe_t *p, ngx_hunk_t *hunk); + + +#endif /* _NGX_EVENT_PIPE_H_INCLUDED_ */ |