Mercurial > hg > nginx

comparison src/event/ngx_event.c @ 8855:9ae239d2547d quic

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
QUIC: separate event handling functions. The functions ngx_quic_handle_read_event() and ngx_quic_handle_write_event() are added. Previously this code was a part of ngx_handle_read_event() and ngx_handle_write_event(). The change simplifies ngx_handle_read_event() and ngx_handle_write_event() by moving QUIC-related code to a QUIC source file.
author Roman Arutyunyan <arut@nginx.com>
date Thu, 09 Sep 2021 16:55:00 +0300
parents 6674a50cbb6c
children c31d95fdaf65
comparison
equal deleted inserted replaced
8854:7416d3b2fac5 8855:9ae239d2547d
271 ngx_connection_t *c; 271 ngx_connection_t *c;
272 272
273 c = rev->data; 273 c = rev->data;
274 274
275 if (c->quic) { 275 if (c->quic) {
276 276 return ngx_quic_handle_read_event(rev, flags);
277 if (!rev->active && !rev->ready) {
278 rev->active = 1;
279
280 } else if (rev->active && (rev->ready || (flags & NGX_CLOSE_EVENT))) {
281 rev->active = 0;
282 }
283
284 return NGX_OK;
285 } 277 }
286 278
287 #endif 279 #endif
288 280
289 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) { 281 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
356 { 348 {
357 ngx_connection_t *c; 349 ngx_connection_t *c;
358 350
359 c = wev->data; 351 c = wev->data;
360 352
353 #if (NGX_QUIC)
354 if (c->quic) {
355 return ngx_quic_handle_write_event(wev, lowat);
356 }
357 #endif
358
361 if (lowat) { 359 if (lowat) {
362 if (ngx_send_lowat(c, lowat) == NGX_ERROR) { 360 if (ngx_send_lowat(c, lowat) == NGX_ERROR) {
363 return NGX_ERROR; 361 return NGX_ERROR;
364 } 362 }
365 } 363 }
366
367 #if (NGX_QUIC)
368
369 if (c->quic) {
370
371 if (!wev->active && !wev->ready) {
372 wev->active = 1;
373
374 } else if (wev->active && wev->ready) {
375 wev->active = 0;
376 }
377
378 return NGX_OK;
379 }
380
381 #endif
382 364
383 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) { 365 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
384 366
385 /* kqueue, epoll */ 367 /* kqueue, epoll */
386 368