logos-messaging/logos-messaging-go
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go.git synced 2026-01-08 00:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: stop creating goroutines if context is already canceled (#1213)

Browse Source
This commit is contained in:
richΛrd 2024-08-30 11:46:19 -04:00 committed by GitHub
parent 69e1b559bc
commit 27d640e391
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
waku/v2/api/missing/missing_messages.go
View File

@ -144,6 +144,13 @@ func (m *MissingMessageVerifier) fetchHistory(c chan<- *protocol.Envelope, inter
j = len(contentTopics) j = len(contentTopics)
} }
select {
case <-interest.ctx.Done():
return
default:
// continue...
}
now := m.timesource.Now() now := m.timesource.Now()
err := m.fetchMessagesBatch(c, interest, i, j, now) err := m.fetchMessagesBatch(c, interest, i, j, now)
if err != nil { if err != nil {
@ -260,6 +267,13 @@ func (m *MissingMessageVerifier) fetchMessagesBatch(c chan<- *protocol.Envelope,
j = len(missingHashes) j = len(missingHashes)
} }
select {
case <-interest.ctx.Done():
return nil
default:
// continue...
}
wg.Add(1) wg.Add(1)
go func(messageHashes []pb.MessageHash) { go func(messageHashes []pb.MessageHash) {
defer wg.Wait() defer wg.Wait()