Mercurial > hg > nginx
annotate src/imap/ngx_imap_handler.c @ 539:371c1cee100d release-0.1.44
nginx-0.1.44-RELEASE import
*) Feature: the IMAP/POP3 proxy supports SSL.
*) Feature: the "proxy_timeout" directive of the ngx_imap_proxy_module.
*) Feature: the "userid_mark" directive.
*) Feature: the $remote_user variable value is determined independently
of authorization use.
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Tue, 06 Sep 2005 16:09:32 +0000 |
| parents | e5d7d0334fdb |
| children | b09ee85d0ac8 |
| 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:
423
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:
423
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:
423
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:
423
diff
changeset
|
5 |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
6 |
|
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
7 #include <ngx_config.h> |
|
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
8 #include <ngx_core.h> |
|
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
9 #include <ngx_event.h> |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
10 #include <ngx_imap.h> |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
11 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
12 |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
13 static void ngx_imap_init_session(ngx_event_t *rev); |
| 527 | 14 static ngx_int_t ngx_imap_read_command(ngx_imap_session_t *s); |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
15 |
| 539 | 16 #if (NGX_IMAP_SSL) |
| 17 static void ngx_imap_ssl_close_handler(ngx_event_t *ev); | |
| 18 #endif | |
| 19 | |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
20 |
| 521 | 21 static ngx_str_t greetings[] = { |
| 527 | 22 ngx_string("+OK POP3 ready" CRLF), |
| 529 | 23 ngx_string("* OK IMAP4 ready" CRLF) |
| 521 | 24 }; |
| 25 | |
| 525 | 26 static ngx_str_t internal_server_errors[] = { |
| 27 ngx_string("-ERR internal server error" CRLF), | |
| 28 ngx_string("* BAD internal server error" CRLF), | |
| 29 }; | |
| 30 | |
| 521 | 31 static u_char pop3_ok[] = "+OK" CRLF; |
| 32 static u_char pop3_invalid_command[] = "-ERR invalid command" CRLF; | |
| 33 | |
| 529 | 34 static u_char imap_ok[] = "OK completed" CRLF; |
| 527 | 35 static u_char imap_next[] = "+ OK" CRLF; |
| 36 static u_char imap_bye[] = "* BYE" CRLF; | |
| 37 static u_char imap_invalid_command[] = "BAD invalid command" CRLF; | |
| 38 | |
| 521 | 39 |
| 40 void | |
| 41 ngx_imap_init_connection(ngx_connection_t *c) | |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
42 { |
| 539 | 43 ngx_imap_session_t *s; |
| 521 | 44 ngx_imap_conf_ctx_t *ctx; |
| 539 | 45 #if (NGX_IMAP_SSL) |
| 46 ngx_int_t rc; | |
| 47 ngx_imap_ssl_conf_t *sslcf; | |
| 48 #endif | |
| 521 | 49 ngx_imap_core_srv_conf_t *cscf; |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
50 |
| 521 | 51 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap init connection"); |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
52 |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
53 c->log_error = NGX_ERROR_INFO; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
54 |
| 521 | 55 ctx = c->ctx; |
| 539 | 56 |
| 57 #if (NGX_IMAP_SSL) | |
| 58 | |
| 59 sslcf = ngx_imap_get_module_srv_conf(ctx, ngx_imap_ssl_module); | |
| 60 | |
| 61 if (sslcf->enable) { | |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
62 |
| 539 | 63 if (ngx_ssl_create_session(sslcf->ssl_ctx, c, NGX_SSL_BUFFER) |
| 64 == NGX_ERROR) | |
| 65 { | |
| 66 ngx_imap_close_connection(c); | |
| 67 return; | |
| 68 } | |
| 521 | 69 |
| 539 | 70 rc = ngx_ssl_handshake(c); |
| 71 | |
| 72 if (rc == NGX_ERROR) { | |
| 73 ngx_imap_close_connection(c); | |
| 74 return; | |
| 75 } | |
| 76 | |
| 77 c->recv = ngx_ssl_recv; | |
| 78 c->send = ngx_ssl_write; | |
| 79 c->send_chain = ngx_ssl_send_chain; | |
| 80 } | |
| 81 | |
| 82 #endif | |
| 83 | |
| 84 s = ngx_pcalloc(c->pool, sizeof(ngx_imap_session_t)); | |
| 85 if (s == NULL) { | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
86 ngx_imap_close_connection(c); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
87 return; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
88 } |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
89 |
| 539 | 90 c->data = s; |
| 91 s->connection = c; | |
| 92 | |
| 93 cscf = ngx_imap_get_module_srv_conf(ctx, ngx_imap_core_module); | |
| 94 s->protocol = cscf->protocol; | |
| 95 | |
| 96 s->ctx = ngx_pcalloc(c->pool, sizeof(void *) * ngx_imap_max_module); | |
| 97 if (s->ctx == NULL) { | |
| 98 ngx_imap_session_internal_server_error(s); | |
| 99 return; | |
| 100 } | |
| 101 | |
| 102 s->main_conf = ctx->main_conf; | |
| 103 s->srv_conf = ctx->srv_conf; | |
| 104 | |
| 105 s->out = greetings[s->protocol]; | |
| 106 | |
| 509 | 107 c->read->handler = ngx_imap_init_session; |
| 539 | 108 c->write->handler = ngx_imap_send; |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
109 |
| 539 | 110 ngx_add_timer(c->write, cscf->timeout); |
| 521 | 111 ngx_add_timer(c->read, cscf->timeout); |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
112 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
113 if (ngx_handle_read_event(c->read, 0) == NGX_ERROR) { |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
114 ngx_imap_close_connection(c); |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
115 } |
| 539 | 116 |
| 117 ngx_imap_send(c->write); | |
| 118 } | |
| 119 | |
| 120 | |
| 121 void | |
| 122 ngx_imap_send(ngx_event_t *wev) | |
| 123 { | |
| 124 ngx_int_t n; | |
| 125 ngx_connection_t *c; | |
| 126 ngx_imap_session_t *s; | |
| 127 | |
| 128 c = wev->data; | |
| 129 s = c->data; | |
| 130 | |
| 131 if (wev->timedout) { | |
| 132 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); | |
| 133 ngx_imap_close_connection(c); | |
| 134 return; | |
| 135 } | |
| 136 | |
| 137 if (s->out.len == 0) { | |
| 138 if (ngx_handle_write_event(c->write, 0) == NGX_ERROR) { | |
| 139 ngx_imap_close_connection(c); | |
| 140 } | |
| 141 | |
| 142 return; | |
| 143 } | |
| 144 | |
| 145 n = c->send(c, s->out.data, s->out.len); | |
| 146 | |
| 147 if (n > 0) { | |
| 148 s->out.len -= n; | |
| 149 | |
| 150 if (s->quit) { | |
| 151 ngx_imap_close_connection(c); | |
| 152 return; | |
| 153 } | |
| 154 | |
| 155 if (s->blocked) { | |
| 156 c->read->handler(c->read); | |
| 157 } | |
| 158 | |
| 159 return; | |
| 160 } | |
| 161 | |
| 162 if (n == NGX_ERROR) { | |
| 163 ngx_imap_close_connection(c); | |
| 164 return; | |
| 165 } | |
| 166 | |
| 167 /* n == NGX_AGAIN */ | |
| 168 | |
| 169 if (ngx_handle_write_event(c->write, 0) == NGX_ERROR) { | |
| 170 ngx_imap_close_connection(c); | |
| 171 return; | |
| 172 } | |
|
413
de9d4726e28a
nginx-0.0.10-2004-08-31-23:05:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
173 } |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
174 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
175 |
| 521 | 176 static void |
| 177 ngx_imap_init_session(ngx_event_t *rev) | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
178 { |
| 521 | 179 size_t size; |
| 180 ngx_connection_t *c; | |
| 181 ngx_imap_session_t *s; | |
| 182 ngx_imap_core_srv_conf_t *cscf; | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
183 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
184 c = rev->data; |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
185 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
186 if (rev->timedout) { |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
187 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
188 ngx_imap_close_connection(c); |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
189 return; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
190 } |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
191 |
| 539 | 192 s = c->data; |
| 521 | 193 |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
194 if (ngx_array_init(&s->args, c->pool, 2, sizeof(ngx_str_t)) == NGX_ERROR) { |
| 527 | 195 ngx_imap_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
|
196 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
197 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
198 |
| 539 | 199 if (s->protocol == NGX_IMAP_POP3_PROTOCOL) { |
| 521 | 200 size = 128; |
| 527 | 201 s->imap_state = ngx_pop3_start; |
| 521 | 202 c->read->handler = ngx_pop3_auth_state; |
| 203 | |
| 204 } else { | |
| 539 | 205 cscf = ngx_imap_get_module_srv_conf(s, ngx_imap_core_module); |
| 521 | 206 size = cscf->imap_client_buffer_size; |
| 527 | 207 s->imap_state = ngx_imap_start; |
| 521 | 208 c->read->handler = ngx_imap_auth_state; |
| 209 } | |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
210 |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
211 s->buffer = ngx_create_temp_buf(c->pool, size); |
|
419
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
212 if (s->buffer == NULL) { |
| 527 | 213 ngx_imap_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
|
214 return; |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
215 } |
|
47709bff4468
nginx-0.0.10-2004-09-09-19:40:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
418
diff
changeset
|
216 |
| 521 | 217 c->read->handler(rev); |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
218 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
219 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
220 |
| 527 | 221 void |
| 521 | 222 ngx_imap_auth_state(ngx_event_t *rev) |
| 223 { | |
| 539 | 224 u_char *text, *last, *p; |
| 225 ssize_t text_len, last_len; | |
| 527 | 226 ngx_str_t *arg; |
| 227 ngx_int_t rc; | |
| 539 | 228 ngx_uint_t tag; |
| 527 | 229 ngx_connection_t *c; |
| 230 ngx_imap_session_t *s; | |
| 231 ngx_imap_core_srv_conf_t *cscf; | |
| 521 | 232 |
| 233 c = rev->data; | |
| 527 | 234 s = c->data; |
| 521 | 235 |
| 527 | 236 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap auth state"); |
| 237 | |
| 238 if (rev->timedout) { | |
| 239 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); | |
| 240 ngx_imap_close_connection(c); | |
| 241 return; | |
| 242 } | |
| 243 | |
| 539 | 244 if (s->out.len) { |
| 245 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap send handler busy"); | |
| 246 s->blocked = 1; | |
| 247 return; | |
| 248 } | |
| 249 | |
| 250 s->blocked = 0; | |
| 251 | |
| 527 | 252 rc = ngx_imap_read_command(s); |
| 253 | |
| 254 ngx_log_debug1(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap auth: %i", rc); | |
| 255 | |
| 256 if (rc == NGX_AGAIN || rc == NGX_ERROR) { | |
| 257 return; | |
| 258 } | |
| 259 | |
| 260 tag = 1; | |
| 261 | |
| 262 text = NULL; | |
| 263 text_len = 0; | |
| 264 | |
| 265 last = imap_ok; | |
| 266 last_len = sizeof(imap_ok) - 1; | |
| 267 | |
| 268 if (rc == NGX_OK) { | |
| 269 | |
| 270 ngx_log_debug1(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap auth command: %i", | |
| 271 s->command); | |
| 272 | |
| 273 switch (s->command) { | |
| 274 | |
| 275 case NGX_IMAP_LOGIN: | |
| 276 if (s->args.nelts == 2) { | |
| 277 | |
| 278 arg = s->args.elts; | |
| 279 | |
| 280 s->login.len = arg[0].len; | |
| 281 s->login.data = ngx_palloc(c->pool, s->login.len); | |
| 282 if (s->login.data == NULL) { | |
| 283 ngx_imap_session_internal_server_error(s); | |
| 284 return; | |
| 285 } | |
| 286 | |
| 287 ngx_memcpy(s->login.data, arg[0].data, s->login.len); | |
| 288 | |
| 289 s->passwd.len = arg[1].len; | |
| 290 s->passwd.data = ngx_palloc(c->pool, s->passwd.len); | |
| 291 if (s->passwd.data == NULL) { | |
| 292 ngx_imap_session_internal_server_error(s); | |
| 293 return; | |
| 294 } | |
| 295 | |
| 296 ngx_memcpy(s->passwd.data, arg[1].data, s->passwd.len); | |
| 297 | |
| 298 ngx_log_debug2(NGX_LOG_DEBUG_IMAP, c->log, 0, | |
| 299 "imap login:\"%V\" passwd:\"%V\"", | |
| 300 &s->login, &s->passwd); | |
| 301 | |
| 302 s->args.nelts = 0; | |
| 303 s->buffer->pos = s->buffer->start; | |
| 304 s->buffer->last = s->buffer->start; | |
| 305 | |
| 306 if (rev->timer_set) { | |
| 307 ngx_del_timer(rev); | |
| 308 } | |
| 309 | |
| 310 s->login_attempt++; | |
| 311 | |
| 312 ngx_imap_auth_http_init(s); | |
| 313 | |
| 314 return; | |
| 315 | |
| 316 } else { | |
| 317 rc = NGX_IMAP_PARSE_INVALID_COMMAND; | |
| 318 } | |
| 319 | |
| 320 break; | |
| 321 | |
| 322 case NGX_IMAP_CAPABILITY: | |
| 323 cscf = ngx_imap_get_module_srv_conf(s, ngx_imap_core_module); | |
| 324 text = cscf->imap_capability->pos; | |
| 325 text_len = cscf->imap_capability->last - cscf->imap_capability->pos; | |
| 326 break; | |
| 327 | |
| 328 case NGX_IMAP_LOGOUT: | |
| 539 | 329 s->quit = 1; |
| 527 | 330 text = imap_bye; |
| 331 text_len = sizeof(imap_bye) - 1; | |
| 332 break; | |
| 333 | |
| 334 case NGX_IMAP_NOOP: | |
| 335 break; | |
| 336 | |
| 337 default: | |
| 338 rc = NGX_IMAP_PARSE_INVALID_COMMAND; | |
| 339 break; | |
| 340 } | |
| 341 | |
| 342 } else if (rc == NGX_IMAP_NEXT) { | |
| 343 last = imap_next; | |
| 344 last_len = sizeof(imap_next) - 1; | |
| 345 tag = 0; | |
| 346 } | |
| 347 | |
| 348 if (rc == NGX_IMAP_PARSE_INVALID_COMMAND) { | |
| 349 last = imap_invalid_command; | |
| 350 last_len = sizeof(imap_invalid_command) - 1; | |
| 351 } | |
| 352 | |
| 353 if (tag) { | |
| 539 | 354 if (s->tagged_line.len < s->tag.len + text_len + last_len) { |
| 355 s->tagged_line.len = s->tag.len + text_len + last_len; | |
| 356 s->tagged_line.data = ngx_palloc(c->pool, s->tagged_line.len); | |
| 357 if (s->tagged_line.data == NULL) { | |
| 527 | 358 ngx_imap_close_connection(c); |
| 359 return; | |
| 360 } | |
| 361 } | |
| 362 | |
| 539 | 363 s->out.data = s->tagged_line.data; |
| 364 s->out.len = s->tag.len + text_len + last_len; | |
| 365 | |
| 366 p = s->out.data; | |
| 527 | 367 |
| 368 if (text) { | |
| 369 p = ngx_cpymem(p, text, text_len); | |
| 370 } | |
| 371 p = ngx_cpymem(p, s->tag.data, s->tag.len); | |
| 372 ngx_memcpy(p, last, last_len); | |
| 373 | |
| 374 | |
| 375 } else { | |
| 539 | 376 s->out.data = last; |
| 377 s->out.len = last_len; | |
| 527 | 378 } |
| 379 | |
| 539 | 380 if (rc != NGX_IMAP_NEXT) { |
| 381 s->args.nelts = 0; | |
| 382 s->buffer->pos = s->buffer->start; | |
| 383 s->buffer->last = s->buffer->start; | |
| 384 s->tag.len = 0; | |
| 527 | 385 } |
| 386 | |
| 539 | 387 ngx_imap_send(c->write); |
| 521 | 388 } |
| 389 | |
| 390 | |
| 527 | 391 void |
| 521 | 392 ngx_pop3_auth_state(ngx_event_t *rev) |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
393 { |
| 527 | 394 u_char *text; |
| 395 ssize_t size; | |
| 396 ngx_int_t rc; | |
| 397 ngx_str_t *arg; | |
| 398 ngx_connection_t *c; | |
| 399 ngx_imap_session_t *s; | |
| 400 ngx_imap_core_srv_conf_t *cscf; | |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
401 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
402 c = rev->data; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
403 s = c->data; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
404 |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
405 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, c->log, 0, "pop3 auth state"); |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
406 |
|
423
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
407 if (rev->timedout) { |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
408 ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
409 ngx_imap_close_connection(c); |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
410 return; |
|
fda5987b188d
nginx-0.0.10-2004-09-13-20:18:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
422
diff
changeset
|
411 } |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
412 |
| 539 | 413 if (s->out.len) { |
| 414 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, c->log, 0, "imap send handler busy"); | |
| 415 s->blocked = 1; | |
| 416 return; | |
| 417 } | |
| 418 | |
| 419 s->blocked = 0; | |
| 420 | |
| 527 | 421 rc = ngx_imap_read_command(s); |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
422 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
423 if (rc == NGX_AGAIN || rc == NGX_ERROR) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
424 return; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
425 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
426 |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
427 text = pop3_ok; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
428 size = sizeof(pop3_ok) - 1; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
429 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
430 if (rc == NGX_OK) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
431 switch (s->imap_state) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
432 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
433 case ngx_pop3_start: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
434 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
435 switch (s->command) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
436 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
437 case NGX_POP3_USER: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
438 if (s->args.nelts == 1) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
439 s->imap_state = ngx_pop3_user; |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
440 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
441 arg = s->args.elts; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
442 s->login.len = arg[0].len; |
| 527 | 443 s->login.data = ngx_palloc(c->pool, s->login.len); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
444 if (s->login.data == NULL) { |
| 527 | 445 ngx_imap_session_internal_server_error(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
446 return; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
447 } |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
448 |
| 527 | 449 ngx_memcpy(s->login.data, arg[0].data, s->login.len); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
450 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
451 ngx_log_debug1(NGX_LOG_DEBUG_IMAP, c->log, 0, |
| 527 | 452 "pop3 login: \"%V\"", &s->login); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
453 |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
454 } else { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
455 rc = NGX_IMAP_PARSE_INVALID_COMMAND; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
456 } |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
457 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
458 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
459 |
| 527 | 460 case NGX_POP3_CAPA: |
| 461 cscf = ngx_imap_get_module_srv_conf(s, ngx_imap_core_module); | |
| 462 text = cscf->pop3_capability->pos; | |
| 463 size = cscf->pop3_capability->last - cscf->pop3_capability->pos; | |
| 464 break; | |
| 465 | |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
466 case NGX_POP3_QUIT: |
| 539 | 467 s->quit = 1; |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
468 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
469 |
| 527 | 470 case NGX_POP3_NOOP: |
| 471 break; | |
| 472 | |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
473 default: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
474 s->imap_state = ngx_pop3_start; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
475 rc = NGX_IMAP_PARSE_INVALID_COMMAND; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
476 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
477 } |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
478 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
479 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
480 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
481 case ngx_pop3_user: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
482 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
483 switch (s->command) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
484 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
485 case NGX_POP3_PASS: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
486 if (s->args.nelts == 1) { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
487 /* STUB */ s->imap_state = ngx_pop3_start; |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
488 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
489 arg = s->args.elts; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
490 s->passwd.len = arg[0].len; |
| 527 | 491 s->passwd.data = ngx_palloc(c->pool, s->passwd.len); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
492 if (s->passwd.data == NULL) { |
| 527 | 493 ngx_imap_session_internal_server_error(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
494 return; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
495 } |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
496 |
| 527 | 497 ngx_memcpy(s->passwd.data, arg[0].data, s->passwd.len); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
498 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
499 ngx_log_debug1(NGX_LOG_DEBUG_IMAP, c->log, 0, |
| 527 | 500 "pop3 passwd: \"%V\"", &s->passwd); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
501 |
| 527 | 502 s->args.nelts = 0; |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
503 s->buffer->pos = s->buffer->start; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
504 s->buffer->last = s->buffer->start; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
505 |
| 527 | 506 if (rev->timer_set) { |
| 507 ngx_del_timer(rev); | |
| 508 } | |
| 509 | |
| 521 | 510 ngx_imap_auth_http_init(s); |
|
422
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
511 |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
512 return; |
|
edaefb2a20fc
nginx-0.0.10-2004-09-12-00:22:11 import
Igor Sysoev <igor@sysoev.ru>
parents:
421
diff
changeset
|
513 |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
514 } else { |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
515 rc = NGX_IMAP_PARSE_INVALID_COMMAND; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
516 } |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
517 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
518 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
519 |
| 527 | 520 case NGX_POP3_CAPA: |
| 521 cscf = ngx_imap_get_module_srv_conf(s, ngx_imap_core_module); | |
| 522 text = cscf->pop3_capability->pos; | |
| 523 size = cscf->pop3_capability->last - cscf->pop3_capability->pos; | |
| 524 break; | |
| 525 | |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
526 case NGX_POP3_QUIT: |
| 539 | 527 s->quit = 1; |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
528 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
529 |
| 527 | 530 case NGX_POP3_NOOP: |
| 531 break; | |
| 532 | |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
533 default: |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
534 s->imap_state = ngx_pop3_start; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
535 rc = NGX_IMAP_PARSE_INVALID_COMMAND; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
536 break; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
537 } |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
538 |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
539 break; |
| 527 | 540 |
| 541 /* suppress warinings */ | |
| 542 case ngx_pop3_passwd: | |
| 543 break; | |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
544 } |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
545 } |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
546 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
547 if (rc == NGX_IMAP_PARSE_INVALID_COMMAND) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
548 text = pop3_invalid_command; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
549 size = sizeof(pop3_invalid_command) - 1; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
550 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
551 |
|
421
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
552 s->args.nelts = 0; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
553 s->buffer->pos = s->buffer->start; |
|
01456a419cf9
nginx-0.0.10-2004-09-10-18:32:02 import
Igor Sysoev <igor@sysoev.ru>
parents:
420
diff
changeset
|
554 s->buffer->last = s->buffer->start; |
| 539 | 555 |
| 556 s->out.data = text; | |
| 557 s->out.len = size; | |
| 558 | |
| 559 ngx_imap_send(c->write); | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
560 } |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
561 |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
562 |
| 521 | 563 static ngx_int_t |
| 527 | 564 ngx_imap_read_command(ngx_imap_session_t *s) |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
565 { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
566 ssize_t n; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
567 ngx_int_t rc; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
568 |
| 539 | 569 n = s->connection->recv(s->connection, s->buffer->last, |
| 570 s->buffer->end - s->buffer->last); | |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
571 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
572 if (n == NGX_ERROR || n == 0) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
573 ngx_imap_close_connection(s->connection); |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
574 return NGX_ERROR; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
575 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
576 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
577 if (n > 0) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
578 s->buffer->last += n; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
579 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
580 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
581 if (n == NGX_AGAIN) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
582 if (ngx_handle_read_event(s->connection->read, 0) == NGX_ERROR) { |
| 527 | 583 ngx_imap_session_internal_server_error(s); |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
584 return NGX_ERROR; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
585 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
586 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
587 return NGX_AGAIN; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
588 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
589 |
| 527 | 590 if (s->protocol == NGX_IMAP_POP3_PROTOCOL) { |
| 591 rc = ngx_pop3_parse_command(s); | |
| 592 } else { | |
| 593 rc = ngx_imap_parse_command(s); | |
| 594 } | |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
595 |
| 527 | 596 if (rc == NGX_AGAIN |
| 597 || rc == NGX_IMAP_NEXT | |
| 598 || rc == NGX_IMAP_PARSE_INVALID_COMMAND) | |
| 599 { | |
|
420
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
600 return rc; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
601 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
602 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
603 if (rc == NGX_ERROR) { |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
604 ngx_imap_close_connection(s->connection); |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
605 return NGX_ERROR; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
606 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
607 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
608 return NGX_OK; |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
609 } |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
610 |
|
33a8253115b4
nginx-0.0.10-2004-09-09-22:55:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
419
diff
changeset
|
611 |
| 521 | 612 void |
| 525 | 613 ngx_imap_session_internal_server_error(ngx_imap_session_t *s) |
| 614 { | |
| 539 | 615 s->out = internal_server_errors[s->protocol]; |
| 616 s->quit = 1; | |
| 525 | 617 |
| 539 | 618 ngx_imap_send(s->connection->write); |
| 525 | 619 } |
| 620 | |
| 621 | |
| 622 void | |
| 521 | 623 ngx_imap_close_connection(ngx_connection_t *c) |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
624 { |
| 479 | 625 ngx_pool_t *pool; |
| 626 | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
627 ngx_log_debug1(NGX_LOG_DEBUG_IMAP, c->log, 0, |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
628 "close imap connection: %d", c->fd); |
|
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
629 |
| 539 | 630 #if (NGX_IMAP_SSL) |
| 631 | |
| 632 if (c->ssl) { | |
| 633 if (ngx_ssl_shutdown(c) == NGX_AGAIN) { | |
| 634 c->read->handler = ngx_imap_ssl_close_handler; | |
| 635 c->write->handler = ngx_imap_ssl_close_handler; | |
| 636 return; | |
| 637 } | |
| 638 } | |
| 639 | |
| 640 #endif | |
| 641 | |
| 479 | 642 pool = c->pool; |
| 643 | |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
644 ngx_close_connection(c); |
| 479 | 645 |
| 501 | 646 ngx_destroy_pool(pool); |
|
417
0526206251f6
nginx-0.0.10-2004-09-07-19:29:22 import
Igor Sysoev <igor@sysoev.ru>
parents:
415
diff
changeset
|
647 } |
| 539 | 648 |
| 649 | |
| 650 #if (NGX_IMAP_SSL) | |
| 651 | |
| 652 static void | |
| 653 ngx_imap_ssl_close_handler(ngx_event_t *ev) | |
| 654 { | |
| 655 ngx_connection_t *c; | |
| 656 | |
| 657 c = ev->data; | |
| 658 | |
| 659 ngx_log_debug0(NGX_LOG_DEBUG_IMAP, ev->log, 0, "http ssl close handler"); | |
| 660 | |
| 661 if (ngx_ssl_shutdown(c) == NGX_AGAIN) { | |
| 662 return; | |
| 663 } | |
| 664 | |
| 665 ngx_imap_close_connection(c); | |
| 666 } | |
| 667 | |
| 668 #endif |