File tree 2 files changed +6
-7
lines changed
2 files changed +6
-7
lines changed Original file line number Diff line number Diff line change 9
9
use secp256k1:: key:: { SecretKey , PublicKey } ;
10
10
11
11
use ln:: msgs;
12
- use ln:: msgs:: NetworkAPI ;
13
12
use util:: ser:: { Writeable , Writer , Readable } ;
14
13
use ln:: peer_channel_encryptor:: { PeerChannelEncryptor , NextNoiseStep } ;
15
14
use util:: byte_utils;
@@ -516,8 +515,8 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
516
515
if self . initial_syncs_sent . load ( Ordering :: Acquire ) < INITIAL_SYNCS_TO_SEND {
517
516
self . initial_syncs_sent . fetch_add ( 1 , Ordering :: AcqRel ) ;
518
517
local_features. set_initial_routing_sync ( ) ;
519
- let channel_messages = self . message_handler . route_handler . get_all_channel_announcements ( ) ;
520
- let node_messages = self . message_handler . route_handler . get_all_node_announcements ( ) ;
518
+ let channel_messages = self . message_handler . route_handler . get_all_channel_announcements ( ) . unwrap ( ) ;
519
+ let node_messages = self . message_handler . route_handler . get_all_node_announcements ( ) . unwrap ( ) ;
521
520
for message in channel_messages. iter ( ) {
522
521
encode_and_send_msg ! ( message, 256 ) ;
523
522
}
Original file line number Diff line number Diff line change @@ -440,10 +440,10 @@ impl RoutingMessageHandler for Router {
440
440
441
441
impl NetworkTopology for Router {
442
442
fn get_all_channel_announcements ( & self ) -> Result < Vec < msgs:: ChannelAnnouncement > , std:: fmt:: Error > {
443
- let result = Vec :: new ( ) ;
443
+ let mut result = Vec :: new ( ) ;
444
444
let network = self . network_map . read ( ) . unwrap ( ) ;
445
445
for ( key, value) in network. channels . iter ( ) {
446
- if let Some ( i) = value. announcement_message {
446
+ if let Some ( ref i) = value. announcement_message {
447
447
result. push ( i. clone ( ) ) ;
448
448
}
449
449
}
@@ -475,10 +475,10 @@ impl NetworkTopology for Router {
475
475
}
476
476
///This function generates a vec of all node_annoucment messages for all nodes it known of
477
477
fn get_all_node_announcements ( & self ) -> Result < Vec < msgs:: NodeAnnouncement > , std:: fmt:: Error > {
478
- let result = Vec :: new ( ) ;
478
+ let mut result = Vec :: new ( ) ;
479
479
let network = self . network_map . read ( ) . unwrap ( ) ;
480
480
for ( key, value) in network. nodes . iter ( ) {
481
- if let Some ( i) = value. announcement_message {
481
+ if let Some ( ref i) = value. announcement_message {
482
482
result. push ( i. clone ( ) ) ;
483
483
}
484
484
/*let msg_contents = msgs::UnsignedNodeAnnouncement{
You can’t perform that action at this time.
0 commit comments