File tree 1 file changed +14
-0
lines changed
crates/sui-core/src/authority_active/execution_driver
1 file changed +14
-0
lines changed Original file line number Diff line number Diff line change 80
80
81
81
let sync_handle = active_authority. node_sync_handle ( ) ;
82
82
83
+ let mut futures = sync_handle
84
+ . handle_execution_request ( pending_transactions. iter ( ) . map ( |( _, digest) | * digest) ) ;
85
+
86
+ let mut executed = Vec :: new ( ) ;
87
+ let mut pending_iter = pending_transactions. iter ( ) ;
88
+ while let Some ( result) = futures. next ( ) . await {
89
+ let ( seq, _) = pending_iter. next ( ) . unwrap ( ) ;
90
+ if result. is_ok ( ) {
91
+ executed. push ( * seq) ;
92
+ }
93
+ }
94
+
95
+ /*
83
96
// Send them for execution
84
97
let executed = sync_handle
85
98
// map to extract digest
92
105
.filter_map(|(result, seq)| async move { result.ok().map(|_| seq) })
93
106
.collect()
94
107
.await;
108
+ */
95
109
96
110
// Now update the pending store.
97
111
active_authority
You can’t perform that action at this time.
0 commit comments