fix download blob recursive calls

lambdaclass · Jun 25, 2024 · f71bd46 · f71bd46
1 parent e289b6c
commit f71bd46
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex b/lib/lambda_ethereum_consensus/p2p/blob_downloader.ex
@@ -53,7 +53,7 @@ defmodule LambdaEthereumConsensus.P2P.BlobDownloader do
 
         if retries > 0 do
           Logger.debug("Retrying request for #{count} blobs", slot: slot)
-          request_blobs_by_range(slot, count, retries - 1)
+          request_blobs_by_range(slot, count, on_blobs, retries - 1)
         else
           on_blobs.({:error, reason})
         end
@@ -99,7 +99,7 @@ defmodule LambdaEthereumConsensus.P2P.BlobDownloader do
 
         if retries > 0 do
           Logger.debug("Retrying request for blobs.")
-          request_blobs_by_root(identifiers, retries - 1)
+          request_blobs_by_root(identifiers, on_blobs, retries - 1)
         else
           on_blobs.({:error, reason})
         end

diff --git a/lib/lambda_ethereum_consensus/p2p/block_downloader.ex b/lib/lambda_ethereum_consensus/p2p/block_downloader.ex
@@ -143,7 +143,7 @@ defmodule LambdaEthereumConsensus.P2P.BlockDownloader do
           :telemetry.execute([:network, :request], %{blocks: 0}, Map.put(tags, :result, "retry"))
           pretty_roots = Enum.map_join(roots, ", ", &Base.encode16/1)
           Logger.debug("Retrying request for blocks with roots #{pretty_roots}")
-          request_blocks_by_root(roots, retries - 1)
+          request_blocks_by_root(roots, on_blocks, retries - 1)
         else
           :telemetry.execute([:network, :request], %{blocks: 0}, Map.put(tags, :result, "error"))
           on_blocks.({:error, reason})