fix countHealthy locking

This commit is contained in:
Alex
2025-02-07 15:46:12 -05:00
committed by Cuong Manh Le
parent 98042d8dbd
commit d37d0e942c

View File

@@ -150,11 +150,11 @@ func (p *prog) checkUpstream(upstream string, uc *ctrld.UpstreamConfig) {
func (um *upstreamMonitor) countHealthy(upstreams []string) int {
var count int
um.mu.RLock()
defer um.mu.RUnlock()
for _, upstream := range upstreams {
if !um.isDown(upstream) {
if !um.down[upstream] {
count++
}
}
um.mu.RUnlock()
return count
}