Mercurial > hg > nginx-vendor-current

comparison src/event/ngx_event_pipe.h @ 0:f0b350454894 NGINX_0_1_0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx 0.1.0 *) The first public version.
author Igor Sysoev <http://sysoev.ru>
date Mon, 04 Oct 2004 00:00:00 +0400
parents
children 8b6db3bda591
comparison
equal deleted inserted replaced
-1:000000000000 0:f0b350454894
1
2 /*
3 * Copyright (C) Igor Sysoev
4 */
5
6
7 #ifndef _NGX_EVENT_PIPE_H_INCLUDED_
8 #define _NGX_EVENT_PIPE_H_INCLUDED_
9
10
11 #include <ngx_config.h>
12 #include <ngx_core.h>
13 #include <ngx_event.h>
14
15
16 typedef struct ngx_event_pipe_s ngx_event_pipe_t;
17
18 typedef ngx_int_t (*ngx_event_pipe_input_filter_pt)(ngx_event_pipe_t *p,
19 ngx_buf_t *buf);
20 typedef ngx_int_t (*ngx_event_pipe_output_filter_pt)(void *data,
21 ngx_chain_t *chain);
22
23
24 struct ngx_event_pipe_s {
25 ngx_connection_t *upstream;
26 ngx_connection_t *downstream;
27
28 ngx_chain_t *free_raw_bufs;
29 ngx_chain_t *in;
30 ngx_chain_t **last_in;
31
32 ngx_chain_t *out;
33 ngx_chain_t **last_out;
34
35 ngx_chain_t *free;
36 ngx_chain_t *busy;
37
38 /*
39 * the input filter i.e. that moves HTTP/1.1 chunks
40 * from the raw bufs to an incoming chain
41 */
42
43 ngx_event_pipe_input_filter_pt input_filter;
44 void *input_ctx;
45
46 ngx_event_pipe_output_filter_pt output_filter;
47 void *output_ctx;
48
49 unsigned read:1;
50 unsigned cachable:1;
51 unsigned single_buf:1;
52 unsigned free_bufs: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;
60
61 ngx_int_t allocated;
62 ngx_bufs_t bufs;
63 ngx_buf_tag_t tag;
64
65 size_t busy_size;
66
67 off_t read_length;
68
69 off_t max_temp_file_size;
70 ssize_t temp_file_write_size;
71
72 ngx_msec_t read_timeout;
73 ngx_msec_t send_timeout;
74 ssize_t send_lowat;
75
76 ngx_pool_t *pool;
77 ngx_log_t *log;
78
79 ngx_chain_t *preread_bufs;
80 size_t preread_size;
81 ngx_buf_t *buf_to_file;
82
83 ngx_temp_file_t *temp_file;
84
85 /* STUB */ int num;
86 };
87
88
89 ngx_int_t ngx_event_pipe(ngx_event_pipe_t *p, int do_write);
90 ngx_int_t ngx_event_pipe_copy_input_filter(ngx_event_pipe_t *p, ngx_buf_t *buf);
91
92
93 #endif /* _NGX_EVENT_PIPE_H_INCLUDED_ */