Merge pull request #22753 from karalabe/p2p-tracker-stopfix

p2p/tracker: only reschedule wake if previous didn't run

Merge pull request #22753 from karalabe/p2p-tracker-stopfix
p2p/tracker: only reschedule wake if previous didn't run
d9c9ee5a · Péter Szilágyi · GitHub · 55043eec · ff3535e8 · d9c9ee5a
隐藏空白更改
内联并排

Showing with 3 addition and 2 deletion

p2p/tracker/tracker.go p2p/tracker/tracker.go +3 -2

未找到文件。
--- a/p2p/tracker/tracker.go
+++ b/p2p/tracker/tracker.go
@@ -188,8 +188,9 @@ func (t *Tracker) Fulfil(peer string, version uint, code uint64, id uint64) {
 	t.expire.Remove(req.expire)
 	delete(t.pending, id)
 	if req.expire.Prev() == nil {
-		t.wake.Stop()
-		t.schedule()
+		if t.wake.Stop() {
+			t.schedule()
+		}
 	}
 	g := fmt.Sprintf("%s/%s/%d/%#02x", trackedGaugeName, t.protocol, req.version, req.reqCode)
 	metrics.GetOrRegisterGauge(g, nil).Dec(1)