status-im/nimbus-eth2
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth2.git synced 2025-02-07 20:28:03 +00:00
Code Issues Projects Releases Wiki Activity

fix reconstruction from gossip logic

Browse Source
This commit is contained in:
Agnish Ghosh 2024-10-12 01:48:18 +05:30
parent 826a4f60f8
commit 6ae1418e91
No known key found for this signature in database
GPG Key ID: 7BDDA05D1B25E9F8
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
beacon_chain/consensus_object_pools/data_column_quarantine.nim
View File

@ -129,9 +129,9 @@ func hasMissingDataColumns*(quarantine: DataColumnQuarantine,
get_custody_columns(quarantine.nodeid, get_custody_columns(quarantine.nodeid,
max(SAMPLES_PER_SLOT.uint64, max(SAMPLES_PER_SLOT.uint64,
localSubnetCount)) localSubnetCount))
for i in localCustodyColumns: for i in localCustodyColumns:
if (blck.root, ColumnIndex i) notin quarantine.data_columns: if (blck.root, ColumnIndex i) notin quarantine.data_columns and
len(blck.message.body.blob_kzg_commitments) != 0:
return false return false
true true

17
beacon_chain/gossip_processing/eth2_processor.nim
View File

@ -398,15 +398,16 @@ proc processDataColumnSidecar*(
let columnless = o.unsafeGet() let columnless = o.unsafeGet()
withBlck(columnless): withBlck(columnless):
when consensusFork >= ConsensusFork.Deneb: when consensusFork >= ConsensusFork.Deneb:
let
columns = self.dataColumnQuarantine[].gatherDataColumns(forkyBlck)
if columns.len >= (NUMBER_OF_COLUMNS div 2):
let
reconstructed_columns =
self.processReconstructionFromGossip(forkyBlck, columns)
for rc in reconstructed_columns.get:
self.dataColumnQuarantine[].put(newClone(rc))
if self.dataColumnQuarantine[].hasEnoughDataColumns(forkyBlck): if self.dataColumnQuarantine[].hasEnoughDataColumns(forkyBlck):
let
columns = self.dataColumnQuarantine[].gatherDataColumns(forkyBlck)
if columns.len >= (NUMBER_OF_COLUMNS div 2) or
self.dataColumnQuarantine[].supernode:
let
reconstructed_columns =
self.processReconstructionFromGossip(forkyBlck, columns)
for rc in reconstructed_columns.get:
self.dataColumnQuarantine[].put(newClone(rc))
self.blockProcessor[].enqueueBlock( self.blockProcessor[].enqueueBlock(
MsgSource.gossip, columnless, MsgSource.gossip, columnless,
Opt.none(BlobSidecars), Opt.none(BlobSidecars),