annotate src/http/ngx_http_upstream_round_robin.h @ 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 e10168d6e371
children c04fa65fe604
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
1
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
2 /*
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
3 * Copyright (C) Igor Sysoev
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
4 */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
5
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
6
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
7 #ifndef _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
8 #define _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
9
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
10
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
11 #include <ngx_config.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
12 #include <ngx_core.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
13 #include <ngx_http.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
14
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
15
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
16 typedef struct {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
17 struct sockaddr *sockaddr;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
18 socklen_t socklen;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
19 ngx_str_t name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
20
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
21 ngx_int_t current_weight;
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
22 ngx_int_t weight;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
23
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
24 ngx_uint_t fails;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
25 time_t accessed;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
26
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
27 ngx_uint_t max_fails;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
28 time_t fail_timeout;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
29
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
30 ngx_uint_t down; /* unsigned down:1; */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
31
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
32 #if (NGX_HTTP_SSL)
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 272
diff changeset
33 ngx_ssl_session_t *ssl_session; /* local to a process */
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
34 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
35 } ngx_http_upstream_rr_peer_t;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
36
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
37
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
38 typedef struct ngx_http_upstream_rr_peers_s ngx_http_upstream_rr_peers_t;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
39
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
40 struct ngx_http_upstream_rr_peers_s {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
41 ngx_uint_t single; /* unsigned single:1; */
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
42 ngx_uint_t number;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
43 ngx_uint_t last_cached;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
44
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
45 /* ngx_mutex_t *mutex; */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
46 ngx_connection_t **cached;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
47
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
48 ngx_str_t *name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
49
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
50 ngx_http_upstream_rr_peers_t *next;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
51
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
52 ngx_http_upstream_rr_peer_t peer[1];
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
53 };
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
54
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
55
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
56 typedef struct {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
57 ngx_http_upstream_rr_peers_t *peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
58 ngx_uint_t current;
272
29a6403156b0 nginx 0.5.6
Igor Sysoev <http://sysoev.ru>
parents: 260
diff changeset
59 uintptr_t *tried;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
60 uintptr_t data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
61 } ngx_http_upstream_rr_peer_data_t;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
62
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
63
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
64 ngx_int_t ngx_http_upstream_init_round_robin(ngx_conf_t *cf,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
65 ngx_http_upstream_srv_conf_t *us);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
66 ngx_int_t ngx_http_upstream_init_round_robin_peer(ngx_http_request_t *r,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
67 ngx_http_upstream_srv_conf_t *us);
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 326
diff changeset
68 ngx_int_t ngx_http_upstream_create_round_robin_peer(ngx_http_request_t *r,
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 326
diff changeset
69 ngx_http_upstream_resolved_t *ur);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
70 ngx_int_t ngx_http_upstream_get_round_robin_peer(ngx_peer_connection_t *pc,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
71 void *data);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
72 void ngx_http_upstream_free_round_robin_peer(ngx_peer_connection_t *pc,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
73 void *data, ngx_uint_t state);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
74
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
75 #if (NGX_HTTP_SSL)
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 272
diff changeset
76 ngx_int_t
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 272
diff changeset
77 ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc,
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 272
diff changeset
78 void *data);
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 272
diff changeset
79 void ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc,
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
80 void *data);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
81 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
82
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
83
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
84
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
85 #endif /* _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_ */