comparison src/event/quic/ngx_event_quic_streams.c @ 8936:86f5a738ac2a quic

QUIC: post stream events instead of calling their handlers. This potentially reduces the number of handler calls.
author Roman Arutyunyan <arut@nginx.com>
date Tue, 23 Nov 2021 21:39:51 +0300
parents d6ef13c5fd8e
children 0692355a3519
comparison
equal deleted inserted replaced
8935:ea78659b70fe 8936:86f5a738ac2a
1118 1118
1119 if (f->offset == qs->recv_offset) { 1119 if (f->offset == qs->recv_offset) {
1120 rev->ready = 1; 1120 rev->ready = 1;
1121 1121
1122 if (rev->active) { 1122 if (rev->active) {
1123 rev->handler(rev); 1123 ngx_post_event(rev, &ngx_posted_events);
1124 } 1124 }
1125 } 1125 }
1126 1126
1127 return NGX_OK; 1127 return NGX_OK;
1128 1128
1365 if (ngx_quic_update_flow(sc, qs->final_size) != NGX_OK) { 1365 if (ngx_quic_update_flow(sc, qs->final_size) != NGX_OK) {
1366 return NGX_ERROR; 1366 return NGX_ERROR;
1367 } 1367 }
1368 1368
1369 if (rev->active) { 1369 if (rev->active) {
1370 rev->handler(rev); 1370 ngx_post_event(rev, &ngx_posted_events);
1371 } 1371 }
1372 1372
1373 return NGX_OK; 1373 return NGX_OK;
1374 1374
1375 cleanup: 1375 cleanup:
1434 } 1434 }
1435 1435
1436 wev = qs->connection->write; 1436 wev = qs->connection->write;
1437 1437
1438 if (wev->active) { 1438 if (wev->active) {
1439 wev->handler(wev); 1439 ngx_post_event(wev, &ngx_posted_events);
1440 } 1440 }
1441 1441
1442 return NGX_OK; 1442 return NGX_OK;
1443 } 1443 }
1444 1444