Fix leak of restore worker go routines after an error (#12933)

hashicorp · Oct 27, 2021 · 493a143 · 493a143
1 parent 6a58268
commit 493a143
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/vault/expiration.go b/vault/expiration.go
@@ -668,8 +668,8 @@ func (m *ExpirationManager) Restore(errorFunc func()) (retErr error) {
 	broker := make(chan *lease)
 	quit := make(chan bool)
 	// Buffer these channels to prevent deadlocks
-	errs := make(chan error, len(existing))
-	result := make(chan struct{}, len(existing))
+	errs := make(chan error, leaseCount)
+	result := make(chan struct{}, leaseCount)
 
 	// Use a wait group
 	wg := &sync.WaitGroup{}