Skip to content

Commit

Permalink
Update routing/providerquerymanager/providerquerymanager.go
Browse files Browse the repository at this point in the history
Co-authored-by: Hector Sanjuan <code@hector.link>
  • Loading branch information
gammazero and hsanjuan authored Nov 27, 2024
1 parent 01610a6 commit fa11dd0
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion routing/providerquerymanager/providerquerymanager.go
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ func (pqm *ProviderQueryManager) FindProvidersAsync(sessionCtx context.Context,

func (pqm *ProviderQueryManager) receiveProviders(sessionCtx context.Context, k cid.Cid, max int, receivedInProgressRequest inProgressRequest, onCloseFn func()) <-chan peer.AddrInfo {
// maintains an unbuffered queue for incoming providers for given request
// for a given session. Eessentially, as a provider comes in, for a given
// for a given session. Essentially, as a provider comes in, for a given
// CID, immediately broadcast to all sessions that queried that CID,
// without worrying about whether the client code is actually reading from
// the returned channel -- so that the broadcast never blocks.
Expand Down

0 comments on commit fa11dd0

Please sign in to comment.