drivers/timers: cleanup
This commit is contained in:
parent
a4c816ef66
commit
42b7c9544a
|
@ -7,7 +7,7 @@
|
|||
"bom-ref": "pkg:nim/syndicate",
|
||||
"name": "syndicate",
|
||||
"description": "Syndicated actors for conversational concurrency",
|
||||
"version": "20240614",
|
||||
"version": "20240621",
|
||||
"authors": [
|
||||
{
|
||||
"name": "Emery Hemingway"
|
||||
|
|
|
@ -4,7 +4,7 @@
|
|||
import
|
||||
std/[tables, times],
|
||||
pkg/preserves,
|
||||
../../syndicate, ../protocols/[timer, dataspace]
|
||||
../../syndicate, ../protocols/timer
|
||||
|
||||
when defined(solo5):
|
||||
import solo5_dispatcher
|
||||
|
@ -87,13 +87,6 @@ else:
|
|||
discard close(fd)
|
||||
driver
|
||||
|
||||
proc earliestFloat(driver: TimerDriver): float =
|
||||
assert driver.deadlines.len > 0
|
||||
result = high float
|
||||
for deadline in driver.deadlines.keys:
|
||||
if deadline < result:
|
||||
result = deadline
|
||||
|
||||
proc await(driver: TimerDriver; deadline: float) {.asyncio.} =
|
||||
## Run timer driver concurrently with actor.
|
||||
let fd = timerfd_create(CLOCK_REALTIME, TFD_NONBLOCK or TFD_CLOEXEC)
|
||||
|
|
Loading…
Reference in New Issue