@@ -38,7 +38,7 @@ impl ChainHeadUpdateListener {
38
38
head_block_number : 0 ,
39
39
} ;
40
40
let ( update_sender, update_receiver) = watch:: channel ( none_update) ;
41
- Self :: listen ( logger , ingestor_metrics, & mut listener, update_sender) ;
41
+ Self :: listen ( ingestor_metrics, & mut listener, update_sender) ;
42
42
43
43
ChainHeadUpdateListener {
44
44
update_receiver,
@@ -51,13 +51,10 @@ impl ChainHeadUpdateListener {
51
51
}
52
52
53
53
fn listen (
54
- logger : Logger ,
55
54
metrics : Arc < BlockIngestorMetrics > ,
56
55
listener : & mut NotificationListener ,
57
56
update_sender : watch:: Sender < ChainHeadUpdate > ,
58
57
) {
59
- let logger = logger. clone ( ) ;
60
-
61
58
// Process chain head updates in a dedicated task
62
59
graph:: spawn (
63
60
listener
@@ -83,14 +80,6 @@ impl ChainHeadUpdateListener {
83
80
futures03:: future:: ok ( Some ( update) )
84
81
} )
85
82
. try_for_each ( move |update| {
86
- debug ! (
87
- logger. clone( ) ,
88
- "Received chain head update" ;
89
- "network" => & update. network_name,
90
- "head_block_hash" => format!( "{}" , update. head_block_hash) ,
91
- "head_block_number" => & update. head_block_number,
92
- ) ;
93
-
94
83
futures03:: future:: ready ( update_sender. broadcast ( update) . map_err ( |_| ( ) ) )
95
84
} ) ,
96
85
) ;
0 commit comments