nxt_event_engine.c (494:7c83ddcc1c42) nxt_event_engine.c (564:762f8c976ead)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 335 unchanged lines hidden (view full) ---

344nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, void *data)
345{
346 nxt_event_engine_t *engine;
347 nxt_event_engine_pipe_t *pipe;
348
349 engine = task->thread->engine;
350 pipe = engine->pipe;
351
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 335 unchanged lines hidden (view full) ---

344nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, void *data)
345{
346 nxt_event_engine_t *engine;
347 nxt_event_engine_pipe_t *pipe;
348
349 engine = task->thread->engine;
350 pipe = engine->pipe;
351
352 nxt_log(task, NXT_LOG_CRIT, "engine pipe(%FD:%FD) event error",
353 pipe->fds[0], pipe->fds[1]);
352 nxt_alert(task, "engine pipe(%FD:%FD) event error",
353 pipe->fds[0], pipe->fds[1]);
354
355 nxt_fd_event_close(engine, &pipe->event);
356 nxt_pipe_close(pipe->event.task, pipe->fds);
357}
358
359
360static void
361nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data)

--- 8 unchanged lines hidden (view full) ---

370 sigev++)
371 {
372 if (signo == (nxt_uint_t) sigev->signo) {
373 sigev->handler(task, (void *) signo, (void *) sigev->name);
374 return;
375 }
376 }
377
354
355 nxt_fd_event_close(engine, &pipe->event);
356 nxt_pipe_close(pipe->event.task, pipe->fds);
357}
358
359
360static void
361nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data)

--- 8 unchanged lines hidden (view full) ---

370 sigev++)
371 {
372 if (signo == (nxt_uint_t) sigev->signo) {
373 sigev->handler(task, (void *) signo, (void *) sigev->name);
374 return;
375 }
376 }
377
378 nxt_log(task, NXT_LOG_CRIT, "signal %ui handler not found",
379 (nxt_uint_t) signo);
378 nxt_alert(task, "signal %ui handler not found", (nxt_uint_t) signo);
380}
381
382
383nxt_int_t
384nxt_event_engine_change(nxt_event_engine_t *engine,
385 const nxt_event_interface_t *interface, nxt_uint_t batch)
386{
387 nxt_uint_t events;

--- 279 unchanged lines hidden ---
379}
380
381
382nxt_int_t
383nxt_event_engine_change(nxt_event_engine_t *engine,
384 const nxt_event_interface_t *interface, nxt_uint_t batch)
385{
386 nxt_uint_t events;

--- 279 unchanged lines hidden ---