Mercurial > hg > nginx
annotate src/stream/ngx_stream_upstream.h @ 6202:6345822f0abb
Stream: upstream "connected" flag.
Once upstream is connected, the upstream buffer is allocated. Previously, the
proxy module used the buffer allocation status to check if upstream is
connected. Now it's enough to check the flag.
| author | Roman Arutyunyan <arut@nginx.com> |
|---|---|
| date | Thu, 25 Jun 2015 12:36:52 +0300 |
| parents | 24488e6db782 |
| children | 8f038068f4bc |
| rev | line source |
|---|---|
| 6115 | 1 |
| 2 /* | |
| 3 * Copyright (C) Igor Sysoev | |
| 4 * Copyright (C) Nginx, Inc. | |
| 5 */ | |
| 6 | |
| 7 | |
| 8 #ifndef _NGX_STREAM_UPSTREAM_H_INCLUDED_ | |
| 9 #define _NGX_STREAM_UPSTREAM_H_INCLUDED_ | |
| 10 | |
| 11 | |
| 12 #include <ngx_config.h> | |
| 13 #include <ngx_core.h> | |
| 14 #include <ngx_stream.h> | |
| 15 #include <ngx_event_connect.h> | |
| 16 | |
| 17 | |
| 18 #define NGX_STREAM_UPSTREAM_CREATE 0x0001 | |
| 19 #define NGX_STREAM_UPSTREAM_WEIGHT 0x0002 | |
| 20 #define NGX_STREAM_UPSTREAM_MAX_FAILS 0x0004 | |
| 21 #define NGX_STREAM_UPSTREAM_FAIL_TIMEOUT 0x0008 | |
| 22 #define NGX_STREAM_UPSTREAM_DOWN 0x0010 | |
| 23 #define NGX_STREAM_UPSTREAM_BACKUP 0x0020 | |
| 24 | |
| 25 | |
| 26 typedef struct { | |
| 27 ngx_array_t upstreams; | |
| 28 /* ngx_stream_upstream_srv_conf_t */ | |
| 29 } ngx_stream_upstream_main_conf_t; | |
| 30 | |
| 31 | |
| 32 typedef struct ngx_stream_upstream_srv_conf_s ngx_stream_upstream_srv_conf_t; | |
| 33 | |
| 34 | |
| 35 typedef ngx_int_t (*ngx_stream_upstream_init_pt)(ngx_conf_t *cf, | |
| 36 ngx_stream_upstream_srv_conf_t *us); | |
| 37 typedef ngx_int_t (*ngx_stream_upstream_init_peer_pt)(ngx_stream_session_t *s, | |
| 38 ngx_stream_upstream_srv_conf_t *us); | |
| 39 | |
| 40 | |
| 41 typedef struct { | |
| 42 ngx_stream_upstream_init_pt init_upstream; | |
| 43 ngx_stream_upstream_init_peer_pt init; | |
| 44 void *data; | |
| 45 } ngx_stream_upstream_peer_t; | |
| 46 | |
| 47 | |
| 48 typedef struct { | |
| 49 ngx_str_t name; | |
| 50 ngx_addr_t *addrs; | |
| 51 ngx_uint_t naddrs; | |
| 52 ngx_uint_t weight; | |
| 53 ngx_uint_t max_fails; | |
| 54 time_t fail_timeout; | |
| 55 | |
| 56 unsigned down:1; | |
| 57 unsigned backup:1; | |
| 58 } ngx_stream_upstream_server_t; | |
| 59 | |
| 60 | |
| 61 struct ngx_stream_upstream_srv_conf_s { | |
| 62 ngx_stream_upstream_peer_t peer; | |
| 63 void **srv_conf; | |
| 64 | |
| 65 ngx_array_t *servers; | |
| 66 /* ngx_stream_upstream_server_t */ | |
| 67 | |
| 68 ngx_uint_t flags; | |
| 69 ngx_str_t host; | |
| 70 u_char *file_name; | |
| 71 ngx_uint_t line; | |
| 72 in_port_t port; | |
| 73 ngx_uint_t no_port; /* unsigned no_port:1 */ | |
| 74 | |
| 75 #if (NGX_STREAM_UPSTREAM_ZONE) | |
| 76 ngx_shm_zone_t *shm_zone; | |
| 77 #endif | |
| 78 }; | |
| 79 | |
| 80 | |
| 81 typedef struct { | |
| 82 ngx_peer_connection_t peer; | |
| 83 ngx_buf_t downstream_buf; | |
| 84 ngx_buf_t upstream_buf; | |
| 85 off_t received; | |
|
6201
24488e6db782
Stream: upstream and downstream limit rates.
Roman Arutyunyan <arut@nginx.com>
parents:
6184
diff
changeset
|
86 time_t start_sec; |
| 6115 | 87 #if (NGX_STREAM_SSL) |
| 88 ngx_str_t ssl_name; | |
| 89 #endif | |
|
6202
6345822f0abb
Stream: upstream "connected" flag.
Roman Arutyunyan <arut@nginx.com>
parents:
6201
diff
changeset
|
90 unsigned connected:1; |
|
6345822f0abb
Stream: upstream "connected" flag.
Roman Arutyunyan <arut@nginx.com>
parents:
6201
diff
changeset
|
91 unsigned proxy_protocol:1; |
| 6115 | 92 } ngx_stream_upstream_t; |
| 93 | |
| 94 | |
| 95 ngx_stream_upstream_srv_conf_t *ngx_stream_upstream_add(ngx_conf_t *cf, | |
| 96 ngx_url_t *u, ngx_uint_t flags); | |
| 97 | |
| 98 | |
| 99 #define ngx_stream_conf_upstream_srv_conf(uscf, module) \ | |
| 100 uscf->srv_conf[module.ctx_index] | |
| 101 | |
| 102 | |
| 103 extern ngx_module_t ngx_stream_upstream_module; | |
| 104 | |
| 105 | |
| 106 #endif /* _NGX_STREAM_UPSTREAM_H_INCLUDED_ */ |