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

added missing Close call on the AddrBook member of GossipSubRouter (#568)

Browse Source
This commit is contained in:
Sorin Stanculeanu 2024-07-11 18:25:52 +03:00 committed by GitHub
parent 093f13ce16
commit e508d8643d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
gossipsub.go
View File

@ -3,6 +3,7 @@ package pubsub
import (
"context"
"fmt"
"io"
"math/rand"
"sort"
"time"
@ -543,6 +544,13 @@ func (gs *GossipSubRouter) manageAddrBook() {
for {
select {
case <-gs.p.ctx.Done():
cabCloser, ok := gs.cab.(io.Closer)
if ok {
errClose := cabCloser.Close()
if errClose != nil {
log.Warnf("failed to close addr book: %v", errClose)
}
}
return
case ev := <-sub.Out():
switch ev := ev.(type) {