diff options
Diffstat (limited to 'gr-dtv/lib/atsc/atsc_derandomizer_impl.cc')
-rw-r--r-- | gr-dtv/lib/atsc/atsc_derandomizer_impl.cc | 55 |
1 files changed, 26 insertions, 29 deletions
diff --git a/gr-dtv/lib/atsc/atsc_derandomizer_impl.cc b/gr-dtv/lib/atsc/atsc_derandomizer_impl.cc index 364713f7b5..31d16b3c1d 100644 --- a/gr-dtv/lib/atsc/atsc_derandomizer_impl.cc +++ b/gr-dtv/lib/atsc/atsc_derandomizer_impl.cc @@ -29,37 +29,34 @@ #include <gnuradio/io_signature.h> namespace gr { - namespace dtv { +namespace dtv { - atsc_derandomizer::sptr - atsc_derandomizer::make() - { - return gnuradio::get_initial_sptr - (new atsc_derandomizer_impl()); - } +atsc_derandomizer::sptr atsc_derandomizer::make() +{ + return gnuradio::get_initial_sptr(new atsc_derandomizer_impl()); +} - atsc_derandomizer_impl::atsc_derandomizer_impl() - : gr::sync_block("dtv_atsc_derandomizer", - io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)), - io_signature::make(1, 1, sizeof(atsc_mpeg_packet))) - { - d_rand.reset(); - } +atsc_derandomizer_impl::atsc_derandomizer_impl() + : gr::sync_block("dtv_atsc_derandomizer", + io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)), + io_signature::make(1, 1, sizeof(atsc_mpeg_packet))) +{ + d_rand.reset(); +} - int - atsc_derandomizer_impl::work (int noutput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items) - { - const atsc_mpeg_packet_no_sync *in = (const atsc_mpeg_packet_no_sync *) input_items[0]; - atsc_mpeg_packet *out = (atsc_mpeg_packet *) output_items[0]; +int atsc_derandomizer_impl::work(int noutput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items) +{ + const atsc_mpeg_packet_no_sync* in = (const atsc_mpeg_packet_no_sync*)input_items[0]; + atsc_mpeg_packet* out = (atsc_mpeg_packet*)output_items[0]; - for (int i = 0; i < noutput_items; i++){ + for (int i = 0; i < noutput_items; i++) { assert(in[i].pli.regular_seg_p()); if (in[i].pli.first_regular_seg_p()) - d_rand.reset(); + d_rand.reset(); d_rand.derandomize(out[i], in[i]); @@ -67,13 +64,13 @@ namespace gr { // corresponding bit in transport packet header. if (in[i].pli.transport_error_p()) - out[i].data[1] |= MPEG_TRANSPORT_ERROR_BIT; + out[i].data[1] |= MPEG_TRANSPORT_ERROR_BIT; else - out[i].data[1] &= ~MPEG_TRANSPORT_ERROR_BIT; - } - - return noutput_items; + out[i].data[1] &= ~MPEG_TRANSPORT_ERROR_BIT; } - } /* namespace dtv */ + return noutput_items; +} + +} /* namespace dtv */ } /* namespace gr */ |