CERBERUS/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2026-05-13 09:36:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Merge 62c9b8447c into 319b4ea63f

Browse source
This commit is contained in:
erhan1209 2026-05-13 03:58:17 +00:00 • committed by GitHub
commit d0d3a79eb5
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 14 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/event/ngx_event_acceptex.c
View file

@ -11,6 +11,7 @@
static void ngx_close_posted_connection(ngx_connection_t *c);
static void ngx_event_acceptex_recycle(ngx_listening_t *ls, ngx_connection_t *c);
void
@ -29,6 +30,7 @@ ngx_event_acceptex(ngx_event_t *rev)
if (rev->ovlp.error) {
ngx_log_error(NGX_LOG_CRIT, c->log, rev->ovlp.error,
"AcceptEx() %V failed", &ls->addr_text);
ngx_event_acceptex_recycle(ls, c);
return;
}
@ -41,7 +43,7 @@ ngx_event_acceptex(ngx_event_t *rev)
ngx_log_error(NGX_LOG_CRIT, c->log, ngx_socket_errno,
"setsockopt(SO_UPDATE_ACCEPT_CONTEXT) failed for %V",
&c->addr_text);
/* TODO: close socket */
ngx_event_acceptex_recycle(ls, c);
return;
}
@ -63,7 +65,7 @@ ngx_event_acceptex(ngx_event_t *rev)
if (ls->addr_ntop) {
c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len);
if (c->addr_text.data == NULL) {
/* TODO: close socket */
ngx_event_acceptex_recycle(ls, c);
return;
}
@ -71,7 +73,7 @@ ngx_event_acceptex(ngx_event_t *rev)
c->addr_text.data,
ls->addr_text_max_len, 0);
if (c->addr_text.len == 0) {
/* TODO: close socket */
ngx_event_acceptex_recycle(ls, c);
return;
}
}
@ -201,6 +203,15 @@ ngx_event_post_acceptex(ngx_listening_t *ls, ngx_uint_t n)
}
static void
ngx_event_acceptex_recycle(ngx_listening_t *ls, ngx_connection_t *c)
{
ngx_close_posted_connection(c);
(void) ngx_event_post_acceptex(ls, 1);
}
static void
ngx_close_posted_connection(ngx_connection_t *c)
{