Skip to content

Commit 298f1ef

Browse files
committed
Fix logging race in systemd_linux.go
The same variable was used for timing every parallel operation. Signed-off-by: Bryan Boreham <[email protected]>
1 parent 6300fab commit 298f1ef

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

collector/systemd_linux.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ func (c *systemdCollector) Update(ch chan<- prometheus.Metric) error {
199199
wg.Add(1)
200200
go func() {
201201
defer wg.Done()
202-
begin = time.Now()
202+
begin := time.Now()
203203
c.collectUnitStatusMetrics(conn, ch, units)
204204
c.logger.Debug("collectUnitStatusMetrics took", "duration_seconds", time.Since(begin).Seconds())
205205
}()
@@ -208,7 +208,7 @@ func (c *systemdCollector) Update(ch chan<- prometheus.Metric) error {
208208
wg.Add(1)
209209
go func() {
210210
defer wg.Done()
211-
begin = time.Now()
211+
begin := time.Now()
212212
c.collectUnitStartTimeMetrics(conn, ch, units)
213213
c.logger.Debug("collectUnitStartTimeMetrics took", "duration_seconds", time.Since(begin).Seconds())
214214
}()
@@ -218,7 +218,7 @@ func (c *systemdCollector) Update(ch chan<- prometheus.Metric) error {
218218
wg.Add(1)
219219
go func() {
220220
defer wg.Done()
221-
begin = time.Now()
221+
begin := time.Now()
222222
c.collectUnitTasksMetrics(conn, ch, units)
223223
c.logger.Debug("collectUnitTasksMetrics took", "duration_seconds", time.Since(begin).Seconds())
224224
}()
@@ -228,7 +228,7 @@ func (c *systemdCollector) Update(ch chan<- prometheus.Metric) error {
228228
wg.Add(1)
229229
go func() {
230230
defer wg.Done()
231-
begin = time.Now()
231+
begin := time.Now()
232232
c.collectTimers(conn, ch, units)
233233
c.logger.Debug("collectTimers took", "duration_seconds", time.Since(begin).Seconds())
234234
}()
@@ -237,13 +237,13 @@ func (c *systemdCollector) Update(ch chan<- prometheus.Metric) error {
237237
wg.Add(1)
238238
go func() {
239239
defer wg.Done()
240-
begin = time.Now()
240+
begin := time.Now()
241241
c.collectSockets(conn, ch, units)
242242
c.logger.Debug("collectSockets took", "duration_seconds", time.Since(begin).Seconds())
243243
}()
244244

245245
if systemdVersion >= minSystemdVersionSystemState {
246-
begin = time.Now()
246+
begin := time.Now()
247247
err = c.collectSystemState(conn, ch)
248248
c.logger.Debug("collectSystemState took", "duration_seconds", time.Since(begin).Seconds())
249249
}

0 commit comments

Comments
 (0)