feat: empty scheduler job (#565)

* feat: empty scheduler job Signed-off-by: Gaius <gaius.qi@gmail.com>
dragonflyoss · Aug 19, 2021 · f73fc50 · f73fc50
1 parent dfb7f1e
commit f73fc50
Showing 1 changed file with 14 additions and 8 deletions.
diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go
@@ -134,12 +134,14 @@ func (s *Server) Serve() error {
 	}()
 
 	// Serve Job
-	go func() {
-		if err := s.job.Serve(); err != nil {
-			logger.Fatalf("job start failed %v", err)
-		}
-		logger.Info("job start successfully")
-	}()
+	if s.job != nil {
+		go func() {
+			if err := s.job.Serve(); err != nil {
+				logger.Fatalf("job start failed %v", err)
+			}
+			logger.Info("job start successfully")
+		}()
+	}
 
 	// Serve Keepalive
 	if s.managerClient != nil {
@@ -226,9 +228,13 @@ func (s *Server) keepAlive(ctx context.Context) error {
 }
 
 func (s *Server) Stop() {
-	s.managerConn.Close()
+	if s.managerConn != nil {
+		s.managerConn.Close()
+	}
 	s.dynConfig.Stop()
 	s.schedulerService.Stop()
-	s.job.Stop()
+	if s.job != nil {
+		s.job.Stop()
+	}
 	rpc.StopServer()
 }