Mercurial > hg > nginx

comparison src/event/ngx_event_connect.c @ 161:88abd07d9f62

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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 }