Merge pull request #2502 from okozachenko1203/patch-1

k8s-ci-robot · web-flow · commit 49d55d77ba30 · 2025-03-28T04:56:35.000-07:00
🐛 fix openstackserver controller concurrency
diff --git a/controllers/openstackserver_controller.go b/controllers/openstackserver_controller.go
@@ -170,7 +170,7 @@ func patchServer(ctx context.Context, patchHelper *patch.Helper, openStackServer
 	return patchHelper.Patch(ctx, openStackServer, options...)
 }
 
-func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, _ controller.Options) error {
+func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error {
 	const imageRefPath = "spec.image.imageRef.name"
 
 	log := ctrl.LoggerFrom(ctx)
@@ -190,6 +190,7 @@ func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ct
 	}
 
 	return ctrl.NewControllerManagedBy(mgr).
+		WithOptions(options).
 		For(&infrav1alpha1.OpenStackServer{}).
 		Watches(&orcv1alpha1.Image{},
 			handler.EnqueueRequestsFromMapFunc(func(ctx context.Context, obj client.Object) []reconcile.Request {

Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,7 @@ func patchServer(ctx context.Context, patchHelper *patch.Helper, openStackServer`
`170`	`170`	`return patchHelper.Patch(ctx, openStackServer, options...)`
`171`	`171`	`}`
`172`	`172`
`173`		`-func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, _ controller.Options) error {`
	`173`	`+func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error {`
`174`	`174`	`const imageRefPath = "spec.image.imageRef.name"`
`175`	`175`
`176`	`176`	`log := ctrl.LoggerFrom(ctx)`
`@@ -190,6 +190,7 @@ func (r *OpenStackServerReconciler) SetupWithManager(ctx context.Context, mgr ct`
`190`	`190`	`}`
`191`	`191`
`192`	`192`	`return ctrl.NewControllerManagedBy(mgr).`
	`193`	`+ WithOptions(options).`
`193`	`194`	`For(&infrav1alpha1.OpenStackServer{}).`
`194`	`195`	`Watches(&orcv1alpha1.Image{},`
`195`	`196`	`handler.EnqueueRequestsFromMapFunc(func(ctx context.Context, obj client.Object) []reconcile.Request {`