logos-storage/nim-chronos
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-chronos.git synced 2026-01-04 06:23:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

add location info to assertions to make them easier to trace

Browse Source
This commit is contained in:
gmega 2023-11-28 09:17:58 -03:00
parent 128531cd83
commit 1d5d02cfa4
No known key found for this signature in database
GPG Key ID: FFD8DAF00660270F
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
chronos/profiler/metrics.nim
View File

@ -45,8 +45,11 @@ proc pop(self: var seq[uint]): uint =
proc peek(self: var seq[uint]): Option[uint] = proc peek(self: var seq[uint]): Option[uint] =
if self.len == 0: none(uint) else: self[^1].some if self.len == 0: none(uint) else: self[^1].some
proc `$`(location: SrcLoc): string =
$location.procedure & "[" & $location.file & ":" & $location.line & "]"
proc futureCreated(self: var ProfilerMetrics, event: Event): void = proc futureCreated(self: var ProfilerMetrics, event: Event): void =
assert not self.partials.hasKey(event.futureId) assert not self.partials.hasKey(event.futureId), $event.location
self.partials[event.futureId] = RunningFuture( self.partials[event.futureId] = RunningFuture(
created: event.timestamp, created: event.timestamp,
@ -63,10 +66,11 @@ proc bindParent(self: var ProfilerMetrics, metrics: ptr RunningFuture): void =
metrics.parent = current metrics.parent = current
proc futureRunning(self: var ProfilerMetrics, event: Event): void = proc futureRunning(self: var ProfilerMetrics, event: Event): void =
assert self.partials.hasKey(event.futureId) assert self.partials.hasKey(event.futureId), $event.location
self.partials.withValue(event.futureId, metrics): self.partials.withValue(event.futureId, metrics):
assert metrics.state == Pending or metrics.state == Paused assert metrics.state == Pending or metrics.state == Paused,
$event.location
self.bindParent(metrics) self.bindParent(metrics)
self.callStack.push(event.futureId) self.callStack.push(event.futureId)
@ -75,11 +79,11 @@ proc futureRunning(self: var ProfilerMetrics, event: Event): void =
metrics.state = Running metrics.state = Running
proc futurePaused(self: var ProfilerMetrics, event: Event): void = proc futurePaused(self: var ProfilerMetrics, event: Event): void =
assert self.partials.hasKey(event.futureId) assert self.partials.hasKey(event.futureId), $event.location
assert event.futureId == self.callStack.pop() assert event.futureId == self.callStack.pop(), $event.location
self.partials.withValue(event.futureId, metrics): self.partials.withValue(event.futureId, metrics):
assert metrics.state == Running assert metrics.state == Running, $event.location
let segmentExecTime = event.timestamp - metrics.lastStarted let segmentExecTime = event.timestamp - metrics.lastStarted