//  Adjust TS packet header

void adjust_TS_packet_header(TS_packet_header* pheader) {     unsigned  char buf[ 4];     memcpy(buf, pheader,  4);     pheader->transport_error_indicator        = buf[ 1] >>  7;     pheader->payload_unit_start_indicator    = buf[ 1] >>  6 &  0x01;     pheader->transport_priority                = buf[ 1] >>  5 &  0x01;     pheader->PID                            = (buf[ 1] &  0x1F) <<  8 | buf[ 2];     pheader->transport_scrambling_control    = buf[ 3] >>  6;     pheader->adaption_field_control            = buf[ 3] >>  4 &  0x03;     pheader->continuity_counter                = buf[ 3] &  0x03; }

//  PAT table

//  Programm Association Table

typedef  struct TS_PAT {     unsigned table_id                        :  8;     unsigned section_syntax_indicator        :  1;     unsigned zero                            :  1;     unsigned reserved_1                        :  2;     unsigned section_length                    :  12;     unsigned transport_stream_id            :  16;     unsigned reserved_2                        :  2;     unsigned version_number                    :  5;     unsigned current_next_indicator            :  1;     unsigned section_number                    :  8;     unsigned last_section_number            :  8;     unsigned program_number                    :  16;     unsigned reserved_3                        :  3;     unsigned network_PID                    :  13;     unsigned program_map_PID                :  13;     unsigned CRC_32                            :  32; } TS_PAT;

//  Adjust PAT table

void adjust_PAT_table ( TS_PAT * packet,  char * buffer ) {      int n =  0, i =  0;      int len =  0;     packet->table_id                    = buffer[ 0];     packet->section_syntax_indicator    = buffer[ 1] >>  7;     packet->zero                        = buffer[ 1] >>  6 &  0x1;     packet->reserved_1                    = buffer[ 1] >>  4 &  0x3;     packet->section_length                = (buffer[ 1] &  0x0F) <<  8 | buffer[ 2];        packet->transport_stream_id            = buffer[ 3] <<  8 | buffer[ 4];     packet->reserved_2                    = buffer[ 5] >>  6;     packet->version_number                = buffer[ 5] >>  1 &   0x1F;     packet->current_next_indicator        = (buffer[ 5] <<  7) >>  7;     packet->section_number                = buffer[ 6];     packet->last_section_number            = buffer[ 7];      //  Get CRC_32

    len =  3 + packet->section_length;     packet->CRC_32                        = (buffer[len- 4] &  0x000000FF) <<  24                                           | (buffer[len- 3] &  0x000000FF) <<  16                                           | (buffer[len- 2] &  0x000000FF) <<  8                                           | (buffer[len- 1] &  0x000000FF);      //  Parse network_PID or program_map_PID

     for ( n =  0; n < packet->section_length -  4; n ++ )     {         packet->program_number            = buffer[ 8] <<  8 | buffer[ 9];         packet->reserved_3                = buffer[ 10] >>  5;          if ( packet->program_number ==  0x0 )             packet->network_PID = (buffer[ 10] <<  3) <<  5 | buffer[ 11];          else         {             packet->program_map_PID = (buffer[ 10] <<  3) <<  5 | buffer[ 11];         }         n +=  5;     } }

//  PMT table

//  Program Map Table

typedef  struct TS_PMT {     unsigned table_id                        :  8;     unsigned section_syntax_indicator        :  1;     unsigned zero                            :  1;     unsigned reserved_1                        :  2;     unsigned section_length                    :  12;     unsigned program_number                    :  16;     unsigned reserved_2                        :  2;     unsigned version_number                    :  5;     unsigned current_next_indicator            :  1;     unsigned section_number                    :  8;     unsigned last_section_number            :  8;     unsigned reserved_3                        :  3;     unsigned PCR_PID                        :  13;     unsigned reserved_4                        :  4;     unsigned program_info_length            :  12;         unsigned stream_type                    :  8;     unsigned reserved_5                        :  3;     unsigned elementary_PID                    :  13;     unsigned reserved_6                        :  4;     unsigned ES_info_length                    :  12;     unsigned CRC_32                            :  32; } TS_PMT;

//  Adjust PMT table

void adjust_PMT_table ( TS_PMT * packet,  char * buffer ) {      int pos =  12, len =  0;      int i =  0;     packet->table_id                            = buffer[ 0];     packet->section_syntax_indicator            = buffer[ 1] >>  7;     packet->zero                                = buffer[ 1] >>  6;     packet->reserved_1                            = buffer[ 1] >>  4;     packet->section_length                        = (buffer[ 1] &  0x0F) <<  8 | buffer[ 2];        packet->program_number                        = buffer[ 3] <<  8 | buffer[ 4];     packet->reserved_2                            = buffer[ 5] >>  6;     packet->version_number                        = buffer[ 5] >>  1 &  0x1F;     packet->current_next_indicator                = (buffer[ 5] <<  7) >>  7;     packet->section_number                        = buffer[ 6];     packet->last_section_number                    = buffer[ 7];     packet->reserved_3                            = buffer[ 8] >>  5;     packet->PCR_PID                                = ((buffer[ 8] <<  8) | buffer[ 9]) &  0x1FFF;     packet->reserved_4                            = buffer[ 10] >>  4;     packet->program_info_length                    = (buffer[ 10] &  0x0F) <<  8 | buffer[ 11];      //  Get CRC_32

    len = packet->section_length +  3;        packet->CRC_32                = (buffer[len- 4] &  0x000000FF) <<  24                                   | (buffer[len- 3] &  0x000000FF) <<  16                                   | (buffer[len- 2] &  0x000000FF) <<  8                                   | (buffer[len- 1] &  0x000000FF);      //  program info descriptor

     if ( packet->program_info_length !=  0 )         pos += packet->program_info_length;         //  Get stream type and PID   

     for ( ; pos <= (packet->section_length +  2 ) -   4; )     {         packet->stream_type                            = buffer[pos];         packet->reserved_5                            = buffer[pos+ 1] >>  5;         packet->elementary_PID                        = ((buffer[pos+ 1] <<  8) | buffer[pos+ 2]) &  0x1FFF;         packet->reserved_6                            = buffer[pos+ 3] >>  4;         packet->ES_info_length                        = (buffer[pos+ 3] &  0x0F) <<  8 | buffer[pos+ 4];          //  Store in es

        es[i].type = packet->stream_type;         es[i].pid = packet->elementary_PID;          if ( packet->ES_info_length !=  0 )         {             pos = pos+ 5;             pos += packet->ES_info_length;         }          else         {             pos +=  5;         }         i++;     } }