summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_event_engine.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/nxt_event_engine.h')
-rw-r--r--src/nxt_event_engine.h7
1 files changed, 5 insertions, 2 deletions
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);