From de532922d9ab42aa15b40d47c8db53ac2af38500 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Mon, 23 Jan 2017 19:56:03 +0300 Subject: Introducing tasks. --- src/nxt_event_engine.h | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'src/nxt_event_engine.h') diff --git a/src/nxt_event_engine.h b/src/nxt_event_engine.h index 0cbfc89d..1ff1399a 100644 --- a/src/nxt_event_engine.h +++ b/src/nxt_event_engine.h @@ -23,6 +23,7 @@ struct nxt_event_engine_s { nxt_event_timers_t timers; + nxt_task_t task; /* The engine ID, the main engine has ID 0. */ uint32_t id; @@ -44,6 +45,7 @@ struct nxt_event_engine_s { nxt_event_signals_t *signals; + nxt_thread_t *thread; nxt_fiber_main_t *fibers; uint8_t shutdown; /* 1 bit */ @@ -61,12 +63,13 @@ NXT_EXPORT nxt_event_engine_t *nxt_event_engine_create(nxt_thread_t *thr, const nxt_event_set_ops_t *event_set, const nxt_event_sig_t *signals, nxt_uint_t flags, nxt_uint_t batch); NXT_EXPORT nxt_int_t nxt_event_engine_change(nxt_thread_t *thr, - const nxt_event_set_ops_t *event_set, nxt_uint_t batch); + nxt_task_t *task, const nxt_event_set_ops_t *event_set, nxt_uint_t batch); NXT_EXPORT void nxt_event_engine_free(nxt_event_engine_t *engine); NXT_EXPORT void nxt_event_engine_start(nxt_event_engine_t *engine); NXT_EXPORT void nxt_event_engine_post(nxt_event_engine_t *engine, - nxt_work_handler_t handler, void *obj, void *data, nxt_log_t *log); + nxt_work_handler_t handler, nxt_task_t *task, void *obj, void *data, + nxt_log_t *log); NXT_EXPORT void nxt_event_engine_signal(nxt_event_engine_t *engine, nxt_uint_t signo); -- cgit