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

Merge branch 'dev/etan/df-safeiter' into feat/splitview

This commit is contained in:
Etan Kissling 2024-04-03 12:39:29 +02:00
parent 4034ad43a0 0363f23527
commit 2a15ec0432
No known key found for this signature in database
GPG Key ID: B21DA824C5A3D03D
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
beacon_chain/sync/request_manager.nim
View File

@ -302,7 +302,7 @@ proc getMissingBlobs(rman: RequestManager): seq[BlobIdentifier] =
var var
fetches: seq[BlobIdentifier] fetches: seq[BlobIdentifier]
ready: seq[Eth2Digest] ready: seq[Eth2Digest]
for root, blobless in rman.quarantine[].peekBlobless(): for blobless in rman.quarantine[].peekBlobless():
# give blobs a chance to arrive over gossip # give blobs a chance to arrive over gossip
if blobless.message.slot == wallSlot and delay < waitDur: if blobless.message.slot == wallSlot and delay < waitDur:
debug "Not handling missing blobs early in slot" debug "Not handling missing blobs early in slot"
@ -323,7 +323,7 @@ proc getMissingBlobs(rman: RequestManager): seq[BlobIdentifier] =
warn "missing blob handler found blobless block with all blobs", warn "missing blob handler found blobless block with all blobs",
blk=blobless.root, blk=blobless.root,
commitments=len(blobless.message.body.blob_kzg_commitments) commitments=len(blobless.message.body.blob_kzg_commitments)
ready.add(root) ready.add(blobless.root)
for root in ready: for root in ready:
let blobless = rman.quarantine[].popBlobless(root).valueOr: let blobless = rman.quarantine[].popBlobless(root).valueOr:
continue continue