logos-messaging/nim-sds
1
0
Fork 0
mirror of https://github.com/logos-messaging/nim-sds.git synced 2026-01-07 16:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding startPeriodicTasks request

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-16 11:47:17 +03:00
parent 11cd637004
commit e7a6435407
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
3 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
library/libsds.h
View File

@ -51,6 +51,8 @@ int MarkDependenciesMet(void* ctx,
SdsCallBack callback, SdsCallBack callback,
void* userData); void* userData);
int StartPeriodicTasks(void* ctx, SdsCallBack callback, void* userData);
#ifdef __cplusplus #ifdef __cplusplus

12
library/libsds.nim
View File

@ -301,5 +301,17 @@ proc MarkDependenciesMet(
userData, userData,
) )
proc StartPeriodicTasks(
ctx: ptr SdsContext, callback: SdsCallBack, userData: pointer
): cint {.dynlib, exportc.} =
checkLibsdsParams(ctx, callback, userData)
handleRequest(
ctx,
RequestType.LIFECYCLE,
SdsLifecycleRequest.createShared(SdsLifecycleMsgType.START_PERIODIC_TASKS),
callback,
userData,
)
### End of exported procs ### End of exported procs
################################################################################ ################################################################################

3
library/sds_thread/inter_thread_communication/requests/sds_lifecycle_request.nim
View File

@ -7,6 +7,7 @@ import ../../../../src/[reliability_utils, reliability, message]
type SdsLifecycleMsgType* = enum type SdsLifecycleMsgType* = enum
CREATE_RELIABILITY_MANAGER CREATE_RELIABILITY_MANAGER
RESET_RELIABILITY_MANAGER RESET_RELIABILITY_MANAGER
START_PERIODIC_TASKS
type SdsLifecycleRequest* = object type SdsLifecycleRequest* = object
operation: SdsLifecycleMsgType operation: SdsLifecycleMsgType
@ -62,5 +63,7 @@ proc process*(
of RESET_RELIABILITY_MANAGER: of RESET_RELIABILITY_MANAGER:
resetReliabilityManager(rm[]).isOkOr: resetReliabilityManager(rm[]).isOkOr:
return err("error processing RESET_RELIABILITY_MANAGER request: " & $error) return err("error processing RESET_RELIABILITY_MANAGER request: " & $error)
of START_PERIODIC_TASKS:
rm[].startPeriodicTasks()
return ok("") return ok("")