Clean up StatsFetcher work when context is exceeded (#6086)

2019-07-12 08:23:28 -06:00 · 2019-07-12 08:23:28 -06:00 · f5634a24e8
parent 6cc936d64b
commit f5634a24e8
1 changed files with 4 additions and 0 deletions
--- a/agent/consul/stats_fetcher.go
+++ b/agent/consul/stats_fetcher.go
@ -107,6 +107,10 @@ func (f *StatsFetcher) Fetch(ctx context.Context, members []serf.Member) map[str
 		case <-ctx.Done():
 			f.logger.Printf("[WARN] consul: error getting server health from %q: %v",
 				workItem.server.Name, ctx.Err())
+
+			f.inflightLock.Lock()
+			delete(f.inflight, workItem.server.ID)
+			f.inflightLock.Unlock()
 		}
 	}
 	return replies