summaryrefslogtreecommitdiff
path: root/gr-dtv/lib/atsc/atsc_derandomizer_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gr-dtv/lib/atsc/atsc_derandomizer_impl.cc')
-rw-r--r--gr-dtv/lib/atsc/atsc_derandomizer_impl.cc55
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 */