mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-06-07 17:52:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

nginx-0.0.1-2003-07-23-17:10:12 import

Browse Source
This commit is contained in:
Igor Sysoev 2003-07-23 13:10:12 +00:00
parent 72f2e36770
commit 3a081188dc
1 changed files with 36 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/event/ngx_event_connect.c
View File

@ -1,11 +1,17 @@
#include <ngx_event_connect.h> #include <ngx_event_connect.h>
/* AF_INET only */
int ngx_event_connect_peer(ngx_peer_connecttion_t *pc) int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
{ {
time_t now; time_t now;
ngx_peer_r *peer;
ngx_socket_t s; ngx_socket_t s;
struct sockaddr_in *addr;
now = ngx_time();
/* ngx_lock_mutex(pc->peers->mutex); */ /* ngx_lock_mutex(pc->peers->mutex); */
@ -22,12 +28,8 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
return NGX_OK; return NGX_OK;
} }
/* ngx_unlock_mutex(pc->peers->mutex); */
pc->cached = 0; pc->cached = 0;
now = ngx_time();
if (pc->peers->number > 1) { if (pc->peers->number > 1) {
/* there are several peers */ /* there are several peers */
@ -36,24 +38,11 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
/* it's a first try - get a current peer */ /* it's a first try - get a current peer */
/* Here is the race condition when the peers are shared between
the threads or the processes but it should not be serious */
pc->cur_peer = pc->peers->current++; pc->cur_peer = pc->peers->current++;
if (cp->peers->current >= cp->peers->number) { if (cp->peers->current >= cp->peers->number) {
pc->peers->current = 0; pc->peers->current = 0;
} }
/* the end of the race condition */
#if (NGX_MULTITHREADED || NGX_MULTIPROCESSED)
/* eliminate the sequences of the race condition */
if (pc->cur_peer >= pc->peers->number) {
pc->cur_peer = 0;
}
#endif
} }
if (pc->peers->max_fails > 0) { if (pc->peers->max_fails > 0) {
@ -63,17 +52,12 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
for ( ;; ) { for ( ;; ) {
peer = &pc->peers->peers[pc->cur_peer]; peer = &pc->peers->peers[pc->cur_peer];
/* Here is the race condition when the peers are shared between
the threads or the processes but it should not be serious */
if (peer->fails <= pc->peers->max_fails if (peer->fails <= pc->peers->max_fails
|| (now - peer->accessed > pc->peers->fail_timeout)) || (now - peer->accessed > pc->peers->fail_timeout))
{ {
break; break;
} }
/* the end of the race condition */
pc->cur_peer++; pc->cur_peer++;
if (pc->cur_peer >= pc->peers->number) { if (pc->cur_peer >= pc->peers->number) {
@ -83,12 +67,15 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
pc->tries--; pc->tries--;
if (pc->tries == 0) { if (pc->tries == 0) {
/* ngx_unlock_mutex(pc->peers->mutex); */
return NGX_ERROR; return NGX_ERROR;
} }
} }
} }
} }
/* ngx_unlock_mutex(pc->peers->mutex); */
pc->addr_port_text = peer->addr_port_text; pc->addr_port_text = peer->addr_port_text;
s = ngx_socket(AF_INET, SOCK_STREAM, IPPROTO_IP, 0); s = ngx_socket(AF_INET, SOCK_STREAM, IPPROTO_IP, 0);
@ -175,4 +162,29 @@ int ngx_event_connect_peer(ngx_peer_connecttion_t *pc)
} }
} }
addr = p->sockaddr;
addr->sin_family = AF_INET;
addr->sin_addr.s_addr = peer->addr;
addr->sin_port = htons(peer->port);
rc = connect(s, p->sockaddr, sizeof(struct sockaddr_in));
if (rc == -1) {
err = ngx_socket_errno;
if (err != NGX_EINPROGRESS) {
ngx_log_error(NGX_LOG_CRIT, pc->log, err, "connect() failed");
if (ngx_close_socket(s) == -1) {
ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
ngx_close_socket_n " failed");
}
return NGX_CONNECT_ERROR;
}
}
c->data = ???;
} }