Mercurial > hg > nginx
diff src/event/ngx_event.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
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/event/ngx_event.c Tue Aug 06 16:39:45 2002 +0000 @@ -0,0 +1,87 @@ + +#include <ngx_config.h> +#include <ngx_types.h> +#include <ngx_log.h> +#include <ngx_alloc.h> +#include <ngx_connection.h> +#include <ngx_event.h> +#include <ngx_event_accept.h> + +#include <ngx_select_module.h> +#if (HAVE_KQUEUE) +#include <ngx_kqueue_module.h> +#endif + + +ngx_connection_t *ngx_connections; +ngx_event_t *ngx_read_events, *ngx_write_events; + +#if !(USE_KQUEUE) + +#if 1 +ngx_event_type_e ngx_event_type = NGX_SELECT_EVENT; +#else +ngx_event_type_e ngx_event_type = NGX_KQUEUE_EVENT; +#endif + +ngx_event_actions_t ngx_event_actions; + +/* ngx_event_type_e order */ +static void (*ngx_event_init[]) (int max_connections, ngx_log_t *log) = { + ngx_select_init, +#if (HAVE_POLL) + ngx_poll_init, +#endif +#if (HAVE_KQUEUE) + ngx_kqueue_init +#endif +}; + +#endif /* USE_KQUEUE */ + + +void ngx_worker(ngx_listen_t *sock, int n, ngx_pool_t *pool, ngx_log_t *log) +{ + int i, fd; + + /* per group */ + int max_connections = 512; + + ngx_init_events(max_connections, log); + + ngx_read_events = ngx_alloc(sizeof(ngx_event_t) * max_connections, log); + ngx_write_events = ngx_alloc(sizeof(ngx_event_t) * max_connections, log); + ngx_connections = ngx_alloc(sizeof(ngx_connection_t) + * max_connections, log); + + /* for each listening socket */ + for (i = 0; i < n; i++) { + fd = sock[i].fd; + + ngx_memzero(&ngx_read_events[fd], sizeof(ngx_event_t)); + ngx_memzero(&ngx_write_events[fd], sizeof(ngx_event_t)); + ngx_memzero(&ngx_connections[fd], sizeof(ngx_connection_t)); + + ngx_connections[fd].fd = fd; + ngx_connections[fd].server = sock[i].server; + ngx_connections[fd].read = (void *) &ngx_read_events[fd].data; + ngx_read_events[fd].data = &ngx_connections[fd]; + ngx_read_events[fd].log = ngx_connections[fd].log = sock[i].log; + ngx_read_events[fd].data = &ngx_connections[fd]; + ngx_read_events[fd].event_handler = &ngx_event_accept; + ngx_read_events[fd].listening = 1; + + ngx_read_events[fd].available = 0; + +#if (HAVE_DEFERRED_ACCEPT) + ngx_read_events[fd].accept_filter = sock->accept_filter; +#endif + ngx_add_event(&ngx_read_events[fd], NGX_READ_EVENT, 0); + } + + while (1) { + ngx_log_debug(log, "ngx_worker cycle"); + + ngx_process_events(log); + } +}