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

fix debug logging

This commit is contained in:
Jacek Sieka 2023-07-11 21:46:22 +02:00
parent f13f23e21b
commit 0660ffcd3e
No known key found for this signature in database
GPG Key ID: A1B09461ABB656B8
1 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_chain/sync/request_manager.nim
View File

@ -44,7 +44,6 @@ type
RequestManager* = object RequestManager* = object
network*: Eth2Node network*: Eth2Node
inpBlockQueue*: AsyncQueue[FetchRecord]
inpBlobQueue: AsyncQueue[BlobIdentifier] inpBlobQueue: AsyncQueue[BlobIdentifier]
getBeaconTime: GetBeaconTimeFn getBeaconTime: GetBeaconTimeFn
inhibit: InhibitFn inhibit: InhibitFn
@ -267,7 +266,6 @@ proc requestManagerBlockLoop(rman: RequestManager) {.async.} =
debug "Request manager block tick", blocks = shortLog(blocks), debug "Request manager block tick", blocks = shortLog(blocks),
succeed = succeed, succeed = succeed,
failed = (len(workers) - succeed), failed = (len(workers) - succeed),
queue_size = len(rman.inpBlockQueue),
sync_speed = speed(start, finish) sync_speed = speed(start, finish)
except CancelledError as exc: except CancelledError as exc:
@ -323,14 +321,6 @@ proc stop*(rman: RequestManager) =
if not(isNil(rman.blobLoopFuture)): if not(isNil(rman.blobLoopFuture)):
rman.blobLoopFuture.cancel() rman.blobLoopFuture.cancel()
proc fetchAncestorBlocks*(rman: RequestManager, roots: seq[FetchRecord]) =
## Enqueue list missing blocks roots ``roots`` for download by
## Request Manager ``rman``.
for item in roots:
try:
rman.inpBlockQueue.addLastNoWait(item)
except AsyncQueueFullError: raiseAssert "unbounded queue"
proc fetchMissingBlobs*(rman: RequestManager, proc fetchMissingBlobs*(rman: RequestManager,
recs: seq[BlobFetchRecord]) = recs: seq[BlobFetchRecord]) =
var idList: seq[BlobIdentifier] var idList: seq[BlobIdentifier]