Mercurial > hg > nginx
annotate src/stream/ngx_stream_upstream.h @ 6201:24488e6db782
Stream: upstream and downstream limit rates.
| author | Roman Arutyunyan <arut@nginx.com> |
|---|---|
| date | Tue, 23 Jun 2015 20:17:48 +0300 |
| parents | fa663739e115 |
| children | 6345822f0abb |
| 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 | |
|
6184
fa663739e115
Stream: client-side PROXY protocol.
Roman Arutyunyan <arut@nginx.com>
parents:
6115
diff
changeset
|
90 ngx_uint_t proxy_protocol; |
|
fa663739e115
Stream: client-side PROXY protocol.
Roman Arutyunyan <arut@nginx.com>
parents:
6115
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_ */ |