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

enabled logging of subnet ids, and data column indices to prevent mismatch

This commit is contained in:
Agnish Ghosh 2024-08-26 12:55:17 +05:30
parent 0f28477295
commit 3e0992e0be
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
beacon_chain/validators/message_router.nim
View File

@ -175,19 +175,23 @@ proc routeSignedBeaconBlock*(
debug "Issue with computing data column from blob bundle"
let data_columns = dataColumnsOpt[].get()
var das_workers = newSeq[Future[SendResult]](len(dataColumnsOpt[].get()))
for dc in data_columns:
let subnet_id = compute_subnet_for_data_column_sidecar(dc.index)
for i in 0..<data_columns.len:
debugEcho "index"
debugEcho i
debugEcho "data column index"
debugEcho data_columns[i].index
let subnet_id = compute_subnet_for_data_column_sidecar(data_columns[i].index)
debugEcho "Subnet ID"
debugEcho subnet_id
das_workers[i] =
router[].network.broadcastDataColumnSidecar(subnet_id, dc)
router[].network.broadcastDataColumnSidecar(subnet_id, data_columns[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(dc), error = res.error[]
data_column = shortLog(data_columns[i]), error = res.error[]
else:
notice "Data columns sent", data_column = shortLog(dataColumnsOpt[].get()[i])
dataColumnRefs = Opt.some(dataColumnsOpt[].get().mapIt(newClone(it)))