nxt_buf_filter.h (0:a63ceefd6ab0) nxt_buf_filter.h (1:fdc027c56872)
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_

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

72 nxt_int_t (*filter_process)(nxt_buf_filter_t *f);
73 nxt_int_t (*filter_flush)(nxt_buf_filter_t *f);
74
75 nxt_int_t (*filter_sync_nobuf)(nxt_buf_filter_t *f);
76 nxt_int_t (*filter_sync_flush)(nxt_buf_filter_t *f);
77 nxt_int_t (*filter_sync_last)(nxt_buf_filter_t *f);
78
79 void (*filter_next)(nxt_buf_filter_t *f);
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_

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

72 nxt_int_t (*filter_process)(nxt_buf_filter_t *f);
73 nxt_int_t (*filter_flush)(nxt_buf_filter_t *f);
74
75 nxt_int_t (*filter_sync_nobuf)(nxt_buf_filter_t *f);
76 nxt_int_t (*filter_sync_flush)(nxt_buf_filter_t *f);
77 nxt_int_t (*filter_sync_last)(nxt_buf_filter_t *f);
78
79 void (*filter_next)(nxt_buf_filter_t *f);
80 void (*filter_error)(nxt_thread_t *thr, void *obj,
81 void *data);
80 nxt_work_handler_t filter_error;
82
83 nxt_buf_filter_file_t *(*job_file_create)(nxt_buf_filter_t *f);
84 void (*job_file_retain)(nxt_buf_filter_t *f);
85 void (*job_file_release)(nxt_buf_filter_t *f);
86} nxt_buf_filter_ops_t;
87
88
89struct nxt_buf_filter_s {

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

102 uint8_t mmap; /* 1 bit */
103 uint8_t done; /* 1 bit */
104 uint8_t queued; /* 1 bit */
105 uint8_t reading; /* 1 bit */
106 uint8_t buffering; /* 1 bit */
107};
108
109
81
82 nxt_buf_filter_file_t *(*job_file_create)(nxt_buf_filter_t *f);
83 void (*job_file_retain)(nxt_buf_filter_t *f);
84 void (*job_file_release)(nxt_buf_filter_t *f);
85} nxt_buf_filter_ops_t;
86
87
88struct nxt_buf_filter_s {

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

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
110NXT_EXPORT void nxt_buf_filter_add(nxt_thread_t *thr, nxt_buf_filter_t *f,
109NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f,
111 nxt_buf_t *b);
110 nxt_buf_t *b);
112NXT_EXPORT void nxt_buf_filter(nxt_thread_t *thr, void *obj, void *data);
113NXT_EXPORT void nxt_buf_filter_enqueue(nxt_thread_t *thr, nxt_buf_filter_t *f);
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);
114
115
116#endif /* _NXT_BUF_FILTER_H_INCLUDED_ */
113
114
115#endif /* _NXT_BUF_FILTER_H_INCLUDED_ */