Fix updater loop bug
This commit is contained in:
@@ -128,7 +128,6 @@ func (l *looper) Run(ctx context.Context, wg *sync.WaitGroup) {
|
|||||||
l.stopped <- struct{}{}
|
l.stopped <- struct{}{}
|
||||||
case servers := <-serversCh:
|
case servers := <-serversCh:
|
||||||
updateCancel()
|
updateCancel()
|
||||||
close(serversCh)
|
|
||||||
l.setAllServers(servers)
|
l.setAllServers(servers)
|
||||||
if err := l.storage.FlushToFile(servers); err != nil {
|
if err := l.storage.FlushToFile(servers); err != nil {
|
||||||
l.logger.Error(err)
|
l.logger.Error(err)
|
||||||
|
|||||||
Reference in New Issue
Block a user