Mercurial > hg > nginx
comparison src/event/ngx_event_connect.c @ 161:88abd07d9f62
nginx-0.0.1-2003-10-27-19:16:17 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Mon, 27 Oct 2003 16:16:17 +0000 |
parents | 5afee0074707 |
children | 96993d4d5067 |
comparison
equal
deleted
inserted
replaced
160:e7e094d34162 | 161:88abd07d9f62 |
---|---|
36 } | 36 } |
37 | 37 |
38 pc->cached = 0; | 38 pc->cached = 0; |
39 pc->connection = NULL; | 39 pc->connection = NULL; |
40 | 40 |
41 peer = &pc->peers->peers[0]; | |
42 | |
43 if (pc->peers->number > 1) { | 41 if (pc->peers->number > 1) { |
44 | 42 |
45 /* there are several peers */ | 43 /* there are several peers */ |
46 | 44 |
47 if (pc->tries == pc->peers->number) { | 45 if (pc->tries == pc->peers->number) { |
83 } | 81 } |
84 } | 82 } |
85 } | 83 } |
86 } | 84 } |
87 | 85 |
86 peer = &pc->peers->peers[pc->cur_peer]; | |
87 | |
88 /* ngx_unlock_mutex(pc->peers->mutex); */ | 88 /* ngx_unlock_mutex(pc->peers->mutex); */ |
89 | 89 |
90 #if 0 | 90 #if 0 |
91 pc->addr_port_text = peer->addr_port_text; | 91 pc->addr_port_text = peer->addr_port_text; |
92 #endif | 92 #endif |
180 | 180 |
181 addr.sin_family = AF_INET; | 181 addr.sin_family = AF_INET; |
182 addr.sin_addr.s_addr = peer->addr; | 182 addr.sin_addr.s_addr = peer->addr; |
183 addr.sin_port = peer->port; | 183 addr.sin_port = peer->port; |
184 | 184 |
185 ngx_log_debug(pc->log, "CONNECT: %s" _ peer->addr_port_text.data); | |
186 | |
185 rc = connect(s, (struct sockaddr *) &addr, sizeof(struct sockaddr_in)); | 187 rc = connect(s, (struct sockaddr *) &addr, sizeof(struct sockaddr_in)); |
186 | 188 |
187 if (rc == -1) { | 189 if (rc == -1) { |
188 err = ngx_socket_errno; | 190 err = ngx_socket_errno; |
189 if (err != NGX_EINPROGRESS) { | 191 if (err != NGX_EINPROGRESS) { |
230 } | 232 } |
231 | 233 |
232 | 234 |
233 void ngx_event_connect_peer_failed(ngx_peer_connection_t *pc) | 235 void ngx_event_connect_peer_failed(ngx_peer_connection_t *pc) |
234 { | 236 { |
237 pc->cur_peer++; | |
238 | |
239 if (pc->cur_peer >= pc->peers->number) { | |
240 pc->cur_peer = 0; | |
241 } | |
242 | |
235 pc->tries--; | 243 pc->tries--; |
236 | 244 |
237 return; | 245 return; |
238 } | 246 } |