[Processor] Use multiple threads to speed up FA processor. (#460)

aptos-labs · Aug 21, 2024 · 66fa26c · 66fa26c
1 parent 1ae9dd5
commit 66fa26c
Show file tree

Hide file tree

Showing 5 changed files with 286 additions and 259 deletions.
diff --git a/rust/Cargo.lock b/rust/Cargo.lock
diff --git a/rust/processor/Cargo.toml b/rust/processor/Cargo.toml
@@ -46,6 +46,7 @@ num_cpus = { workspace = true }
 once_cell = { workspace = true }
 prometheus = { workspace = true }
 prost = { workspace = true }
+rayon = { workspace = true }
 regex = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }

diff --git a/rust/processor/src/db/common/models/fungible_asset_models/v2_fungible_asset_activities.rs b/rust/processor/src/db/common/models/fungible_asset_models/v2_fungible_asset_activities.rs
@@ -59,7 +59,7 @@ pub struct FungibleAssetActivity {
 }
 
 impl FungibleAssetActivity {
-    pub async fn get_v2_from_event(
+    pub fn get_v2_from_event(
         event: &Event,
         txn_version: i64,
         block_height: i64,

diff --git a/rust/processor/src/db/common/models/fungible_asset_models/v2_fungible_asset_balances.rs b/rust/processor/src/db/common/models/fungible_asset_models/v2_fungible_asset_balances.rs
@@ -148,7 +148,7 @@ impl From<&CurrentFungibleAssetBalance> for CurrentUnifiedFungibleAssetBalance {
 
 impl FungibleAssetBalance {
     /// Basically just need to index FA Store, but we'll need to look up FA metadata
-    pub async fn get_v2_from_write_resource(
+    pub fn get_v2_from_write_resource(
         write_resource: &WriteResource,
         write_set_change_index: i64,
         txn_version: i64,