Code Review
/
ric-plt
/
lib
/
rmr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add new func, update rts
[ric-plt/lib/rmr.git]
/
src
/
bindings
/
rmr-python
/
rmr
/
rmr.py
diff --git
a/src/bindings/rmr-python/rmr/rmr.py
b/src/bindings/rmr-python/rmr/rmr.py
index
b264cd5
..
45515c8
100644
(file)
--- a/
src/bindings/rmr-python/rmr/rmr.py
+++ b/
src/bindings/rmr-python/rmr/rmr.py
@@
-343,11
+343,22
@@
_rmr_rts_msg.argtypes = [c_void_p, POINTER(rmr_mbuf_t)]
_rmr_rts_msg.restype = POINTER(rmr_mbuf_t)
_rmr_rts_msg.restype = POINTER(rmr_mbuf_t)
-def rmr_rts_msg(vctx, ptr_mbuf):
+def rmr_rts_msg(vctx, ptr_mbuf
, payload=None, mtype=None
):
"""
Refer to the rmr C documentation for rmr_rts_msg
extern rmr_mbuf_t* rmr_rts_msg(void* vctx, rmr_mbuf_t* msg)
"""
Refer to the rmr C documentation for rmr_rts_msg
extern rmr_mbuf_t* rmr_rts_msg(void* vctx, rmr_mbuf_t* msg)
+
+ additional features beyond c-rmr:
+ if payload is not None, attempts to set the payload
+ if mtype is not None, sets the sbuf's message type
"""
"""
+
+ if payload:
+ set_payload_and_length(payload, ptr_mbuf)
+
+ if mtype:
+ ptr_mbuf.contents.mtype = mtype
+
return _rmr_rts_msg(vctx, ptr_mbuf)
return _rmr_rts_msg(vctx, ptr_mbuf)