Fix go routine leak in auto encrypt ca roots tracking

4 years ago · 29d0cfdd7d
1 changed files with 1 additions and 0 deletions
--- a/agent/consul/server.go
+++ b/agent/consul/server.go
@ -640,6 +640,7 @@ func (s *Server) trackAutoEncryptCARoots() {
 		ws := memdb.NewWatchSet()
 		state := s.fsm.State()
 		ws.Add(state.AbandonCh())
+		ws.Add(s.shutdownCh)
 		_, cas, err := state.CARoots(ws)
 		if err != nil {
 			s.logger.Error("Failed to watch AutoEncrypt CARoot", "error", err)