discovery+server: send lazy gossip msgs
This commit is contained in:
parent
2e5bc783f7
commit
0ae06c8189
@ -358,7 +358,7 @@ func (d *AuthenticatedGossiper) SynchronizeNode(syncPeer lnpeer.Peer) error {
|
|||||||
|
|
||||||
// With all the announcement messages gathered, send them all in a
|
// With all the announcement messages gathered, send them all in a
|
||||||
// single batch to the target peer.
|
// single batch to the target peer.
|
||||||
return syncPeer.SendMessage(false, announceMessages...)
|
return syncPeer.SendMessageLazy(false, announceMessages...)
|
||||||
}
|
}
|
||||||
|
|
||||||
// PropagateChanPolicyUpdate signals the AuthenticatedGossiper to update the
|
// PropagateChanPolicyUpdate signals the AuthenticatedGossiper to update the
|
||||||
@ -1111,7 +1111,7 @@ func (d *AuthenticatedGossiper) InitSyncState(syncPeer lnpeer.Peer,
|
|||||||
encodingType: encoding,
|
encodingType: encoding,
|
||||||
chunkSize: encodingTypeToChunkSize[encoding],
|
chunkSize: encodingTypeToChunkSize[encoding],
|
||||||
sendToPeer: func(msgs ...lnwire.Message) error {
|
sendToPeer: func(msgs ...lnwire.Message) error {
|
||||||
return syncPeer.SendMessage(false, msgs...)
|
return syncPeer.SendMessageLazy(false, msgs...)
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
copy(syncer.peerPub[:], nodeID[:])
|
copy(syncer.peerPub[:], nodeID[:])
|
||||||
|
@ -2080,7 +2080,7 @@ func (s *server) sendPeerMessages(
|
|||||||
errChans = append(errChans, errChan)
|
errChans = append(errChans, errChan)
|
||||||
}
|
}
|
||||||
|
|
||||||
targetPeer.queueMsg(msg, errChan)
|
targetPeer.queueMsgLazy(msg, errChan)
|
||||||
}
|
}
|
||||||
|
|
||||||
return errChans
|
return errChans
|
||||||
|
Loading…
Reference in New Issue
Block a user