nginx-0.0.1-2003-10-21-20:49:56 import
diff --git a/src/event/ngx_event_pipe.h b/src/event/ngx_event_pipe.h
new file mode 100644
index 0000000..aef80de
--- /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_ */
