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

Add async method with callabck for Codex start

Browse Source
This commit is contained in:
Arnaud 2025-09-16 14:49:30 +02:00 committed by Eric
parent 12abe3c719
commit 1b40e358c8
No known key found for this signature in database
1 changed files with 29 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
examples/golang/codex.go
View File

@ -330,30 +330,44 @@ func (self *CodexNode) CodexRepo() (string, error) {
return bridge.wait()
}
// CodexStart returns the bridgeCtx to allow the caller
// to wait for the operation to complete or not.
// TODO: be consistent and do not free the bridgeCtx here
func (self *CodexNode) CodexStart() (*bridgeCtx, error) {
func (self *CodexNode) CodexStart() error {
bridge := newBridgeCtx()
defer bridge.free()
if C.cGoCodexStart(self.ctx, bridge.resp) != C.RET_OK {
return nil, bridge.CallError("cGoCodexStart")
return bridge.CallError("cGoCodexStart")
}
return bridge, nil
_, err := bridge.wait()
return err
}
// CodexStop returns the bridgeCtx to allow the caller
// to wait for the operation to complete or not.
// TODO: be consistent and do not free the bridgeCtx here
func (self *CodexNode) CodexStop() (*bridgeCtx, error) {
func (self *CodexNode) CodexStartAsync(cb func(error)) error {
bridge := newBridgeCtx()
defer bridge.free()
if C.cGoCodexStop(self.ctx, bridge.resp) != C.RET_OK {
return nil, bridge.CallError("cGoCodexStop")
if C.cGoCodexStart(self.ctx, bridge.resp) != C.RET_OK {
return bridge.CallError("cGoCodexStart")
}
return bridge, nil
go func() {
_, err := bridge.wait()
cb(err)
}()
return nil
}
func (self *CodexNode) CodexStop() error {
bridge := newBridgeCtx()
defer bridge.free()
if C.cGoCodexStop(self.ctx, bridge.resp) != C.RET_OK {
return bridge.CallError("cGoCodexStop")
}
_, err := bridge.wait()
return err
}
func (self *CodexNode) CodexDestroy() error {
@ -430,18 +444,12 @@ func main() {
log.Println("Starting Codex...")
bridge, err := node.CodexStart()
err = node.CodexStart()
if err != nil {
log.Fatal("Error happened:", err.Error())
}
defer bridge.free()
if _, err := bridge.wait(); err != nil {
log.Fatal("Error happened:", err)
}
log.Println("Codex started...")
// Wait for a SIGINT or SIGTERM signal
@ -451,20 +459,14 @@ func main() {
log.Println("Stopping the node...")
bridge, err = node.CodexStop()
err = node.CodexStop()
if err != nil {
log.Fatal("Error happened:", err.Error())
}
defer bridge.free()
log.Println("Codex stopped...")
if _, err := bridge.wait(); err != nil {
log.Fatal("Error happened:", err)
}
log.Println("Destroying the node...")
err = node.CodexDestroy()