fix(qrm): fix network plugin possible memory leak (#190)

kubewharf · Aug 8, 2023 · 3229ded · 3229ded
1 parent 2f6c4fb
commit 3229ded
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/agent/qrm-plugins/network/staticpolicy/policy.go b/pkg/agent/qrm-plugins/network/staticpolicy/policy.go
@@ -185,8 +185,12 @@ func (p *StaticPolicy) Start() (err error) {
 
 	p.Lock()
 	defer func() {
-		if err == nil {
-			p.started = true
+		if !p.started {
+			if err == nil {
+				p.started = true
+			} else {
+				close(p.stopCh)
+			}
 		}
 		p.Unlock()
 	}()