diff --git a/beacon_chain/gossip_processing/block_processor.nim b/beacon_chain/gossip_processing/block_processor.nim index d2c385291..11974fca7 100644 --- a/beacon_chain/gossip_processing/block_processor.nim +++ b/beacon_chain/gossip_processing/block_processor.nim @@ -893,7 +893,7 @@ proc storeBlock( # discard self.consensusManager.quarantine[].addBlobless( # dag.finalizedHead.slot, forkyBlck) - if self.dataColumnQuarantine[].hasMissingDataColumns(forkyBlck): + if self.dataColumnQuarantine[].hasEnoughDataColumns(forkyBlck): let data_columns = self.dataColumnQuarantine[].popDataColumns( forkyBlck.root, forkyBlck) self[].enqueueBlock(MsgSource.gossip, quarantined, Opt.none(BlobSidecars), Opt.some(data_columns)) diff --git a/beacon_chain/gossip_processing/eth2_processor.nim b/beacon_chain/gossip_processing/eth2_processor.nim index b1ca47367..eb1bac660 100644 --- a/beacon_chain/gossip_processing/eth2_processor.nim +++ b/beacon_chain/gossip_processing/eth2_processor.nim @@ -414,16 +414,16 @@ proc processDataColumnSidecar*( Opt.none(BlobSidecars), Opt.some(self.dataColumnQuarantine[].popDataColumns(block_root, forkyBlck))) elif self.dataColumnQuarantine[].hasEnoughDataColumns(forkyBlck): - let - columns = self.dataColumnQuarantine[].gatherDataColumns(block_root) - if columns.len >= (NUMBER_OF_COLUMNS div 2) and - self.dataColumnQuarantine[].supernode: - let - reconstructed_columns = - self.processReconstructionFromGossip(forkyBlck, columns.mapIt(it[])) - for rc in reconstructed_columns.get: - if rc notin self.dataColumnQuarantine[].gatherDataColumns(block_root).mapIt(it[]): - self.dataColumnQuarantine[].put(newClone(rc)) + # let + # columns = self.dataColumnQuarantine[].gatherDataColumns(block_root) + # if columns.len >= (NUMBER_OF_COLUMNS div 2) and + # self.dataColumnQuarantine[].supernode: + # let + # reconstructed_columns = + # self.processReconstructionFromGossip(forkyBlck, columns.mapIt(it[])) + # for rc in reconstructed_columns.get: + # if rc notin self.dataColumnQuarantine[].gatherDataColumns(block_root).mapIt(it[]): + # self.dataColumnQuarantine[].put(newClone(rc)) self.blockProcessor[].enqueueBlock( MsgSource.gossip, columnless, Opt.none(BlobSidecars),