nit - renaming variables to concise names
This commit is contained in:
parent
6bc6384f8e
commit
e97ffb55cb
|
@ -177,14 +177,14 @@ impl QosService {
|
||||||
pub fn update_or_remove_transaction_costs<'a>(
|
pub fn update_or_remove_transaction_costs<'a>(
|
||||||
transaction_costs: impl Iterator<Item = &'a TransactionCost>,
|
transaction_costs: impl Iterator<Item = &'a TransactionCost>,
|
||||||
transaction_qos_results: impl Iterator<Item = &'a transaction::Result<()>>,
|
transaction_qos_results: impl Iterator<Item = &'a transaction::Result<()>>,
|
||||||
transaction_commited_status: Option<&Vec<bool>>,
|
transaction_committed_status: Option<&Vec<bool>>,
|
||||||
bank: &Arc<Bank>,
|
bank: &Arc<Bank>,
|
||||||
) {
|
) {
|
||||||
match transaction_commited_status {
|
match transaction_committed_status {
|
||||||
Some(transaction_commited_status) => Self::update_transaction_costs(
|
Some(transaction_committed_status) => Self::update_transaction_costs(
|
||||||
transaction_costs,
|
transaction_costs,
|
||||||
transaction_qos_results,
|
transaction_qos_results,
|
||||||
transaction_commited_status,
|
transaction_committed_status,
|
||||||
bank,
|
bank,
|
||||||
),
|
),
|
||||||
None => {
|
None => {
|
||||||
|
@ -196,18 +196,18 @@ impl QosService {
|
||||||
fn update_transaction_costs<'a>(
|
fn update_transaction_costs<'a>(
|
||||||
transaction_costs: impl Iterator<Item = &'a TransactionCost>,
|
transaction_costs: impl Iterator<Item = &'a TransactionCost>,
|
||||||
transaction_qos_results: impl Iterator<Item = &'a transaction::Result<()>>,
|
transaction_qos_results: impl Iterator<Item = &'a transaction::Result<()>>,
|
||||||
transaction_commited_status: &Vec<bool>,
|
transaction_committed_status: &Vec<bool>,
|
||||||
bank: &Arc<Bank>,
|
bank: &Arc<Bank>,
|
||||||
) {
|
) {
|
||||||
let mut cost_tracker = bank.write_cost_tracker().unwrap();
|
let mut cost_tracker = bank.write_cost_tracker().unwrap();
|
||||||
transaction_costs
|
transaction_costs
|
||||||
.zip(transaction_qos_results)
|
.zip(transaction_qos_results)
|
||||||
.zip(transaction_commited_status)
|
.zip(transaction_committed_status)
|
||||||
.for_each(|((tx_cost, qos_inclusion_result), commited_status)| {
|
.for_each(|((tx_cost, qos_inclusion_result), was_committed)| {
|
||||||
// Only transactions that the qos service included have to be
|
// Only transactions that the qos service included have to be
|
||||||
// checked for update
|
// checked for update
|
||||||
if qos_inclusion_result.is_ok() {
|
if qos_inclusion_result.is_ok() {
|
||||||
if *commited_status {
|
if *was_committed {
|
||||||
cost_tracker.update_execution_cost(tx_cost, None);
|
cost_tracker.update_execution_cost(tx_cost, None);
|
||||||
} else {
|
} else {
|
||||||
cost_tracker.remove(tx_cost);
|
cost_tracker.remove(tx_cost);
|
||||||
|
|
Loading…
Reference in New Issue