diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
| commit | de532922d9ab42aa15b40d47c8db53ac2af38500 (patch) | |
| tree | d6b7c6b21c7a6e0e3620a3e0c7198e63454d05e3 /src/nxt_buf_filter.h | |
| parent | 16cbf3c076a0aca6d47adaf3f719493674cf2363 (diff) | |
| download | unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.gz unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.bz2 | |
Introducing tasks.
Diffstat (limited to 'src/nxt_buf_filter.h')
| -rw-r--r-- | src/nxt_buf_filter.h | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/nxt_buf_filter.h b/src/nxt_buf_filter.h index 8252ca3d..b1015455 100644 --- a/src/nxt_buf_filter.h +++ b/src/nxt_buf_filter.h @@ -77,8 +77,7 @@ typedef struct { nxt_int_t (*filter_sync_last)(nxt_buf_filter_t *f); void (*filter_next)(nxt_buf_filter_t *f); - void (*filter_error)(nxt_thread_t *thr, void *obj, - void *data); + nxt_work_handler_t filter_error; nxt_buf_filter_file_t *(*job_file_create)(nxt_buf_filter_t *f); void (*job_file_retain)(nxt_buf_filter_t *f); @@ -107,10 +106,10 @@ struct nxt_buf_filter_s { }; -NXT_EXPORT void nxt_buf_filter_add(nxt_thread_t *thr, nxt_buf_filter_t *f, +NXT_EXPORT void nxt_buf_filter_add(nxt_task_t *task, nxt_buf_filter_t *f, nxt_buf_t *b); -NXT_EXPORT void nxt_buf_filter(nxt_thread_t *thr, void *obj, void *data); -NXT_EXPORT void nxt_buf_filter_enqueue(nxt_thread_t *thr, nxt_buf_filter_t *f); +NXT_EXPORT void nxt_buf_filter(nxt_task_t *task, void *obj, void *data); +NXT_EXPORT void nxt_buf_filter_enqueue(nxt_task_t *task, nxt_buf_filter_t *f); #endif /* _NXT_BUF_FILTER_H_INCLUDED_ */ |