Procházet zdrojové kódy

src/consensus/proto: removed redundant continue

aggstam před 4 roky
rodič
revize
b64edcbe41

+ 0 - 1
src/consensus/proto/protocol_participant.rs

@@ -65,7 +65,6 @@ impl ProtocolParticipant {
                     self.p2p.broadcast_with_exclude(participant_copy, &exclude_list).await
                     self.p2p.broadcast_with_exclude(participant_copy, &exclude_list).await
                 {
                 {
                     error!("ProtocolParticipant::handle_receive_participant(): p2p broadcast failed: {}", e);
                     error!("ProtocolParticipant::handle_receive_participant(): p2p broadcast failed: {}", e);
-                    continue
                 };
                 };
             }
             }
         }
         }

+ 0 - 1
src/consensus/proto/protocol_tx.rs

@@ -98,7 +98,6 @@ impl ProtocolTx {
             if self.state.write().await.append_tx(tx_copy.clone()) {
             if self.state.write().await.append_tx(tx_copy.clone()) {
                 if let Err(e) = self.p2p.broadcast_with_exclude(tx_copy, &exclude_list).await {
                 if let Err(e) = self.p2p.broadcast_with_exclude(tx_copy, &exclude_list).await {
                     error!("handle_receive_tx(): p2p broadcast fail: {}", e);
                     error!("handle_receive_tx(): p2p broadcast fail: {}", e);
-                    continue
                 };
                 };
             }
             }
         }
         }