|
@@ -190,6 +190,9 @@ func (t *ProgressEmitter) CommitConfiguration(from, to config.Configuration) boo
|
|
defer t.mut.Unlock()
|
|
defer t.mut.Unlock()
|
|
|
|
|
|
t.interval = time.Duration(to.Options.ProgressUpdateIntervalS) * time.Second
|
|
t.interval = time.Duration(to.Options.ProgressUpdateIntervalS) * time.Second
|
|
|
|
+ if t.interval < time.Second {
|
|
|
|
+ t.interval = time.Second
|
|
|
|
+ }
|
|
t.minBlocks = to.Options.TempIndexMinBlocks
|
|
t.minBlocks = to.Options.TempIndexMinBlocks
|
|
l.Debugln("progress emitter: updated interval", t.interval)
|
|
l.Debugln("progress emitter: updated interval", t.interval)
|
|
|
|
|