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

resolve remaining build errors

This commit is contained in:
JP 2015-08-06 12:00:03 -05:00
parent d318ef6df7
commit 2601a09a83
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
agent.go
View File

@ -164,7 +164,7 @@ func (a *Agent) crankParallel() error {
bp.Points = append(bp.Points, sub.Points...) bp.Points = append(bp.Points, sub.Points...)
} }
return a.flush(bp) return a.flush(&bp)
} }
func (a *Agent) crank() error { func (a *Agent) crank() error {
@ -184,7 +184,7 @@ func (a *Agent) crank() error {
acc.Tags = a.Config.Tags acc.Tags = a.Config.Tags
acc.Time = time.Now() acc.Time = time.Now()
return a.flush(acc) return a.flush(&acc)
} }
func (a *Agent) crankSeparate(shutdown chan struct{}, plugin *runningPlugin) error { func (a *Agent) crankSeparate(shutdown chan struct{}, plugin *runningPlugin) error {
@ -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
} }
@ -224,9 +224,9 @@ func (a *Agent) flush(bp *BatchPoints) error {
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(ro *runningOutput) {
defer wg.Done() defer wg.Done()
outerr = output.Write(bp.BatchPoints) outerr = ro.output.Write(bp.BatchPoints)
}(o) }(o)
} }