feat(rpc): add exclusive backoff for signature fetch

metaplex-foundation · Jan 29, 2025 · 68f14ba · 68f14ba
1 parent 6217b6b
commit 68f14ba
Show file tree

Hide file tree

Showing 4 changed files with 423 additions and 80 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/backfill_rpc/Cargo.toml b/backfill_rpc/Cargo.toml
@@ -19,6 +19,11 @@ plerkle_serialization = { workspace = true }
 flatbuffers = { workspace = true }
 tracing = { workspace = true }
 usecase = { path = "../usecase" }
+tokio-retry = { workspace = true }
 
 [features]
 rpc_tests = []
+
+[dev-dependencies]
+serde_json = { workspace = true }
+warp = "0.3.7"
diff --git a/backfill_rpc/src/block_producer.rs b/backfill_rpc/src/block_producer.rs
@@ -8,7 +8,7 @@ use solana_transaction_status::{TransactionDetails, UiConfirmedBlock};
 use tracing::error;
 use usecase::bigtable::is_bubblegum_transaction_encoded;
 
-use crate::rpc::{BackfillRPC, GET_TX_RETRIES};
+use crate::rpc::{BackfillRPC, MAX_RPC_RETRIES};
 
 const SECONDS_TO_RETRY_GET_BLOCK: u64 = 5;
 
@@ -19,7 +19,7 @@ impl BlockProducer for BackfillRPC {
         slot: u64,
         _backup_provider: Option<Arc<impl BlockProducer>>,
     ) -> Result<UiConfirmedBlock, StorageError> {
-        let mut counter = GET_TX_RETRIES;
+        let mut counter = MAX_RPC_RETRIES;
 
         loop {
             let mut encoded_block = match self