diff --git a/pkg/agent/qrm-plugins/network/staticpolicy/policy.go b/pkg/agent/qrm-plugins/network/staticpolicy/policy.go index e11e64162..20e93ac46 100644 --- 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() }()