github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-21 00:33:15 +00:00
Code Issues Projects Releases Wiki Activity

mark device manager as haelthy before it started for the first time

Browse Source
This commit is contained in:
Sergey Kanzhelev
2025-11-05 19:45:03 +00:00
parent fd556dc8ca
commit 2d3e063923
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
View File

@@ -57,8 +57,8 @@ type server struct {
chandler ClientHandler
clients map[string]Client
// isStarted indicates whether the service has started successfully.
isStarted bool
// lastError records the last runtime error. A server is considered healthy till an actual error occurs.
lastError error
api.UnsafeRegistrationServer
}
@@ -119,7 +119,7 @@ func (s *server) Start(logger klog.Logger) error {
defer s.wg.Done()
s.setHealthy()
if err = s.grpc.Serve(ln); err != nil {
s.setUnhealthy()
s.setUnhealthy(err)
logger.Error(err, "Error while serving device plugin registration grpc server")
}
}()
@@ -211,18 +211,19 @@ func (s *server) Name() string {
}
func (s *server) Check(_ *http.Request) error {
if s.isStarted {
return nil
}
return fmt.Errorf("device plugin registration gRPC server failed and no device plugins can register")
return s.lastError
}
// setHealthy sets the health status of the gRPC server.
func (s *server) setHealthy() {
s.isStarted = true
s.lastError = nil
}
// setUnhealthy sets the health status of the gRPC server to unhealthy.
func (s *server) setUnhealthy() {
s.isStarted = false
func (s *server) setUnhealthy(err error) {
if err == nil {
s.lastError = fmt.Errorf("device registration error: device plugin registration gRPC server failed and no device plugins can register")
return
}
s.lastError = fmt.Errorf("device registration error: device plugin registration gRPC server failed and no device plugins can register: %w", err)
}