sync claim status

Signed-off-by: Aylei <rayingecho@gmail.com>

Author: aylei

pkg/controllers/cnclaim/controller.go

@@ -139,7 +139,7 @@ func (r *Actor) doClaimCN(ctx *recon.Context[*v1alpha1.CNClaim], orphans []corev
 	baseSelector := common.MustAsSelector(c.Spec.Selector)
 	podSelector := baseSelector.Add(common.MustEqual(v1alpha1.CNPodPhaseLabel, v1alpha1.CNPodPhaseIdle))
 	if c.Spec.PoolName != "" {
-		podSelector = podSelector.Add(common.MustEqual(v1alpha1.PoolNameLabel, c.Spec.PodName))
+		podSelector = podSelector.Add(common.MustEqual(v1alpha1.PoolNameLabel, c.Spec.PoolName))
 	}
 	idleCNs, err := common.ListPods(ctx, client.InNamespace(c.Namespace), client.MatchingLabelsSelector{Selector: podSelector})
 	if err != nil && !apierrors.IsNotFound(err) {

pkg/controllers/cnstore/pooling.go

@@ -66,6 +66,8 @@ func (c *withCNSet) poolingCNReconcile(ctx *recon.Context[*corev1.Pod]) error {
 			if err != nil {
 				return errors.Wrap(err, "error patch CN phase idle")
 			}
+		} else {
+			ctx.Log.V(4).Info("CN Pod not ready")
 		}
 	default:
 		return errors.Errorf("unkown CN phase %s", pod.Labels[v1alpha1.CNPodPhaseLabel])

pkg/hacli/hakeeper_client.go

@@ -120,6 +120,7 @@ func (m *HAKeeperClientManager) doGC() {
 		err := m.kubeCli.Get(context.TODO(), v.lsRef, ls)
 		if err != nil {
 			if apierrors.IsNotFound(err) {
+				m.logger.Info("logset deleted, clean handler", "logset", v.lsRef)
 				delete(m.logSetToClients, uid)
 				closeFn()
 				continue
@@ -129,6 +130,7 @@ func (m *HAKeeperClientManager) doGC() {
 		}
 		// logset has been re-created, clean stale cache
 		if ls.UID != uid && recon.IsReady(ls) {
+			m.logger.Info("logset recreated, clean legeacy handler", "logset", v.lsRef, "old UID", uid, "new UID", ls.UID)
 			delete(m.logSetToClients, uid)
 			closeFn()
 		}