Mercurial > hg > nginx
annotate src/mail/ngx_mail_proxy_module.c @ 2309:8156bc03982a
smtp_auth none
patch by Maxim Dounin
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Thu, 13 Nov 2008 13:25:34 +0000 |
| parents | 2a92804f4109 |
| children | 6bad42a41dd8 |
| 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:
426
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:
426
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:
426
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:
426
diff
changeset
|
5 |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
6 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
7 #include <ngx_config.h> |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
8 #include <ngx_core.h> |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
9 #include <ngx_event.h> |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
10 #include <ngx_event_connect.h> |
| 1136 | 11 #include <ngx_mail.h> |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
12 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
13 |
| 521 | 14 typedef struct { |
| 15 ngx_flag_t enable; | |
| 857 | 16 ngx_flag_t pass_error_message; |
| 1136 | 17 ngx_flag_t xclient; |
| 539 | 18 size_t buffer_size; |
| 19 ngx_msec_t timeout; | |
| 1136 | 20 } ngx_mail_proxy_conf_t; |
| 521 | 21 |
| 22 | |
| 1136 | 23 static void ngx_mail_proxy_block_read(ngx_event_t *rev); |
| 24 static void ngx_mail_proxy_pop3_handler(ngx_event_t *rev); | |
| 25 static void ngx_mail_proxy_imap_handler(ngx_event_t *rev); | |
| 26 static void ngx_mail_proxy_smtp_handler(ngx_event_t *rev); | |
| 27 static void ngx_mail_proxy_dummy_handler(ngx_event_t *ev); | |
| 28 static ngx_int_t ngx_mail_proxy_read_response(ngx_mail_session_t *s, | |
| 663 | 29 ngx_uint_t state); |
| 1136 | 30 static void ngx_mail_proxy_handler(ngx_event_t *ev); |
| 31 static void ngx_mail_proxy_upstream_error(ngx_mail_session_t *s); | |
| 32 static void ngx_mail_proxy_internal_server_error(ngx_mail_session_t *s); | |
| 33 static void ngx_mail_proxy_close_session(ngx_mail_session_t *s); | |
| 34 static void *ngx_mail_proxy_create_conf(ngx_conf_t *cf); | |
| 35 static char *ngx_mail_proxy_merge_conf(ngx_conf_t *cf, void *parent, | |
| 521 | 36 void *child); |
| 37 | |
| 38 | |
| 1136 | 39 static ngx_command_t ngx_mail_proxy_commands[] = { |
| 539 | 40 |
| 521 | 41 { ngx_string("proxy"), |
| 1136 | 42 NGX_MAIL_MAIN_CONF|NGX_MAIL_SRV_CONF|NGX_CONF_FLAG, |
| 521 | 43 ngx_conf_set_flag_slot, |
| 1136 | 44 NGX_MAIL_SRV_CONF_OFFSET, |
| 45 offsetof(ngx_mail_proxy_conf_t, enable), | |
| 521 | 46 NULL }, |
| 47 | |
| 539 | 48 { ngx_string("proxy_buffer"), |
| 1136 | 49 NGX_MAIL_MAIN_CONF|NGX_MAIL_SRV_CONF|NGX_CONF_TAKE1, |
| 539 | 50 ngx_conf_set_size_slot, |
| 1136 | 51 NGX_MAIL_SRV_CONF_OFFSET, |
| 52 offsetof(ngx_mail_proxy_conf_t, buffer_size), | |
| 539 | 53 NULL }, |
| 54 | |
| 55 { ngx_string("proxy_timeout"), | |
| 1136 | 56 NGX_MAIL_MAIN_CONF|NGX_MAIL_SRV_CONF|NGX_CONF_TAKE1, |
| 539 | 57 ngx_conf_set_msec_slot, |
| 1136 | 58 NGX_MAIL_SRV_CONF_OFFSET, |
| 59 offsetof(ngx_mail_proxy_conf_t, timeout), | |
| 539 | 60 NULL }, |
| 61 | |
| 857 | 62 { ngx_string("proxy_pass_error_message"), |
| 1136 | 63 NGX_MAIL_MAIN_CONF|NGX_MAIL_SRV_CONF|NGX_CONF_TAKE1, |
| 857 | 64 ngx_conf_set_flag_slot, |
| 1136 | 65 NGX_MAIL_SRV_CONF_OFFSET, |
| 66 offsetof(ngx_mail_proxy_conf_t, pass_error_message), | |
| 67 NULL }, | |
| 68 | |
| 69 { ngx_string("xclient"), | |
| 70 NGX_MAIL_MAIN_CONF|NGX_MAIL_SRV_CONF|NGX_CONF_FLAG, | |
| 71 ngx_conf_set_flag_slot, | |
| 72 NGX_MAIL_SRV_CONF_OFFSET, | |
| 73 offsetof(ngx_mail_proxy_conf_t, xclient), | |
| 857 | 74 NULL }, |
| 75 | |
| 521 | 76 ngx_null_command |
| 77 }; | |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
78 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
79 |
| 1136 | 80 static ngx_mail_module_t ngx_mail_proxy_module_ctx = { |
|
1487
f69493e8faab
ngx_mail_pop3_module, ngx_mail_imap_module, and ngx_mail_smtp_module
Igor Sysoev <igor@sysoev.ru>
parents:
1342
diff
changeset
|
81 NULL, /* protocol */ |
|
f69493e8faab
ngx_mail_pop3_module, ngx_mail_imap_module, and ngx_mail_smtp_module
Igor Sysoev <igor@sysoev.ru>
parents:
1342
diff
changeset
|
82 |
| 521 | 83 NULL, /* create main configuration */ |
| 84 NULL, /* init main configuration */ | |
| 85 | |
| 1136 | 86 ngx_mail_proxy_create_conf, /* create server configuration */ |
| 87 ngx_mail_proxy_merge_conf /* merge server configuration */ | |
| 521 | 88 }; |
| 89 | |
| 90 | |
| 1136 | 91 ngx_module_t ngx_mail_proxy_module = { |
| 521 | 92 NGX_MODULE_V1, |
| 1136 | 93 &ngx_mail_proxy_module_ctx, /* module context */ |
| 94 ngx_mail_proxy_commands, /* module directives */ | |
| 95 NGX_MAIL_MODULE, /* module type */ | |
| 541 | 96 NULL, /* init master */ |
| 521 | 97 NULL, /* init module */ |
| 541 | 98 NULL, /* init process */ |
| 99 NULL, /* init thread */ | |
| 100 NULL, /* exit thread */ | |
| 101 NULL, /* exit process */ | |
| 102 NULL, /* exit master */ | |
| 103 NGX_MODULE_V1_PADDING | |
| 521 | 104 }; |
| 105 | |
| 106 | |
| 2309 | 107 static u_char smtp_auth_ok[] = "235 2.0.0 OK" CRLF; |
| 108 static u_char smtp_ok[] = "250 2.0.0 OK" CRLF; | |
| 1136 | 109 |
| 110 | |
| 521 | 111 void |
| 1136 | 112 ngx_mail_proxy_init(ngx_mail_session_t *s, ngx_peer_addr_t *peer) |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
113 { |
| 587 | 114 int keepalive; |
| 527 | 115 ngx_int_t rc; |
| 1136 | 116 ngx_mail_proxy_ctx_t *p; |
| 117 ngx_mail_proxy_conf_t *pcf; | |
| 118 ngx_mail_core_srv_conf_t *cscf; | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
119 |
| 587 | 120 s->connection->log->action = "connecting to upstream"; |
| 121 | |
| 1136 | 122 cscf = ngx_mail_get_module_srv_conf(s, ngx_mail_core_module); |
| 587 | 123 |
| 124 if (cscf->so_keepalive) { | |
| 125 keepalive = 1; | |
| 126 | |
| 127 if (setsockopt(s->connection->fd, SOL_SOCKET, SO_KEEPALIVE, | |
| 128 (const void *) &keepalive, sizeof(int)) | |
| 129 == -1) | |
| 130 { | |
| 131 ngx_log_error(NGX_LOG_ALERT, s->connection->log, ngx_socket_errno, | |
| 132 "setsockopt(SO_KEEPALIVE) failed"); | |
| 133 } | |
| 134 } | |
| 135 | |
| 1136 | 136 p = ngx_pcalloc(s->connection->pool, sizeof(ngx_mail_proxy_ctx_t)); |
| 501 | 137 if (p == NULL) { |
| 1136 | 138 ngx_mail_session_internal_server_error(s); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
139 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
140 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
141 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
142 s->proxy = p; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
143 |
| 884 | 144 p->upstream.sockaddr = peer->sockaddr; |
| 145 p->upstream.socklen = peer->socklen; | |
| 146 p->upstream.name = &peer->name; | |
| 147 p->upstream.get = ngx_event_get_peer; | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
148 p->upstream.log = s->connection->log; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
149 p->upstream.log_error = NGX_ERROR_ERR; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
150 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
151 rc = ngx_event_connect_peer(&p->upstream); |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
152 |
| 543 | 153 if (rc == NGX_ERROR || rc == NGX_BUSY || rc == NGX_DECLINED) { |
| 1136 | 154 ngx_mail_proxy_internal_server_error(s); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
155 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
156 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
157 |
| 527 | 158 ngx_add_timer(p->upstream.connection->read, cscf->timeout); |
| 159 | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
160 p->upstream.connection->data = s; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
161 p->upstream.connection->pool = s->connection->pool; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
162 |
| 1136 | 163 s->connection->read->handler = ngx_mail_proxy_block_read; |
| 164 p->upstream.connection->write->handler = ngx_mail_proxy_dummy_handler; | |
| 165 | |
| 166 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); | |
| 167 | |
| 168 s->proxy->buffer = ngx_create_temp_buf(s->connection->pool, | |
| 169 pcf->buffer_size); | |
| 170 if (s->proxy->buffer == NULL) { | |
| 171 ngx_mail_proxy_internal_server_error(s); | |
| 172 return; | |
| 173 } | |
| 174 | |
| 1981 | 175 s->out.len = 0; |
| 176 | |
| 1136 | 177 switch (s->protocol) { |
| 527 | 178 |
| 1136 | 179 case NGX_MAIL_POP3_PROTOCOL: |
| 180 p->upstream.connection->read->handler = ngx_mail_proxy_pop3_handler; | |
| 181 s->mail_state = ngx_pop3_start; | |
| 182 break; | |
| 527 | 183 |
| 1136 | 184 case NGX_MAIL_IMAP_PROTOCOL: |
| 185 p->upstream.connection->read->handler = ngx_mail_proxy_imap_handler; | |
| 186 s->mail_state = ngx_imap_start; | |
| 187 break; | |
| 188 | |
| 189 default: /* NGX_MAIL_SMTP_PROTOCOL */ | |
| 190 p->upstream.connection->read->handler = ngx_mail_proxy_smtp_handler; | |
| 191 s->mail_state = ngx_smtp_start; | |
| 192 break; | |
| 527 | 193 } |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
194 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
195 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
196 |
| 521 | 197 static void |
| 1136 | 198 ngx_mail_proxy_block_read(ngx_event_t *rev) |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
199 { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
200 ngx_connection_t *c; |
| 1136 | 201 ngx_mail_session_t *s; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
202 |
| 1136 | 203 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy block read"); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
204 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
205 if (ngx_handle_read_event(rev, 0) == NGX_ERROR) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
206 c = rev->data; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
207 s = c->data; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
208 |
| 1136 | 209 ngx_mail_proxy_close_session(s); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
210 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
211 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
212 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
213 |
| 521 | 214 static void |
| 1136 | 215 ngx_mail_proxy_pop3_handler(ngx_event_t *rev) |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
216 { |
| 539 | 217 u_char *p; |
| 218 ngx_int_t rc; | |
| 219 ngx_str_t line; | |
| 220 ngx_connection_t *c; | |
| 1136 | 221 ngx_mail_session_t *s; |
| 222 ngx_mail_proxy_conf_t *pcf; | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
223 |
| 1136 | 224 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, |
| 225 "mail proxy pop3 auth handler"); | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
226 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
227 c = rev->data; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
228 s = c->data; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
229 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
230 if (rev->timedout) { |
| 527 | 231 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, |
| 232 "upstream timed out"); | |
| 577 | 233 c->timedout = 1; |
| 1136 | 234 ngx_mail_proxy_internal_server_error(s); |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
235 return; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
236 } |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
237 |
| 1136 | 238 rc = ngx_mail_proxy_read_response(s, 0); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
239 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
240 if (rc == NGX_AGAIN) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
241 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
242 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
243 |
| 571 | 244 if (rc == NGX_ERROR) { |
| 1136 | 245 ngx_mail_proxy_upstream_error(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
246 return; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
247 } |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
248 |
| 1136 | 249 switch (s->mail_state) { |
| 587 | 250 |
| 1136 | 251 case ngx_pop3_start: |
| 252 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send user"); | |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
253 |
| 587 | 254 s->connection->log->action = "sending user name to upstream"; |
| 255 | |
| 1136 | 256 line.len = sizeof("USER ") - 1 + s->login.len + 2; |
| 2049 | 257 line.data = ngx_pnalloc(c->pool, line.len); |
| 527 | 258 if (line.data == NULL) { |
| 1136 | 259 ngx_mail_proxy_internal_server_error(s); |
| 527 | 260 return; |
| 261 } | |
| 262 | |
| 1136 | 263 p = ngx_cpymem(line.data, "USER ", sizeof("USER ") - 1); |
| 264 p = ngx_cpymem(p, s->login.data, s->login.len); | |
| 265 *p++ = CR; *p = LF; | |
| 527 | 266 |
| 1136 | 267 s->mail_state = ngx_pop3_user; |
| 527 | 268 break; |
| 269 | |
| 1136 | 270 case ngx_pop3_user: |
| 271 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send pass"); | |
| 527 | 272 |
| 587 | 273 s->connection->log->action = "sending password to upstream"; |
| 274 | |
| 1136 | 275 line.len = sizeof("PASS ") - 1 + s->passwd.len + 2; |
| 2049 | 276 line.data = ngx_pnalloc(c->pool, line.len); |
| 501 | 277 if (line.data == NULL) { |
| 1136 | 278 ngx_mail_proxy_internal_server_error(s); |
| 527 | 279 return; |
| 280 } | |
| 281 | |
| 1136 | 282 p = ngx_cpymem(line.data, "PASS ", sizeof("PASS ") - 1); |
| 283 p = ngx_cpymem(p, s->passwd.data, s->passwd.len); | |
| 527 | 284 *p++ = CR; *p = LF; |
| 285 | |
| 1136 | 286 s->mail_state = ngx_pop3_passwd; |
| 527 | 287 break; |
| 288 | |
| 1136 | 289 case ngx_pop3_passwd: |
| 290 s->connection->read->handler = ngx_mail_proxy_handler; | |
| 291 s->connection->write->handler = ngx_mail_proxy_handler; | |
| 292 rev->handler = ngx_mail_proxy_handler; | |
| 293 c->write->handler = ngx_mail_proxy_handler; | |
| 663 | 294 |
| 1136 | 295 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); |
| 663 | 296 ngx_add_timer(s->connection->read, pcf->timeout); |
| 297 ngx_del_timer(c->read); | |
| 298 | |
| 299 c->log->action = NULL; | |
| 300 ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); | |
| 301 | |
| 1136 | 302 ngx_mail_proxy_handler(s->connection->write); |
| 663 | 303 |
| 304 return; | |
| 305 | |
| 527 | 306 default: |
| 307 #if (NGX_SUPPRESS_WARN) | |
| 308 line.len = 0; | |
| 309 line.data = NULL; | |
| 310 #endif | |
| 311 break; | |
| 312 } | |
| 313 | |
| 539 | 314 if (c->send(c, line.data, line.len) < (ssize_t) line.len) { |
| 527 | 315 /* |
| 316 * we treat the incomplete sending as NGX_ERROR | |
| 317 * because it is very strange here | |
| 318 */ | |
| 1136 | 319 ngx_mail_proxy_internal_server_error(s); |
| 527 | 320 return; |
| 321 } | |
| 322 | |
| 323 s->proxy->buffer->pos = s->proxy->buffer->start; | |
| 324 s->proxy->buffer->last = s->proxy->buffer->start; | |
| 325 } | |
| 326 | |
| 327 | |
| 328 static void | |
| 1136 | 329 ngx_mail_proxy_imap_handler(ngx_event_t *rev) |
| 527 | 330 { |
| 539 | 331 u_char *p; |
| 332 ngx_int_t rc; | |
| 333 ngx_str_t line; | |
| 334 ngx_connection_t *c; | |
| 1136 | 335 ngx_mail_session_t *s; |
| 336 ngx_mail_proxy_conf_t *pcf; | |
| 527 | 337 |
| 1136 | 338 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, |
| 339 "mail proxy imap auth handler"); | |
| 527 | 340 |
| 341 c = rev->data; | |
| 342 s = c->data; | |
| 343 | |
| 344 if (rev->timedout) { | |
| 345 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, | |
| 346 "upstream timed out"); | |
| 577 | 347 c->timedout = 1; |
| 1136 | 348 ngx_mail_proxy_internal_server_error(s); |
| 527 | 349 return; |
| 350 } | |
| 351 | |
| 1136 | 352 rc = ngx_mail_proxy_read_response(s, s->mail_state); |
| 527 | 353 |
| 354 if (rc == NGX_AGAIN) { | |
| 355 return; | |
| 356 } | |
| 357 | |
| 571 | 358 if (rc == NGX_ERROR) { |
| 1136 | 359 ngx_mail_proxy_upstream_error(s); |
| 527 | 360 return; |
| 361 } | |
| 362 | |
| 1136 | 363 switch (s->mail_state) { |
| 527 | 364 |
| 1136 | 365 case ngx_imap_start: |
| 366 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, | |
| 367 "mail proxy send login"); | |
| 527 | 368 |
| 1136 | 369 s->connection->log->action = "sending LOGIN command to upstream"; |
| 587 | 370 |
| 1136 | 371 line.len = s->tag.len + sizeof("LOGIN ") - 1 |
| 372 + 1 + NGX_SIZE_T_LEN + 1 + 2; | |
| 2049 | 373 line.data = ngx_pnalloc(c->pool, line.len); |
| 527 | 374 if (line.data == NULL) { |
| 1136 | 375 ngx_mail_proxy_internal_server_error(s); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
376 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
377 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
378 |
| 1136 | 379 line.len = ngx_sprintf(line.data, "%VLOGIN {%uz}" CRLF, |
| 380 &s->tag, s->login.len) | |
| 381 - line.data; | |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
382 |
| 1136 | 383 s->mail_state = ngx_imap_login; |
| 527 | 384 break; |
| 385 | |
| 1136 | 386 case ngx_imap_login: |
| 387 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send user"); | |
| 388 | |
| 389 s->connection->log->action = "sending user name to upstream"; | |
| 390 | |
| 391 line.len = s->login.len + 1 + 1 + NGX_SIZE_T_LEN + 1 + 2; | |
| 2049 | 392 line.data = ngx_pnalloc(c->pool, line.len); |
| 1136 | 393 if (line.data == NULL) { |
| 394 ngx_mail_proxy_internal_server_error(s); | |
| 395 return; | |
| 396 } | |
| 397 | |
| 398 line.len = ngx_sprintf(line.data, "%V {%uz}" CRLF, | |
| 399 &s->login, s->passwd.len) | |
| 400 - line.data; | |
| 401 | |
| 402 s->mail_state = ngx_imap_user; | |
| 403 break; | |
| 404 | |
| 405 case ngx_imap_user: | |
| 406 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, | |
| 407 "mail proxy send passwd"); | |
| 527 | 408 |
| 587 | 409 s->connection->log->action = "sending password to upstream"; |
| 410 | |
| 1136 | 411 line.len = s->passwd.len + 2; |
| 2049 | 412 line.data = ngx_pnalloc(c->pool, line.len); |
| 527 | 413 if (line.data == NULL) { |
| 1136 | 414 ngx_mail_proxy_internal_server_error(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
415 return; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
416 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
417 |
| 1136 | 418 p = ngx_cpymem(line.data, s->passwd.data, s->passwd.len); |
| 527 | 419 *p++ = CR; *p = LF; |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
420 |
| 1136 | 421 s->mail_state = ngx_imap_passwd; |
| 527 | 422 break; |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
423 |
| 1136 | 424 case ngx_imap_passwd: |
| 425 s->connection->read->handler = ngx_mail_proxy_handler; | |
| 426 s->connection->write->handler = ngx_mail_proxy_handler; | |
| 427 rev->handler = ngx_mail_proxy_handler; | |
| 428 c->write->handler = ngx_mail_proxy_handler; | |
| 663 | 429 |
| 1136 | 430 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); |
| 663 | 431 ngx_add_timer(s->connection->read, pcf->timeout); |
| 432 ngx_del_timer(c->read); | |
| 433 | |
| 434 c->log->action = NULL; | |
| 435 ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); | |
| 436 | |
| 1136 | 437 ngx_mail_proxy_handler(s->connection->write); |
| 663 | 438 |
| 439 return; | |
| 440 | |
| 527 | 441 default: |
| 442 #if (NGX_SUPPRESS_WARN) | |
| 443 line.len = 0; | |
| 444 line.data = NULL; | |
| 445 #endif | |
| 446 break; | |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
447 } |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
448 |
| 539 | 449 if (c->send(c, line.data, line.len) < (ssize_t) line.len) { |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
450 /* |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
451 * we treat the incomplete sending as NGX_ERROR |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
452 * because it is very strange here |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
453 */ |
| 1136 | 454 ngx_mail_proxy_internal_server_error(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
455 return; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
456 } |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
457 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
458 s->proxy->buffer->pos = s->proxy->buffer->start; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
459 s->proxy->buffer->last = s->proxy->buffer->start; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
460 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
461 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
462 |
| 521 | 463 static void |
| 1136 | 464 ngx_mail_proxy_smtp_handler(ngx_event_t *rev) |
| 465 { | |
| 466 u_char *p; | |
| 467 ngx_int_t rc; | |
| 468 ngx_str_t line; | |
| 2309 | 469 ngx_buf_t *b; |
| 1136 | 470 ngx_connection_t *c; |
| 471 ngx_mail_session_t *s; | |
| 472 ngx_mail_proxy_conf_t *pcf; | |
| 473 ngx_mail_core_srv_conf_t *cscf; | |
| 474 | |
| 475 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, | |
| 476 "mail proxy smtp auth handler"); | |
| 477 | |
| 478 c = rev->data; | |
| 479 s = c->data; | |
| 480 | |
| 481 if (rev->timedout) { | |
| 482 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, | |
| 483 "upstream timed out"); | |
| 484 c->timedout = 1; | |
| 485 ngx_mail_proxy_internal_server_error(s); | |
| 486 return; | |
| 487 } | |
| 488 | |
| 489 rc = ngx_mail_proxy_read_response(s, s->mail_state); | |
| 490 | |
| 491 if (rc == NGX_AGAIN) { | |
| 492 return; | |
| 493 } | |
| 494 | |
| 495 if (rc == NGX_ERROR) { | |
| 496 ngx_mail_proxy_upstream_error(s); | |
| 497 return; | |
| 498 } | |
| 499 | |
| 500 switch (s->mail_state) { | |
| 501 | |
| 502 case ngx_smtp_start: | |
| 503 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, "mail proxy send ehlo"); | |
| 504 | |
| 505 s->connection->log->action = "sending HELO/EHLO to upstream"; | |
| 506 | |
| 507 cscf = ngx_mail_get_module_srv_conf(s, ngx_mail_core_module); | |
| 508 | |
| 509 line.len = sizeof("HELO ") - 1 + cscf->server_name.len + 2; | |
| 2049 | 510 line.data = ngx_pnalloc(c->pool, line.len); |
| 1136 | 511 if (line.data == NULL) { |
| 512 ngx_mail_proxy_internal_server_error(s); | |
| 513 return; | |
| 514 } | |
| 515 | |
| 516 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); | |
| 517 | |
| 518 p = ngx_cpymem(line.data, | |
| 519 ((s->esmtp || pcf->xclient) ? "EHLO " : "HELO "), | |
| 520 sizeof("HELO ") - 1); | |
| 521 | |
| 522 p = ngx_cpymem(p, cscf->server_name.data, cscf->server_name.len); | |
| 523 *p++ = CR; *p = LF; | |
| 524 | |
| 2309 | 525 if (pcf->xclient) { |
| 526 s->mail_state = ngx_smtp_helo_xclient; | |
| 527 | |
| 528 } else if (s->auth_method == NGX_MAIL_AUTH_NONE) { | |
| 529 s->mail_state = ngx_smtp_helo_from; | |
| 530 | |
| 531 } else { | |
| 532 s->mail_state = ngx_smtp_helo; | |
| 533 } | |
| 1136 | 534 |
| 535 break; | |
| 536 | |
| 2309 | 537 case ngx_smtp_helo_xclient: |
| 1136 | 538 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, |
| 539 "mail proxy send xclient"); | |
| 540 | |
| 541 s->connection->log->action = "sending XCLIENT to upstream"; | |
| 542 | |
|
1892
057d362ee50e
resolver in smtp proxy module
Igor Sysoev <igor@sysoev.ru>
parents:
1487
diff
changeset
|
543 line.len = sizeof("XCLIENT PROTO=SMTP HELO= ADDR= LOGIN= NAME=" |
|
057d362ee50e
resolver in smtp proxy module
Igor Sysoev <igor@sysoev.ru>
parents:
1487
diff
changeset
|
544 CRLF) - 1 |
| 1136 | 545 + s->esmtp + s->smtp_helo.len |
|
1892
057d362ee50e
resolver in smtp proxy module
Igor Sysoev <igor@sysoev.ru>
parents:
1487
diff
changeset
|
546 + s->connection->addr_text.len + s->login.len + s->host.len; |
| 1136 | 547 |
| 2049 | 548 line.data = ngx_pnalloc(c->pool, line.len); |
| 1136 | 549 if (line.data == NULL) { |
| 550 ngx_mail_proxy_internal_server_error(s); | |
| 551 return; | |
| 552 } | |
| 553 | |
| 2309 | 554 line.len = ngx_sprintf(line.data, |
| 555 "XCLIENT PROTO=%sSMTP%s%V ADDR=%V%s%V NAME=%V" CRLF, | |
| 556 (s->esmtp ? "E" : ""), | |
| 557 (s->smtp_helo.len ? " HELO=" : ""), &s->smtp_helo, | |
| 558 &s->connection->addr_text, | |
| 559 (s->login.len ? " LOGIN=" : ""), &s->login, &s->host) | |
| 560 - line.data; | |
| 561 | |
| 562 s->mail_state = (s->auth_method == NGX_MAIL_AUTH_NONE) ? | |
| 563 ngx_smtp_xclient_from : ngx_smtp_xclient; | |
| 564 | |
| 565 break; | |
| 566 | |
| 567 case ngx_smtp_helo_from: | |
| 568 case ngx_smtp_xclient_from: | |
| 569 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, | |
| 570 "mail proxy send mail from"); | |
| 571 | |
| 572 s->connection->log->action = "sending MAIL FROM to upstream"; | |
| 573 | |
| 574 line.len = s->smtp_from.len + sizeof(CRLF) - 1; | |
| 575 line.data = ngx_pnalloc(c->pool, line.len); | |
| 576 if (line.data == NULL) { | |
| 577 ngx_mail_proxy_internal_server_error(s); | |
| 578 return; | |
| 1136 | 579 } |
| 580 | |
| 2309 | 581 p = ngx_cpymem(line.data, s->smtp_from.data, s->smtp_from.len); |
| 582 *p++ = CR; *p = LF; | |
| 583 | |
| 584 s->mail_state = ngx_smtp_from; | |
| 585 | |
| 1136 | 586 break; |
| 587 | |
| 2309 | 588 case ngx_smtp_from: |
| 589 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, rev->log, 0, | |
| 590 "mail proxy send rcpt to"); | |
| 591 | |
| 592 s->connection->log->action = "sending RCPT TO to upstream"; | |
| 593 | |
| 594 line.len = s->smtp_to.len + sizeof(CRLF) - 1; | |
| 595 line.data = ngx_pnalloc(c->pool, line.len); | |
| 596 if (line.data == NULL) { | |
| 597 ngx_mail_proxy_internal_server_error(s); | |
| 598 return; | |
| 599 } | |
| 600 | |
| 601 p = ngx_cpymem(line.data, s->smtp_to.data, s->smtp_to.len); | |
| 602 *p++ = CR; *p = LF; | |
| 603 | |
| 604 s->mail_state = ngx_smtp_to; | |
| 1136 | 605 |
| 2309 | 606 break; |
| 607 | |
| 608 case ngx_smtp_helo: | |
| 609 case ngx_smtp_xclient: | |
| 610 case ngx_smtp_to: | |
| 611 | |
| 612 b = s->proxy->buffer; | |
| 1136 | 613 |
| 2309 | 614 if (s->auth_method == NGX_MAIL_AUTH_NONE) { |
| 615 ngx_memcpy(b->start, smtp_ok, sizeof(smtp_ok) - 1); | |
| 616 b->last = b->start + sizeof(smtp_ok) - 1; | |
| 617 | |
| 618 } else { | |
| 619 ngx_memcpy(b->start, smtp_auth_ok, sizeof(smtp_auth_ok) - 1); | |
| 620 b->last = b->start + sizeof(smtp_auth_ok) - 1; | |
| 621 } | |
| 622 | |
| 623 b->pos = b->start; | |
| 1136 | 624 |
| 625 s->connection->read->handler = ngx_mail_proxy_handler; | |
| 626 s->connection->write->handler = ngx_mail_proxy_handler; | |
| 627 rev->handler = ngx_mail_proxy_handler; | |
| 628 c->write->handler = ngx_mail_proxy_handler; | |
| 629 | |
| 630 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); | |
| 631 ngx_add_timer(s->connection->read, pcf->timeout); | |
| 632 ngx_del_timer(c->read); | |
| 633 | |
| 634 c->log->action = NULL; | |
| 635 ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); | |
| 636 | |
| 637 ngx_mail_proxy_handler(s->connection->write); | |
| 638 | |
| 639 return; | |
| 640 | |
| 641 default: | |
| 642 #if (NGX_SUPPRESS_WARN) | |
| 643 line.len = 0; | |
| 644 line.data = NULL; | |
| 645 #endif | |
| 646 break; | |
| 647 } | |
| 648 | |
| 649 if (c->send(c, line.data, line.len) < (ssize_t) line.len) { | |
| 650 /* | |
| 651 * we treat the incomplete sending as NGX_ERROR | |
| 652 * because it is very strange here | |
| 653 */ | |
| 654 ngx_mail_proxy_internal_server_error(s); | |
| 655 return; | |
| 656 } | |
| 657 | |
| 658 s->proxy->buffer->pos = s->proxy->buffer->start; | |
| 659 s->proxy->buffer->last = s->proxy->buffer->start; | |
| 660 } | |
| 661 | |
| 662 | |
| 663 static void | |
| 664 ngx_mail_proxy_dummy_handler(ngx_event_t *wev) | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
665 { |
| 583 | 666 ngx_connection_t *c; |
| 1136 | 667 ngx_mail_session_t *s; |
| 583 | 668 |
| 1136 | 669 ngx_log_debug0(NGX_LOG_DEBUG_MAIL, wev->log, 0, "mail proxy dummy handler"); |
| 583 | 670 |
| 671 if (ngx_handle_write_event(wev, 0) == NGX_ERROR) { | |
| 672 c = wev->data; | |
| 673 s = c->data; | |
| 674 | |
| 1136 | 675 ngx_mail_proxy_close_session(s); |
| 583 | 676 } |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
677 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
678 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
679 |
| 521 | 680 static ngx_int_t |
| 1136 | 681 ngx_mail_proxy_read_response(ngx_mail_session_t *s, ngx_uint_t state) |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
682 { |
| 857 | 683 u_char *p; |
| 684 ssize_t n; | |
| 685 ngx_buf_t *b; | |
| 1136 | 686 ngx_mail_proxy_conf_t *pcf; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
687 |
| 587 | 688 s->connection->log->action = "reading response from upstream"; |
| 689 | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
690 b = s->proxy->buffer; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
691 |
| 539 | 692 n = s->proxy->upstream.connection->recv(s->proxy->upstream.connection, |
| 693 b->last, b->end - b->last); | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
694 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
695 if (n == NGX_ERROR || n == 0) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
696 return NGX_ERROR; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
697 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
698 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
699 if (n == NGX_AGAIN) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
700 return NGX_AGAIN; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
701 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
702 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
703 b->last += n; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
704 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
705 if (b->last - b->pos < 5) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
706 return NGX_AGAIN; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
707 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
708 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
709 if (*(b->last - 2) != CR || *(b->last - 1) != LF) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
710 if (b->last == b->end) { |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
711 *(b->last - 1) = '\0'; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
712 ngx_log_error(NGX_LOG_ERR, s->connection->log, 0, |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
713 "upstream sent too long response line: \"%s\"", |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
714 b->pos); |
| 571 | 715 return NGX_ERROR; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
716 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
717 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
718 return NGX_AGAIN; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
719 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
720 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
721 p = b->pos; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
722 |
| 1136 | 723 switch (s->protocol) { |
| 724 | |
| 725 case NGX_MAIL_POP3_PROTOCOL: | |
| 527 | 726 if (p[0] == '+' && p[1] == 'O' && p[2] == 'K') { |
| 727 return NGX_OK; | |
| 728 } | |
| 1136 | 729 break; |
| 527 | 730 |
| 1136 | 731 case NGX_MAIL_IMAP_PROTOCOL: |
| 663 | 732 switch (state) { |
| 733 | |
| 734 case ngx_imap_start: | |
| 527 | 735 if (p[0] == '*' && p[1] == ' ' && p[2] == 'O' && p[3] == 'K') { |
| 736 return NGX_OK; | |
| 737 } | |
| 663 | 738 break; |
| 527 | 739 |
| 663 | 740 case ngx_imap_login: |
| 741 case ngx_imap_user: | |
| 529 | 742 if (p[0] == '+') { |
| 527 | 743 return NGX_OK; |
| 744 } | |
| 663 | 745 break; |
| 746 | |
| 747 case ngx_imap_passwd: | |
| 748 if (ngx_strncmp(p, s->tag.data, s->tag.len) == 0) { | |
| 749 p += s->tag.len; | |
| 750 if (p[0] == 'O' && p[1] == 'K') { | |
| 751 return NGX_OK; | |
| 752 } | |
| 753 } | |
| 754 break; | |
| 527 | 755 } |
| 1136 | 756 |
| 757 break; | |
| 758 | |
| 759 default: /* NGX_MAIL_SMTP_PROTOCOL */ | |
| 760 switch (state) { | |
| 761 | |
| 762 case ngx_smtp_helo: | |
| 2309 | 763 case ngx_smtp_helo_from: |
| 764 case ngx_smtp_helo_xclient: | |
| 765 case ngx_smtp_from: | |
| 766 case ngx_smtp_to: | |
| 1166 | 767 if (p[0] == '2' && p[1] == '5' && p[2] == '0') { |
| 768 return NGX_OK; | |
| 769 } | |
| 770 break; | |
| 1136 | 771 |
| 772 case ngx_smtp_start: | |
| 2309 | 773 if (p[0] == '2' && p[1] == '2' && p[2] == '0') { |
| 774 return NGX_OK; | |
| 775 } | |
| 776 break; | |
| 777 | |
| 1136 | 778 case ngx_smtp_xclient: |
| 2309 | 779 case ngx_smtp_xclient_from: |
| 780 if (p[0] == '2' && (p[1] == '2' || p[1] == '5') && p[2] == '0') { | |
| 1166 | 781 return NGX_OK; |
| 782 } | |
| 783 break; | |
| 1136 | 784 } |
| 785 | |
| 1166 | 786 break; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
787 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
788 |
| 1136 | 789 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); |
| 857 | 790 |
| 791 if (pcf->pass_error_message == 0) { | |
| 792 *(b->last - 2) = '\0'; | |
| 793 ngx_log_error(NGX_LOG_ERR, s->connection->log, 0, | |
| 794 "upstream sent invalid response: \"%s\"", p); | |
| 795 return NGX_ERROR; | |
| 796 } | |
| 797 | |
| 798 s->out.len = b->last - p - 2; | |
| 799 s->out.data = p; | |
| 800 | |
| 801 ngx_log_error(NGX_LOG_INFO, s->connection->log, 0, | |
| 802 "upstream sent invalid response: \"%V\"", &s->out); | |
| 803 | |
| 804 s->out.len = b->last - b->pos; | |
| 805 s->out.data = b->pos; | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
806 |
| 571 | 807 return NGX_ERROR; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
808 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
809 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
810 |
| 521 | 811 static void |
| 1136 | 812 ngx_mail_proxy_handler(ngx_event_t *ev) |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
813 { |
| 583 | 814 char *action, *recv_action, *send_action; |
| 539 | 815 size_t size; |
| 816 ssize_t n; | |
| 817 ngx_buf_t *b; | |
| 583 | 818 ngx_uint_t do_write; |
| 539 | 819 ngx_connection_t *c, *src, *dst; |
| 1136 | 820 ngx_mail_session_t *s; |
| 821 ngx_mail_proxy_conf_t *pcf; | |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
822 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
823 c = ev->data; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
824 s = c->data; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
825 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
826 if (ev->timedout) { |
| 583 | 827 c->log->action = "proxying"; |
| 828 | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
829 if (c == s->connection) { |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
830 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
831 "client timed out"); |
| 577 | 832 c->timedout = 1; |
| 833 | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
834 } else { |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
835 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
836 "upstream timed out"); |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
837 } |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
838 |
| 1136 | 839 ngx_mail_proxy_close_session(s); |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
840 return; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
841 } |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
842 |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
843 if (c == s->connection) { |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
844 if (ev->write) { |
| 583 | 845 recv_action = "proxying and reading from upstream"; |
| 846 send_action = "proxying and sending to client"; | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
847 src = s->proxy->upstream.connection; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
848 dst = c; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
849 b = s->proxy->buffer; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
850 |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
851 } else { |
| 583 | 852 recv_action = "proxying and reading from client"; |
| 853 send_action = "proxying and sending to upstream"; | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
854 src = c; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
855 dst = s->proxy->upstream.connection; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
856 b = s->buffer; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
857 } |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
858 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
859 } else { |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
860 if (ev->write) { |
| 589 | 861 recv_action = "proxying and reading from client"; |
| 862 send_action = "proxying and sending to upstream"; | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
863 src = s->connection; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
864 dst = c; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
865 b = s->buffer; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
866 |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
867 } else { |
| 589 | 868 recv_action = "proxying and reading from upstream"; |
| 869 send_action = "proxying and sending to client"; | |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
870 src = c; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
871 dst = s->connection; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
872 b = s->proxy->buffer; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
873 } |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
874 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
875 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
876 do_write = ev->write ? 1 : 0; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
877 |
| 1136 | 878 ngx_log_debug3(NGX_LOG_DEBUG_MAIL, ev->log, 0, |
| 879 "mail proxy handler: %d, #%d > #%d", | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
880 do_write, src->fd, dst->fd); |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
881 |
| 583 | 882 for ( ;; ) { |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
883 |
| 583 | 884 if (do_write) { |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
885 |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
886 size = b->last - b->pos; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
887 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
888 if (size && dst->write->ready) { |
| 583 | 889 c->log->action = send_action; |
| 890 | |
| 539 | 891 n = dst->send(dst, b->pos, size); |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
892 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
893 if (n == NGX_ERROR) { |
| 1136 | 894 ngx_mail_proxy_close_session(s); |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
895 return; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
896 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
897 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
898 if (n > 0) { |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
899 b->pos += n; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
900 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
901 if (b->pos == b->last) { |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
902 b->pos = b->start; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
903 b->last = b->start; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
904 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
905 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
906 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
907 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
908 |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
909 size = b->end - b->last; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
910 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
911 if (size && src->read->ready) { |
| 583 | 912 c->log->action = recv_action; |
| 913 | |
| 539 | 914 n = src->recv(src, b->last, size); |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
915 |
| 583 | 916 if (n == NGX_AGAIN || n == 0) { |
| 917 break; | |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
918 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
919 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
920 if (n > 0) { |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
921 do_write = 1; |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
922 b->last += n; |
| 583 | 923 |
| 924 continue; | |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
925 } |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
926 |
| 583 | 927 if (n == NGX_ERROR) { |
| 928 src->read->eof = 1; | |
| 539 | 929 } |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
930 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
931 |
| 583 | 932 break; |
| 933 } | |
| 934 | |
| 935 c->log->action = "proxying"; | |
| 936 | |
|
1342
be2e13691c60
fix case when client has closed connection but upstream buffer is not empty
Igor Sysoev <igor@sysoev.ru>
parents:
1166
diff
changeset
|
937 if ((s->connection->read->eof && s->buffer->pos == s->buffer->last) |
|
be2e13691c60
fix case when client has closed connection but upstream buffer is not empty
Igor Sysoev <igor@sysoev.ru>
parents:
1166
diff
changeset
|
938 || (s->proxy->upstream.connection->read->eof |
|
be2e13691c60
fix case when client has closed connection but upstream buffer is not empty
Igor Sysoev <igor@sysoev.ru>
parents:
1166
diff
changeset
|
939 && s->proxy->buffer->pos == s->proxy->buffer->last) |
|
be2e13691c60
fix case when client has closed connection but upstream buffer is not empty
Igor Sysoev <igor@sysoev.ru>
parents:
1166
diff
changeset
|
940 || (s->connection->read->eof |
|
be2e13691c60
fix case when client has closed connection but upstream buffer is not empty
Igor Sysoev <igor@sysoev.ru>
parents:
1166
diff
changeset
|
941 && s->proxy->upstream.connection->read->eof)) |
| 583 | 942 { |
| 943 action = c->log->action; | |
| 944 c->log->action = NULL; | |
| 945 ngx_log_error(NGX_LOG_INFO, c->log, 0, "proxied session done"); | |
| 946 c->log->action = action; | |
| 947 | |
| 1136 | 948 ngx_mail_proxy_close_session(s); |
| 583 | 949 return; |
| 950 } | |
| 951 | |
| 952 if (ngx_handle_write_event(dst->write, 0) == NGX_ERROR) { | |
| 1136 | 953 ngx_mail_proxy_close_session(s); |
| 583 | 954 return; |
| 955 } | |
| 956 | |
| 957 if (ngx_handle_read_event(dst->read, 0) == NGX_ERROR) { | |
| 1136 | 958 ngx_mail_proxy_close_session(s); |
| 583 | 959 return; |
| 960 } | |
| 961 | |
| 962 if (ngx_handle_write_event(src->write, 0) == NGX_ERROR) { | |
| 1136 | 963 ngx_mail_proxy_close_session(s); |
| 583 | 964 return; |
| 965 } | |
| 966 | |
| 967 if (ngx_handle_read_event(src->read, 0) == NGX_ERROR) { | |
| 1136 | 968 ngx_mail_proxy_close_session(s); |
| 583 | 969 return; |
| 970 } | |
| 971 | |
| 972 if (c == s->connection) { | |
| 1136 | 973 pcf = ngx_mail_get_module_srv_conf(s, ngx_mail_proxy_module); |
| 583 | 974 ngx_add_timer(c->read, pcf->timeout); |
| 975 } | |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
976 } |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
977 |
|
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
978 |
| 521 | 979 static void |
| 1136 | 980 ngx_mail_proxy_upstream_error(ngx_mail_session_t *s) |
| 857 | 981 { |
| 982 if (s->proxy->upstream.connection) { | |
| 1136 | 983 ngx_log_debug1(NGX_LOG_DEBUG_MAIL, s->connection->log, 0, |
| 984 "close mail proxy connection: %d", | |
| 857 | 985 s->proxy->upstream.connection->fd); |
| 986 | |
| 987 ngx_close_connection(s->proxy->upstream.connection); | |
| 988 } | |
| 989 | |
| 990 if (s->out.len == 0) { | |
| 1136 | 991 ngx_mail_session_internal_server_error(s); |
| 857 | 992 return; |
| 993 } | |
| 994 | |
| 995 s->quit = 1; | |
| 1136 | 996 ngx_mail_send(s->connection->write); |
| 857 | 997 } |
| 998 | |
| 999 | |
| 1000 static void | |
| 1136 | 1001 ngx_mail_proxy_internal_server_error(ngx_mail_session_t *s) |
| 527 | 1002 { |
| 1003 if (s->proxy->upstream.connection) { | |
| 1136 | 1004 ngx_log_debug1(NGX_LOG_DEBUG_MAIL, s->connection->log, 0, |
| 1005 "close mail proxy connection: %d", | |
| 527 | 1006 s->proxy->upstream.connection->fd); |
| 1007 | |
| 1008 ngx_close_connection(s->proxy->upstream.connection); | |
| 1009 } | |
| 1010 | |
| 1136 | 1011 ngx_mail_session_internal_server_error(s); |
| 527 | 1012 } |
| 1013 | |
| 1014 | |
| 1015 static void | |
| 1136 | 1016 ngx_mail_proxy_close_session(ngx_mail_session_t *s) |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
1017 { |
| 521 | 1018 if (s->proxy->upstream.connection) { |
| 1136 | 1019 ngx_log_debug1(NGX_LOG_DEBUG_MAIL, s->connection->log, 0, |
| 1020 "close mail proxy connection: %d", | |
| 521 | 1021 s->proxy->upstream.connection->fd); |
| 1022 | |
| 1023 ngx_close_connection(s->proxy->upstream.connection); | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
1024 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
1025 |
| 1136 | 1026 ngx_mail_close_connection(s->connection); |
|
418
cf072d26d6d6
nginx-0.0.10-2004-09-08-09:18:51 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
1027 } |
| 521 | 1028 |
| 1029 | |
| 1030 static void * | |
| 1136 | 1031 ngx_mail_proxy_create_conf(ngx_conf_t *cf) |
| 577 | 1032 { |
| 1136 | 1033 ngx_mail_proxy_conf_t *pcf; |
| 577 | 1034 |
| 1136 | 1035 pcf = ngx_pcalloc(cf->pool, sizeof(ngx_mail_proxy_conf_t)); |
| 521 | 1036 if (pcf == NULL) { |
| 1037 return NGX_CONF_ERROR; | |
| 1038 } | |
| 1039 | |
| 1040 pcf->enable = NGX_CONF_UNSET; | |
| 857 | 1041 pcf->pass_error_message = NGX_CONF_UNSET; |
| 1136 | 1042 pcf->xclient = NGX_CONF_UNSET; |
| 539 | 1043 pcf->buffer_size = NGX_CONF_UNSET_SIZE; |
| 1044 pcf->timeout = NGX_CONF_UNSET_MSEC; | |
| 521 | 1045 |
| 1046 return pcf; | |
| 1047 } | |
| 1048 | |
| 1049 | |
| 1050 static char * | |
| 1136 | 1051 ngx_mail_proxy_merge_conf(ngx_conf_t *cf, void *parent, void *child) |
| 521 | 1052 { |
| 1136 | 1053 ngx_mail_proxy_conf_t *prev = parent; |
| 1054 ngx_mail_proxy_conf_t *conf = child; | |
| 521 | 1055 |
| 539 | 1056 ngx_conf_merge_value(conf->enable, prev->enable, 0); |
| 857 | 1057 ngx_conf_merge_value(conf->pass_error_message, prev->pass_error_message, 0); |
| 1136 | 1058 ngx_conf_merge_value(conf->xclient, prev->xclient, 1); |
| 539 | 1059 ngx_conf_merge_size_value(conf->buffer_size, prev->buffer_size, |
| 1060 (size_t) ngx_pagesize); | |
| 1061 ngx_conf_merge_msec_value(conf->timeout, prev->timeout, 24 * 60 * 60000); | |
| 521 | 1062 |
| 1063 return NGX_CONF_OK; | |
| 1064 } |