X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fbindings%2Frmr-python%2Frmr%2Frmr.py;h=b264cd5f8dc05a77d66835e87408505c0ccca815;hb=d98d3b614654072555a3ff568ff4beae2daae827;hp=99c208819f79d59bade31e2bc8abecafa5f7c212;hpb=acb31bd5a9daecc76e228bac2df4cb3a09f55f72;p=ric-plt%2Flib%2Frmr.git diff --git a/src/bindings/rmr-python/rmr/rmr.py b/src/bindings/rmr-python/rmr/rmr.py index 99c2088..b264cd5 100644 --- a/src/bindings/rmr-python/rmr/rmr.py +++ b/src/bindings/rmr-python/rmr/rmr.py @@ -216,7 +216,7 @@ _rmr_alloc_msg.argtypes = [c_void_p, c_int] _rmr_alloc_msg.restype = POINTER(rmr_mbuf_t) -def rmr_alloc_msg(vctx, size, payload=None, gen_transaction_id=False, mtype=None, meid=None): +def rmr_alloc_msg(vctx, size, payload=None, gen_transaction_id=False, mtype=None, meid=None, sub_id=None): """ Refer to the rmr C documentation for rmr_alloc_msg extern rmr_mbuf_t* rmr_alloc_msg(void* vctx, int size) @@ -228,9 +228,11 @@ def rmr_alloc_msg(vctx, size, payload=None, gen_transaction_id=False, mtype=None """ sbuf = _rmr_alloc_msg(vctx, size) - # make sure it's good try: + # make sure the alloc worked sbuf.contents + + # set specified fields if payload: set_payload_and_length(payload, sbuf) @@ -243,6 +245,9 @@ def rmr_alloc_msg(vctx, size, payload=None, gen_transaction_id=False, mtype=None if meid: rmr_set_meid(sbuf, meid) + if sub_id: + sbuf.contents.sub_id = sub_id + return sbuf except ValueError: