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

calling the GC when destrouying nodes

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-03-13 13:15:27 +02:00
parent d5f18cf455
commit 1090b6018f
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
library/libwaku.nim
View File

@ -183,6 +183,17 @@ proc waku_destroy(
initializeLibrary() initializeLibrary()
checkLibwakuParams(ctx, callback, userData) checkLibwakuParams(ctx, callback, userData)
let retCode = handleRequest(
ctx,
RequestType.LIFECYCLE,
NodeLifecycleRequest.createShared(NodeLifecycleMsgType.DESTROY_NODE, nil, nil),
callback,
userData,
)
if retCode != RET_OK:
return RET_ERR
waku_thread.destroyWakuThread(ctx).isOkOr: waku_thread.destroyWakuThread(ctx).isOkOr:
let msg = "libwaku error: " & $error let msg = "libwaku error: " & $error
callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData) callback(RET_ERR, unsafeAddr msg[0], cast[csize_t](len(msg)), userData)
@ -191,6 +202,8 @@ proc waku_destroy(
## always need to invoke the callback although we don't retrieve value to the caller ## always need to invoke the callback although we don't retrieve value to the caller
callback(RET_OK, nil, 0, userData) callback(RET_OK, nil, 0, userData)
echo "----------- calling GC_fullCollect in host thread"
GC_fullCollect()
return RET_OK return RET_OK
proc waku_version( proc waku_version(

4
library/waku_thread/inter_thread_communication/requests/node_lifecycle_request.nim
View File

@ -14,6 +14,7 @@ type NodeLifecycleMsgType* = enum
CREATE_NODE CREATE_NODE
START_NODE START_NODE
STOP_NODE STOP_NODE
DESTROY_NODE
type NodeLifecycleRequest* = object type NodeLifecycleRequest* = object
operation: NodeLifecycleMsgType operation: NodeLifecycleMsgType
@ -99,5 +100,8 @@ proc process*(
except Exception: except Exception:
error "STOP_NODE failed", error = getCurrentExceptionMsg() error "STOP_NODE failed", error = getCurrentExceptionMsg()
return err("exception stopping node: " & getCurrentExceptionMsg()) return err("exception stopping node: " & getCurrentExceptionMsg())
of DESTROY_NODE:
echo "----------- calling GC_fullCollect in waku thread"
GC_fullCollect()
return ok("") return ok("")