@@ -211,41 +211,6 @@ func getMissingColumnsLog(
211211 raiseAssert " Unsupported fork"
212212 " [ " & res.join (" ," ) & " ]"
213213
214- func getMissingSidecarsLog (
215- overseer: SyncOverseerRef2 ,
216- blck: ref ForkedSignedBeaconBlock ,
217- fullSupernodeLog = false
218- ): string =
219- var res = " ["
220- withBlck (blck[]):
221- when consensusFork < ConsensusFork .Deneb :
222- discard
223- elif consensusFork in [ConsensusFork .Deneb , ConsensusFork .Electra ]:
224- let indices =
225- overseer.blobQuarantine[].getMissingSidecarIndices (
226- forkyBlck.root, forkyBlck)
227- if len (indices) > 0 :
228- res.add (indices.mapIt ($ uint8 (it)).join (" ," ))
229- elif consensusFork == ConsensusFork .Fulu :
230- let indices =
231- overseer.columnQuarantine[].getMissingSidecarIndices (
232- forkyBlck.root, forkyBlck)
233- if len (indices) > 0 :
234- if overseer.config.peerdasSupernode:
235- if fullSupernodeLog:
236- res.add (indices.mapIt ($ uint8 (it)).join (" ," ))
237- else :
238- let superCount = (NUMBER_OF_COLUMNS div 2 ) - 1
239- res.add ($ len (indices))
240- res.add (" of " )
241- res.add ($ superCount)
242- else :
243- res.add (indices.mapIt ($ uint8 (it)).join (" ," ))
244- else :
245- raiseAssert " Unsupported fork"
246- res.add (" ]" )
247- res
248-
249214func consensusForkAtEpoch (
250215 overseer: SyncOverseerRef2 ,
251216 epoch: Epoch
@@ -322,14 +287,6 @@ proc shouldGetColumns(overseer: SyncOverseerRef2, slot: Slot): bool =
322287 return false
323288 slot.epoch () >= overseer.getColumnsHorizon ()
324289
325- proc getPeerColumns (overseer: SyncOverseerRef2 , peer: Peer ): seq [ColumnIndex ] =
326- let
327- cfg = overseer.consensusManager.dag.cfg
328- nodeId = peer.fetchNodeIdFromPeerId ()
329- custodyGroupCount = peer.lookupCgcFromPeer ()
330- # TODO : get_custody_groups performs O(custodyGroupCount) eth2digest operations
331- cfg.get_custody_groups (nodeId, custodyGroupCount)
332-
333290proc getPeerColumnMap (
334291 overseer: SyncOverseerRef2 ,
335292 peer: Peer
@@ -1328,7 +1285,6 @@ proc doPeerUpdateRootsSidecars(
13281285 blobRoots: seq [BlobIdentifier ]
13291286 columnRoots: seq [DataColumnsByRootIdentifier ]
13301287 columnsCount = 0
1331- peerColumns: seq [ColumnIndex ]
13321288
13331289 logScope:
13341290 peer = peer
@@ -1731,7 +1687,7 @@ proc doRangeSidecarsStep(
17311687 logScope:
17321688 peer = peer
17331689 block_slot = blockSlot
1734- block_range = $ block_range
1690+ block_range = $ blockRange
17351691 head = shortLog (dag.head)
17361692 block_buffer = shortLog (overseer.sbuffer (direction))
17371693 blocks_queue = shortLog (overseer.bsqueue (direction))
@@ -2536,7 +2492,7 @@ proc blockMonitoringLoop(
25362492 let
25372493 dag = overseer.consensusManager.dag
25382494 eventKey = overseer.blocksQueueBus.register ()
2539- blockQuarantine = overseer.blockQuarantine
2495+
25402496 debug " Block monitoring established"
25412497 while true :
25422498 let
@@ -2668,11 +2624,6 @@ proc mainLoop*(
26682624
26692625 overseer.fblockBuffer =
26702626 BlocksRangeBuffer .init (SyncQueueKind .Forward , 320 )
2671- let backSlot =
2672- if dag.backfill.parent_root != dag.tail.root:
2673- dag.backfill.slot
2674- else :
2675- dag.tail.slot
26762627 overseer.bblockBuffer =
26772628 BlocksRangeBuffer .init (SyncQueueKind .Backward , 320 )
26782629
0 commit comments