File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -575,7 +575,7 @@ pub trait ChannelMessageHandler : events::MessageSendEventsProvider + Send + Syn
575
575
/// Handle an incoming error message from the given peer.
576
576
fn handle_error ( & self , their_node_id : & PublicKey , msg : & ErrorMessage ) ;
577
577
}
578
-
578
+ # [ derive ( PartialEq ) ]
579
579
///Enum used to keep track of syncing information/state of peer and if a sync is required
580
580
pub enum InitSyncTracker {
581
581
///This indicates if a sync is required or not, false is no sync required, true is sync required but not started
Original file line number Diff line number Diff line change @@ -927,7 +927,7 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
927
927
let encoded_msg = encode_msg ! ( msg, 258 ) ;
928
928
929
929
for ( ref descriptor, ref mut peer) in peers. peers . iter_mut ( ) {
930
- if !peer. channel_encryptor . is_ready_for_encryption ( ) || peer. their_global_features . is_none ( ) {
930
+ if !peer. channel_encryptor . is_ready_for_encryption ( ) || peer. their_global_features . is_none ( ) || peer . sync_status != msgs :: InitSyncTracker :: Sync ( false ) {
931
931
continue
932
932
}
933
933
peer. pending_outbound_buffer . push_back ( peer. channel_encryptor . encrypt_message ( & encoded_msg[ ..] ) ) ;
You can’t perform that action at this time.
0 commit comments