From 16cbf3c076a0aca6d47adaf3f719493674cf2363 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Tue, 17 Jan 2017 20:00:00 +0300 Subject: Initial version. --- src/nxt_source.h | 43 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 src/nxt_source.h (limited to 'src/nxt_source.h') diff --git a/src/nxt_source.h b/src/nxt_source.h new file mode 100644 index 00000000..23bebb3c --- /dev/null +++ b/src/nxt_source.h @@ -0,0 +1,43 @@ + +/* + * 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, next, out) \ + do { \ + if (thr->engine->batch != 0) { \ + nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \ + next, out, thr->log); \ + \ + } else { \ + (next)->filter(thr, (next)->context, out); \ + } \ + \ + } while (0) + + +NXT_EXPORT void nxt_source_filter_handler(nxt_thread_t *thr, void *obj, + void *data); + + +#endif /* _NXT_SOURCE_H_INCLUDED_ */ -- cgit