From 5435e0d1a1ae187f638ba3c852996713aa27d370 Mon Sep 17 00:00:00 2001
From: ucwong <ucwong@126.com>
Date: Thu, 18 Jun 2020 23:58:49 +0800
Subject: [PATCH] whisper : use timer.Ticker instead of sleep (#21240)
* whisper : use timer.Ticker instead of sleep
* lint: Fix linter error
Co-authored-by: Guillaume Ballet <gballet@gmail.com>
---
whisper/whisperv6/whisper.go | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
index af513888d..8fe648a7a 100644
--- a/whisper/whisperv6/whisper.go
+++ b/whisper/whisperv6/whisper.go
@@ -249,7 +249,10 @@ func (whisper *Whisper) SetBloomFilter(bloom []byte) error {
go func() {
// allow some time before all the peers have processed the notification
defer whisper.wg.Done()
- time.Sleep(time.Duration(whisper.syncAllowance) * time.Second)
+ ticker := time.NewTicker(time.Duration(whisper.syncAllowance) * time.Second)
+ defer ticker.Stop()
+
+ <-ticker.C
whisper.settings.Store(bloomFilterToleranceIdx, b)
}()
@@ -269,7 +272,10 @@ func (whisper *Whisper) SetMinimumPoW(val float64) error {
go func() {
defer whisper.wg.Done()
// allow some time before all the peers have processed the notification
- time.Sleep(time.Duration(whisper.syncAllowance) * time.Second)
+ ticker := time.NewTicker(time.Duration(whisper.syncAllowance) * time.Second)
+ defer ticker.Stop()
+
+ <-ticker.C
whisper.settings.Store(minPowToleranceIdx, val)
}()
--
GitLab