fix: only flush dirty metrics (#2418)

ethersphere · Aug 18, 2021 · 87d83ed · 87d83ed
1 parent 586618a
commit 87d83ed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/topology/kademlia/internal/metrics/metrics.go b/pkg/topology/kademlia/internal/metrics/metrics.go
@@ -164,7 +164,7 @@ type Counters struct {
 
 // flush writes the current state of in memory counters into the given db.
 func (cs *Counters) flush(db *shed.DB, batch *leveldb.Batch) error {
-	if cs.dirty.Load() > 1 {
+	if cs.dirty.Load() < 3 {
 		return nil
 	}
 	cs.dirty.CAS(3, 2)