highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-08-26 21:51:27 +02:00
Code Issues Packages Projects Releases Wiki Activity

discovery: pass context to ProcessRemoteAnnouncement

Browse Source 
With this, we move a context.TODO() out of the gossiper and into the
brontide package - this will be removed in a future PR which focuses on
threading contexts through that code.
This commit is contained in:
Elle Mouton
2025-04-07 11:13:01 +02:00
committed by ziggie
parent 1a5821a873
commit 1a8e7587f9
4 changed files with 431 additions and 353 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
peer/brontide.go
View File

@@ -1989,9 +1989,13 @@ func newChanMsgStream(p *Brontide, cid lnwire.ChannelID) *msgStream {
// channel announcements.
func newDiscMsgStream(p *Brontide) *msgStream {
apply := func(msg lnwire.Message) {
// TODO(elle): thread contexts through the peer system properly
// so that a parent context can be passed in here.
ctx := context.TODO()
// TODO(yy): `ProcessRemoteAnnouncement` returns an error chan
// and we need to process it.
p.cfg.AuthGossiper.ProcessRemoteAnnouncement(msg, p)
p.cfg.AuthGossiper.ProcessRemoteAnnouncement(ctx, msg, p)
}
return newMsgStream(