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

adding reset function

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-10 14:25:53 +03:00
parent 6235fb1876
commit 7609aa36b0
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
3 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
library/libsds.h
View File

@ -30,6 +30,8 @@ void SetEventCallback(void* ctx, SdsCallBack callback, void* userData);
int CleanupReliabilityManager(void* ctx, SdsCallBack callback, void* userData); int CleanupReliabilityManager(void* ctx, SdsCallBack callback, void* userData);
int ResetReliabilityManager(void* ctx, SdsCallBack callback, void* userData);
#ifdef __cplusplus #ifdef __cplusplus
} }

12
library/libsds.nim
View File

@ -163,5 +163,17 @@ proc CleanupReliabilityManager(
return RET_OK return RET_OK
proc ResetReliabilityManager(
ctx: ptr SdsContext, callback: SdsCallBack, userData: pointer
): cint {.dynlib, exportc.} =
checkLibsdsParams(ctx, callback, userData)
handleRequest(
ctx,
RequestType.LIFECYCLE,
SdsLifecycleRequest.createShared(SdsLifecycleMsgType.RESET_RELIABILITY_MANAGER),
callback,
userData,
)
### End of exported procs ### End of exported procs
################################################################################ ################################################################################

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

@ -6,6 +6,7 @@ import ../../../../src/[reliability_utils, reliability, message]
type SdsLifecycleMsgType* = enum type SdsLifecycleMsgType* = enum
CREATE_RELIABILITY_MANAGER CREATE_RELIABILITY_MANAGER
RESET_RELIABILITY_MANAGER
type SdsLifecycleRequest* = object type SdsLifecycleRequest* = object
operation: SdsLifecycleMsgType operation: SdsLifecycleMsgType
@ -58,5 +59,8 @@ proc process*(
rm[] = (await createReliabilityManager(self.channelId)).valueOr: rm[] = (await createReliabilityManager(self.channelId)).valueOr:
error "CREATE_RELIABILITY_MANAGER failed", error = error error "CREATE_RELIABILITY_MANAGER failed", error = error
return err("error processing CREATE_RELIABILITY_MANAGER request: " & $error) return err("error processing CREATE_RELIABILITY_MANAGER request: " & $error)
of RESET_RELIABILITY_MANAGER:
resetReliabilityManager(rm[]).isOkOr:
return err("error processing RESET_RELIABILITY_MANAGER request: " & $error)
return ok("") return ok("")