diff options
| author | Tom Rondeau <tom@trondeau.com> | 2014-05-16 15:58:47 -0400 |
|---|---|---|
| committer | Tom Rondeau <tom@trondeau.com> | 2014-05-17 17:45:17 -0400 |
| commit | 15ef5ba664896481faba85c39dc3539f5a4ee5aa (patch) | |
| tree | bcaa2b1cb4011b5e06a6594ea51f5bb8f71b87c6 /gr-fec/python/fec/extended_async_encoder.py | |
| parent | bbc5882fb9ac4b1a9815c9c634d977e8776d73fa (diff) | |
fec: wip: adding extended encoder for async version.
not quite working yet, needs work on the message-passing hier_block and added async puncturing block.
Diffstat (limited to 'gr-fec/python/fec/extended_async_encoder.py')
| -rw-r--r-- | gr-fec/python/fec/extended_async_encoder.py | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/gr-fec/python/fec/extended_async_encoder.py b/gr-fec/python/fec/extended_async_encoder.py new file mode 100644 index 0000000000..fffe64aeb8 --- /dev/null +++ b/gr-fec/python/fec/extended_async_encoder.py @@ -0,0 +1,67 @@ +#!/usr/bin/env python +# +# Copyright 2014 Free Software Foundation, Inc. +# +# This file is part of GNU Radio +# +# GNU Radio is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; either version 3, or (at your option) +# any later version. +# +# GNU Radio is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with GNU Radio; see the file COPYING. If not, write to +# the Free Software Foundation, Inc., 51 Franklin Street, +# Boston, MA 02110-1301, USA. +# + +from gnuradio import gr +import fec_swig as fec +from bitflip import read_bitlist +import weakref + +class extended_async_encoder(gr.hier_block2): + def __init__(self, encoder_obj_list, puncpat=None): + gr.hier_block2.__init__(self, "extended_async_encoder", + gr.io_signature(0, 0, 0), + gr.io_signature(0, 0, 0)) + + # Set us up as a message passing block + self.message_port_register_hier_in('in') + self.message_port_register_hier_out('out') + + self.puncpat=puncpat + + # If it's a list of encoders, take the first one, unless it's + # a list of lists of encoders. + if(type(encoder_obj_list) == list): + # This block doesn't handle parallelism of > 1 + if(type(encoder_obj_list[0]) == list): + gr.log.info("fec.extended_encoder: Parallelism must be 0 or 1.") + raise AttributeError + + encoder_obj = encoder_obj_list[0] + + # Otherwise, just take it as is + else: + encoder_obj = encoder_obj_list + + self.encoder = fec.async_encoder(encoder_obj) + + #self.puncture = None + #if self.puncpat != '11': + # self.puncture = fec.puncture_bb(len(puncpat), read_bitlist(puncpat), 0) + + self.msg_connect(weakref.proxy(self), "in", self.encoder, "in") + + #if(self.puncture): + # self.msg_connect(self.encoder, "out", self.puncture, "in") + # self.msg_connect(self.puncture, "out", weakref.proxy(self), "out") + #else: + # self.msg_connect(self.encoder, "out", weakref.proxy(self), "out") + self.msg_connect(self.encoder, "out", weakref.proxy(self), "out") |