status-im/nimbus-eth2
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth2.git synced 2025-02-23 19:58:22 +00:00
Code Issues Projects Releases Wiki Activity

fix indentation

Browse Source
This commit is contained in:
Agnish Ghosh 2025-01-27 18:28:33 +05:30 committed by Agnish Ghosh
parent 1fef674040
commit 7b3304becd
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
beacon_chain/validators/message_router.nim
View File

@ -204,29 +204,29 @@ proc routeSignedBeaconBlock*(
das_workers[i] =
router[].network.broadcastDataColumnSidecar(subnet_id,
dataColumns[i])
let allres = await allFinished(das_workers)
for i in 0..<allres.len:
let res = allres[i]
doAssert res.finished()
if res.failed():
notice "Data columns not sent",
data_column = shortLog(dataColumns[i]), error = res.error[]
else:
notice "Data columns sent",
data_column = shortLog(dataColumns[i])
# Push only those columns to processor for which we custody
let
metadata = router[].network.metadata.custody_group_count.uint64
custody_columns =
router[].network.nodeId.resolve_columns_from_custody_groups(
max(SAMPLES_PER_SLOT.uint64,
metadata))
let allres = await allFinished(das_workers)
for i in 0..<allres.len:
let res = allres[i]
doAssert res.finished()
if res.failed():
notice "Data columns not sent",
data_column = shortLog(dataColumns[i]), error = res.error[]
else:
notice "Data columns sent",
data_column = shortLog(dataColumns[i])
# Push only those columns to processor for which we custody
let
metadata = router[].network.metadata.custody_group_count.uint64
custody_columns =
router[].network.nodeId.resolve_columns_from_custody_groups(
max(SAMPLES_PER_SLOT.uint64,
metadata))
var final_columns: seq[DataColumnSidecar]
for dc in dataColumns:
if dc.index in custody_columns:
final_columns.add dc
dataColumnRefs = Opt.some(final_columns.mapIt(newClone(it)))
var final_columns: seq[DataColumnSidecar]
for dc in dataColumns:
if dc.index in custody_columns:
final_columns.add dc
dataColumnRefs = Opt.some(final_columns.mapIt(newClone(it)))
elif typeof(blck).kind >= ConsensusFork.Deneb:
if blobsOpt.isSome():