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 debug to subnet ids

This commit is contained in:
Agnish Ghosh 2024-08-26 12:19:13 +05:30
parent 7d5139c44c
commit 0f28477295
No known key found for this signature in database
GPG Key ID: 7BDDA05D1B25E9F8
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_chain/validators/message_router.nim
View File

@ -175,17 +175,19 @@ proc routeSignedBeaconBlock*(
debug "Issue with computing data column from blob bundle" debug "Issue with computing data column from blob bundle"
let data_columns = dataColumnsOpt[].get() let data_columns = dataColumnsOpt[].get()
var das_workers = newSeq[Future[SendResult]](len(dataColumnsOpt[].get())) var das_workers = newSeq[Future[SendResult]](len(dataColumnsOpt[].get()))
for i in 0..<data_columns.len: for dc in data_columns:
let subnet_id = compute_subnet_for_data_column_sidecar(uint64(i)) let subnet_id = compute_subnet_for_data_column_sidecar(dc.index)
debugEcho "Subnet ID"
debugEcho subnet_id
das_workers[i] = das_workers[i] =
router[].network.broadcastDataColumnSidecar(subnet_id, dataColumnsOpt[].get()[int(i)]) router[].network.broadcastDataColumnSidecar(subnet_id, dc)
let allres = await allFinished(das_workers) let allres = await allFinished(das_workers)
for i in 0..<allres.len: for i in 0..<allres.len:
let res = allres[i] let res = allres[i]
doAssert res.finished() doAssert res.finished()
if res.failed(): if res.failed():
notice "Data Columns not sent", notice "Data Columns not sent",
data_column = shortLog(dataColumnsOpt[].get()[i]), error = res.error[] data_column = shortLog(dc), error = res.error[]
else: else:
notice "Data columns sent", data_column = shortLog(dataColumnsOpt[].get()[i]) notice "Data columns sent", data_column = shortLog(dataColumnsOpt[].get()[i])
dataColumnRefs = Opt.some(dataColumnsOpt[].get().mapIt(newClone(it))) dataColumnRefs = Opt.some(dataColumnsOpt[].get().mapIt(newClone(it)))