From 2d9fab8b18fd3147235df58109cfccb45b39f701 Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Thu, 10 Aug 2023 17:52:35 +0800 Subject: [PATCH] fix Signed-off-by: Ryan Leung --- pkg/mcs/resourcemanager/server/server.go | 2 +- pkg/mcs/scheduling/server/server.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/mcs/resourcemanager/server/server.go b/pkg/mcs/resourcemanager/server/server.go index dd2ae496d41..19c10bb8cf9 100644 --- a/pkg/mcs/resourcemanager/server/server.go +++ b/pkg/mcs/resourcemanager/server/server.go @@ -129,7 +129,7 @@ func (s *Server) primaryElectionLoop() { for { select { - case <-s.ctx.Done(): + case <-s.serverLoopCtx.Done(): log.Info("server is closed, exit resource manager primary election loop") return default: diff --git a/pkg/mcs/scheduling/server/server.go b/pkg/mcs/scheduling/server/server.go index 3d1f9105f2f..845dbe38aa5 100644 --- a/pkg/mcs/scheduling/server/server.go +++ b/pkg/mcs/scheduling/server/server.go @@ -175,7 +175,7 @@ func (s *Server) primaryElectionLoop() { for { select { - case <-s.ctx.Done(): + case <-s.serverLoopCtx.Done(): log.Info("server is closed, exit resource manager primary election loop") return default: