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 } |