Skip to content

Commit

Permalink
update transaction_outputs
Browse files Browse the repository at this point in the history
  • Loading branch information
xiaodi007 authored and stefan-mysten committed Dec 17, 2024
1 parent a1c79df commit 96c3569
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
2 changes: 1 addition & 1 deletion crates/sui-core/src/transaction_orchestrator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -632,7 +632,7 @@ impl TransactionOrchestratorMetrics {
)
.unwrap(),
wait_for_finality_finished: register_int_counter_with_registry!(
"tx_orchestrator_wait_for_finality_fnished",
"tx_orchestrator_wait_for_finality_finished",
"Total number of txns Transaction Orchestrator gets responses from Quorum Driver before timeout, either success or failure",
registry,
)
Expand Down
5 changes: 2 additions & 3 deletions crates/sui-core/src/transaction_outputs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -50,8 +50,7 @@ impl TransactionOutputs {
let modified_at: HashSet<_> = effects.modified_at_versions().into_iter().collect();
let possible_to_receive = transaction.transaction_data().receiving_objects();
let received_objects = possible_to_receive
.iter()
.cloned()
.into_iter()
.filter(|obj_ref| modified_at.contains(&(obj_ref.0, obj_ref.1)));

// We record any received or deleted objects since they could be pruned, and smear shared
Expand Down Expand Up @@ -94,7 +93,7 @@ impl TransactionOutputs {
.filter_map(|(id, ((version, digest), owner))| {
owner.is_address_owned().then_some((id, version, digest))
})
.chain(received_objects)
.chain(received_objects.into_iter())
.collect();

let new_locks_to_init: Vec<_> = written
Expand Down

0 comments on commit 96c3569

Please sign in to comment.