mirror of
https://github.com/qdm12/gluetun.git
synced 2026-05-10 04:30:20 +02:00
@@ -106,14 +106,22 @@ func (c *Checker) Start(ctx context.Context) (runError <-chan error, err error)
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
err = fmt.Errorf("small periodic check: %w", err)
|
err = fmt.Errorf("small periodic check: %w", err)
|
||||||
}
|
}
|
||||||
runErrorCh <- err
|
select {
|
||||||
|
case <-ctx.Done():
|
||||||
|
continue
|
||||||
|
case runErrorCh <- err:
|
||||||
|
}
|
||||||
smallCheckTimer.Reset(smallCheckPeriod)
|
smallCheckTimer.Reset(smallCheckPeriod)
|
||||||
case <-fullCheckTimer.C:
|
case <-fullCheckTimer.C:
|
||||||
err := c.fullPeriodicCheck(ctx)
|
err := c.fullPeriodicCheck(ctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
err = fmt.Errorf("full periodic check: %w", err)
|
err = fmt.Errorf("full periodic check: %w", err)
|
||||||
}
|
}
|
||||||
runErrorCh <- err
|
select {
|
||||||
|
case <-ctx.Done():
|
||||||
|
continue
|
||||||
|
case runErrorCh <- err:
|
||||||
|
}
|
||||||
fullCheckTimer.Reset(fullCheckPeriod)
|
fullCheckTimer.Reset(fullCheckPeriod)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user