summaryrefslogtreecommitdiff
path: root/gr-blocks/python/blocks/msg_pair_to_var.py
diff options
context:
space:
mode:
Diffstat (limited to 'gr-blocks/python/blocks/msg_pair_to_var.py')
-rw-r--r--gr-blocks/python/blocks/msg_pair_to_var.py36
1 files changed, 36 insertions, 0 deletions
diff --git a/gr-blocks/python/blocks/msg_pair_to_var.py b/gr-blocks/python/blocks/msg_pair_to_var.py
new file mode 100644
index 0000000000..17cd7fcc38
--- /dev/null
+++ b/gr-blocks/python/blocks/msg_pair_to_var.py
@@ -0,0 +1,36 @@
+#!/usr/bin/env python
+#
+# Copyright 2020 Free Software Foundation, Inc.
+#
+# This file is part of GNU Radio
+#
+# SPDX-License-Identifier: GPL-3.0-or-later
+#
+#
+
+from gnuradio import gr
+import pmt
+
+class msg_pair_to_var(gr.sync_block):
+ """
+ This block will take an input message pair and allow you to set a gnuradio variable.
+ """
+ def __init__(self, callback):
+ gr.sync_block.__init__(self, name="msg_pair_to_var", in_sig=None, out_sig=None)
+
+ self.callback = callback
+
+ self.message_port_register_in(pmt.intern("inpair"))
+ self.set_msg_handler(pmt.intern("inpair"), self.msg_handler)
+
+ def msg_handler(self, msg):
+ try:
+ new_val = pmt.to_python(pmt.cdr(msg))
+
+ self.callback(new_val)
+
+ except Exception as e:
+ gr.log.error("Error with message conversion: %s" % str(e))
+
+ def stop(self):
+ return True