summaryrefslogtreecommitdiff
path: root/gr-dtv/lib/atsc/atsc_randomizer_impl.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gr-dtv/lib/atsc/atsc_randomizer_impl.cc')
-rw-r--r--gr-dtv/lib/atsc/atsc_randomizer_impl.cc74
1 files changed, 34 insertions, 40 deletions
diff --git a/gr-dtv/lib/atsc/atsc_randomizer_impl.cc b/gr-dtv/lib/atsc/atsc_randomizer_impl.cc
index f6b6a6a370..f77bb80f9d 100644
--- a/gr-dtv/lib/atsc/atsc_randomizer_impl.cc
+++ b/gr-dtv/lib/atsc/atsc_randomizer_impl.cc
@@ -27,44 +27,38 @@
#include "gnuradio/dtv/atsc_consts.h"
namespace gr {
- namespace dtv {
+namespace dtv {
- atsc_randomizer::sptr
- atsc_randomizer::make()
- {
- return gnuradio::get_initial_sptr
- (new atsc_randomizer_impl());
- }
+atsc_randomizer::sptr atsc_randomizer::make()
+{
+ return gnuradio::get_initial_sptr(new atsc_randomizer_impl());
+}
- atsc_randomizer_impl::atsc_randomizer_impl()
- : gr::sync_block("atsc_randomizer",
- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet)),
- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)))
- {
- reset();
- }
+atsc_randomizer_impl::atsc_randomizer_impl()
+ : gr::sync_block("atsc_randomizer",
+ gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet)),
+ gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)))
+{
+ reset();
+}
- atsc_randomizer_impl::~atsc_randomizer_impl()
- {
- }
+atsc_randomizer_impl::~atsc_randomizer_impl() {}
- void
- atsc_randomizer_impl::reset()
- {
- d_rand.reset();
- d_field2 = false;
- d_segno = 0;
- }
+void atsc_randomizer_impl::reset()
+{
+ d_rand.reset();
+ d_field2 = false;
+ d_segno = 0;
+}
- int
- atsc_randomizer_impl::work(int noutput_items,
- gr_vector_const_void_star &input_items,
- gr_vector_void_star &output_items)
- {
- const atsc_mpeg_packet *in = (const atsc_mpeg_packet *) input_items[0];
- atsc_mpeg_packet_no_sync *out = (atsc_mpeg_packet_no_sync *) output_items[0];
+int atsc_randomizer_impl::work(int noutput_items,
+ gr_vector_const_void_star& input_items,
+ gr_vector_void_star& output_items)
+{
+ const atsc_mpeg_packet* in = (const atsc_mpeg_packet*)input_items[0];
+ atsc_mpeg_packet_no_sync* out = (atsc_mpeg_packet_no_sync*)output_items[0];
- for (int i = 0; i < noutput_items; i++) {
+ for (int i = 0; i < noutput_items; i++) {
// sanity check incoming data.
assert((in[i].data[0] == MPEG_SYNC_BYTE));
assert((in[i].data[1] & MPEG_TRANSPORT_ERROR_BIT) == 0);
@@ -78,20 +72,20 @@ namespace gr {
d_segno++;
if (d_segno == 312) {
- d_segno = 0;
- d_field2 = !d_field2;
+ d_segno = 0;
+ d_field2 = !d_field2;
}
if (out[i].pli.first_regular_seg_p()) {
- d_rand.reset();
+ d_rand.reset();
}
d_rand.randomize(out[i], in[i]);
- }
-
- // Tell runtime system how many output items we produced.
- return noutput_items;
}
- } /* namespace dtv */
+ // Tell runtime system how many output items we produced.
+ return noutput_items;
+}
+
+} /* namespace dtv */
} /* namespace gr */