non-blocking send
This commit is contained in:
parent
b168820dbe
commit
644d0fe955
|
@ -134,7 +134,10 @@ func (pw *PluginWatcher) watchPluginTicker(pluginName string) {
|
||||||
}
|
}
|
||||||
case <-pw.tomb.Dying():
|
case <-pw.tomb.Dying():
|
||||||
ticker.Stop()
|
ticker.Stop()
|
||||||
pw.PluginEvents <- pluginName
|
select {
|
||||||
|
case pw.PluginEvents <- pluginName:
|
||||||
|
default:
|
||||||
|
}
|
||||||
log.Tracef("sending alerts to %s", pluginName)
|
log.Tracef("sending alerts to %s", pluginName)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue