update all

leancodebox · Jun 30, 2024 · 6982fa1 · 6982fa1
1 parent 7a4bf84
commit 6982fa1
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/jobmanager/job_get.go b/jobmanager/job_get.go
@@ -54,6 +54,15 @@ func JobStop(jobId string) error {
 	return nil
 }
 
+func StopAll() {
+	jobManager.Range(func(key, value any) bool {
+		if jh, ok := value.(*jobHandle); ok {
+			jh.StopJob()
+		}
+		return true
+	})
+}
+
 func RunStartTime() time.Time {
 	return startTime
 }

diff --git a/jobmanagerserver/server.go b/jobmanagerserver/server.go
@@ -110,6 +110,7 @@ func ServeStop() {
 	if err := srv.Shutdown(ctx); err != nil {
 		slog.Info("Server Shutdown:", "err", err.Error())
 	}
+	jobmanager.StopAll()
 }
 
 type fsFunc func(name string) (fs.File, error)