logos-messaging/sds-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/sds-go-bindings.git synced 2026-01-02 06:03:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding StartPeriodicTasks

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-16 11:51:28 +03:00
parent 45e4f122b2
commit 94fe0d4919
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
sds/sds.go
View File

@ -120,6 +120,10 @@ package sds
resp);
}
static void cGoStartPeriodicTasks(void* rmCtx, void* resp) {
StartPeriodicTasks(rmCtx, (SdsCallBack) GoCallback, resp);
}
*/
import "C"
import (
@ -454,3 +458,31 @@ func (rm *ReliabilityManager) MarkDependenciesMet(messageIDs []MessageID) error
return errors.New(errMsg)
}
func (rm *ReliabilityManager) StartPeriodicTasks() error {
if rm == nil {
err := errors.New("reliability manager is nil")
Error("Failed to start periodic tasks %v", err)
return err
}
Debug("Starting periodic tasks")
wg := sync.WaitGroup{}
var resp = C.allocResp(unsafe.Pointer(&wg))
defer C.freeResp(resp)
wg.Add(1)
C.cGoStartPeriodicTasks(rm.rmCtx, resp)
wg.Wait()
if C.getRet(resp) == C.RET_OK {
Debug("Successfully started periodic tasks")
return nil
}
errMsg := "error StartPeriodicTasks: " + C.GoStringN(C.getMyCharPtr(resp), C.int(C.getMyCharLen(resp)))
Error("Failed to start periodic tasks: %v", errMsg)
return errors.New(errMsg)
}