status-im
/
nimbus-eth2
mirror of https://github.com/status-im/nimbus-eth2.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

added timer for parallel reconstruction

This commit is contained in:
Agnish Ghosh 2024-11-18 17:27:39 +07:00
parent 62019442f3
commit a8a9c9a728
No known key found for this signature in database
GPG Key ID: 7BDDA05D1B25E9F8
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
beacon_chain/spec/eip7594_helpers.nim
View File

@ -10,6 +10,7 @@
# Uncategorized helper functions from the spec # Uncategorized helper functions from the spec
import import
taskpools, taskpools,
chronos,
std/[algorithm, macros, tables, cpuinfo], std/[algorithm, macros, tables, cpuinfo],
stew/results, stew/results,
ssz_serialization/[ ssz_serialization/[
@ -195,6 +196,7 @@ proc recover_cells_and_proofs_parallel*(
data_columns: seq[DataColumnSidecar]): data_columns: seq[DataColumnSidecar]):
Result[seq[CellsAndProofs], cstring] = Result[seq[CellsAndProofs], cstring] =
let start = Moment.now()
# This helper recovers blobs from the data column sidecars # This helper recovers blobs from the data column sidecars
if not (data_columns.len != 0): if not (data_columns.len != 0):
return err("DataColumnSidecar: Length should not be 0") return err("DataColumnSidecar: Length should not be 0")
@ -220,6 +222,8 @@ proc recover_cells_and_proofs_parallel*(
if res.isOk: if res.isOk:
recovered_cps.add(result.get) recovered_cps.add(result.get)
let finish = Moment.now()
debug "Time taken to reconstruct in parallel", time = finish - start
ok(recovered_cps) ok(recovered_cps)
proc parallelColumnReconstruction*( proc parallelColumnReconstruction*(