diff --git a/plugin/manager_linux.go b/plugin/manager_linux.go index 6756dba995..bf477f4163 100644 --- a/plugin/manager_linux.go +++ b/plugin/manager_linux.go @@ -26,6 +26,7 @@ func (pm *Manager) enable(p *v2.Plugin, force bool) error { } p.Lock() p.Restart = true + p.ExitChan = make(chan bool) p.Unlock() if err := pm.containerdClient.Create(p.GetID(), "", "", specs.Spec(*spec), attachToLog(p.GetID())); err != nil { return err @@ -92,7 +93,6 @@ func (pm *Manager) Shutdown() { } if pm.containerdClient != nil && p.IsEnabled() { p.Lock() - p.ExitChan = make(chan bool) p.Restart = false p.Unlock() shutdownPlugin(p, pm.containerdClient)