aljaz/lightning
1
0
Fork 0
mirror of https://github.com/aljazceru/lightning.git synced 2025-12-22 16:44:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

gossipd: make sure we also spam private channels with the peer involved.

Browse Source 
Probably not required, but nice to have.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
This commit is contained in:
Rusty Russell
2023-03-22 07:44:32 +10:30
committed by ShahanaFarooqui
parent 8ef4b36a1f
commit 46bb6beee7
1 changed files with 26 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
gossipd/gossipd.c
View File

@@ -129,6 +129,15 @@ void queue_peer_from_store(struct peer *peer,
queue_peer_msg(peer, take(gossip_store_get(NULL, gs, bcast->index))); queue_peer_msg(peer, take(gossip_store_get(NULL, gs, bcast->index)));
} }
static void queue_priv_update(struct peer *peer,
const struct broadcastable *bcast)
{
struct gossip_store *gs = peer->daemon->rstate->gs;
queue_peer_msg(peer,
take(gossip_store_get_private_update(NULL, gs,
bcast->index)));
}
/*~ We don't actually keep node_announcements in memory; we keep them in /*~ We don't actually keep node_announcements in memory; we keep them in
* a file called `gossip_store`. If we need some node details, we reload * a file called `gossip_store`. If we need some node details, we reload
* and reparse. It's slow, but generally rare. */ * and reparse. It's slow, but generally rare. */
@@ -422,15 +431,26 @@ static void dump_our_gossip(struct daemon *daemon, struct peer *peer)
return; return;
for (chan = first_chan(me, &i); chan; chan = next_chan(me, &i)) { for (chan = first_chan(me, &i); chan; chan = next_chan(me, &i)) {
int dir; int dir = half_chan_idx(me, chan);
if (!is_chan_public(chan)) if (!is_chan_public(chan)) {
continue; /* Don't leak private channels, unless it's with you! */
if (!node_id_eq(&chan->nodes[!dir]->id, &peer->id))
continue;
/* There's no announce for this, of course! */
/* Private channel updates are wrapped in the store. */
else {
if (!is_halfchan_defined(&chan->half[dir]))
continue;
queue_priv_update(peer, &chan->half[dir].bcast);
continue;
}
} else {
/* Send announce */
queue_peer_from_store(peer, &chan->bcast);
}
/* Send announce */
queue_peer_from_store(peer, &chan->bcast);
/* Send update if we have one */ /* Send update if we have one */
dir = half_chan_idx(me, chan);
if (is_halfchan_defined(&chan->half[dir])) if (is_halfchan_defined(&chan->half[dir]))
queue_peer_from_store(peer, &chan->half[dir].bcast); queue_peer_from_store(peer, &chan->half[dir].bcast);
} }