CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix minor agent race condition around error messages (#7999)

This commit is contained in:
Steven Soroka 2020-08-18 11:27:58 -04:00 committed by GitHub
parent 34c8abb555
commit e9d5b1fb34
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
agent/agent.go
View File

@ -149,7 +149,7 @@ func (a *Agent) Run(ctx context.Context) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runOutputs(ou) err := a.runOutputs(ou)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running outputs: %v", err) log.Printf("E! [agent] Error running outputs: %v", err)
} }
@ -159,7 +159,7 @@ func (a *Agent) Run(ctx context.Context) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(apu) err := a.runProcessors(apu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -168,7 +168,7 @@ func (a *Agent) Run(ctx context.Context) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runAggregators(startTime, au) err := a.runAggregators(startTime, au)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running aggregators: %v", err) log.Printf("E! [agent] Error running aggregators: %v", err)
} }
@ -179,7 +179,7 @@ func (a *Agent) Run(ctx context.Context) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(pu) err := a.runProcessors(pu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -189,7 +189,7 @@ func (a *Agent) Run(ctx context.Context) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runInputs(ctx, startTime, iu) err := a.runInputs(ctx, startTime, iu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running inputs: %v", err) log.Printf("E! [agent] Error running inputs: %v", err)
} }
@ -944,7 +944,7 @@ func (a *Agent) test(ctx context.Context, wait time.Duration, outputC chan<- tel
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(apu) err := a.runProcessors(apu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -953,7 +953,7 @@ func (a *Agent) test(ctx context.Context, wait time.Duration, outputC chan<- tel
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runAggregators(startTime, au) err := a.runAggregators(startTime, au)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running aggregators: %v", err) log.Printf("E! [agent] Error running aggregators: %v", err)
} }
@ -964,7 +964,7 @@ func (a *Agent) test(ctx context.Context, wait time.Duration, outputC chan<- tel
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(pu) err := a.runProcessors(pu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -974,7 +974,7 @@ func (a *Agent) test(ctx context.Context, wait time.Duration, outputC chan<- tel
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.testRunInputs(ctx, wait, iu) err := a.testRunInputs(ctx, wait, iu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running inputs: %v", err) log.Printf("E! [agent] Error running inputs: %v", err)
} }
@ -1060,7 +1060,7 @@ func (a *Agent) once(ctx context.Context, wait time.Duration) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runOutputs(ou) err := a.runOutputs(ou)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running outputs: %v", err) log.Printf("E! [agent] Error running outputs: %v", err)
} }
@ -1070,7 +1070,7 @@ func (a *Agent) once(ctx context.Context, wait time.Duration) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(apu) err := a.runProcessors(apu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -1079,7 +1079,7 @@ func (a *Agent) once(ctx context.Context, wait time.Duration) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runAggregators(startTime, au) err := a.runAggregators(startTime, au)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running aggregators: %v", err) log.Printf("E! [agent] Error running aggregators: %v", err)
} }
@ -1090,7 +1090,7 @@ func (a *Agent) once(ctx context.Context, wait time.Duration) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.runProcessors(pu) err := a.runProcessors(pu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running processors: %v", err) log.Printf("E! [agent] Error running processors: %v", err)
} }
@ -1100,7 +1100,7 @@ func (a *Agent) once(ctx context.Context, wait time.Duration) error {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
err = a.testRunInputs(ctx, wait, iu) err := a.testRunInputs(ctx, wait, iu)
if err != nil { if err != nil {
log.Printf("E! [agent] Error running inputs: %v", err) log.Printf("E! [agent] Error running inputs: %v", err)
} }