tasks: iocscanner minor improvements

 - stop scheduler properly.
 - skip closing channels for now.

Author: gustavo-iniguez-goya

daemon/tasks/iocscanner/main.go

@@ -113,9 +113,10 @@ func (pm *IOCScanner) Start(ctx context.Context, cancel context.CancelFunc) erro
 		return fmt.Errorf("no tools configured")
 	}
 	for n, schedCfg := range pm.Config.Schedule {
-		sched := scheduler.New(ctx, cancel, schedCfg)
-		sched.Start()
 		go func() {
+			sched := scheduler.New(ctx, cancel, schedCfg)
+			sched.Start()
+
 			for {
 				select {
 				case <-sched.Ctx.Done():
@@ -138,6 +139,7 @@ func (pm *IOCScanner) Start(ctx context.Context, cancel context.CancelFunc) erro
 			}
 		Exit:
 			log.Debug("[IOCScanner] scheduler stopped")
+			sched.Stop()
 		}()
 	}
 
@@ -184,8 +186,8 @@ func (pm *IOCScanner) Stop() error {
 	if pm.Cancel != nil {
 		pm.Cancel()
 	}
-	close(pm.TaskBase.Results)
-	close(pm.TaskBase.Errors)
+	//close(pm.TaskBase.Results)
+	//close(pm.TaskBase.Errors)
 	return nil
 }
 

daemon/tasks/scheduler/scheduler.go

@@ -122,16 +122,8 @@ func (s *Scheduler) SetupDailyTimers() {
 }
 
 func (s *Scheduler) Start() {
-	if len(s.Tickers) > 0 {
-		for _, t := range s.Tickers {
-			if t != nil {
-				t.Stop()
-			}
-		}
-		if s.Cancel != nil {
-			s.Cancel()
-		}
-	}
+	log.Debug("[tasks-scheduler] Start()")
+
 	if len(s.Config.Time) > 0 {
 		go s.SetupDailyTimers()
 	}
@@ -230,9 +222,6 @@ func (s *Scheduler) Stop() {
 	if s.Ticker != nil {
 		s.Ticker.Stop()
 	}
-	if s.Cancel != nil {
-		s.Cancel()
-	}
 }
 
 func (s *Scheduler) Tick() <-chan time.Time {