feat(prq): don't try to cancel finished provider requests

ffef00d9 · Steven Allen · 9394d3b6 · ffef00d9
Commit ffef00d9 authored Feb 26, 2019 by Steven Allen
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

providerquerymanager/providerquerymanager.go providerquerymanager/providerquerymanager.go +3 -1

No files found.
--- a/providerquerymanager/providerquerymanager.go
+++ b/providerquerymanager/providerquerymanager.go
@@ -177,7 +177,9 @@ func (pqm *ProviderQueryManager) receiveProviders(sessionCtx context.Context, k
 			case <-pqm.ctx.Done():
 				return
 			case <-sessionCtx.Done():
-				pqm.cancelProviderRequest(k, incomingProviders)
+				if incomingProviders != nil {
+					pqm.cancelProviderRequest(k, incomingProviders)
+				}
 				return
 			case provider, ok := <-incomingProviders:
 				if !ok {