From 09d0a376542b448b70f59b0faeadf7f0181036a2 Mon Sep 17 00:00:00 2001 From: Mohamed Abukar Date: Sun, 14 Jul 2019 08:45:30 +0300 Subject: [PATCH] Add new send-interface Change-Id: Ib2a8d4c1ac429b0cc4b12fbca1beaf2da147cd6f Signed-off-by: Mohamed Abukar --- pkg/xapp/rmr.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go index 0b643d5..c2ba4b1 100755 --- a/pkg/xapp/rmr.go +++ b/pkg/xapp/rmr.go @@ -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) -- 2.16.6