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 event callback

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-10 12:45:33 +03:00
parent 355de25fec
commit e4d22bd6cf
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
sds/sds.go
View File

@ -61,6 +61,22 @@ package sds
void* ret = NewReliabilityManager(channelId, (SdsCallBack) GoCallback, resp);
return ret;
}
static void cGoSetEventCallback(void* rmCtx) {
// The 'globalEventCallback' Go function is shared amongst all possible Reliability Manager instances.
// Given that the 'globalEventCallback' is shared, we pass again the
// rmCtx instance but in this case is needed to pick up the correct method
// that will handle the event.
// In other words, for every call libsds makes to globalEventCallback,
// the 'userData' parameter will bring the context of the rm that registered
// that globalEventCallback.
// This technique is needed because cgo only allows to export Go functions and not methods.
SetEventCallback(rmCtx, (SdsCallBack) globalEventCallback, rmCtx);
}
*/
import "C"
import (
@ -118,7 +134,7 @@ func NewReliabilityManager(channelId string, rmName string) (*ReliabilityManager
rm.rmCtx = C.cGoNewReliabilityManager(cChannelId, resp)
wg.Wait()
// C.cGoWakuSetEventCallback(n.wakuCtx) TODO
C.cGoSetEventCallback(rm.rmCtx)
registerReliabilityManager(rm)
Debug("Successfully created WakuNode: %s", rmName)