- atsc_depad.h

-/*

- *

- *

- *

-

- *

- * To avoid accidental use of raw pointers, dtv::atsc_field_sync_mux's

- * constructor is in a private implementation

- * class. dtv::atsc_field_sync_mux::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

-

- *

- * To avoid accidental use of raw pointers, dtv::atsc_interleaver's

- * constructor is in a private implementation

- * class. dtv::atsc_interleaver::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

-

- *

- * To avoid accidental use of raw pointers, dtv::atsc_pad's

- * constructor is in a private implementation

- * class. dtv::atsc_pad::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

- *

- * To avoid accidental use of raw pointers, dtv::atsc_randomizer's

- * constructor is in a private implementation

- * class. dtv::atsc_randomizer::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

- *

- * To avoid accidental use of raw pointers, dtv::atsc_rs_encoder's

- * constructor is in a private implementation

- * class. dtv::atsc_rs_encoder::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

-

- *

- * To avoid accidental use of raw pointers, dtv::atsc_trellis_encoder's

- * constructor is in a private implementation

- * class. dtv::atsc_trellis_encoder::make is the public interface for

- * creating new instances.

-

-/*

- *

- *

- *

- assert (input < 4);

- int index = (state << 2) + input;

- state = next_state[index];

- return out_symbol[index];

-

-/*

- *

- *

- *

- private:

- public:

-/*

- *

- *

- *

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(atsc_data_segment)),

- gr::io_signature::make(1, 1, sizeof(atsc_data_segment)))

- d_already_output_field_sync = false;

- for (int i = 0; i < N_SAVED_SYMBOLS; i++)

- {

- d_saved_symbols[i] = 0;

- /*

- * Our virtual destructor.

- */

- const unsigned char saved_symbols[N_SAVED_SYMBOLS])

- static const unsigned char bin_map[2] = {1, 6}; // map binary values to 1 of 8 levels

- int i = 0;

- p[i++] = bin_map[1]; // data segment sync pulse

- p[i++] = bin_map[0];

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

- for (int j = 0; j < 511; j++) // PN511

- {

- p[i++] = bin_map[atsc_pn511[j]];

- }

- for (int j = 0; j < 63; j++) // PN63

- {

- p[i++] = bin_map[atsc_pn63[j]];

- }

- for (int j = 0; j < 63; j++) // PN63, toggled on field 2

- {

- p[i++] = bin_map[atsc_pn63[j] ^ mask];

- }

- for (int j = 0; j < 63; j++) // PN63

- {

- p[i++] = bin_map[atsc_pn63[j]];

- }

- p[i++] = bin_map[0]; // 24 bits of 8VSB mode identifier

- p[i++] = bin_map[0];

- p[i++] = bin_map[0];

- p[i++] = bin_map[0];

-

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

-

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

-

- p[i++] = bin_map[1];

- p[i++] = bin_map[1];

- p[i++] = bin_map[1];

- p[i++] = bin_map[1];

-

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

-

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

- p[i++] = bin_map[1];

- p[i++] = bin_map[0];

-

- for (int j = 0; j < 92; j++) // 92 more bits

- {

- p[i++] = bin_map[atsc_pn63[j % 63]];

- }

- // now copy the last 12 symbols of the previous segment

- for (int j = 0; j < N_SAVED_SYMBOLS; j++)

- {

- p[i++] = saved_symbols[j];

- }

- assert (i == ATSC_DATA_SEGMENT_LENGTH);

- const unsigned char saved_symbols[N_SAVED_SYMBOLS])

- init_field_sync_common(&s->data[0], 0, saved_symbols);

- const unsigned char saved_symbols[N_SAVED_SYMBOLS])

- init_field_sync_common(&s->data[0], 1, saved_symbols);

- for (int i = 0; i < N_SAVED_SYMBOLS; i++)

- {

- saved_symbols[i] = seg.data[i + ATSC_DATA_SEGMENT_LENGTH - N_SAVED_SYMBOLS];

- return pli.regular_seg_p() && (pli.segno() == ATSC_DSEGS_PER_FIELD - 1);

- ninput_items_required[0] = noutput_items;

- gr_vector_int &ninput_items,

- gr_vector_const_void_star &input_items,

- gr_vector_void_star &output_items)

- const atsc_data_segment *in = (const atsc_data_segment *) input_items[0];

- atsc_data_segment *out = (atsc_data_segment *) output_items[0];

- int in_length = ninput_items[0];

- int index = 0;

- int outdex = 0;

-

- for (outdex = 0; outdex < noutput_items && index < in_length; outdex++)

