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

resolve go vet issues

This commit is contained in:
JP 2015-08-06 11:52:46 -05:00
parent 7ed19de44e
commit d318ef6df7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
agent.go
View File

@ -205,7 +205,7 @@ func (a *Agent) crankSeparate(shutdown chan struct{}, plugin *runningPlugin) err
acc.Tags = a.Config.Tags acc.Tags = a.Config.Tags
acc.Time = time.Now() acc.Time = time.Now()
err = a.flush(acc) err = a.flush(*acc)
if err != nil { if err != nil {
return err return err
} }
@ -219,14 +219,14 @@ func (a *Agent) crankSeparate(shutdown chan struct{}, plugin *runningPlugin) err
} }
} }
func (a *Agent) flush(bp BatchPoints) error { func (a *Agent) flush(bp *BatchPoints) error {
var wg sync.WaitGroup var wg sync.WaitGroup
var outerr error var outerr error
for _, o := range a.outputs { for _, o := range a.outputs {
wg.Add(1) wg.Add(1)
go func(output *runningOutput) { go func(output *runningOutput) {
defer wg.Done() defer wg.Done()
outerr = o.output.Write(bp.BatchPoints) outerr = output.Write(bp.BatchPoints)
}(o) }(o)
} }