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