Annotation of embedaddon/nginx/src/core/ngx_buf.h, revision 1.1.1.1
1.1 misho 1:
2: /*
3: * Copyright (C) Igor Sysoev
4: * Copyright (C) Nginx, Inc.
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;
48: unsigned sync:1;
49: unsigned last_buf:1;
50: unsigned last_in_chain:1;
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:
71: typedef struct ngx_output_chain_ctx_s ngx_output_chain_ctx_t;
72:
73: typedef ngx_int_t (*ngx_output_chain_filter_pt)(void *ctx, ngx_chain_t *in);
74:
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 {
81: ngx_buf_t *buf;
82: ngx_chain_t *in;
83: ngx_chain_t *free;
84: ngx_chain_t *busy;
85:
86: unsigned sendfile:1;
87: unsigned directio:1;
88: #if (NGX_HAVE_ALIGNED_DIRECTIO)
89: unsigned unaligned:1;
90: #endif
91: unsigned need_in_memory:1;
92: unsigned need_in_temp:1;
93: #if (NGX_HAVE_FILE_AIO)
94: unsigned aio:1;
95:
96: ngx_output_chain_aio_pt aio_handler;
97: #endif
98:
99: off_t alignment;
100:
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;
108: };
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)
125:
126: #define ngx_buf_special(b) \
127: ((b->flush || b->last_buf || b->sync) \
128: && !ngx_buf_in_memory(b) && !b->in_file)
129:
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:
134: #define ngx_buf_size(b) \
135: (ngx_buf_in_memory(b) ? (off_t) (b->last - b->pos): \
136: (b->file_last - b->file_pos))
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:
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:
150:
151:
152: ngx_int_t ngx_output_chain(ngx_output_chain_ctx_t *ctx, ngx_chain_t *in);
153: ngx_int_t ngx_chain_writer(void *ctx, ngx_chain_t *in);
154:
155: ngx_int_t ngx_chain_add_copy(ngx_pool_t *pool, ngx_chain_t **chain,
156: ngx_chain_t *in);
157: ngx_chain_t *ngx_chain_get_free_buf(ngx_pool_t *p, ngx_chain_t **free);
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);
160:
161:
162: #endif /* _NGX_BUF_H_INCLUDED_ */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>