From 495c2a61a07d0d3a3f0afe877c0aae6b8edc4fb1 Mon Sep 17 00:00:00 2001 From: nick Date: Wed, 13 Sep 2023 12:58:24 -0500 Subject: [PATCH] Add rx_rate parameter option to prdcr_subscribe --- ldms/python/ldmsd/ldmsd_communicator.py | 4 ++-- ldms/python/ldmsd/ldmsd_controller | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ldms/python/ldmsd/ldmsd_communicator.py b/ldms/python/ldmsd/ldmsd_communicator.py index 0f25bd11b..3269d9f2c 100644 --- a/ldms/python/ldmsd/ldmsd_communicator.py +++ b/ldms/python/ldmsd/ldmsd_communicator.py @@ -2201,7 +2201,7 @@ def prdcr_stop(self, name, regex=True): self.close() return errno.ENOTCONN, str(e) - def prdcr_subscribe(self, regex, stream, rx_rate=-1): + def prdcr_subscribe(self, regex, stream, rx_rate='-1'): """ Subscribe to stream data from matching producers @@ -2219,7 +2219,7 @@ def prdcr_subscribe(self, regex, stream, rx_rate=-1): attrs = [ LDMSD_Req_Attr(attr_id=LDMSD_Req_Attr.REGEX, value=regex), LDMSD_Req_Attr(attr_id=LDMSD_Req_Attr.STREAM, value=stream), - LDMSD_Req_Attr(attr_id=LDMSD_Req_Attr.RX_RATE, value=rx_rate) + LDMSD_Req_Attr(attr_id=LDMSD_Req_Attr.RX_RATE, value=str(int(rx_rate))) ]) try: req.send(self) diff --git a/ldms/python/ldmsd/ldmsd_controller b/ldms/python/ldmsd/ldmsd_controller index 86b925335..e536ca6cf 100755 --- a/ldms/python/ldmsd/ldmsd_controller +++ b/ldms/python/ldmsd/ldmsd_controller @@ -360,7 +360,7 @@ class LdmsdCmdParser(cmd.Cmd): interval= The connection retry interval (us) (Deprecated, please use 'reconnect'.) auth= The authentication method [perm=] The permission to modify the producer in the future. - [rail=] The number of rail endpooints for the prdcr (default: 1). + [rail=] The number of rail endpoints for the prdcr (default: 1). [credits=] The send credits our ldmsd (the one we are controlling) advertises to the prdcr (default: value from ldmsd --credits option). This limits how much outstanding data our ldmsd