1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
/*
* Copyright (C) Igor Sysoev
* Copyright (C) NGINX, Inc.
*/
#ifndef _NXT_SOURCE_H_INCLUDED_
#define _NXT_SOURCE_H_INCLUDED_
/*
* A source handler should store a pointer to a passed source hook, but not
* the hook's values themselves, because a source filter may change the values.
*/
typedef struct {
void *context;
nxt_work_handler_t filter;
} nxt_source_hook_t;
typedef void (*nxt_source_handler_t)(void *source_context,
nxt_source_hook_t *query);
#define nxt_source_filter(thr, wq, task, next, out) \
do { \
if (thr->engine->batch != 0) { \
nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \
task, next, out); \
\
} else { \
(next)->filter(task, (next)->context, out); \
} \
\
} while (0)
NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj,
void *data);
#endif /* _NXT_SOURCE_H_INCLUDED_ */
|
