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