Add new send-interface 14/514/1 v0.0.6
authorMohamed Abukar <abukar.mohamed@nokia.com>
Sun, 14 Jul 2019 05:45:30 +0000 (08:45 +0300)
committerMohamed Abukar <abukar.mohamed@nokia.com>
Sun, 14 Jul 2019 05:45:37 +0000 (08:45 +0300)
Change-Id: Ib2a8d4c1ac429b0cc4b12fbca1beaf2da147cd6f
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
pkg/xapp/rmr.go

index 0b643d5..c2ba4b1 100755 (executable)
@@ -144,11 +144,15 @@ func (m *RMRClient) Allocate() *C.rmr_mbuf_t {
 }
 
 func (m *RMRClient) Send(mtype int, sid int, payload []byte, meid *RMRMeid) bool {
+       return m.SendMsg(mtype, sid, meid, payload, len(payload))
+}
+
+func (m *RMRClient) SendMsg(mtype int, sid int, meid *RMRMeid, payload []byte, payloadLen int) bool {
        buf := m.Allocate()
 
        buf.mtype = C.int(mtype)
        buf.sub_id = C.int(sid)
-       buf.len = C.int(len(payload))
+       buf.len = C.int(payloadLen)
        datap := C.CBytes(payload)
        defer C.free(datap)