|
0
|
1
|
|
|
2 /*
|
|
|
3 * Copyright (C) Igor Sysoev
|
|
660
|
4 * Copyright (C) Nginx, Inc.
|
|
0
|
5 */
|
|
|
6
|
|
|
7
|
|
|
8 #ifndef _NGX_BUF_H_INCLUDED_
|
|
|
9 #define _NGX_BUF_H_INCLUDED_
|
|
|
10
|
|
|
11
|
|
|
12 #include <ngx_config.h>
|
|
|
13 #include <ngx_core.h>
|
|
|
14
|
|
|
15
|
|
|
16 typedef void * ngx_buf_tag_t;
|
|
|
17
|
|
|
18 typedef struct ngx_buf_s ngx_buf_t;
|
|
|
19
|
|
|
20 struct ngx_buf_s {
|
|
|
21 u_char *pos;
|
|
|
22 u_char *last;
|
|
|
23 off_t file_pos;
|
|
|
24 off_t file_last;
|
|
|
25
|
|
|
26 u_char *start; /* start of buffer */
|
|
|
27 u_char *end; /* end of buffer */
|
|
|
28 ngx_buf_tag_t tag;
|
|
|
29 ngx_file_t *file;
|
|
|
30 ngx_buf_t *shadow;
|
|
|
31
|
|
|
32
|
|
|
33 /* the buf's content could be changed */
|
|
|
34 unsigned temporary:1;
|
|
|
35
|
|
|
36 /*
|
|
|
37 * the buf's content is in a memory cache or in a read only memory
|
|
|
38 * and must not be changed
|
|
|
39 */
|
|
|
40 unsigned memory:1;
|
|
|
41
|
|
|
42 /* the buf's content is mmap()ed and must not be changed */
|
|
|
43 unsigned mmap:1;
|
|
|
44
|
|
|
45 unsigned recycled:1;
|
|
|
46 unsigned in_file:1;
|
|
|
47 unsigned flush:1;
|
|
58
|
48 unsigned sync:1;
|
|
0
|
49 unsigned last_buf:1;
|
|
58
|
50 unsigned last_in_chain:1;
|
|
0
|
51
|
|
|
52 unsigned last_shadow:1;
|
|
|
53 unsigned temp_file:1;
|
|
|
54
|
|
|
55 /* STUB */ int num;
|
|
|
56 };
|
|
|
57
|
|
|
58
|
|
|
59 struct ngx_chain_s {
|
|
|
60 ngx_buf_t *buf;
|
|
|
61 ngx_chain_t *next;
|
|
|
62 };
|
|
|
63
|
|
|
64
|
|
|
65 typedef struct {
|
|
|
66 ngx_int_t num;
|
|
|
67 size_t size;
|
|
|
68 } ngx_bufs_t;
|
|
|
69
|
|
|
70
|
|
518
|
71 typedef struct ngx_output_chain_ctx_s ngx_output_chain_ctx_t;
|
|
|
72
|
|
28
|
73 typedef ngx_int_t (*ngx_output_chain_filter_pt)(void *ctx, ngx_chain_t *in);
|
|
0
|
74
|
|
518
|
75 #if (NGX_HAVE_FILE_AIO)
|
|
|
76 typedef void (*ngx_output_chain_aio_pt)(ngx_output_chain_ctx_t *ctx,
|
|
|
77 ngx_file_t *file);
|
|
|
78 #endif
|
|
|
79
|
|
|
80 struct ngx_output_chain_ctx_s {
|
|
0
|
81 ngx_buf_t *buf;
|
|
|
82 ngx_chain_t *in;
|
|
|
83 ngx_chain_t *free;
|
|
|
84 ngx_chain_t *busy;
|
|
|
85
|
|
516
|
86 unsigned sendfile:1;
|
|
|
87 unsigned directio:1;
|
|
410
|
88 #if (NGX_HAVE_ALIGNED_DIRECTIO)
|
|
516
|
89 unsigned unaligned:1;
|
|
410
|
90 #endif
|
|
516
|
91 unsigned need_in_memory:1;
|
|
|
92 unsigned need_in_temp:1;
|
|
526
|
93 #if (NGX_HAVE_FILE_AIO)
|
|
|
94 unsigned aio:1;
|
|
|
95
|
|
|
96 ngx_output_chain_aio_pt aio_handler;
|
|
|
97 #endif
|
|
0
|
98
|
|
518
|
99 off_t alignment;
|
|
|
100
|
|
0
|
101 ngx_pool_t *pool;
|
|
|
102 ngx_int_t allocated;
|
|
|
103 ngx_bufs_t bufs;
|
|
|
104 ngx_buf_tag_t tag;
|
|
|
105
|
|
|
106 ngx_output_chain_filter_pt output_filter;
|
|
|
107 void *filter_ctx;
|
|
518
|
108 };
|
|
0
|
109
|
|
|
110
|
|
|
111 typedef struct {
|
|
|
112 ngx_chain_t *out;
|
|
|
113 ngx_chain_t **last;
|
|
|
114 ngx_connection_t *connection;
|
|
|
115 ngx_pool_t *pool;
|
|
|
116 off_t limit;
|
|
|
117 } ngx_chain_writer_ctx_t;
|
|
|
118
|
|
|
119
|
|
|
120 #define NGX_CHAIN_ERROR (ngx_chain_t *) NGX_ERROR
|
|
|
121
|
|
|
122
|
|
|
123 #define ngx_buf_in_memory(b) (b->temporary || b->memory || b->mmap)
|
|
|
124 #define ngx_buf_in_memory_only(b) (ngx_buf_in_memory(b) && !b->in_file)
|
|
144
|
125
|
|
0
|
126 #define ngx_buf_special(b) \
|
|
58
|
127 ((b->flush || b->last_buf || b->sync) \
|
|
|
128 && !ngx_buf_in_memory(b) && !b->in_file)
|
|
0
|
129
|
|
144
|
130 #define ngx_buf_sync_only(b) \
|
|
|
131 (b->sync \
|
|
|
132 && !ngx_buf_in_memory(b) && !b->in_file && !b->flush && !b->last_buf)
|
|
|
133
|
|
0
|
134 #define ngx_buf_size(b) \
|
|
48
|
135 (ngx_buf_in_memory(b) ? (off_t) (b->last - b->pos): \
|
|
|
136 (b->file_last - b->file_pos))
|
|
0
|
137
|
|
|
138 ngx_buf_t *ngx_create_temp_buf(ngx_pool_t *pool, size_t size);
|
|
|
139 ngx_chain_t *ngx_create_chain_of_bufs(ngx_pool_t *pool, ngx_bufs_t *bufs);
|
|
|
140
|
|
|
141
|
|
|
142 #define ngx_alloc_buf(pool) ngx_palloc(pool, sizeof(ngx_buf_t))
|
|
|
143 #define ngx_calloc_buf(pool) ngx_pcalloc(pool, sizeof(ngx_buf_t))
|
|
|
144
|
|
56
|
145 ngx_chain_t *ngx_alloc_chain_link(ngx_pool_t *pool);
|
|
|
146 #define ngx_free_chain(pool, cl) \
|
|
|
147 cl->next = pool->chain; \
|
|
|
148 pool->chain = cl
|
|
|
149
|
|
0
|
150
|
|
|
151
|
|
|
152 ngx_int_t ngx_output_chain(ngx_output_chain_ctx_t *ctx, ngx_chain_t *in);
|
|
28
|
153 ngx_int_t ngx_chain_writer(void *ctx, ngx_chain_t *in);
|
|
0
|
154
|
|
|
155 ngx_int_t ngx_chain_add_copy(ngx_pool_t *pool, ngx_chain_t **chain,
|
|
48
|
156 ngx_chain_t *in);
|
|
130
|
157 ngx_chain_t *ngx_chain_get_free_buf(ngx_pool_t *p, ngx_chain_t **free);
|
|
640
|
158 void ngx_chain_update_chains(ngx_pool_t *p, ngx_chain_t **free,
|
|
|
159 ngx_chain_t **busy, ngx_chain_t **out, ngx_buf_tag_t tag);
|
|
0
|
160
|
|
|
161
|
|
|
162 #endif /* _NGX_BUF_H_INCLUDED_ */
|
