diff --git a/go.mod b/go.mod index 4d62aae..609f341 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module github.com/ipfs/go-peertaskqueue go 1.24.6 require ( - github.com/ipfs/go-ipfs-pq v0.0.3 + github.com/ipfs/go-ipfs-pq v0.0.4 github.com/libp2p/go-libp2p v0.46.0 ) diff --git a/go.sum b/go.sum index 8a6b56e..0ec20f7 100644 --- a/go.sum +++ b/go.sum @@ -8,8 +8,8 @@ github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU= github.com/ipfs/go-cid v0.5.0 h1:goEKKhaGm0ul11IHA7I6p1GmKz8kEYniqFopaB5Otwg= github.com/ipfs/go-cid v0.5.0/go.mod h1:0L7vmeNXpQpUS9vt+yEARkJ8rOg43DF3iPgn4GIN0mk= -github.com/ipfs/go-ipfs-pq v0.0.3 h1:YpoHVJB+jzK15mr/xsWC574tyDLkezVrDNeaalQBsTE= -github.com/ipfs/go-ipfs-pq v0.0.3/go.mod h1:btNw5hsHBpRcSSgZtiNm/SLj5gYIZ18AKtv3kERkRb4= +github.com/ipfs/go-ipfs-pq v0.0.4 h1:U7jjENWJd1jhcrR8X/xHTaph14PTAK9O+yaLJbjqgOw= +github.com/ipfs/go-ipfs-pq v0.0.4/go.mod h1:9UdLOIIb99IFrgT0Fc53pvbvlJBhpUb4GJuAQf3+O2A= github.com/klauspost/cpuid/v2 v2.2.10 h1:tBs3QSyvjDyFTq3uoc/9xFpCuOsJQFNPiAhYdw2skhE= github.com/klauspost/cpuid/v2 v2.2.10/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0= github.com/libp2p/go-buffer-pool v0.1.0 h1:oK4mSFcQz7cTQIfqbe4MIj9gLW+mnanjyFtc6cdF0Y8= diff --git a/peertracker/peertracker.go b/peertracker/peertracker.go index 7d0c3e7..0e695e2 100644 --- a/peertracker/peertracker.go +++ b/peertracker/peertracker.go @@ -344,9 +344,7 @@ func (p *PeerTracker) TaskDone(task *peertask.Task) { delete(p.activeTasks, task.Topic) } else { // Garbage collection. - for i := len(newTasks); i < len(activeTasks); i++ { - activeTasks[i] = nil - } + clear(activeTasks[len(newTasks):]) p.activeTasks[task.Topic] = newTasks }