File tree 1 file changed +4
-8
lines changed
1 file changed +4
-8
lines changed Original file line number Diff line number Diff line change @@ -68,16 +68,12 @@ impl crate::chain::vm::Vm for ChainVm {
68
68
let mut vm = self . inner . write ( ) . await ;
69
69
70
70
log:: debug!( "vm::submit store called" ) ;
71
- storage:: submit ( & vm. state . clone ( ) , & mut txs)
72
- . await
73
- . map_err ( |e| Error :: new ( ErrorKind :: Other , e. to_string ( ) ) ) ?;
71
+ storage:: submit ( & vm. state . clone ( ) , & mut txs) . await ?;
74
72
75
73
let mempool = & mut vm. mempool ;
76
74
log:: debug!( "vm::submit add to mempool" ) ;
77
75
for tx in txs. iter_mut ( ) {
78
- let _ = mempool
79
- . add ( tx)
80
- . map_err ( |e| Error :: new ( ErrorKind :: Other , e. to_string ( ) ) ) ?;
76
+ let _ = mempool. add ( tx) ?;
81
77
}
82
78
log:: debug!( "vm::submit complete" ) ;
83
79
@@ -92,10 +88,10 @@ impl crate::chain::vm::Vm for ChainVm {
92
88
let vm = self . inner . read ( ) . await ;
93
89
94
90
if let Some ( engine) = & vm. to_engine {
95
- let _ = engine
91
+ engine
96
92
. send ( subnet:: rpc:: common:: message:: Message :: PendingTxs )
97
93
. await
98
- . map_err ( |e| log:: warn!( "dropping message to consensus engine: {}" , e. to_string ( ) ) ) ;
94
+ . unwrap_or_else ( |e| log:: warn!( "dropping message to consensus engine: {}" , e) ) ;
99
95
} else {
100
96
log:: error!( "consensus engine channel failed to initialized" ) ;
101
97
}
You can’t perform that action at this time.
0 commit comments