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