diff options
| author | Ruslan Ermilov <ru@nginx.com> | 2016-09-22 19:32:47 +0300 |
|---|---|---|
| committer | Ruslan Ermilov <ru@nginx.com> | 2016-09-22 19:32:47 +0300 |
| commit | f674f32c09c9938d5f2b19509166e5c5e28a9e3c (patch) | |
| tree | 225a53166111dd4f818b83a4d603aab4d187e52e /src/stream/ngx_stream_upstream_round_robin.c | |
| parent | fd9e74f656b3a7683424304da3bc859988407acf (diff) | |
| download | nginx-f674f32c09c9938d5f2b19509166e5c5e28a9e3c.tar.gz nginx-f674f32c09c9938d5f2b19509166e5c5e28a9e3c.zip | |
Upstream: max_conns.
Diffstat (limited to 'src/stream/ngx_stream_upstream_round_robin.c')
| -rw-r--r-- | src/stream/ngx_stream_upstream_round_robin.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/stream/ngx_stream_upstream_round_robin.c b/src/stream/ngx_stream_upstream_round_robin.c index 768aaff4e..3f4bfcfa5 100644 --- a/src/stream/ngx_stream_upstream_round_robin.c +++ b/src/stream/ngx_stream_upstream_round_robin.c @@ -96,6 +96,7 @@ ngx_stream_upstream_init_round_robin(ngx_conf_t *cf, peer[n].weight = server[i].weight; peer[n].effective_weight = server[i].weight; peer[n].current_weight = 0; + peer[n].max_conns = server[i].max_conns; peer[n].max_fails = server[i].max_fails; peer[n].fail_timeout = server[i].fail_timeout; peer[n].down = server[i].down; @@ -159,6 +160,7 @@ ngx_stream_upstream_init_round_robin(ngx_conf_t *cf, peer[n].weight = server[i].weight; peer[n].effective_weight = server[i].weight; peer[n].current_weight = 0; + peer[n].max_conns = server[i].max_conns; peer[n].max_fails = server[i].max_fails; peer[n].fail_timeout = server[i].fail_timeout; peer[n].down = server[i].down; @@ -227,6 +229,7 @@ ngx_stream_upstream_init_round_robin(ngx_conf_t *cf, peer[i].weight = 1; peer[i].effective_weight = 1; peer[i].current_weight = 0; + peer[i].max_conns = 0; peer[i].max_fails = 1; peer[i].fail_timeout = 10; *peerp = &peer[i]; @@ -438,6 +441,10 @@ ngx_stream_upstream_get_round_robin_peer(ngx_peer_connection_t *pc, void *data) goto failed; } + if (peer->max_conns && peer->conns >= peer->max_conns) { + goto failed; + } + rrp->current = peer; } else { @@ -539,6 +546,10 @@ ngx_stream_upstream_get_peer(ngx_stream_upstream_rr_peer_data_t *rrp) continue; } + if (peer->max_conns && peer->conns >= peer->max_conns) { + continue; + } + peer->current_weight += peer->effective_weight; total += peer->effective_weight; |