Deleted
Added
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 --- |