File tree Expand file tree Collapse file tree 1 file changed +9
-5
lines changed
jormungandr/src/blockchain Expand file tree Collapse file tree 1 file changed +9
-5
lines changed Original file line number Diff line number Diff line change @@ -230,14 +230,18 @@ pub fn run_handle_input(
230
230
}
231
231
BlockMsg :: ChainHeaders ( handle) => {
232
232
let ( stream, reply) = handle. into_stream_and_reply ( ) ;
233
- let future = candidate_forest . advance_branch ( stream ) ;
233
+ let logger = info . logger ( ) . clone ( ) ;
234
234
235
- let future = future. then ( |resp| match resp {
235
+ let future = candidate_forest. advance_branch ( stream) ;
236
+ let future = future. then ( move |resp| match resp {
236
237
Err ( e) => {
238
+ info ! (
239
+ logger,
240
+ "error processing an incoming header stream" ;
241
+ "reason" => %e,
242
+ ) ;
237
243
reply. reply_error ( chain_header_error_into_reply ( e) ) ;
238
- Either :: A ( future:: err :: < ( ) , Error > (
239
- format ! ( "Error processing ChainHeader handling" ) . into ( ) ,
240
- ) )
244
+ Either :: A ( future:: ok ( ( ) ) )
241
245
}
242
246
Ok ( ( hashes, maybe_remainder) ) => {
243
247
if hashes. is_empty ( ) {
You can’t perform that action at this time.
0 commit comments