Mercurial > hg > nginx
changeset 121:b3655b21375a
nginx-0.0.1-2003-07-22-23:53:10 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Tue, 22 Jul 2003 19:53:10 +0000 |
parents | b776ad95d96d |
children | cd91e4a1ad0d |
files | src/event/modules/ngx_select_module.c src/event/ngx_event_accept.c src/event/ngx_event_connect.c src/event/ngx_event_connect.h |
diffstat | 4 files changed, 53 insertions(+), 29 deletions(-) [+] |
line wrap: on
line diff
--- a/src/event/modules/ngx_select_module.c Mon Jul 21 16:24:25 2003 +0000 +++ b/src/event/modules/ngx_select_module.c Tue Jul 22 19:53:10 2003 +0000 @@ -428,7 +428,7 @@ ecf = ngx_event_get_conf(cycle->conf_ctx, ngx_event_core_module); - /* disable warnings: the default FD_SETSIZE is 1024U in FreeBSD 5.x */ + /* disable warning: the default FD_SETSIZE is 1024U in FreeBSD 5.x */ if ((unsigned) ecf->connections > FD_SETSIZE) { return "maximum number of connections "
--- a/src/event/ngx_event_accept.c Mon Jul 21 16:24:25 2003 +0000 +++ b/src/event/ngx_event_accept.c Tue Jul 22 19:53:10 2003 +0000 @@ -66,7 +66,7 @@ return; } - /* disable warnings: Win32 SOCKET is u_int while UNIX socket is int */ + /* disable warning: Win32 SOCKET is u_int while UNIX socket is int */ if ((unsigned) s >= (unsigned) ecf->connections) {
--- a/src/event/ngx_event_connect.c Mon Jul 21 16:24:25 2003 +0000 +++ b/src/event/ngx_event_connect.c Tue Jul 22 19:53:10 2003 +0000 @@ -4,9 +4,27 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc) { - time_t now; + time_t now; + ngx_socket_t s; + + /* ngx_lock_mutex(pc->peers->mutex); */ + + if (pc->peers->last_cached) { + + /* cached connection */ - /* TODO: cached connection */ + pc->connection = pc->peers->cached[pc->peers->last_cached] + pc->peers->last_cached--; + + /* ngx_unlock_mutex(pc->peers->mutex); */ + + pc->cached = 1; + return NGX_OK; + } + + /* ngx_unlock_mutex(pc->peers->mutex); */ + + pc->cached = 0; now = ngx_time(); @@ -71,26 +89,24 @@ } } - - - + pc->addr_port_text = peer->addr_port_text; s = ngx_socket(AF_INET, SOCK_STREAM, IPPROTO_IP, 0); if (s == -1) { - ngx_log_error(NGX_LOG_ALERT, cp->log, ngx_socket_errno, + ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, ngx_socket_n " failed"); return NGX_ERROR; } - if (cp->rcvbuf) { + if (pc->rcvbuf) { if (setsockopt(s, SOL_SOCKET, SO_RCVBUF, - (const void *) &cp->rcvbuf, sizeof(int)) == -1) { - ngx_log_error(NGX_LOG_ALERT, cp->log, ngx_socket_errno, + (const void *) &pc->rcvbuf, sizeof(int)) == -1) { + ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, "setsockopt(SO_RCVBUF) failed"); if (ngx_close_socket(s) == -1) { - ngx_log_error(NGX_LOG_ALERT, cp->log, ngx_socket_errno, + ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, ngx_close_socket_n " failed"); } @@ -99,11 +115,11 @@ } if (ngx_nonblocking(s) == -1) { - ngx_log_error(NGX_LOG_ALERT, cn->log, ngx_socket_errno, + ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, ngx_nonblocking_n " failed"); if (ngx_close_socket(s) == -1) { - ngx_log_error(NGX_LOG_ALERT, cn->log, ngx_socket_errno, + ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, ngx_close_socket_n " failed"); } @@ -111,17 +127,17 @@ } #if (WIN32) - /* - * Winsock assignes a socket number divisible by 4 - * so to find a connection we divide a socket number by 4. - */ + /* + * Winsock assignes a socket number divisible by 4 + * so to find a connection we divide a socket number by 4. + */ - if (s % 4) { - ngx_log_error(NGX_LOG_EMERG, cp->log, 0, - ngx_socket_n - " created socket %d, not divisible by 4", s); - exit(1); - } + if (s % 4) { + ngx_log_error(NGX_LOG_EMERG, pc->log, 0, + ngx_socket_n + " created socket %d, not divisible by 4", s); + exit(1); + } c = &ngx_cycle->connections[s / 4]; rev = &ngx_cycle->read_events[s / 4]; @@ -148,9 +164,15 @@ rev->instance = wev->instance = !instance; - !!!!!!!!!!!!!!! + rev->log = wev->log = c->log = pc->log; + c->fd = s; + + pc->connection = c; - rev->log = wev->log = c->log = cn->log; - c->fd = s; - wev->close_handler = rev->close_handler = ngx_event_close_connection; + if (ngx_add_conn) { + if (ngx_add_conn(c) == NGX_ERROR) { + return NGX_ERROR; + } + } + }
--- a/src/event/ngx_event_connect.h Mon Jul 21 16:24:25 2003 +0000 +++ b/src/event/ngx_event_connect.h Tue Jul 22 19:53:10 2003 +0000 @@ -11,7 +11,7 @@ u_int32_t addr; ngx_str_t host; int port; - ngx_str_t addr_port_name; + ngx_str_t addr_port_text; int fails; time_t accessed; @@ -38,6 +38,8 @@ ngx_connection_t *connection; + int rcvbuf; + unsigned cached:1; } ngx_peer_connection_t;