timing

Signed-off-by: dwertent <[email protected]>
dwertent · Dec 17, 2024 · 5b4c6c2 · 5b4c6c2
1 parent 0e2fc1f
commit 5b4c6c2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/operator/internal/controller/paladin_controller.go b/operator/internal/controller/paladin_controller.go
@@ -200,10 +200,10 @@ func (r *PaladinReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ct
 		changeable = false
 	}
 
-	// if changeable {
-	// 	// level-trigger, we want to check back in every so often in case we missed something
-	// 	return ctrl.Result{RequeueAfter: 2 * time.Minute}, nil
-	// }
+	if changeable {
+		// level-trigger, we want to check back in every so often in case we missed something
+		return ctrl.Result{RequeueAfter: 2 * time.Minute}, nil
+	}
 	// requeue after a bit to check if the change is released
 	return ctrl.Result{RequeueAfter: 5 * time.Second}, nil
 }

diff --git a/operator/internal/controller/paladinregistration_controller.go b/operator/internal/controller/paladinregistration_controller.go
@@ -305,10 +305,12 @@ func (r *PaladinRegistrationReconciler) buildTransportTX(ctx context.Context, re
 	}
 	var transportDetails string
 	if err := regNodeRPC.CallRPC(ctx, &transportDetails, "transport_localTransportDetails", transportName); err != nil || transportDetails == "" {
+		log.FromContext(ctx).Error(err, "transport_localTransportDetails")
 		return false, nil, err
 	}
 	var nodeName string
 	if err := regNodeRPC.CallRPC(ctx, &nodeName, "transport_nodeName"); err != nil || nodeName == "" {
+		log.FromContext(ctx).Error(err, "transport_nodeName")
 		return false, nil, err
 	}
 
@@ -359,7 +361,7 @@ func (r *PaladinRegistrationReconciler) SetupWithManager(mgr ctrl.Manager) error
 		Watches(&corev1alpha1.PaladinRegistry{}, handler.EnqueueRequestsFromMapFunc(r.reconcileRegistry), reconcileEveryChange()).
 		Watches(&corev1alpha1.Paladin{}, handler.EnqueueRequestsFromMapFunc(r.reconcilePaladin), reconcileEveryChange()).
 		WithOptions(controller.Options{
-			MaxConcurrentReconciles: 10,
+			MaxConcurrentReconciles: 2,
 		}).
 		Complete(r)
 }