adding more logging around db
This commit is contained in:
parent
5b467d060c
commit
75eda5341f
|
@ -258,6 +258,8 @@ proc storeBackfillBlock(
|
||||||
let data_columns = dataColumnsOpt.valueOr: DataColumnSidecars @[]
|
let data_columns = dataColumnsOpt.valueOr: DataColumnSidecars @[]
|
||||||
for c in data_columns:
|
for c in data_columns:
|
||||||
self.consensusManager.dag.db.putDataColumnSidecar(c[])
|
self.consensusManager.dag.db.putDataColumnSidecar(c[])
|
||||||
|
debug "Data column written to database!",
|
||||||
|
data_column = shortLog(c[])
|
||||||
|
|
||||||
res
|
res
|
||||||
|
|
||||||
|
|
|
@ -528,7 +528,6 @@ proc validateDataColumnSidecar*(
|
||||||
block_header.slot, block_header.proposer_index, data_column_sidecar.index):
|
block_header.slot, block_header.proposer_index, data_column_sidecar.index):
|
||||||
return errIgnore("DataColumnSidecar: already have valid data column from same proposer")
|
return errIgnore("DataColumnSidecar: already have valid data column from same proposer")
|
||||||
|
|
||||||
|
|
||||||
# [REJECT] The sidecar's column data is valid as
|
# [REJECT] The sidecar's column data is valid as
|
||||||
# verified by `verify_data_column_kzg_proofs(sidecar)`
|
# verified by `verify_data_column_kzg_proofs(sidecar)`
|
||||||
block:
|
block:
|
||||||
|
|
|
@ -1531,6 +1531,9 @@ proc tryReconstructingDataColumns* (self: BeaconNode,
|
||||||
data_column_sidecars.add data_column[]
|
data_column_sidecars.add data_column[]
|
||||||
storedColumns.add data_column.index
|
storedColumns.add data_column.index
|
||||||
|
|
||||||
|
debugEcho "Pre stored columns"
|
||||||
|
debugEcho storedColumns
|
||||||
|
|
||||||
# storedColumn number is less than the NUMBER_OF_COLUMNS
|
# storedColumn number is less than the NUMBER_OF_COLUMNS
|
||||||
# then reconstruction is not possible, and if all the data columns
|
# then reconstruction is not possible, and if all the data columns
|
||||||
# are already stored then we do not need to reconstruct at all
|
# are already stored then we do not need to reconstruct at all
|
||||||
|
@ -1549,6 +1552,8 @@ proc tryReconstructingDataColumns* (self: BeaconNode,
|
||||||
|
|
||||||
finalisedDataColumns.add(data_column)
|
finalisedDataColumns.add(data_column)
|
||||||
db.putDataColumnSidecar(data_column)
|
db.putDataColumnSidecar(data_column)
|
||||||
|
debug "Reconstructed data column written to database",
|
||||||
|
data_column = shortLog(data_column)
|
||||||
ok(finalisedDataColumns)
|
ok(finalisedDataColumns)
|
||||||
|
|
||||||
proc reconstructAndSendDataColumns*(node: BeaconNode) {.async.} =
|
proc reconstructAndSendDataColumns*(node: BeaconNode) {.async.} =
|
||||||
|
@ -1569,6 +1574,7 @@ proc reconstructAndSendDataColumns*(node: BeaconNode) {.async.} =
|
||||||
var
|
var
|
||||||
das_workers = newSeq[Future[SendResult]](dc.len)
|
das_workers = newSeq[Future[SendResult]](dc.len)
|
||||||
for i in 0..<dc.lenu64:
|
for i in 0..<dc.lenu64:
|
||||||
|
debugEcho "Computing subnet before broadcasting reconstructed data columns"
|
||||||
let subnet_id = compute_subnet_for_data_column_sidecar(dc[i].index)
|
let subnet_id = compute_subnet_for_data_column_sidecar(dc[i].index)
|
||||||
das_workers[i] =
|
das_workers[i] =
|
||||||
node.network.broadcastDataColumnSidecar(subnet_id, dc[i])
|
node.network.broadcastDataColumnSidecar(subnet_id, dc[i])
|
||||||
|
|
Loading…
Reference in New Issue