Skip to content

Commit 1716ddb

Browse files
committed
fix
1 parent 44e5203 commit 1716ddb

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/ln/peer_handler.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -915,7 +915,7 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
915915
let encoded_update_msg = encode_msg!(update_msg, 258);
916916

917917
for (ref descriptor, ref mut peer) in peers.peers.iter_mut() {
918-
if !peer.channel_encryptor.is_ready_for_encryption() || peer.their_global_features.is_none() ||!peer.is_channel_allowed_to_forward(msg.short_channel_id) {
918+
if !peer.channel_encryptor.is_ready_for_encryption() || peer.their_global_features.is_none() ||!peer.is_channel_allowed_to_forward(msg.contents.short_channel_id) {
919919
continue
920920
}
921921
match peer.their_node_id {
@@ -938,7 +938,7 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
938938
let encoded_msg = encode_msg!(msg, 258);
939939

940940
for (ref descriptor, ref mut peer) in peers.peers.iter_mut() {
941-
if !peer.channel_encryptor.is_ready_for_encryption() || peer.their_global_features.is_none() || !peer.is_channel_allowed_to_forward(msg.short_channel_id) {
941+
if !peer.channel_encryptor.is_ready_for_encryption() || peer.their_global_features.is_none() || !peer.is_channel_allowed_to_forward(msg.contents.short_channel_id) {
942942
continue
943943
}
944944
peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encoded_msg[..]));

src/util/test_utils.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -168,10 +168,10 @@ impl msgs::RoutingMessageHandler for TestRoutingMessageHandler {
168168
Err(HandleError { err: "", action: None })
169169
}
170170
fn handle_htlc_fail_channel_update(&self, _update: &msgs::HTLCFailChannelUpdate) {}
171-
fn get_next_channel_announcements(&self, starting_point: &mut InitSyncTracker, batch_amount: u8)->(Vec<(msgs::ChannelAnnouncement, msgs::ChannelUpdate,msgs::ChannelUpdate)>){
171+
fn get_next_channel_announcements(&self, _starting_point: &mut InitSyncTracker, _batch_amount: u8)->(Vec<(msgs::ChannelAnnouncement, msgs::ChannelUpdate,msgs::ChannelUpdate)>){
172172
Vec::new()
173173
}
174-
fn get_next_node_announcements(&self, starting_point: &mut InitSyncTracker, batch_amount: u8)->(Vec<msgs::NodeAnnouncement>){
174+
fn get_next_node_announcements(&self, _starting_point: &mut InitSyncTracker, _batch_amount: u8)->(Vec<msgs::NodeAnnouncement>){
175175
Vec::new()
176176
}
177177
}

0 commit comments

Comments
 (0)