nxt_buf_filter.h (1:fdc027c56872) nxt_buf_filter.h (65:10688b89aa16)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_BUF_FILTER_H_INCLUDED_
8#define _NXT_BUF_FILTER_H_INCLUDED_

--- 80 unchanged lines hidden (view full) ---

89 nxt_buf_t *current;
90 nxt_buf_t *input;
91 nxt_buf_t *output;
92 nxt_buf_t *last;
93
94 nxt_work_queue_t *work_queue;
95 nxt_buf_filter_file_t *filter_file;
96 void *data;
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_BUF_FILTER_H_INCLUDED_
8#define _NXT_BUF_FILTER_H_INCLUDED_

--- 80 unchanged lines hidden (view full) ---

89 nxt_buf_t *current;
90 nxt_buf_t *input;
91 nxt_buf_t *output;
92 nxt_buf_t *last;
93
94 nxt_work_queue_t *work_queue;
95 nxt_buf_filter_file_t *filter_file;
96 void *data;
97 nxt_mem_pool_t *mem_pool;
97 nxt_mp_t *mem_pool;
98
99 const nxt_buf_filter_ops_t *run;
100
101 uint8_t mmap; /* 1 bit */
102 uint8_t done; /* 1 bit */
103 uint8_t queued; /* 1 bit */
104 uint8_t reading; /* 1 bit */
105 uint8_t buffering; /* 1 bit */
106};
107
108
109NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f,
110 nxt_buf_t *b);
111NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data);
112NXT_EXPORT void nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f);
113
114
115#endif /* _NXT_BUF_FILTER_H_INCLUDED_ */
98
99 const nxt_buf_filter_ops_t *run;
100
101 uint8_t mmap; /* 1 bit */
102 uint8_t done; /* 1 bit */
103 uint8_t queued; /* 1 bit */
104 uint8_t reading; /* 1 bit */
105 uint8_t buffering; /* 1 bit */
106};
107
108
109NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f,
110 nxt_buf_t *b);
111NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data);
112NXT_EXPORT void nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f);
113
114
115#endif /* _NXT_BUF_FILTER_H_INCLUDED_ */