Mercurial > hg > nginx
diff src/event/ngx_event_accept.c @ 0:4eff17414a43
nginx-0.0.1-2002-08-06-20:39:45 import
The first code that uses "ngx_" prefix, the previous one used "gx_" prefix.
At that point the code is not yet usable. The first draft ideas are dated
back to 23.10.2001.
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Tue, 06 Aug 2002 16:39:45 +0000 |
parents | |
children | 34a521b1a148 |
line wrap: on
line diff
new file mode 100644 --- /dev/null +++ b/src/event/ngx_event_accept.c @@ -0,0 +1,83 @@ + +#include <ngx_config.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, (struct sockaddr *) &addr, &addrlen)) == -1) { + err = ngx_socket_errno; + if (err == NGX_EAGAIN) { + ngx_log_error(NGX_LOG_INFO, ev->log, err, + "ngx_event_accept: EAGAIN while accept"); + return 0; + } + + ngx_log_error(NGX_LOG_ERR, ev->log, err, + "ngx_event_accept: accept failed"); + /* if we return -1 listen socket would be closed */ + return 0; + } + + ngx_log_debug(ev->log, "ngx_event_accept: accepted socket: %d" _ s); + + 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_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_read_events[s].unexpected_eof = 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; + + ngx_write_events[s].close_handler = + ngx_read_events[s].close_handler = ngx_event_close; + + 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->server->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; +}