Compare commits
2 Commits
f072525dd4
...
25d1e40990
Author | SHA1 | Date |
---|---|---|
Emery Hemingway | 25d1e40990 | |
Emery Hemingway | 89f23f14f5 |
|
@ -10,10 +10,11 @@ proc main =
|
||||||
data = map(commandLineParams(), parsePreserves)
|
data = map(commandLineParams(), parsePreserves)
|
||||||
|
|
||||||
discard bootDataspace("msg") do (turn: var Turn; root: Cap):
|
discard bootDataspace("msg") do (turn: var Turn; root: Cap):
|
||||||
|
spawnRelays(turn, root)
|
||||||
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
||||||
for e in data:
|
for e in data:
|
||||||
message(turn, ds, e)
|
message(turn, ds, e)
|
||||||
|
|
||||||
for _ in 1..4: poll()
|
for _ in 1..2: poll()
|
||||||
|
|
||||||
main()
|
main()
|
||||||
|
|
|
@ -49,7 +49,7 @@ type
|
||||||
|
|
||||||
CacheArgumentsField0* {.preservesDictionary.} = object
|
CacheArgumentsField0* {.preservesDictionary.} = object
|
||||||
`dataspace`* {.preservesEmbedded.}: EmbeddedRef
|
`dataspace`* {.preservesEmbedded.}: EmbeddedRef
|
||||||
`lifetime`*: float32
|
`lifetime`*: BiggestFloat
|
||||||
|
|
||||||
CacheArguments* {.preservesRecord: "cache".} = object
|
CacheArguments* {.preservesRecord: "cache".} = object
|
||||||
`field0`*: CacheArgumentsField0
|
`field0`*: CacheArgumentsField0
|
||||||
|
|
|
@ -5,9 +5,9 @@ import
|
||||||
type
|
type
|
||||||
RoundTripTime* {.preservesRecord: "rtt".} = object
|
RoundTripTime* {.preservesRecord: "rtt".} = object
|
||||||
`address`*: string
|
`address`*: string
|
||||||
`minimum`*: float32
|
`minimum`*: BiggestFloat
|
||||||
`average`*: float32
|
`average`*: BiggestFloat
|
||||||
`maximum`*: float32
|
`maximum`*: BiggestFloat
|
||||||
|
|
||||||
proc `$`*(x: RoundTripTime): string =
|
proc `$`*(x: RoundTripTime): string =
|
||||||
`$`(toPreserves(x))
|
`$`(toPreserves(x))
|
||||||
|
|
|
@ -81,6 +81,7 @@ proc extractTuple(stmt: Stmt; arity: cint): Value =
|
||||||
proc spawnSqliteActor*(turn: var Turn; root: Cap): Actor {.discardable.} =
|
proc spawnSqliteActor*(turn: var Turn; root: Cap): Actor {.discardable.} =
|
||||||
spawn("sqlite-actor", turn) do (turn: var Turn):
|
spawn("sqlite-actor", turn) do (turn: var Turn):
|
||||||
during(turn, root, ?:SqliteArguments) do (path: string, ds: Cap):
|
during(turn, root, ?:SqliteArguments) do (path: string, ds: Cap):
|
||||||
|
stderr.writeLine("opening SQLite database ", path)
|
||||||
var db: Sqlite3
|
var db: Sqlite3
|
||||||
if open_v2(path, addr db, SQLITE_OPEN_READONLY, nil) != SQLITE_OK:
|
if open_v2(path, addr db, SQLITE_OPEN_READONLY, nil) != SQLITE_OK:
|
||||||
logError(db, path)
|
logError(db, path)
|
||||||
|
@ -104,6 +105,7 @@ proc spawnSqliteActor*(turn: var Turn; root: Cap): Actor {.discardable.} =
|
||||||
if finalize(stmt) != SQLITE_OK: logError(db, statement)
|
if finalize(stmt) != SQLITE_OK: logError(db, statement)
|
||||||
do:
|
do:
|
||||||
close(db)
|
close(db)
|
||||||
|
stderr.writeLine("closed SQLite database ", path)
|
||||||
|
|
||||||
when isMainModule:
|
when isMainModule:
|
||||||
runActor("main") do (turn: var Turn; root: Cap):
|
runActor("main") do (turn: var Turn; root: Cap):
|
||||||
|
|
|
@ -126,6 +126,7 @@ proc main =
|
||||||
else:
|
else:
|
||||||
let entity = DumpEntity()
|
let entity = DumpEntity()
|
||||||
runActor("syndex_card") do (root: Cap; turn: var Turn):
|
runActor("syndex_card") do (root: Cap; turn: var Turn):
|
||||||
|
spawnRelays(turn, root)
|
||||||
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
||||||
discard observe(turn, ds, pat, entity)
|
discard observe(turn, ds, pat, entity)
|
||||||
|
|
||||||
|
|
|
@ -64,6 +64,7 @@ proc main =
|
||||||
runActor("syndex_card") do (root: Cap; turn: var Turn):
|
runActor("syndex_card") do (root: Cap; turn: var Turn):
|
||||||
for pat in patterns:
|
for pat in patterns:
|
||||||
discard observe(turn, root, pat, entity)
|
discard observe(turn, root, pat, entity)
|
||||||
|
spawnRelays(turn, root)
|
||||||
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
resolve(turn, root, route) do (turn: var Turn; ds: Cap):
|
||||||
for pat in patterns:
|
for pat in patterns:
|
||||||
discard observe(turn, ds, pat, entity)
|
discard observe(turn, ds, pat, entity)
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
# Package
|
# Package
|
||||||
|
|
||||||
version = "20240120"
|
version = "20240205"
|
||||||
author = "Emery Hemingway"
|
author = "Emery Hemingway"
|
||||||
description = "Utilites for Syndicated Actors and Synit"
|
description = "Utilites for Syndicated Actors and Synit"
|
||||||
license = "unlicense"
|
license = "unlicense"
|
||||||
|
|
Loading…
Reference in New Issue