summaryrefslogtreecommitdiff
path: root/modules/caddyhttp/reverseproxy/selectionpolicies_test.go
diff options
context:
space:
mode:
authorSimão Gomes Viana <simao.gomes@toowoxx.de>2021-04-29 18:52:22 +0200
committerGitHub <noreply@github.com>2021-04-29 10:52:22 -0600
commit90175571698d7cb0e4184d257a425f0bd11c713d (patch)
treecfa7d28aa0491fc38547e640ff458a21c1c5f3cd /modules/caddyhttp/reverseproxy/selectionpolicies_test.go
parent3a1e81dbf6587d2e886529d55e7a02eabeaa7c47 (diff)
reverseproxy: fix hash selection policy (#4137)
* caddyhttp: reverseproxy: fix hash selection policy Fixes: #4135 Test: go test './...' -count=1 * caddyhttp: reverseproxy: add test to catch #4135 If you revert the last commit, the test will fail.
Diffstat (limited to 'modules/caddyhttp/reverseproxy/selectionpolicies_test.go')
-rw-r--r--modules/caddyhttp/reverseproxy/selectionpolicies_test.go29
1 files changed, 29 insertions, 0 deletions
diff --git a/modules/caddyhttp/reverseproxy/selectionpolicies_test.go b/modules/caddyhttp/reverseproxy/selectionpolicies_test.go
index 70d05ac..60a2702 100644
--- a/modules/caddyhttp/reverseproxy/selectionpolicies_test.go
+++ b/modules/caddyhttp/reverseproxy/selectionpolicies_test.go
@@ -198,6 +198,35 @@ func TestIPHashPolicy(t *testing.T) {
if h != nil {
t.Error("Expected ip hash policy host to be nil.")
}
+
+ // Reproduce #4135
+ pool = UpstreamPool{
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ {Host: new(upstreamHost)},
+ }
+ pool[0].SetHealthy(false)
+ pool[1].SetHealthy(false)
+ pool[2].SetHealthy(false)
+ pool[3].SetHealthy(false)
+ pool[4].SetHealthy(false)
+ pool[5].SetHealthy(false)
+ pool[6].SetHealthy(false)
+ pool[7].SetHealthy(false)
+ pool[8].SetHealthy(true)
+
+ // We should get a result back when there is one healthy host left.
+ h = ipHash.Select(pool, req, nil)
+ if h == nil {
+ // If it is nil, it means we missed a host even though one is available
+ t.Error("Expected ip hash policy host to not be nil, but it is nil.")
+ }
}
func TestFirstPolicy(t *testing.T) {