From f9d8761dddc293dfc3ee23208e41bbba3f962d0b Mon Sep 17 00:00:00 2001
From: Airren <qiang.ren@intel.com>
Date: Wed, 31 Jul 2024 23:35:09 +0800
Subject: [PATCH] fix: hub without dedinic

Signed-off-by: Airren <qiang.ren@intel.com>
---
 pkg/cnf/CNFManager.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/pkg/cnf/CNFManager.go b/pkg/cnf/CNFManager.go
index 3e3fb0f0..07fc4bf1 100644
--- a/pkg/cnf/CNFManager.go
+++ b/pkg/cnf/CNFManager.go
@@ -47,8 +47,16 @@ type Manager struct {
 }
 
 func (m *Manager) Run(ctx context.Context) error {
-	go m.startLeaderElection(m.leaderLock, ctx)
+	if !m.agentSpec.AsHub {
+		go m.startLeaderElection(m.leaderLock, ctx)
+		m.dedinicEngine(ctx)
+	} else {
+		m.startLeaderElection(m.leaderLock, ctx)
+	}
+	return nil
+}
 
+func (m *Manager) dedinicEngine(ctx context.Context) {
 	dedinic.CNFPodName = os.Getenv("NAUTI_PODNAME")
 	if dedinic.CNFPodName == "" {
 		klog.Fatalf("get self pod name failed")
@@ -68,7 +76,6 @@ func (m *Manager) Run(ctx context.Context) error {
 
 	klog.Info("start nri dedicated plugin run")
 	dedinic.InitNRIPlugin(m.localK8sClient)
-	return nil
 }
 
 // NewCNFManager returns a new CNFController.