Lines Matching refs:engine
104 nxt_event_engine_signal(thr->engine, signo); in nxt_signal_handler()
111 nxt_signal_thread_start(nxt_event_engine_t *engine) in nxt_signal_thread_start() argument
116 if (engine->signals->process == nxt_pid) { in nxt_signal_thread_start()
120 if (sigprocmask(SIG_BLOCK, &engine->signals->sigmask, NULL) != 0) { in nxt_signal_thread_start()
130 for (sigev = engine->signals->sigev; sigev->signo != 0; sigev++) { in nxt_signal_thread_start()
140 link->work.data = engine; in nxt_signal_thread_start()
142 if (nxt_thread_create(&engine->signals->thread, link) == NXT_OK) { in nxt_signal_thread_start()
143 engine->signals->process = nxt_pid; in nxt_signal_thread_start()
158 nxt_event_engine_t *engine; in nxt_signal_thread() local
160 engine = data; in nxt_signal_thread()
167 err = sigwait(&engine->signals->sigmask, &signo); in nxt_signal_thread()
174 nxt_event_engine_signal(engine, signo); in nxt_signal_thread()
184 nxt_signal_thread_stop(nxt_event_engine_t *engine) in nxt_signal_thread_stop() argument
188 thread = engine->signals->thread; in nxt_signal_thread_stop()