fix: removed depth check for skip list

ethersphere · Jul 6, 2021 · 4a7382e · 4a7382e
1 parent 3a83603
commit 4a7382e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/pushsync/pushsync.go b/pkg/pushsync/pushsync.go
@@ -393,7 +393,7 @@ func (ps *PushSync) pushToClosest(ctx context.Context, ch swarm.Chunk, retryAllo
 				ps.metrics.TotalFailedSendAttempts.Inc()
 
 				// if the node has warmed up AND no other closer peer has been tried
-				if time.Now().After(ps.warmupPeriod) && !ps.skipList.HasChunk(ch.Address()) && ps.topologyDriver.IsWithinDepth(ch.Address()) {
+				if time.Now().After(ps.warmupPeriod) && !ps.skipList.HasChunk(ch.Address()) {
 					ps.skipList.Add(peer, ch.Address(), skipPeerExpiration)
 				}
 			}