Remove unnecessary clones and use multi threads in default processor.

aptos-labs · Sep 16, 2024 · 8a9c4b1 · 8a9c4b1
1 parent 35dcd59
commit 8a9c4b1
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 9 deletions.
diff --git a/rust/processor/src/db/common/models/default_models/transactions.rs b/rust/processor/src/db/common/models/default_models/transactions.rs
@@ -25,6 +25,7 @@ use aptos_protos::transaction::v1::{
 };
 use bigdecimal::BigDecimal;
 use field_count::FieldCount;
+use rayon::prelude::*;
 use serde::{Deserialize, Serialize};
 
 #[derive(Clone, Debug, Deserialize, FieldCount, Identifiable, Insertable, Serialize)]
@@ -330,9 +331,13 @@ impl Transaction {
         let mut wscs = vec![];
         let mut wsc_details = vec![];
 
-        for txn in transactions {
-            let (txn, block_metadata, mut wsc_list, mut wsc_detail_list) =
-                Self::from_transaction(txn);
+        let processed_txns: Vec<_> = transactions
+            .par_iter()
+            .map(Self::from_transaction)
+            .collect();
+
+        for processed_txn in processed_txns {
+            let (txn, block_metadata, mut wsc_list, mut wsc_detail_list) = processed_txn;
             txns.push(txn);
             if let Some(a) = block_metadata {
                 block_metadata_txns.push(a);

diff --git a/rust/processor/src/processors/default_processor.rs b/rust/processor/src/processors/default_processor.rs
@@ -403,7 +403,7 @@ fn process_transactions(
         TransactionModel::from_transactions(&transactions);
     let mut block_metadata_transactions = vec![];
     for block_metadata_txn in block_metadata_txns {
-        block_metadata_transactions.push(block_metadata_txn.clone());
+        block_metadata_transactions.push(block_metadata_txn);
     }
     let mut move_modules = vec![];
     let mut move_resources = vec![];
@@ -412,19 +412,19 @@ fn process_transactions(
     let mut table_metadata = AHashMap::new();
     for detail in wsc_details {
         match detail {
-            WriteSetChangeDetail::Module(module) => move_modules.push(module.clone()),
-            WriteSetChangeDetail::Resource(resource) => move_resources.push(resource.clone()),
+            WriteSetChangeDetail::Module(module) => move_modules.push(module),
+            WriteSetChangeDetail::Resource(resource) => move_resources.push(resource),
             WriteSetChangeDetail::Table(item, current_item, metadata) => {
-                table_items.push(item.clone());
+                table_items.push(item);
                 current_table_items.insert(
                     (
                         current_item.table_handle.clone(),
                         current_item.key_hash.clone(),
                     ),
-                    current_item.clone(),
+                    current_item,
                 );
                 if let Some(meta) = metadata {
-                    table_metadata.insert(meta.handle.clone(), meta.clone());
+                    table_metadata.insert(meta.handle.clone(), meta);
                 }
             },
         }