nxt_event_engine.c (53:0b10a73d4993) nxt_event_engine.c (63:b79fe37d9f24)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

523
524 for ( ;; ) {
525 handler = nxt_event_engine_queue_pop(engine, &task, &obj, &data);
526
527 if (handler == NULL) {
528 break;
529 }
530
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

523
524 for ( ;; ) {
525 handler = nxt_event_engine_queue_pop(engine, &task, &obj, &data);
526
527 if (handler == NULL) {
528 break;
529 }
530
531 thr->task = task;
532
531 handler(task, obj, data);
532 }
533
534 /* Attach some event engine work queues in preferred order. */
535
536 timeout = nxt_timer_find(engine);
537
538 engine->event.poll(engine, timeout);
539
540 now = nxt_thread_monotonic_time(thr) / 1000000;
541
542 nxt_timer_expire(engine, now);
543 }
544}
533 handler(task, obj, data);
534 }
535
536 /* Attach some event engine work queues in preferred order. */
537
538 timeout = nxt_timer_find(engine);
539
540 engine->event.poll(engine, timeout);
541
542 now = nxt_thread_monotonic_time(thr) / 1000000;
543
544 nxt_timer_expire(engine, now);
545 }
546}