@@ -43,17 +43,13 @@ impl RLPxInitiator {
4343
4444 pub async fn spawn ( context : P2PContext ) {
4545 info ! ( "Starting RLPx Initiator" ) ;
46-
4746 let state = RLPxInitiator :: new ( context) ;
48-
4947 let mut server = RLPxInitiator :: start ( state. clone ( ) ) ;
50-
5148 let _ = server. cast ( InMessage :: LookForPeers ) . await ;
5249 }
5350
5451 async fn look_for_peers ( & mut self ) -> Result < ( ) , RLPxInitiatorError > {
55- info ! ( "Looking for peers" ) ;
56-
52+ debug ! ( "Looking for peers" ) ;
5753 if !self . context . table . target_peers_reached ( ) . await ? {
5854 let contacts = self
5955 . context
@@ -65,7 +61,7 @@ impl RLPxInitiator {
6561 METRICS . record_new_rlpx_conn_attempt ( ) . await ;
6662 }
6763 } else {
68- info ! ( "Target peer connections reached, no need to initiate new connections." ) ;
64+ debug ! ( "Target peer connections reached, no need to initiate new connections." ) ;
6965 }
7066 Ok ( ( ) )
7167 }
@@ -76,7 +72,7 @@ impl RLPxInitiator {
7672 if num_peers < self . target_peers {
7773 self . initial_lookup_interval
7874 } else {
79- info ! ( "Reached target number of peers. Using longer lookup interval." ) ;
75+ debug ! ( "Reached target number of peers. Using longer lookup interval." ) ;
8076 self . lookup_interval
8177 }
8278 }
@@ -106,7 +102,6 @@ impl GenServer for RLPxInitiator {
106102 match message {
107103 Self :: CastMsg :: LookForPeers => {
108104 debug ! ( received = "Look for peers" ) ;
109-
110105 let _ = self
111106 . look_for_peers ( )
112107 . await
0 commit comments