From 7bd0ebfe16bbd7cc18eeac6a22733349553bca5a Mon Sep 17 00:00:00 2001 From: Yuan Liu Date: Tue, 24 Sep 2024 15:54:38 -0700 Subject: [PATCH] restart the device plugin if NotifyRegistrationStatus returns failure Today it only logs and stop the rpc server. The plugin hangs after that. Signed-off-by: Yuan Liu --- pkg/resources/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/resources/server.go b/pkg/resources/server.go index 5951d0cd9..4ceb5a1e5 100644 --- a/pkg/resources/server.go +++ b/pkg/resources/server.go @@ -115,8 +115,8 @@ func (rs *resourceServer) NotifyRegistrationStatus(ctx context.Context, if regstat.PluginRegistered { glog.Infof("Plugin: %s gets registered successfully at Kubelet\n", rs.endPoint) } else { - glog.Infof("Plugin: %s failed to be registered at Kubelet: %v; restarting.\n", rs.endPoint, regstat.Error) rs.grpcServer.Stop() + glog.Fatalf("Plugin: %s failed to be registered at Kubelet: %v; restarting.\n", rs.endPoint, regstat.Error) } return ®isterapi.RegistrationStatusResponse{}, nil }