diff options
| author | ghostop14 <ghostop14@gmail.com> | 2020-02-13 09:26:07 -0500 |
|---|---|---|
| committer | Michael Dickens <michael.dickens@ettus.com> | 2020-02-15 18:50:33 -0500 |
| commit | f6a346d8b59050b2da520c80f7fab9d85018e350 (patch) | |
| tree | cd09945ad44a76838a2e1b058d4658acc94264fb /gr-blocks/python/blocks/msg_pair_to_var.py | |
| parent | d9750796171a2b98e78b8a1e9b55ff8c8a414ad0 (diff) | |
gr-blocks Add Msg to Var and Var to Msg Conversion Blocks
These 3 new blocks provide the missing glue to move between messages
and variables in the same flowgraph. There are 3 variants here:
1. Monitor a variable and produce a user-specified message (pair)
when the variable changes. Useful bridging standard GUI controls
to message-based blocks.
2. When an inbound message (pair) is received, update a specified
variable.
3. When an inbound message (dict) is received, extract a single
dictionary entry and produce a message pair (useful if you have a
multi-value dictionary but you just want to pull off a single
attribute such as frequency or gain without modifying the upstream
block. This can be paired with (2) if necessary to move from a
dictionary item to a variable.
Diffstat (limited to 'gr-blocks/python/blocks/msg_pair_to_var.py')
| -rw-r--r-- | gr-blocks/python/blocks/msg_pair_to_var.py | 36 |
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 |