Mercurial > hg > nginx
comparison src/event/ngx_event_connect.c @ 290:87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Tue, 16 Mar 2004 07:10:12 +0000 |
parents | f81d075ad172 |
children | 117ccc7c4055 |
comparison
equal
deleted
inserted
replaced
289:0750faf8d7e3 | 290:87e73f067470 |
---|---|
8 | 8 |
9 /* AF_INET only */ | 9 /* AF_INET only */ |
10 | 10 |
11 int ngx_event_connect_peer(ngx_peer_connection_t *pc) | 11 int ngx_event_connect_peer(ngx_peer_connection_t *pc) |
12 { | 12 { |
13 int rc, instance; | 13 int rc; |
14 ngx_uint_t instance; | |
14 u_int event; | 15 u_int event; |
15 time_t now; | 16 time_t now; |
16 ngx_err_t err; | 17 ngx_err_t err; |
17 ngx_peer_t *peer; | 18 ngx_peer_t *peer; |
18 ngx_socket_t s; | 19 ngx_socket_t s; |
168 | 169 |
169 c->read = rev; | 170 c->read = rev; |
170 c->write = wev; | 171 c->write = wev; |
171 wev->write = 1; | 172 wev->write = 1; |
172 | 173 |
173 rev->instance = !instance; | 174 rev->instance = (u_char) !instance; |
174 wev->instance = !instance; | 175 wev->instance = (u_char) !instance; |
175 | 176 |
176 c->log = pc->log; | 177 c->log = pc->log; |
177 rev->log = pc->log; | 178 rev->log = pc->log; |
178 wev->log = pc->log; | 179 wev->log = pc->log; |
179 | 180 |
201 } | 202 } |
202 | 203 |
203 ngx_memzero(&addr, sizeof(struct sockaddr_in)); | 204 ngx_memzero(&addr, sizeof(struct sockaddr_in)); |
204 | 205 |
205 addr.sin_family = AF_INET; | 206 addr.sin_family = AF_INET; |
206 addr.sin_port = peer->port; | 207 addr.sin_port = (u_short) peer->port; |
207 addr.sin_addr.s_addr = peer->addr; | 208 addr.sin_addr.s_addr = peer->addr; |
208 | 209 |
209 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0, | 210 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0, |
210 "connect to %s", peer->addr_port_text.data); | 211 "connect to %s", peer->addr_port_text.data); |
211 | 212 |
222 if (ngx_close_socket(s) == -1) { | 223 if (ngx_close_socket(s) == -1) { |
223 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, | 224 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno, |
224 ngx_close_socket_n " failed"); | 225 ngx_close_socket_n " failed"); |
225 } | 226 } |
226 | 227 |
227 c->fd = -1; | 228 c->fd = (ngx_socket_t) -1; |
228 | 229 |
229 return NGX_CONNECT_ERROR; | 230 return NGX_CONNECT_ERROR; |
230 } | 231 } |
231 } | 232 } |
232 | 233 |