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

Move toTheSinks out of for loop

Browse Source
This commit is contained in:
Holger Obermaier 2022-02-14 18:53:37 +01:00
parent 416a94aceb
commit a3ad9d0cb0
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
sinks/sinkManager.go
View File

@ -100,18 +100,17 @@ func (sm *sinkManager) Start() {
cclog.ComponentDebug("SinkManager", "DONE") cclog.ComponentDebug("SinkManager", "DONE")
} }
for { toTheSinks := func(p lp.CCMetric) {
// Send received metric to all outputs
toTheSinks := func(p lp.CCMetric) { cclog.ComponentDebug("SinkManager", "WRITE", p)
// Send received metric to all outputs for _, s := range sm.sinks {
cclog.ComponentDebug("SinkManager", "WRITE", p) if err := s.Write(p); err != nil {
for _, s := range sm.sinks { cclog.ComponentError("SinkManager", "WRITE", s.Name(), "write failed:", err.Error())
if err := s.Write(p); err != nil {
cclog.ComponentError("SinkManager", "WRITE", s.Name(), "write failed:", err.Error())
}
} }
} }
}
for {
select { select {
case <-sm.done: case <-sm.done:
done() done()