【OSCP】Kuscia Task 资源及连通性前置检查 (#531) (#797) (#825)

* 【OSCP】Kuscia Task 资源及连通性前置检查 (#531) (#797)

Signed-off-by: MikkiYang <hecy7@asiainfo.com>

* 【OSCP】Kuscia Task 资源及连通性前置检查 (#531)

Signed-off-by: MikkiYang <hecy7@asiainfo.com>

---------

Signed-off-by: MikkiYang <hecy7@asiainfo.com>

Author: MiKKiYang

pkg/controllers/kusciatask/resource/node_resource_manager.go

@@ -106,10 +106,6 @@ func NewNodeResourceManager(
 		resourceStore:  nodeStatusStore,
 	}
 
-	if err := manager.start(); err != nil {
-		nlog.Errorf("Failed to initialize node resource manager: %v", err)
-	}
-
 	manager.addPodEventHandler()
 	manager.addNodeEventHandler()
 
@@ -519,6 +515,11 @@ func (nrm *NodeResourceManager) Run(workers int) error {
 		go wait.Until(nrm.runNodeHandleWorker, time.Second, nrm.ctx.Done())
 	}
 
+	if err := nrm.syncAllNodes(); err != nil {
+		nlog.Errorf("Failed to initialize node resource manager: %v", err)
+		return err
+	}
+
 	<-nrm.ctx.Done()
 	return nil
 }
@@ -677,7 +678,7 @@ func (nrm *NodeResourceManager) ResourceCheck(domainName string, cpuReq, memReq
 	return false, fmt.Errorf("resource-check no node status available for domain %s", domainName)
 }
 
-func (nrm *NodeResourceManager) start() error {
+func (nrm *NodeResourceManager) syncAllNodes() error {
 	domains, err := nrm.domainInformer.Lister().List(labels.Everything())
 	if err != nil {
 		return fmt.Errorf("failed to list domains: %v", err)