Update sweeper.go

libp2p · Mar 14, 2024 · 7e2a3e1 · 7e2a3e1
1 parent 6f13c62
commit 7e2a3e1
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/sweeper.go b/sweeper.go
@@ -3,7 +3,6 @@ package flow
 import (
 	"math"
 	"sync"
-	"sync/atomic"
 	"time"
 
 	"github.com/benbjohnson/clock"
@@ -103,7 +102,7 @@ func (sw *sweeper) update() {
 
 		// update the totals but leave the rates alone.
 		for _, m := range sw.meters {
-			m.snapshot.Total = atomic.LoadUint64(&m.accumulator)
+			m.snapshot.Total = m.accumulator.Load()
 		}
 		return
 	} else if tdiff <= ewmaRate/10 {