nginx/src/core/ngx_buf.h

153 lines
4.4 KiB
C
Raw Normal View History

/*
* Copyright (C) Igor Sysoev
*/
#ifndef _NGX_BUF_H_INCLUDED_
#define _NGX_BUF_H_INCLUDED_
#include <ngx_config.h>
2003-06-03 23:42:58 +08:00
#include <ngx_core.h>
typedef void * ngx_buf_tag_t;
typedef struct ngx_buf_s ngx_buf_t;
2003-06-03 23:42:58 +08:00
struct ngx_buf_s {
2004-03-16 15:10:12 +08:00
u_char *pos;
u_char *last;
2003-10-22 15:05:29 +08:00
off_t file_pos;
off_t file_last;
u_char *start; /* start of buffer */
u_char *end; /* end of buffer */
ngx_buf_tag_t tag;
2003-10-22 15:05:29 +08:00
ngx_file_t *file;
ngx_buf_t *shadow;
/* the buf's content could be changed */
unsigned temporary:1;
/*
* the buf's content is in a memory cache or in a read only memory
* and must not be changed
*/
unsigned memory:1;
/* the buf's content is mmap()ed and must not be changed */
unsigned mmap:1;
unsigned recycled:1;
unsigned in_file:1;
unsigned flush:1;
unsigned last_buf:1;
unsigned last_shadow:1;
unsigned temp_file:1;
unsigned zerocopy_busy:1;
2003-10-22 15:05:29 +08:00
/* STUB */ int num;
};
2003-02-12 00:42:23 +08:00
2003-06-03 23:42:58 +08:00
typedef struct ngx_chain_s ngx_chain_t;
struct ngx_chain_s {
ngx_buf_t *buf;
ngx_chain_t *next;
};
2002-09-02 22:48:24 +08:00
2003-10-08 23:32:54 +08:00
typedef struct {
2004-03-16 15:10:12 +08:00
ngx_int_t num;
2003-10-31 00:51:33 +08:00
size_t size;
2003-10-08 23:32:54 +08:00
} ngx_bufs_t;
2003-10-27 16:53:49 +08:00
typedef int (*ngx_output_chain_filter_pt)(void *ctx, ngx_chain_t *out);
typedef struct {
ngx_buf_t *buf;
2003-10-27 16:53:49 +08:00
ngx_chain_t *in;
ngx_chain_t *free;
ngx_chain_t *busy;
unsigned sendfile;
unsigned need_in_memory;
unsigned need_in_temp;
ngx_pool_t *pool;
ngx_int_t allocated;
2003-10-27 16:53:49 +08:00
ngx_bufs_t bufs;
ngx_buf_tag_t tag;
2003-10-27 16:53:49 +08:00
ngx_output_chain_filter_pt output_filter;
2004-03-23 14:01:52 +08:00
void *filter_ctx;
2003-10-27 16:53:49 +08:00
} ngx_output_chain_ctx_t;
2003-10-28 05:01:00 +08:00
typedef struct {
ngx_chain_t *out;
ngx_chain_t **last;
ngx_connection_t *connection;
ngx_pool_t *pool;
2004-06-21 23:59:32 +08:00
off_t limit;
2003-10-30 16:51:06 +08:00
} ngx_chain_writer_ctx_t;
2003-10-28 05:01:00 +08:00
2003-02-12 00:42:23 +08:00
#define NGX_CHAIN_ERROR (ngx_chain_t *) NGX_ERROR
#define ngx_buf_in_memory(b) (b->temporary || b->memory || b->mmap)
#define ngx_buf_in_memory_only(b) (ngx_buf_in_memory(b) && !b->in_file)
#define ngx_buf_special(b) \
2004-06-09 15:45:27 +08:00
((b->flush || b->last_buf) && !ngx_buf_in_memory(b) && !b->in_file)
#define ngx_buf_size(b) \
(ngx_buf_in_memory(b) ? (size_t) (b->last - b->pos): \
(size_t) (b->file_last - b->file_pos))
ngx_buf_t *ngx_create_temp_buf(ngx_pool_t *pool, size_t size);
ngx_chain_t *ngx_create_chain_of_bufs(ngx_pool_t *pool, ngx_bufs_t *bufs);
2003-10-14 23:06:38 +08:00
2002-09-02 22:48:24 +08:00
#define ngx_alloc_buf(pool) ngx_palloc(pool, sizeof(ngx_buf_t))
#define ngx_calloc_buf(pool) ngx_pcalloc(pool, sizeof(ngx_buf_t))
2003-04-15 01:04:58 +08:00
2002-08-30 00:59:54 +08:00
2003-10-23 00:38:26 +08:00
#define ngx_alloc_chain_link(pool) ngx_palloc(pool, sizeof(ngx_chain_t))
#define ngx_alloc_link_and_set_buf(chain, b, pool, error) \
2002-08-22 23:24:03 +08:00
do { \
2003-10-23 00:38:26 +08:00
ngx_test_null(chain, ngx_alloc_chain_link(pool), error); \
chain->buf = b; \
2002-08-22 23:24:03 +08:00
chain->next = NULL; \
} while (0);
2003-10-14 00:32:29 +08:00
2003-10-23 00:38:26 +08:00
#define ngx_chain_add_link(chain, last, cl) \
2003-10-14 00:32:29 +08:00
if (chain) { \
2003-10-23 00:38:26 +08:00
*last = cl; \
2003-10-14 00:32:29 +08:00
} else { \
2003-10-23 00:38:26 +08:00
chain = cl; \
2003-10-14 00:32:29 +08:00
} \
2003-10-23 00:38:26 +08:00
last = &cl->next
2003-10-14 00:32:29 +08:00
2004-06-16 23:32:11 +08:00
ngx_int_t ngx_output_chain(ngx_output_chain_ctx_t *ctx, ngx_chain_t *in);
ngx_int_t ngx_chain_writer(void *data, ngx_chain_t *in);
2003-10-28 05:01:00 +08:00
2004-06-16 23:32:11 +08:00
ngx_int_t ngx_chain_add_copy(ngx_pool_t *pool, ngx_chain_t **chain,
ngx_chain_t *in);
2003-09-26 13:45:21 +08:00
void ngx_chain_update_chains(ngx_chain_t **free, ngx_chain_t **busy,
ngx_chain_t **out, ngx_buf_tag_t tag);
2003-09-26 13:45:21 +08:00
#endif /* _NGX_BUF_H_INCLUDED_ */