dom/telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix mongodb input concurrent map read/write

Browse Source
This commit is contained in:
Kane Dou
2016-05-17 18:02:51 +08:00
parent a7b632eb5e
commit 0d5f95bbef
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/inputs/mongodb/mongodb.go
View File

@@ -69,10 +69,10 @@ func (m *MongoDB) Gather(acc telegraf.Accumulator) error {
} }
} }
wg.Add(1) wg.Add(1)
go func() { go func(srv *Server) {
defer wg.Done() defer wg.Done()
outerr = m.gatherServer(m.getMongoServer(u), acc) outerr = m.gatherServer(srv, acc)
}() }(m.getMongoServer(u))
} }
wg.Wait() wg.Wait()