mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-19 18:32:23 +00:00
core/rawdb: use go ticker instead of timer
This commit is contained in:
parent
a71f6f91fd
commit
b20fe588f8
1 changed files with 3 additions and 4 deletions
|
|
@ -149,8 +149,8 @@ func (f *chainFreezer) freeze(db ethdb.KeyValueStore) {
|
||||||
triggered chan struct{} // Used in tests
|
triggered chan struct{} // Used in tests
|
||||||
nfdb = &nofreezedb{KeyValueStore: db}
|
nfdb = &nofreezedb{KeyValueStore: db}
|
||||||
)
|
)
|
||||||
timer := time.NewTimer(freezerRecheckInterval)
|
ticker := time.NewTicker(freezerRecheckInterval)
|
||||||
defer timer.Stop()
|
defer ticker.Stop()
|
||||||
|
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
|
|
@ -166,9 +166,8 @@ func (f *chainFreezer) freeze(db ethdb.KeyValueStore) {
|
||||||
triggered = nil
|
triggered = nil
|
||||||
}
|
}
|
||||||
select {
|
select {
|
||||||
case <-timer.C:
|
case <-ticker.C:
|
||||||
backoff = false
|
backoff = false
|
||||||
timer.Reset(freezerRecheckInterval)
|
|
||||||
case triggered = <-f.trigger:
|
case triggered = <-f.trigger:
|
||||||
backoff = false
|
backoff = false
|
||||||
case <-f.quit:
|
case <-f.quit:
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue