mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-17 03:43:11 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix comment, use atomic add

Browse source
This commit is contained in:
Neil Alexander 2020-05-06 10:26:27 +01:00
parent b167f3c608
commit 0eee57cbea
1 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
federationsender/types/statistics.go
View file

@ -63,8 +63,7 @@ type ServerStatistics struct {
// failure counters. If a host was blacklisted at this point then
// we will unblacklist it.
func (s *ServerStatistics) Success() {
sentCounter := s.failCounter.Load()
s.successCounter.Store(sentCounter + 1)
s.successCounter.Add(1)
s.failCounter.Store(0)
s.blacklisted.Store(false)
}
@ -75,9 +74,7 @@ func (s *ServerStatistics) Success() {
// as blacklisted.
func (s *ServerStatistics) Failure() bool {
// Increase the fail counter.
failCounter := s.failCounter.Load()
failCounter++
s.failCounter.Store(failCounter)
failCounter := s.failCounter.Add(1)
// Check that we haven't failed more times than is acceptable.
if failCounter >= FailuresUntilBlacklist {
@ -100,8 +97,8 @@ func (s *ServerStatistics) Failure() bool {
return false
}
// WaitUntil returns both a bool stating whether to wait, and then
// if true, a duration to wait for.
// BackoffDuration returns both a bool stating whether to wait,
// and then if true, a duration to wait for.
func (s *ServerStatistics) BackoffDuration() (bool, time.Duration) {
backoff, until := false, time.Second
if b, ok := s.backoffUntil.Load().(time.Time); ok {