restart the device plugin if NotifyRegistrationStatus returns failure

liuyuan10 · liuyuan10 · commit 595569db872f · 2024-09-24T15:56:34.000-07:00
Today it only logs and stop the rpc server. The plugin hangs after that.

Signed-off-by: Yuan Liu &lt;liuyuan@google.com&gt;
diff --git a/pkg/resources/server.go b/pkg/resources/server.go
@@ -115,8 +115,9 @@ 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 &registerapi.RegistrationStatusResponse{}, nil
 }

Original file line number	Diff line number	Diff line change
`@@ -115,8 +115,9 @@ func (rs *resourceServer) NotifyRegistrationStatus(ctx context.Context,`
`115`	`115`	`if regstat.PluginRegistered {`
`116`	`116`	`glog.Infof("Plugin: %s gets registered successfully at Kubelet\n", rs.endPoint)`
`117`	`117`	`} else {`
`118`		`- glog.Infof("Plugin: %s failed to be registered at Kubelet: %v; restarting.\n", rs.endPoint, regstat.Error)`
`119`	`118`	`rs.grpcServer.Stop()`
	`119`	`+ glog.Fatalf("Plugin: %s failed to be registered at Kubelet: %v; restarting.\n", rs.endPoint, regstat.Error)`
	`120`	`+`
`120`	`121`	`}`
`121`	`122`	`return &registerapi.RegistrationStatusResponse{}, nil`
`122`	`123`	`}`