annotate src/core/ngx_queue.c @ 436:9b19e26b2660

Mail: smtp pipelining support. Basically, this does the following two changes (and corresponding modifications of related code): 1. Does not reset session buffer unless it's reached it's end, and always wait for LF to terminate command (even if we detected invalid command). 2. Record command name as the first argument to make it available for handlers (since now we can't assume that command starts from s->buffer->start).
author Maxim Dounin <mdounin@mdounin.ru>
date Thu, 11 Sep 2008 15:26:25 +0400
parents 820f6378fc00
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
378
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
1
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
2 /*
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
3 * Copyright (C) Igor Sysoev
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
4 */
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
5
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
6
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
7 #include <ngx_config.h>
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
8 #include <ngx_core.h>
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
9
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
10
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
11 /*
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
12 * find the middle queue element if the queue has odd number of elements
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
13 * or the first element of the queue's second part otherwise
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
14 */
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
15
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
16 ngx_queue_t *
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
17 ngx_queue_middle(ngx_queue_t *queue)
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
18 {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
19 ngx_queue_t *middle, *next;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
20
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
21 middle = ngx_queue_head(queue);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
22
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
23 if (middle == ngx_queue_last(queue)) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
24 return middle;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
25 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
26
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
27 next = ngx_queue_head(queue);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
28
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
29 for ( ;; ) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
30 middle = ngx_queue_next(middle);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
31
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
32 next = ngx_queue_next(next);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
33
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
34 if (next == ngx_queue_last(queue)) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
35 return middle;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
36 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
37
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
38 next = ngx_queue_next(next);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
39
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
40 if (next == ngx_queue_last(queue)) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
41 return middle;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
42 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
43 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
44 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
45
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
46
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
47 /* the stable insertion sort */
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
48
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
49 void
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
50 ngx_queue_sort(ngx_queue_t *queue,
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
51 ngx_int_t (*cmp)(const ngx_queue_t *, const ngx_queue_t *))
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
52 {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
53 ngx_queue_t *q, *prev, *next;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
54
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
55 q = ngx_queue_head(queue);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
56
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
57 if (q == ngx_queue_last(queue)) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
58 return;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
59 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
60
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
61 for (q = ngx_queue_next(q); q != ngx_queue_sentinel(queue); q = next) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
62
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
63 prev = ngx_queue_prev(q);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
64 next = ngx_queue_next(q);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
65
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
66 ngx_queue_remove(q);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
67
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
68 do {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
69 if (cmp(prev, q) <= 0) {
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
70 break;
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
71 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
72
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
73 prev = ngx_queue_prev(prev);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
74
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
75 } while (prev != ngx_queue_sentinel(queue));
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
76
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
77 ngx_queue_insert_after(prev, q);
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
78 }
820f6378fc00 nginx 0.7.1
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
79 }