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/var_to_msg.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/var_to_msg.py')
| -rw-r--r-- | gr-blocks/python/blocks/var_to_msg.py | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/gr-blocks/python/blocks/var_to_msg.py b/gr-blocks/python/blocks/var_to_msg.py new file mode 100644 index 0000000000..77a947ed0c --- /dev/null +++ b/gr-blocks/python/blocks/var_to_msg.py @@ -0,0 +1,38 @@ +#!/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 var_to_msg_pair(gr.sync_block): + """ + This block will monitor a variable, and when it changes, generate a message. + """ + def __init__(self, pairname): + gr.sync_block.__init__(self, name="var_to_msg_pair", in_sig=None, out_sig=None) + + self.pairname = pairname + + self.message_port_register_out(pmt.intern("msgout")) + + def variable_changed(self, value): + if type(value) == float: + p = pmt.from_float(value) + elif type(value) == int: + p = pmt.from_long(value) + elif type(value) == bool: + p = pmt.from_bool(value) + else: + p = pmt.intern(value) + + self.message_port_pub(pmt.intern("msgout"), pmt.cons(pmt.intern(self.pairname), p)) + + def stop(self): + return True |