ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2024-11-12 21:17:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

Use non-blocking send at close

Browse Source
This commit is contained in:
Thomas Roehl 2022-01-26 16:52:56 +01:00
parent 09b7538479
commit babd7a9af8
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
collectors/collectorManager.go
View File

@ -150,7 +150,10 @@ func (cm *collectorManager) AddOutput(output chan lp.CCMetric) {
// Close finishes / stops the metric collector manager // Close finishes / stops the metric collector manager
func (cm *collectorManager) Close() { func (cm *collectorManager) Close() {
cm.done <- true select {
case cm.done <- true:
default:
}
cclog.ComponentDebug("CollectorManager", "CLOSE") cclog.ComponentDebug("CollectorManager", "CLOSE")
} }