fix(providerquerymanager): use find providers async context

ipfs · Nov 28, 2023 · add7775 · add7775
1 parent fe55533
commit add7775
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/bitswap/client/internal/providerquerymanager/providerquerymanager.go b/bitswap/client/internal/providerquerymanager/providerquerymanager.go
@@ -378,8 +378,8 @@ func (npqm *newProvideQueryMessage) debugMessage() string {
 func (npqm *newProvideQueryMessage) handle(pqm *ProviderQueryManager) {
 	requestStatus, ok := pqm.inProgressRequestStatuses[npqm.k]
 	if !ok {
-
-		ctx, cancelFn := context.WithCancel(pqm.ctx)
+		// used the passed in context to FindProvidersAsync for this call
+		ctx, cancelFn := context.WithCancel(npqm.ctx)
 		requestStatus = &inProgressRequestStatus{
 			listeners: make(map[chan peer.ID]struct{}),
 			ctx:       ctx,