nginx: src/event/ngx_event_connect.c annotate

annotate src/event/ngx_event_connect.c @ 483:621229427cba release-0.1.16

nginx-0.1.16-RELEASE import *) Bugfix: if the response were transferred by chunks, then on the HEAD request the final chunk was issued. *) Bugfix: the "Connection: keep-alive" header were issued, even if the keepalive_timeout directive forbade the keep-alive use. *) Bugfix: the errors in the ngx_http_fastcgi_module caused the segmentation faults. *) Bugfix: the compressed response encrypted by SSL may not transferred complete. *) Bugfix: the TCP-specific TCP_NODELAY, TCP_NOPSUH, and TCP_CORK options, are not used for the unix domain sockets. *) Feature: the rewrite directive supports the arguments rewriting. *) Bugfix: the response code 400 was returned for the POST request with the "Content-Length: 0" header; the bug had appeared in 0.1.14.

author	Igor Sysoev <igor@sysoev.ru>
date	Tue, 25 Jan 2005 12:27:35 +0000
parents	c52408583801
children	31ff3e943e16

rev	line source
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 417 diff changeset	1
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 417 diff changeset	2 /*
444 42d11f017717 nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	3 * Copyright (C) Igor Sysoev
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 417 diff changeset	4 */
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 417 diff changeset	5
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	6
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	7 #include <ngx_config.h>
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	8 #include <ngx_core.h>
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	9 #include <ngx_event.h>
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	10 #include <ngx_event_connect.h>
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	11
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	12
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	13 ngx_int_t ngx_event_connect_peer(ngx_peer_connection_t *pc)
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	14 {
290 87e73f067470 nginx-0.0.2-2004-03-16-10:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 288 diff changeset	15 int rc;
381 02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	16 ngx_uint_t instance;
194 2357fa41738a nginx-0.0.1-2003-11-21-09:30:49 import Igor Sysoev <igor@sysoev.ru> parents: 191 diff changeset	17 u_int event;
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	18 time_t now;
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	19 ngx_err_t err;
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	20 ngx_peer_t *peer;
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	21 ngx_socket_t s;
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	22 ngx_event_t rev, wev;
da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	23 ngx_connection_t *c;
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	24 ngx_event_conf_t *ecf;
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	25
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	26 now = ngx_time();
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	27
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	28 /* ngx_lock_mutex(pc->peers->mutex); */
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	29
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	30 if (pc->peers->last_cached) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	31
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	32 /* cached connection */
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	33
381 02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	34 c = pc->peers->cached[pc->peers->last_cached];
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	35 pc->peers->last_cached--;
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	36
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	37 /* ngx_unlock_mutex(pc->peers->mutex); */
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	38
381 02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	39 #if (NGX_THREADS)
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	40 c->read->lock = c->read->own_lock;
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	41 c->write->lock = c->write->own_lock;
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	42 #endif
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	43
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	44 pc->connection = c;
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	45 pc->cached = 1;
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	46 return NGX_OK;
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	47 }
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	48
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	49 pc->cached = 0;
124 842a78cebbb7 nginx-0.0.1-2003-08-01-18:56:33 import Igor Sysoev <igor@sysoev.ru> parents: 122 diff changeset	50 pc->connection = NULL;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	51
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	52 if (pc->peers->number == 1) {
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	53 peer = &pc->peers->peer[0];
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	54
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	55 } else {
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	56
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	57 /* there are several peers */
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	58
120 b776ad95d96d nginx-0.0.1-2003-07-21-20:24:25 import Igor Sysoev <igor@sysoev.ru> parents: 119 diff changeset	59 if (pc->tries == pc->peers->number) {
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	60
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	61 /* it's a first try - get a current peer */
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	62
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	63 pc->cur_peer = pc->peers->current;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	64
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	65 pc->peers->weight--;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	66
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	67 if (pc->peers->weight == 0) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	68 pc->peers->current++;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	69 }
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	70
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	71 if (pc->peers->current >= pc->peers->number) {
120 b776ad95d96d nginx-0.0.1-2003-07-21-20:24:25 import Igor Sysoev <igor@sysoev.ru> parents: 119 diff changeset	72 pc->peers->current = 0;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	73 }
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	74
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	75 if (pc->peers->weight == 0) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	76 pc->peers->weight = pc->peers->peer[pc->peers->current].weight;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	77 }
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	78 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	79
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	80 for ( ;; ) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	81 peer = &pc->peers->peer[pc->cur_peer];
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	82
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	83 if (peer->fails <= peer->max_fails) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	84 break;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	85 }
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	86
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	87 if (now - peer->accessed > peer->fail_timeout) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	88 peer->fails = 0;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	89 break;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	90 }
473 8e8f3af115b5 nginx-0.1.11-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 461 diff changeset	91
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	92 pc->cur_peer++;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	93
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	94 if (pc->cur_peer >= pc->peers->number) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	95 pc->cur_peer = 0;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	96 }
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	97
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	98 pc->tries--;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	99
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	100 if (pc->tries == 0) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	101 /* ngx_unlock_mutex(pc->peers->mutex); */
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	102
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	103 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	104 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	105 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	106 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	107
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	108 /* ngx_unlock_mutex(pc->peers->mutex); */
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	109
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	110
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	111 s = ngx_socket(peer->sockaddr->sa_family, SOCK_STREAM, 0);
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	112
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	113 if (s == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	114 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	115 ngx_socket_n " failed");
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	116 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	117 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	118
323 ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	119
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	120 ecf = ngx_event_get_conf(ngx_cycle->conf_ctx, ngx_event_core_module);
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	121
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	122 /* disable warning: Win32 SOCKET is u_int while UNIX socket is int */
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	123
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	124 if ((ngx_uint_t) s >= ecf->connections) {
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	125
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	126 ngx_log_error(NGX_LOG_ALERT, pc->log, 0,
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	127 "socket() returned socket #%d while only %d "
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	128 "connections was configured, closing the socket",
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	129 s, ecf->connections);
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	130
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	131 if (ngx_close_socket(s) == -1) {
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	132 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	133 ngx_close_socket_n "failed");
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	134 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	135
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	136 /* TODO: sleep for some time */
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	137
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	138 return NGX_ERROR;
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	139 }
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	140
ba876b26b76d nginx-0.0.3-2004-04-21-22:54:33 import Igor Sysoev <igor@sysoev.ru> parents: 309 diff changeset	141
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	142 if (pc->rcvbuf) {
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	143 if (setsockopt(s, SOL_SOCKET, SO_RCVBUF,
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	144 (const void *) &pc->rcvbuf, sizeof(int)) == -1) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	145 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	146 "setsockopt(SO_RCVBUF) failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	147
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	148 if (ngx_close_socket(s) == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	149 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	150 ngx_close_socket_n " failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	151 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	152
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	153 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	154 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	155 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	156
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	157 if (ngx_nonblocking(s) == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	158 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	159 ngx_nonblocking_n " failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	160
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	161 if (ngx_close_socket(s) == -1) {
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	162 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	163 ngx_close_socket_n " failed");
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	164 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	165
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	166 return NGX_ERROR;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	167 }
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	168
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	169 #if (NGX_WIN32)
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	170
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	171 /*
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	172 * Winsock assignes a socket number divisible by 4
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	173 * so to find a connection we divide a socket number by 4.
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	174 */
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	175
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	176 if (s % 4) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	177 ngx_log_error(NGX_LOG_EMERG, pc->log, 0,
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	178 ngx_socket_n
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	179 " created socket %d, not divisible by 4", s);
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	180 exit(1);
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	181 }
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	182
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	183 c = &ngx_cycle->connections[s / 4];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	184 rev = &ngx_cycle->read_events[s / 4];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	185 wev = &ngx_cycle->write_events[s / 4];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	186
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	187 #else
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	188
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	189 c = &ngx_cycle->connections[s];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	190 rev = &ngx_cycle->read_events[s];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	191 wev = &ngx_cycle->write_events[s];
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	192
cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	193 #endif
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	194
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	195 instance = rev->instance;
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	196
379 73688d5d7fc3 nginx-0.0.7-2004-07-06-20:12:16 import Igor Sysoev <igor@sysoev.ru> parents: 377 diff changeset	197 #if (NGX_THREADS)
380 5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	198
5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	199 if (*(&c->lock)) {
379 73688d5d7fc3 nginx-0.0.7-2004-07-06-20:12:16 import Igor Sysoev <igor@sysoev.ru> parents: 377 diff changeset	200 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0,
380 5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	201 "spinlock in connect, fd:%d", s);
5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	202 ngx_spinlock(&c->lock, 1000);
5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	203 ngx_unlock(&c->lock);
379 73688d5d7fc3 nginx-0.0.7-2004-07-06-20:12:16 import Igor Sysoev <igor@sysoev.ru> parents: 377 diff changeset	204 }
380 5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	205
379 73688d5d7fc3 nginx-0.0.7-2004-07-06-20:12:16 import Igor Sysoev <igor@sysoev.ru> parents: 377 diff changeset	206 #endif
73688d5d7fc3 nginx-0.0.7-2004-07-06-20:12:16 import Igor Sysoev <igor@sysoev.ru> parents: 377 diff changeset	207
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	208 ngx_memzero(c, sizeof(ngx_connection_t));
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	209 ngx_memzero(rev, sizeof(ngx_event_t));
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	210 ngx_memzero(wev, sizeof(ngx_event_t));
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	211
381 02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	212 rev->instance = !instance;
02a511569afb nginx-0.0.7-2004-07-07-19:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 380 diff changeset	213 wev->instance = !instance;
306 6b91bfbc4123 nginx-0.0.3-2004-04-05-00:32:09 import Igor Sysoev <igor@sysoev.ru> parents: 300 diff changeset	214
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	215 rev->index = NGX_INVALID_INDEX;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	216 wev->index = NGX_INVALID_INDEX;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	217
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	218 rev->data = c;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	219 wev->data = c;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	220
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	221 c->read = rev;
3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	222 c->write = wev;
140 e32405df0e77 nginx-0.0.1-2003-10-08-08:34:07 import Igor Sysoev <igor@sysoev.ru> parents: 139 diff changeset	223 wev->write = 1;
86 3973260705cc nginx-0.0.1-2003-05-12-19:52:24 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	224
191 71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	225 c->log = pc->log;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	226 rev->log = pc->log;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	227 wev->log = pc->log;
71ce40b3c37b nginx-0.0.1-2003-11-19-19:26:41 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	228
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	229 c->fd = s;
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	230
288 f81d075ad172 nginx-0.0.2-2004-03-14-23:46:25 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	231 c->log_error = pc->log_error;
f81d075ad172 nginx-0.0.2-2004-03-14-23:46:25 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	232
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	233 if (peer->sockaddr->sa_family != AF_INET) {
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	234 c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	235 c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	236 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	237
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	238 pc->connection = c;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	239
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	240 /*
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	241 * TODO: MT: - atomic increment (x86: lock xadd)
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	242 * or protection by critical section or mutex
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	243 *
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	244 * TODO: MP: - allocated in a shared memory
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	245 * - atomic increment (x86: lock xadd)
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	246 * or protection by critical section or mutex
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	247 */
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	248
309 2e899477243a nginx-0.0.3-2004-04-09-20:03:04 import Igor Sysoev <igor@sysoev.ru> parents: 306 diff changeset	249 c->number = ngx_atomic_inc(ngx_connection_counter);
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	250
377 41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	251 #if (NGX_THREADS)
41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	252 rev->lock = pc->lock;
41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	253 wev->lock = pc->lock;
380 5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	254 rev->own_lock = &c->lock;
5ce6561246a5 nginx-0.0.7-2004-07-07-10:15:04 import Igor Sysoev <igor@sysoev.ru> parents: 379 diff changeset	255 wev->own_lock = &c->lock;
377 41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	256 #endif
41437e4fd9b4 nginx-0.0.7-2004-07-05-19:08:23 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	257
121 b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	258 if (ngx_add_conn) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	259 if (ngx_add_conn(c) == NGX_ERROR) {
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	260 return NGX_ERROR;
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	261 }
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	262 }
b3655b21375a nginx-0.0.1-2003-07-22-23:53:10 import Igor Sysoev <igor@sysoev.ru> parents: 120 diff changeset	263
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	264 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, pc->log, 0,
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	265 "connect to %V, #%d", &peer->name, c->number);
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	266
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	267 rc = connect(s, peer->sockaddr, peer->socklen);
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	268
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	269 if (rc == -1) {
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	270 err = ngx_socket_errno;
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	271
288 f81d075ad172 nginx-0.0.2-2004-03-14-23:46:25 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	272 /* Winsock returns WSAEWOULDBLOCK (NGX_EAGAIN) */
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	273
c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	274 if (err != NGX_EINPROGRESS && err != NGX_EAGAIN) {
288 f81d075ad172 nginx-0.0.2-2004-03-14-23:46:25 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	275 ngx_connection_error(c, err, "connect() failed");
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	276
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	277 if (ngx_close_socket(s) == -1) {
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	278 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	279 ngx_close_socket_n " failed");
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	280 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	281
290 87e73f067470 nginx-0.0.2-2004-03-16-10:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 288 diff changeset	282 c->fd = (ngx_socket_t) -1;
139 54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 137 diff changeset	283
122 cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	284 return NGX_CONNECT_ERROR;
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	285 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	286 }
cd91e4a1ad0d nginx-0.0.1-2003-07-23-17:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 121 diff changeset	287
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	288 if (ngx_add_conn) {
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	289 if (rc == -1) {
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	290 /* NGX_EINPROGRESS */
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	291 return NGX_AGAIN;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	292 }
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	293
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	294 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	295
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	296 wev->ready = 1;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	297
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	298 return NGX_OK;
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	299 }
e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 323 diff changeset	300
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	301 if (ngx_event_flags & NGX_USE_AIO_EVENT) {
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	302
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	303 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, ngx_socket_errno,
295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	304 "connect(): %d", rc);
295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	305
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	306 /* aio, iocp */
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	307
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	308 if (ngx_blocking(s) == -1) {
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	309 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	310 ngx_blocking_n " failed");
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	311
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	312 if (ngx_close_socket(s) == -1) {
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	313 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	314 ngx_close_socket_n " failed");
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	315 }
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	316
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	317 return NGX_ERROR;
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	318 }
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	319
8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	320 /*
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	321 * FreeBSD aio allows to post operation on non-connected socket.
186 c1f3a3c7c5db nginx-0.0.1-2003-11-17-00:49:42 import Igor Sysoev <igor@sysoev.ru> parents: 169 diff changeset	322 * NT does not support it.
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	323 *
169 edf29bb717da nginx-0.0.1-2003-10-31-19:05:33 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	324 * TODO: check in Win32, etc. As workaround we can use NGX_ONESHOT_EVENT
167 8aef3c72e5da nginx-0.0.1-2003-10-30-19:51:33 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	325 */
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	326
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	327 rev->ready = 1;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	328 wev->ready = 1;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	329
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	330 return NGX_OK;
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	331 }
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 162 diff changeset	332
144 ef8c87afcfc5 nginx-0.0.1-2003-10-12-20:49:16 import Igor Sysoev <igor@sysoev.ru> parents: 140 diff changeset	333 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) { /* kqueue */
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	334 event = NGX_CLEAR_EVENT;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	335
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	336 } else { /* select, poll, /dev/poll */
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	337 event = NGX_LEVEL_EVENT;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	338 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	339
162 96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	340 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	341 return NGX_ERROR;
96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	342 }
96993d4d5067 nginx-0.0.1-2003-10-28-00:01:00 import Igor Sysoev <igor@sysoev.ru> parents: 161 diff changeset	343
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	344 if (rc == -1) {
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	345
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	346 /* NGX_EINPROGRESS */
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	347
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	348 if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	349 return NGX_ERROR;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	350 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	351
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	352 return NGX_AGAIN;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	353 }
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	354
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	355 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
189 c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	356
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	357 wev->ready = 1;
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	358
136 da00cde00e8a nginx-0.0.1-2003-10-02-09:39:37 import Igor Sysoev <igor@sysoev.ru> parents: 131 diff changeset	359 return NGX_OK;
119 cd54bcbaf3b5 nginx-0.0.1-2003-07-21-01:15:59 import Igor Sysoev <igor@sysoev.ru> parents: 86 diff changeset	360 }
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	361
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	362
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	363 void ngx_event_connect_peer_failed(ngx_peer_connection_t *pc)
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	364 {
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	365 time_t now;
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	366
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	367 now = ngx_time();
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	368
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	369 /* ngx_lock_mutex(pc->peers->mutex); */
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	370
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	371 pc->peers->peer[pc->cur_peer].fails++;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	372 pc->peers->peer[pc->cur_peer].accessed = now;
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	373
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	374 /* ngx_unlock_mutex(pc->peers->mutex); */
ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 167 diff changeset	375
161 88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	376 pc->cur_peer++;
88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	377
88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	378 if (pc->cur_peer >= pc->peers->number) {
88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	379 pc->cur_peer = 0;
88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	380 }
88abd07d9f62 nginx-0.0.1-2003-10-27-19:16:17 import Igor Sysoev <igor@sysoev.ru> parents: 148 diff changeset	381
137 2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	382 pc->tries--;
2a615b036870 nginx-0.0.1-2003-10-03-19:50:53 import Igor Sysoev <igor@sysoev.ru> parents: 136 diff changeset	383
131 049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	384 return;
049e78b1f852 nginx-0.0.1-2003-08-14-10:00:28 import Igor Sysoev <igor@sysoev.ru> parents: 124 diff changeset	385 }

Mercurial > hg > nginx

annotate src/event/ngx_event_connect.c @ 483:621229427cba release-0.1.16