Log failures of storing incoming blocks

input-output-hk · Feb 14, 2019 · e8cd77d · e8cd77d
1 parent e56b275
commit e8cd77d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/src/blockchain/process.rs b/src/blockchain/process.rs
@@ -17,20 +17,24 @@ pub fn process<Chain>(
     <Chain::Settings as property::Settings>::Update: Clone,
     <Chain::Leader as property::LeaderSelection>::Update: Clone,
 {
-    match bquery {
+    let res = match bquery {
         BlockMsg::NetworkBlock(block) => {
             debug!("received block from the network: {:#?}", block);
-            blockchain.write().unwrap().handle_incoming_block(block);
+            blockchain.write().unwrap().handle_incoming_block(block)
         }
         BlockMsg::LeadershipBlock(block) => {
             debug!("received block from the leadership: {:#?}", block);
-            blockchain
+            let res = blockchain
                 .write()
                 .unwrap()
                 .handle_incoming_block(block.clone());
             network_broadcast
                 .unbounded_send(NetworkBroadcastMsg::Block(block))
                 .unwrap();
+            res
         }
+    };
+    if let Err(e) = res {
+        error!("error processing an incoming block: {:?}", e);
     }
 }
diff --git a/src/network/grpc/bootstrap.rs b/src/network/grpc/bootstrap.rs
@@ -59,7 +59,10 @@ where
     stream
         .fold(blockchain, |blockchain, block| {
             // debug!("received block from the bootstrap node: {:#?}", &block);
-            blockchain.write().unwrap().handle_incoming_block(block);
+            let res = blockchain.write().unwrap().handle_incoming_block(block);
+            if let Err(e) = res {
+                error!("error processing a bootstrap block: {:?}", e);
+            }
             future::ok(blockchain)
         })
         .map(|_| ())