|
@@ -111,11 +111,14 @@ func (pm *PluginManager) Run(ctx context.Context) error {
|
|
|
pm.checkForUpdates()
|
|
pm.checkForUpdates()
|
|
|
|
|
|
|
|
ticker := time.NewTicker(time.Minute * 10)
|
|
ticker := time.NewTicker(time.Minute * 10)
|
|
|
- for {
|
|
|
|
|
|
|
+ run := true
|
|
|
|
|
+
|
|
|
|
|
+ for run {
|
|
|
select {
|
|
select {
|
|
|
case <-ticker.C:
|
|
case <-ticker.C:
|
|
|
pm.checkForUpdates()
|
|
pm.checkForUpdates()
|
|
|
case <-ctx.Done():
|
|
case <-ctx.Done():
|
|
|
|
|
+ run = false
|
|
|
break
|
|
break
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -125,7 +128,7 @@ func (pm *PluginManager) Run(ctx context.Context) error {
|
|
|
p.Kill()
|
|
p.Kill()
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- return nil
|
|
|
|
|
|
|
+ return ctx.Err()
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func checkPluginPaths() error {
|
|
func checkPluginPaths() error {
|