codex-storage
/
nim-codex
mirror of https://github.com/codex-storage/nim-codex.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix counter update bug

This commit is contained in:
gmega 2023-11-09 12:40:59 -03:00
parent b795d8a3f5
commit e70c40cb45
No known key found for this signature in database
GPG Key ID: FFD8DAF00660270F
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
codex/utils/asyncprofiler/asyncprofiler.nim
View File

@ -51,14 +51,10 @@ proc addRun(self: var OverallMetrics, run: FutureMetrics) =
## Adds metrics for a single run of a given async proc to its OverallMetrics. ## Adds metrics for a single run of a given async proc to its OverallMetrics.
self.totalExecTime += run.duration self.totalExecTime += run.duration
self.totalWallTime += Moment.now() - run.created self.totalWallTime += Moment.now() - run.created
self.totalRunTime += self.totalExecTime + run.durationChildren self.totalRunTime += run.duration + run.durationChildren
self.count.inc self.count.inc
self.minSingleTime = min(self.minSingleTime, run.duration) self.minSingleTime = min(self.minSingleTime, run.duration)
self.maxSingleTime = max(self.maxSingleTime, run.duration) self.maxSingleTime = max(self.maxSingleTime, run.duration)
# handle overflow
if self.count == self.count.typeof.high:
self.totalExecTime = ZeroDuration
self.count = 0
if not isNil(onChange): if not isNil(onChange):
onChange() onChange()
@ -69,7 +65,6 @@ proc setFutureCreate(fut: FutureBase) {.raises: [].} =
perFutureMetrics[fut.id] = FutureMetrics() perFutureMetrics[fut.id] = FutureMetrics()
perFutureMetrics.withValue(fut.id, metric): perFutureMetrics.withValue(fut.id, metric):
metric.created = Moment.now() metric.created = Moment.now()
# echo loc, "; future create "
proc setFutureStart(fut: FutureBase) {.raises: [].} = proc setFutureStart(fut: FutureBase) {.raises: [].} =
## used for setting the duration ## used for setting the duration
@ -79,7 +74,6 @@ proc setFutureStart(fut: FutureBase) {.raises: [].} =
let ts = Moment.now() let ts = Moment.now()
metric.start = some ts metric.start = some ts
metric.blocks.inc() metric.blocks.inc()
# echo loc, "; future start: ", metric.initDuration
proc setFuturePause(fut, child: FutureBase) {.raises: [].} = proc setFuturePause(fut, child: FutureBase) {.raises: [].} =
{.cast(gcsafe).}: {.cast(gcsafe).}: