mirror of
https://github.com/nginx/nginx.git
synced 2024-12-15 05:09:06 +08:00
88 lines
2.3 KiB
C
88 lines
2.3 KiB
C
|
|
||
|
#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);
|
||
|
}
|
||
|
}
|