discovery+server: add more trace log

This commit is contained in:
yyforyongyu 2023-03-08 21:02:53 +08:00
parent ca3debf351
commit f22b25a1bf
No known key found for this signature in database
GPG key ID: 9BCD95C4FF296868
3 changed files with 5 additions and 2 deletions

View file

@ -1293,7 +1293,8 @@ func (d *AuthenticatedGossiper) sendRemoteBatch(annBatch []msgWithSenders) {
// We'll first attempt to filter out this new message for all peers
// that have active gossip syncers active.
for _, syncer := range syncerPeers {
for pub, syncer := range syncerPeers {
log.Tracef("Sending messages batch to GossipSyncer(%x)", pub)
syncer.FilterGossipMsgs(annBatch...)
}

View file

@ -1251,6 +1251,8 @@ func (g *GossipSyncer) FilterGossipMsgs(msgs ...msgWithSenders) {
// If the peer doesn't have an update horizon set, then we won't send
// it any new update messages.
if g.remoteUpdateHorizon == nil {
log.Tracef("GossipSyncer(%x): skipped due to nil "+
"remoteUpdateHorizon", g.cfg.peerPub[:])
return
}

View file

@ -3202,7 +3202,7 @@ func (s *server) BroadcastMessage(skips map[route.Vertex]struct{},
for pubStr, sPeer := range s.peersByPub {
if skips != nil {
if _, ok := skips[sPeer.PubKey()]; ok {
srvrLog.Debugf("Skipping %x in broadcast with "+
srvrLog.Tracef("Skipping %x in broadcast with "+
"pubStr=%x", sPeer.PubKey(), pubStr)
continue
}