@@ -22,6 +22,7 @@ use lightning::onion_message::messenger::{Destination, MessageRouter, OnionMessa
22
22
use lightning:: routing:: gossip:: NodeId ;
23
23
use lightning:: util:: logger:: Logger ;
24
24
use lightning:: { ln:: msgs:: SocketAddress , log_warn} ;
25
+ use lightning:: { log_debug, log_error} ;
25
26
use std:: sync:: atomic:: AtomicBool ;
26
27
use std:: sync:: Arc ;
27
28
@@ -388,14 +389,14 @@ pub(crate) async fn connect_peer_if_necessary<
388
389
while retries < max_retries {
389
390
match pending_connections. try_lock ( ) {
390
391
Some ( mut pending) => {
391
- log :: debug! ( "get pending connections" ) ;
392
+ log_debug ! ( logger , "get pending connections" ) ;
392
393
let now_secs = utils:: now ( ) . as_secs ( ) as u32 ;
393
394
let pending_expire_secs = now_secs - IGNORE_CONN_SECS ;
394
395
if pending
395
396
. get ( & node_id)
396
397
. is_some_and ( |& last| pending_expire_secs < last)
397
398
{
398
- log :: debug! ( "Ignoring connection request to {node_id}" ) ;
399
+ log_debug ! ( logger , "Ignoring connection request to {node_id}" ) ;
399
400
return Ok ( ( ) ) ;
400
401
}
401
402
@@ -409,12 +410,12 @@ pub(crate) async fn connect_peer_if_necessary<
409
410
break ;
410
411
}
411
412
None if retries > max_retries => {
412
- log :: error! ( "Can't get pending connections lock" ) ;
413
+ log_error ! ( logger , "Can't get pending connections lock" ) ;
413
414
return Err ( MutinyError :: ConnectionFailed ) ;
414
415
}
415
416
None => {
416
417
retries += 1 ;
417
- log :: debug! ( "Can't get pending connections lock {retries}" ) ;
418
+ log_debug ! ( logger , "Can't get pending connections lock {retries}" ) ;
418
419
sleep ( 200 ) . await ;
419
420
continue ;
420
421
}
0 commit comments