- {

- assert(in[index].pli.regular_seg_p());

-

- if (!in[index].pli.first_regular_seg_p())

- {

- out[outdex] = in[index]; // just copy in to out

-

- if (last_regular_seg_p(in[index].pli))

- {

- save_last_symbols(d_saved_symbols, in[index]);

- }

- index++;

- else

- { // first_regular_seg_p

- if (!d_already_output_field_sync)

- {

- // write out field sync...

- atsc_data_segment field_sync;

-

- if (in[index].pli.in_field1_p())

- {

- init_field_sync_1(&field_sync, d_saved_symbols);

- }

- else

- {

- init_field_sync_2(&field_sync, d_saved_symbols);

- }

-

- // note that index doesn't advance in this branch

- out[outdex] = field_sync;

- d_already_output_field_sync = true;

- }

- else

- {

- // already output field sync, now output first regular segment

- out[outdex] = in[index];

- index++;

- d_already_output_field_sync = false;

- }

- // Tell runtime system how many input items we consumed on

- // each input stream.

- consume_each (index);

- // Tell runtime system how many output items we produced.

- return outdex;

-

-/*

- *

- *

- *

- private:

- public:

-

-/*

- *

- *

- *

-#include <gnuradio/io_signature.h>

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_rs_encoded)),

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_rs_encoded)))

- I = 52; /* ATSC interleaver */

- J = 4;

- registers = (unsigned char *) malloc(sizeof(unsigned char) * I * ((I - 1) * J));

- if (registers == NULL) {

- fprintf(stderr, "Out of memory.\n");

- exit(1);

- }

-

- pointers = (int *) malloc(sizeof(int) * I);

- if (pointers == NULL) {

- fprintf(stderr, "Out of memory.\n");

- exit(1);

- }

-

- memset(registers, 0, sizeof(unsigned char) * I * ((I - 1) * J));

- memset(pointers, 0, sizeof(int) * I);

-

- this->I = I;

- this->J = J;

- commutator = 0;

- /*

- * Our virtual destructor.

- */

- free(pointers);

- free(registers);

- const atsc_mpeg_packet_rs_encoded *in = (const atsc_mpeg_packet_rs_encoded *) input_items[0];

- atsc_mpeg_packet_rs_encoded *out = (atsc_mpeg_packet_rs_encoded *) output_items[0];

- int p, n = ATSC_MPEG_RS_ENCODED_LENGTH;

-

- for (int i = 0; i < noutput_items; i++)

- {

- assert(in[i].pli.regular_seg_p());

- plinfo::sanity_check(in[i].pli);

-

- out[i].pli = in[i].pli; // copy pipeline info

- if (in[i].pli.first_regular_seg_p()) // reset commutator if required

- {

- commutator = 0;

- }

- for (int j = 0; j < n; j++)

- {

- if (commutator == 0)

- {

- out[i].data[j] = in[i].data[j];

- }

- else

- {

- p = pointers[commutator];

-

- out[i].data[j] = registers[commutator * (I - 1) * J + p];

- registers[commutator * (I - 1) * J + p] = in[i].data[j];

-

- pointers[commutator] = (p + 1) % (commutator * J);

- }

- commutator = (commutator + 1) % I;

- }

- // Tell runtime system how many output items we produced.

- return noutput_items;

-

-/*

- *

- *

- *

- private:

- public:

-

-/*

- *

- *

- *

-#include <gnuradio/io_signature.h>

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(unsigned char)),

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet)), ATSC_MPEG_PKT_LENGTH)

- {}

- /*

- * Our virtual destructor.

- */

- const unsigned char *in = (const unsigned char *) input_items[0];

- atsc_mpeg_packet *out = (atsc_mpeg_packet *) output_items[0];

- for (int i = 0; i < noutput_items; i++)

- {

- memcpy(out[i].data, &in[i * ATSC_MPEG_PKT_LENGTH], ATSC_MPEG_PKT_LENGTH);

- }

- // Tell runtime system how many output items we produced.

- return noutput_items;

-

-/*

- *

- *

- *

- public:

-

-/*

- *

- *

- *

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet)),

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)))

- reset();

- /*

- * Our virtual destructor.

- */

- d_rand.reset();

- d_field2 = false;

- d_segno = 0;

- 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++)

- {

- // sanity check incoming data.

- assert((in[i].data[0] == MPEG_SYNC_BYTE));

- assert((in[i].data[1] & MPEG_TRANSPORT_ERROR_BIT) == 0);

- // initialize plinfo for downstream

- //

- // We do this here because the randomizer is effectively

- // the head of the tx processing chain

- //

- out[i].pli.set_regular_seg(d_field2, d_segno);

- d_segno++;

- if (d_segno == 312)

- {

- d_segno = 0;

- d_field2 = !d_field2;

- }

- if (out[i].pli.first_regular_seg_p())

- {

- d_rand.reset();

- }

- d_rand.randomize(out[i], in[i]);

- // Tell runtime system how many output items we produced.

- return noutput_items;

-

-/*

- *

- *

- *

- private:

- public:

-

-/*

- *

- *

- *

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_no_sync)),

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_rs_encoded)))

- d_rs = init_rs_char(rs_init_symsize, rs_init_gfpoly, rs_init_fcr, rs_init_prim, rs_init_nroots);

- assert (d_rs != 0);

- /*

- * Our virtual destructor.

- */

- if (d_rs)

- {

- free_rs_char(d_rs);

- }

- d_rs = 0;

- unsigned char tmp[K];

- assert((int)(amount_of_pad + sizeof (in.data)) == K);

- // add missing prefix zero padding to message

- memset(tmp, 0, amount_of_pad);

- memcpy(&tmp[amount_of_pad], in.data, sizeof (in.data));

- // copy message portion to output packet

- memcpy(out.data, in.data, sizeof (in.data));

- // now compute parity bytes and add them to tail end of output packet

- encode_rs_char(d_rs, tmp, &out.data[sizeof (in.data)]);

- const atsc_mpeg_packet_no_sync *in = (const atsc_mpeg_packet_no_sync *) input_items[0];

- atsc_mpeg_packet_rs_encoded *out = (atsc_mpeg_packet_rs_encoded *) output_items[0];

-

- for (int i = 0; i < noutput_items; i++)

- {

- assert(in[i].pli.regular_seg_p());

- out[i].pli = in[i].pli; // copy pipeline info...

- encode(out[i], in[i]);

- }

-

- // Tell runtime system how many output items we produced.

- return noutput_items;

-

-/*

- *

- *

- *

- private:

- public:

-

-/*

- *

- *

- *

-#include <gnuradio/io_signature.h>

-#include <stdio.h>

-static const int DIBITS_PER_BYTE = 4;

-/* How many separate Trellis encoders / Viterbi decoders run in parallel */

-static const int NCODERS = 12;

-/* A Segment sync symbol is an 8VSB +5,-5,-5,+5 sequence that occurs at

- the start of each 207-byte segment (including field sync segments). */

-/* Shift counts to bit numbers (high order, low order); 9x entries unused */

-static const int bit1[8] = {1, 99, 3, 98, 5, 97, 7, 96};

-static const int bit2[8] = {0, 99, 2, 98, 4, 97, 6, 96};

- /*

- * The private constructor

- */

- gr::io_signature::make(1, 1, sizeof(atsc_mpeg_packet_rs_encoded)),

- gr::io_signature::make(1, 1, sizeof(atsc_data_segment)))

- reset();

- debug = false;

- set_output_multiple(NCODERS);

- /*

- * Our virtual destructor.

- */

- for (int i = 0; i < NCODERS; i++)

- {

- enc[i].reset();

- }

- unsigned char out_copy[OUTPUT_SIZE];

- unsigned char in_copy[INPUT_SIZE];

-

- assert (sizeof (in_copy) == sizeof (in[0].data) * NCODERS);

- assert (sizeof (out_copy) == sizeof (out[0].data) * NCODERS);

-

- // copy input into continguous temporary buffer

- for (int i = 0; i < NCODERS; i++)

- {

- assert(in[i].pli.regular_seg_p());

- plinfo::sanity_check (in[i].pli);

- memcpy(&in_copy[i * INPUT_SIZE / NCODERS], &in[i].data[0], ATSC_MPEG_RS_ENCODED_LENGTH * sizeof (in_copy[0]));

- }

- memset(out_copy, 0, sizeof (out_copy)); // FIXME, sanity check

- // do the deed...

- encode_helper(out_copy, in_copy);

- // copy output from contiguous temp buffer into final output

- for (int i = 0; i < NCODERS; i++)

- {

- memcpy(&out[i].data[0], &out_copy[i * OUTPUT_SIZE / NCODERS], ATSC_DATA_SEGMENT_LENGTH * sizeof (out_copy[0]));

- // copy pipeline info

- out[i].pli = in[i].pli;

- plinfo::sanity_check(out[i].pli);

- assert(out[i].pli.regular_seg_p());

- }

- int i;

- int encoder;

- unsigned char trellis_buffer[NCODERS];

- int trellis_wherefrom[NCODERS];

- unsigned char *out, *next_out_seg;

- int chunk;

- int shift;

- unsigned char dibit;

- unsigned char symbol;

- int skip_encoder_bump;

-

- /* FIXME, we may want special processing here for a flag

- * byte to keep track of which part of the field we're in?

- encoder = NCODERS - ENCODER_SEG_BUMP;

- skip_encoder_bump = 0;

- out = output;

- next_out_seg = out;

-

- for (chunk = 0; chunk < INPUT_SIZE; chunk += NCODERS)

- {

- /* Load a new chunk of bytes into the Trellis encoder buffers.

- * They get loaded in an order that depends on where we are in

- * the segment sync progress (sigh).

- * GRR! When the chunk reload happens at the same time as the

- * segment boundary, we should bump the encoder NOW for the reload,

- * rather than LATER during the bitshift transition!!!

- if (out >= next_out_seg)

- {

- encoder = (encoder + ENCODER_SEG_BUMP) % NCODERS;

- skip_encoder_bump = 1;

- for (i = 0; i < NCODERS; i++)

- {

- /* for debug */

- trellis_wherefrom[encoder] = chunk + i;

- trellis_buffer[encoder] = input [chunk + i];

- encoder++;

- if (encoder >= NCODERS)

- {

- encoder = 0;

- }

- for (shift = 6; shift >= 0; shift -= 2)

- {

- /* Segment boundaries happen to occur on some bitshift transitions. */

- if (out >= next_out_seg)

- {

- /* Segment transition. Output a data segment sync symbol,

- * and mess with the trellis encoder mux.

- */

- *out++ = DSEG_SYNC_SYM1;

- *out++ = DSEG_SYNC_SYM2;

- *out++ = DSEG_SYNC_SYM3;

- *out++ = DSEG_SYNC_SYM4;

- if (debug)

- {

- printf("SYNC SYNC SYNC SYNC\n");

- }

- next_out_seg = out + (SEGMENT_SIZE * DIBITS_PER_BYTE);

-

- if (!skip_encoder_bump)

- {

- encoder = (encoder + ENCODER_SEG_BUMP) % NCODERS;

- }

- skip_encoder_bump = 0;

- }

-

- /* Now run each of the 12 Trellis encoders to spit out 12 symbols.

- * Each encoder takes input from the same byte of the chunk, but

- * the outputs of the encoders come out in various orders.

- * NOPE -- this is false. The encoders take input from various

- * bytes of the chunk (which changes at segment sync time), AND

- * they also come out in various orders. You really do have to

- * keep separate track of: the input bytes, the encoders, and

- * the output bytes -- because they're all moving with respect

- * to each other!!!

- */

- for (i = 0; i < NCODERS; i++)

- {

- dibit = 0x03 & (trellis_buffer[encoder] >> shift);

- if (debug)

- {

- printf("Seg %ld Symb %3ld Trell %2d Byte %6d Bits %d-%d = dibit %d ", (long) SEGOF(out-output), (long) SYMOF(out-output), encoder, trellis_wherefrom[encoder], bit1[shift], bit2[shift], dibit);

- }

- symbol = enc[encoder].encode(dibit);

- *out++ = symbol;

- encoder++;

- if (encoder >= NCODERS)

- {

- encoder = 0;

- }

- if (debug)

- {

- printf("sym %d\n", symbol);

- }

- } /* Encoders */

- } /* Bit shifts */

- } /* Chunks */

-

- /* Check up on ourselves */

- assert (0 == (INPUT_SIZE * DIBITS_PER_BYTE) % NCODERS);

- assert (OUTPUT_SIZE == out - output);

- assert (NCODERS - ENCODER_SEG_BUMP == encoder);

- const atsc_mpeg_packet_rs_encoded *in = (const atsc_mpeg_packet_rs_encoded *) input_items[0];

- atsc_data_segment *out = (atsc_data_segment *) output_items[0];

- for (int i = 0; i < noutput_items; i += NCODERS)

- {

- encode(&out[i], &in[i]);

- }

- // Tell runtime system how many output items we produced.

- return noutput_items;

-

-/*

- *

- *

- *

- private:

- public:

-

-#include "gnuradio/dtv/atsc_rs_decoder.h"

-#include "gnuradio/dtv/atsc_sync.h"

-#include "gnuradio/dtv/atsc_viterbi_decoder.h"

-#include "gnuradio/dtv/atsc_interleaver.h"

-#include "gnuradio/dtv/atsc_field_sync_mux.h"

-%include "gnuradio/dtv/atsc_rs_decoder.h"

-%include "gnuradio/dtv/atsc_sync.h"

-%include "gnuradio/dtv/atsc_viterbi_decoder.h"

-%include "gnuradio/dtv/atsc_interleaver.h"

-%include "gnuradio/dtv/atsc_field_sync_mux.h"

-GR_SWIG_BLOCK_MAGIC2(dtv, atsc_rs_decoder);

-GR_SWIG_BLOCK_MAGIC2(dtv, atsc_sync);

-GR_SWIG_BLOCK_MAGIC2(dtv, atsc_viterbi_decoder);

-GR_SWIG_BLOCK_MAGIC2(dtv, atsc_interleaver);

-GR_SWIG_BLOCK_MAGIC2(dtv, atsc_field_sync_mux);