forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

whisper/whisperv6/peer, whisper : fix quit goroutine leak

Browse source
This commit is contained in:
ucwong 2020-04-03 04:49:34 +00:00
parent f7b29ec942
commit bf3fc09c3e
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
whisper/whisperv6/peer.go
View file

@ -57,7 +57,7 @@ func newPeer(host *Whisper, remote *p2p.Peer, rw p2p.MsgReadWriter) *Peer {
trusted: false, trusted: false,
powRequirement: 0.0, powRequirement: 0.0,
known: mapset.NewSet(), known: mapset.NewSet(),
quit: make(chan struct{}), quit: make(chan struct{}, 1),
bloomFilter: MakeFullNodeBloom(), bloomFilter: MakeFullNodeBloom(),
fullNode: true, fullNode: true,
} }

2
whisper/whisperv6/whisper.go
View file

@ -106,7 +106,7 @@ func New(cfg *Config) *Whisper {
peers: make(map[*Peer]struct{}), peers: make(map[*Peer]struct{}),
messageQueue: make(chan *Envelope, messageQueueLimit), messageQueue: make(chan *Envelope, messageQueueLimit),
p2pMsgQueue: make(chan *Envelope, messageQueueLimit), p2pMsgQueue: make(chan *Envelope, messageQueueLimit),
quit: make(chan struct{}), quit: make(chan struct{}, 1),
syncAllowance: DefaultSyncAllowance, syncAllowance: DefaultSyncAllowance,
} }