fullrt: execOnMany abort early if executing on no peers

5eb9aaa3 · Adin Schmahmann · 0da80650 · 5eb9aaa3
Commit 5eb9aaa3 authored May 26, 2021 by Adin Schmahmann
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

fullrt/dht.go fullrt/dht.go +4 -0

No files found.
--- a/fullrt/dht.go
+++ b/fullrt/dht.go
@@ -831,6 +831,10 @@ func (dht *FullRT) Provide(ctx context.Context, key cid.Cid, brdcst bool) (err e
 }

 func (dht *FullRT) execOnMany(ctx context.Context, fn func(context.Context, peer.ID) error, peers []peer.ID) int {
+	if len(peers) == 0 {
+		return 0
+	}
+
 	putctx, cancel := context.WithCancel(ctx)
 	defer cancel()