Mercurial > hg > nginx-quic
view src/event/ngx_event_accept.c @ 21:df7fb216a149
nginx-0.0.1-2002-12-04-19:29:40 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 04 Dec 2002 16:29:40 +0000 |
parents | 708f8bb772ec |
children | 77c7629a2627 |
line wrap: on
line source
#include <ngx_config.h> #include <ngx_core.h> #include <ngx_types.h> #include <ngx_log.h> #include <ngx_connection.h> #include <ngx_event.h> #include <ngx_event_close.h> #include <ngx_event_accept.h> int ngx_event_accept(ngx_event_t *ev) { ngx_err_t err; ngx_socket_t s; struct sockaddr_in addr; int addrlen = sizeof(struct sockaddr_in); ngx_connection_t *cn = (ngx_connection_t *) ev->data; ngx_log_debug(ev->log, "ngx_event_accept: accept ready: %d" _ ev->available); ev->ready = 0; do { if ((s = accept(cn->fd, cn->sockaddr, &cn->socklen)) == -1) { err = ngx_socket_errno; if (err == NGX_EAGAIN) { ngx_log_error(NGX_LOG_INFO, ev->log, err, "ngx_event_accept: EAGAIN while accept %s", cn->addr_text); return NGX_OK; } ngx_log_error(NGX_LOG_ERR, ev->log, err, "ngx_event_accept: accept %s failed", cn->addr_text); /* if we return NGX_ERROR listen socket would be closed */ return NGX_OK; } ngx_log_debug(ev->log, "ngx_event_accept: accept: %d" _ s); #if !(HAVE_INHERITED_NONBLOCK) if (ngx_nonblocking(s) == -1) ngx_log_error(NGX_LOG_ERR, log, ngx_socket_errno, ngx_nonblocking_n "failed"); #endif ngx_memzero(&ngx_read_events[s], sizeof(ngx_event_t)); ngx_memzero(&ngx_write_events[s], sizeof(ngx_event_t)); ngx_memzero(&ngx_connections[s], sizeof(ngx_connection_t)); ngx_connections[s].sockaddr = cn->sockaddr; ngx_connections[s].family = cn->family; ngx_connections[s].socklen = cn->socklen; ngx_connections[s].addr = cn->addr; ngx_connections[s].addr_textlen = cn->addr_textlen; ngx_connections[s].post_accept_timeout = cn->post_accept_timeout; ngx_read_events[s].data = ngx_write_events[s].data = &ngx_connections[s]; ngx_connections[s].read = &ngx_read_events[s]; ngx_connections[s].write = &ngx_write_events[s]; ngx_connections[s].fd = s; ngx_connections[s].unexpected_eof = 1; ngx_write_events[s].write = 1; ngx_write_events[s].ready = 1; ngx_write_events[s].timer = ngx_read_events[s].timer = 10000; ngx_write_events[s].timer_handler = ngx_read_events[s].timer_handler = ngx_event_close_connection; ngx_write_events[s].close_handler = ngx_read_events[s].close_handler = ngx_event_close_connection; ngx_connections[s].server = cn->server; ngx_connections[s].servers = cn->servers; ngx_connections[s].log = ngx_read_events[s].log = ngx_write_events[s].log = ev->log; #if (HAVE_DEFERRED_ACCEPT) if (ev->accept_filter) ngx_read_events[s].ready = 1; #endif cn->handler(&ngx_connections[s]); #if (HAVE_KQUEUE) #if !(USE_KQUEUE) if (ngx_event_type == NGX_KQUEUE_EVENT) #endif ev->available--; #endif } while (ev->available); return 0; }