falkTX
/
FFmpeg
mirror of https://github.com/falkTX/FFmpeg.git
1
0
Fork 0
Code Issues 0 Releases 338 Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
15702 Commits
32 Branches
933MB
Tree: 5f86057ffd
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '5f86057ffd'
${ noResults }
FFmpeg/libavformat/mpegts.c

1542 lines
44KB
Raw Blame History 

  1. /*

  2.  * MPEG2 transport stream (aka DVB) demuxer

  3.  * Copyright (c) 2002-2003 Fabrice Bellard.

  4.  *

  5.  * This file is part of FFmpeg.

  6.  *

  7.  * FFmpeg is free software; you can redistribute it and/or

  8.  * modify it under the terms of the GNU Lesser General Public

  9.  * License as published by the Free Software Foundation; either

  10.  * version 2.1 of the License, or (at your option) any later version.

  11.  *

  12.  * FFmpeg is distributed in the hope that it will be useful,

  13.  * but WITHOUT ANY WARRANTY; without even the implied warranty of

  14.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

  15.  * Lesser General Public License for more details.

  16.  *

  17.  * You should have received a copy of the GNU Lesser General Public

  18.  * License along with FFmpeg; if not, write to the Free Software

  19.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

  20.  */

  21. 

  22. #include "libavutil/crc.h"

  23. #include "avformat.h"

  24. #include "mpegts.h"

  25. 

  26. //#define DEBUG_SI

  27. //#define DEBUG_SEEK

  28. 

  29. /* 1.0 second at 24Mbit/s */

  30. #define MAX_SCAN_PACKETS 32000

  31. 

  32. /* maximum size in which we look for synchronisation if

  33.    synchronisation is lost */

  34. #define MAX_RESYNC_SIZE 4096

  35. #define REGISTRATION_DESCRIPTOR 5

  36. 

  37. typedef struct PESContext PESContext;

  38. 

  39. static PESContext* add_pes_stream(MpegTSContext *ts, int pid, int pcr_pid, int stream_type);

  40. static AVStream* new_pes_av_stream(PESContext *pes, uint32_t code);

  41. extern void av_set_program_name(AVProgram *program, char *provider_name, char *name);

  42. extern void av_program_add_stream_index(AVFormatContext *ac, int progid, unsigned int idx);

  43. 

  44. enum MpegTSFilterType {

  45.     MPEGTS_PES,

  46.     MPEGTS_SECTION,

  47. };

  48. 

  49. typedef struct MpegTSFilter MpegTSFilter;

  50. 

  51. typedef void PESCallback(MpegTSFilter *f, const uint8_t *buf, int len, int is_start);

  52. 

  53. typedef struct MpegTSPESFilter {

  54.     PESCallback *pes_cb;

  55.     void *opaque;

  56. } MpegTSPESFilter;

  57. 

  58. typedef void SectionCallback(MpegTSFilter *f, const uint8_t *buf, int len);

  59. 

  60. typedef void SetServiceCallback(void *opaque, int ret);

  61. 

  62. typedef struct MpegTSSectionFilter {

  63.     int section_index;

  64.     int section_h_size;

  65.     uint8_t *section_buf;

  66.     unsigned int check_crc:1;

  67.     unsigned int end_of_section_reached:1;

  68.     SectionCallback *section_cb;

  69.     void *opaque;

  70. } MpegTSSectionFilter;

  71. 

  72. struct MpegTSFilter {

  73.     int pid;

  74.     int last_cc; /* last cc code (-1 if first packet) */

  75.     enum MpegTSFilterType type;

  76.     union {

  77.         MpegTSPESFilter pes_filter;

  78.         MpegTSSectionFilter section_filter;

  79.     } u;

  80. };

  81. 

  82. #define MAX_PIDS_PER_PROGRAM 64

  83. typedef struct {

  84.     unsigned int id; //program id/service id

  85.     unsigned int nb_pids;

  86.     unsigned int pids[MAX_PIDS_PER_PROGRAM];

  87. } Program_t;

  88. 

  89. struct MpegTSContext {

  90.     /* user data */

  91.     AVFormatContext *stream;

  92.     /** raw packet size, including FEC if present            */

  93.     int raw_packet_size;

  94. 

  95.     int pos47;

  96. 

  97.     /** if true, all pids are analyzed to find streams       */

  98.     int auto_guess;

  99. 

  100.     /** compute exact PCR for each transport stream packet   */

  101.     int mpeg2ts_compute_pcr;

  102. 

  103.     int64_t cur_pcr;    /**< used to estimate the exact PCR  */

  104.     int pcr_incr;       /**< used to estimate the exact PCR  */

  105. 

  106.     /* data needed to handle file based ts */

  107.     /** stop parsing loop                                    */

  108.     int stop_parse;

  109.     /** packet containing Audio/Video data                   */

  110.     AVPacket *pkt;

  111. 

  112.     /******************************************/

  113.     /* private mpegts data */

  114.     /* scan context */

  115.     /** structure to keep track of Program->pids mapping     */

  116.     unsigned int nb_prg;

  117.     Program_t *prg;

  118. 

  119. 

  120.     /** filters for various streams specified by PMT + for the PAT and PMT */

  121.     MpegTSFilter *pids[NB_PID_MAX];

  122. };

  123. 

  124. /* TS stream handling */

  125. 

  126. enum MpegTSState {

  127.     MPEGTS_HEADER = 0,

  128.     MPEGTS_PESHEADER_FILL,

  129.     MPEGTS_PAYLOAD,

  130.     MPEGTS_SKIP,

  131. };

  132. 

  133. /* enough for PES header + length */

  134. #define PES_START_SIZE 9

  135. #define MAX_PES_HEADER_SIZE (9 + 255)

  136. 

  137. struct PESContext {

  138.     int pid;

  139.     int pcr_pid; /**< if -1 then all packets containing PCR are considered */

  140.     int stream_type;

  141.     MpegTSContext *ts;

  142.     AVFormatContext *stream;

  143.     AVStream *st;

  144.     enum MpegTSState state;

  145.     /* used to get the format */

  146.     int data_index;

  147.     int total_size;

  148.     int pes_header_size;

  149.     int64_t pts, dts;

  150.     uint8_t header[MAX_PES_HEADER_SIZE];

  151. };

  152. 

  153. extern AVInputFormat mpegts_demuxer;

  154. 

  155. static void clear_program(MpegTSContext *ts, unsigned int programid)

  156. {

  157.     int i;

  158. 

  159.     for(i=0; i<ts->nb_prg; i++)

  160.         if(ts->prg[i].id == programid)

  161.             ts->prg[i].nb_pids = 0;

  162. }

  163. 

  164. static void clear_programs(MpegTSContext *ts)

  165. {

  166.     av_freep(&ts->prg);

  167.     ts->nb_prg=0;

  168. }

  169. 

  170. static void add_pat_entry(MpegTSContext *ts, unsigned int programid)

  171. {

  172.     Program_t *p;

  173.     void *tmp = av_realloc(ts->prg, (ts->nb_prg+1)*sizeof(Program_t));

  174.     if(!tmp)

  175.         return;

  176.     ts->prg = tmp;

  177.     p = &ts->prg[ts->nb_prg];

  178.     p->id = programid;

  179.     p->nb_pids = 0;

  180.     ts->nb_prg++;

  181. }

  182. 

  183. static void add_pid_to_pmt(MpegTSContext *ts, unsigned int programid, unsigned int pid)

  184. {

  185.     int i;

  186.     Program_t *p = NULL;

  187.     for(i=0; i<ts->nb_prg; i++) {

  188.         if(ts->prg[i].id == programid) {

  189.             p = &ts->prg[i];

  190.             break;

  191.         }

  192.     }

  193.     if(!p)

  194.         return;

  195. 

  196.     if(p->nb_pids >= MAX_PIDS_PER_PROGRAM)

  197.         return;

  198.     p->pids[p->nb_pids++] = pid;

  199. }

  200. 

  201. /**

  202.  * \brief discard_pid() decides if the pid is to be discarded according

  203.  *                      to caller's programs selection

  204.  * \param ts    : - TS context

  205.  * \param pid   : - pid

  206.  * \return 1 if the pid is only comprised in programs that have .discard=AVDISCARD_ALL

  207.  *         0 otherwise

  208.  */

  209. static int discard_pid(MpegTSContext *ts, unsigned int pid)

  210. {

  211.     int i, j, k;

  212.     int used = 0, discarded = 0;

  213.     Program_t *p;

  214.     for(i=0; i<ts->nb_prg; i++) {

  215.         p = &ts->prg[i];

  216.         for(j=0; j<p->nb_pids; j++) {

  217.             if(p->pids[j] != pid)

  218.                 continue;

  219.             //is program with id p->id set to be discarded?

  220.             for(k=0; k<ts->stream->nb_programs; k++) {

  221.                 if(ts->stream->programs[k]->id == p->id) {

  222.                     if(ts->stream->programs[k]->discard == AVDISCARD_ALL)

  223.                         discarded++;

  224.                     else

  225.                         used++;

  226.                 }

  227.             }

  228.         }

  229.     }

  230. 

  231.     return !used && discarded;

  232. }

  233. 

  234. /**

  235.  *  Assembles PES packets out of TS packets, and then calls the "section_cb"

  236.  *  function when they are complete.

  237.  */

  238. static void write_section_data(AVFormatContext *s, MpegTSFilter *tss1,

  239.                                const uint8_t *buf, int buf_size, int is_start)

  240. {

  241.     MpegTSSectionFilter *tss = &tss1->u.section_filter;

  242.     int len;

  243. 

  244.     if (is_start) {

  245.         memcpy(tss->section_buf, buf, buf_size);

  246.         tss->section_index = buf_size;

  247.         tss->section_h_size = -1;

  248.         tss->end_of_section_reached = 0;

  249.     } else {

  250.         if (tss->end_of_section_reached)

  251.             return;

  252.         len = 4096 - tss->section_index;

  253.         if (buf_size < len)

  254.             len = buf_size;

  255.         memcpy(tss->section_buf + tss->section_index, buf, len);

  256.         tss->section_index += len;

  257.     }

  258. 

  259.     /* compute section length if possible */

  260.     if (tss->section_h_size == -1 && tss->section_index >= 3) {

  261.         len = (AV_RB16(tss->section_buf + 1) & 0xfff) + 3;

  262.         if (len > 4096)

  263.             return;

  264.         tss->section_h_size = len;

  265.     }

  266. 

  267.     if (tss->section_h_size != -1 && tss->section_index >= tss->section_h_size) {

  268.         tss->end_of_section_reached = 1;

  269.         if (!tss->check_crc ||

  270.             av_crc(av_crc_get_table(AV_CRC_32_IEEE), -1,

  271.                    tss->section_buf, tss->section_h_size) == 0)

  272.             tss->section_cb(tss1, tss->section_buf, tss->section_h_size);

  273.     }

  274. }

  275. 

  276. static MpegTSFilter *mpegts_open_section_filter(MpegTSContext *ts, unsigned int pid,

  277.                                          SectionCallback *section_cb, void *opaque,

  278.                                          int check_crc)

  279. 

  280. {

  281.     MpegTSFilter *filter;

  282.     MpegTSSectionFilter *sec;

  283. 

  284. #ifdef DEBUG_SI

  285.     av_log(ts->stream, AV_LOG_DEBUG, "Filter: pid=0x%x\n", pid);

  286. #endif

  287.     if (pid >= NB_PID_MAX || ts->pids[pid])

  288.         return NULL;

  289.     filter = av_mallocz(sizeof(MpegTSFilter));

  290.     if (!filter)

  291.         return NULL;

  292.     ts->pids[pid] = filter;

  293.     filter->type = MPEGTS_SECTION;

  294.     filter->pid = pid;

  295.     filter->last_cc = -1;

  296.     sec = &filter->u.section_filter;

  297.     sec->section_cb = section_cb;

  298.     sec->opaque = opaque;

  299.     sec->section_buf = av_malloc(MAX_SECTION_SIZE);

  300.     sec->check_crc = check_crc;

  301.     if (!sec->section_buf) {

  302.         av_free(filter);

  303.         return NULL;

  304.     }

  305.     return filter;

  306. }

  307. 

  308. static MpegTSFilter *mpegts_open_pes_filter(MpegTSContext *ts, unsigned int pid,

  309.                                      PESCallback *pes_cb,

  310.                                      void *opaque)

  311. {

  312.     MpegTSFilter *filter;

  313.     MpegTSPESFilter *pes;

  314. 

  315.     if (pid >= NB_PID_MAX || ts->pids[pid])

  316.         return NULL;

  317.     filter = av_mallocz(sizeof(MpegTSFilter));

  318.     if (!filter)

  319.         return NULL;

  320.     ts->pids[pid] = filter;

  321.     filter->type = MPEGTS_PES;

  322.     filter->pid = pid;

  323.     filter->last_cc = -1;

  324.     pes = &filter->u.pes_filter;

  325.     pes->pes_cb = pes_cb;

  326.     pes->opaque = opaque;

  327.     return filter;

  328. }

  329. 

  330. static void mpegts_close_filter(MpegTSContext *ts, MpegTSFilter *filter)

  331. {

  332.     int pid;

  333. 

  334.     pid = filter->pid;

  335.     if (filter->type == MPEGTS_SECTION)

  336.         av_freep(&filter->u.section_filter.section_buf);

  337. 

  338.     av_free(filter);

  339.     ts->pids[pid] = NULL;

  340. }

  341. 

  342. static int analyze(const uint8_t *buf, int size, int packet_size, int *index){

  343.     int stat[packet_size];

  344.     int i;

  345.     int x=0;

  346.     int best_score=0;

  347. 

  348.     memset(stat, 0, packet_size*sizeof(int));

  349. 

  350.     for(x=i=0; i<size-3; i++){

  351.         if(buf[i] == 0x47 && !(buf[i+1] & 0x80) && (buf[i+3] & 0x30)){

  352.             stat[x]++;

  353.             if(stat[x] > best_score){

  354.                 best_score= stat[x];

  355.                 if(index) *index= x;

  356.             }

  357.         }

  358. 

  359.         x++;

  360.         if(x == packet_size) x= 0;

  361.     }

  362. 

  363.     return best_score;

  364. }

  365. 

  366. /* autodetect fec presence. Must have at least 1024 bytes  */

  367. static int get_packet_size(const uint8_t *buf, int size)

  368. {

  369.     int score, fec_score, dvhs_score;

  370. 

  371.     if (size < (TS_FEC_PACKET_SIZE * 5 + 1))

  372.         return -1;

  373. 

  374.     score    = analyze(buf, size, TS_PACKET_SIZE, NULL);

  375.     dvhs_score    = analyze(buf, size, TS_DVHS_PACKET_SIZE, NULL);

  376.     fec_score= analyze(buf, size, TS_FEC_PACKET_SIZE, NULL);

  377. //    av_log(NULL, AV_LOG_DEBUG, "score: %d, dvhs_score: %d, fec_score: %d \n", score, dvhs_score, fec_score);

  378. 

  379.     if     (score > fec_score && score > dvhs_score) return TS_PACKET_SIZE;

  380.     else if(dvhs_score > score && dvhs_score > fec_score) return TS_DVHS_PACKET_SIZE;

  381.     else if(score < fec_score && dvhs_score < fec_score) return TS_FEC_PACKET_SIZE;

  382.     else                       return -1;

  383. }

  384. 

  385. typedef struct SectionHeader {

  386.     uint8_t tid;

  387.     uint16_t id;

  388.     uint8_t version;

  389.     uint8_t sec_num;

  390.     uint8_t last_sec_num;

  391. } SectionHeader;

  392. 

  393. static inline int get8(const uint8_t **pp, const uint8_t *p_end)

  394. {

  395.     const uint8_t *p;

  396.     int c;

  397. 

  398.     p = *pp;

  399.     if (p >= p_end)

  400.         return -1;

  401.     c = *p++;

  402.     *pp = p;

  403.     return c;

  404. }

  405. 

  406. static inline int get16(const uint8_t **pp, const uint8_t *p_end)

  407. {

  408.     const uint8_t *p;

  409.     int c;

  410. 

  411.     p = *pp;

  412.     if ((p + 1) >= p_end)

  413.         return -1;

  414.     c = AV_RB16(p);

  415.     p += 2;

  416.     *pp = p;

  417.     return c;

  418. }

  419. 

  420. /* read and allocate a DVB string preceeded by its length */

  421. static char *getstr8(const uint8_t **pp, const uint8_t *p_end)

  422. {

  423.     int len;

  424.     const uint8_t *p;

  425.     char *str;

  426. 

  427.     p = *pp;

  428.     len = get8(&p, p_end);

  429.     if (len < 0)

  430.         return NULL;

  431.     if ((p + len) > p_end)

  432.         return NULL;

  433.     str = av_malloc(len + 1);

  434.     if (!str)

  435.         return NULL;

  436.     memcpy(str, p, len);

  437.     str[len] = '\0';

  438.     p += len;

  439.     *pp = p;

  440.     return str;

  441. }

  442. 

  443. static int parse_section_header(SectionHeader *h,

  444.                                 const uint8_t **pp, const uint8_t *p_end)

  445. {

  446.     int val;

  447. 

  448.     val = get8(pp, p_end);

  449.     if (val < 0)

  450.         return -1;

  451.     h->tid = val;

  452.     *pp += 2;

  453.     val = get16(pp, p_end);

  454.     if (val < 0)

  455.         return -1;

  456.     h->id = val;

  457.     val = get8(pp, p_end);

  458.     if (val < 0)

  459.         return -1;

  460.     h->version = (val >> 1) & 0x1f;

  461.     val = get8(pp, p_end);

  462.     if (val < 0)

  463.         return -1;

  464.     h->sec_num = val;

  465.     val = get8(pp, p_end);

  466.     if (val < 0)

  467.         return -1;

  468.     h->last_sec_num = val;

  469.     return 0;

  470. }

  471. 

  472. 

  473. static void pmt_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)

  474. {

  475.     MpegTSContext *ts = filter->u.section_filter.opaque;

  476.     SectionHeader h1, *h = &h1;

  477.     PESContext *pes;

  478.     AVStream *st;

  479.     const uint8_t *p, *p_end, *desc_list_end, *desc_end;

  480.     int program_info_length, pcr_pid, pid, stream_type;

  481.     int desc_list_len, desc_len, desc_tag;

  482.     int comp_page = 0, anc_page = 0; /* initialize to kill warnings */

  483.     char language[4] = {0}; /* initialize to kill warnings */

  484.     int has_hdmv_descr = 0;

  485.     int has_dirac_descr = 0;

  486. 

  487. #ifdef DEBUG_SI

  488.     av_log(ts->stream, AV_LOG_DEBUG, "PMT: len %i\n", section_len);

  489.     av_hex_dump_log(ts->stream, AV_LOG_DEBUG, (uint8_t *)section, section_len);

  490. #endif

  491.     p_end = section + section_len - 4;

  492.     p = section;

  493.     if (parse_section_header(h, &p, p_end) < 0)

  494.         return;

  495. #ifdef DEBUG_SI

  496.     av_log(ts->stream, AV_LOG_DEBUG, "sid=0x%x sec_num=%d/%d\n",

  497.            h->id, h->sec_num, h->last_sec_num);

  498. #endif

  499.     if (h->tid != PMT_TID)

  500.         return;

  501. 

  502.     clear_program(ts, h->id);

  503.     pcr_pid = get16(&p, p_end) & 0x1fff;

  504.     if (pcr_pid < 0)

  505.         return;

  506.     add_pid_to_pmt(ts, h->id, pcr_pid);

  507. #ifdef DEBUG_SI

  508.     av_log(ts->stream, AV_LOG_DEBUG, "pcr_pid=0x%x\n", pcr_pid);

  509. #endif

  510.     program_info_length = get16(&p, p_end) & 0xfff;

  511.     if (program_info_length < 0)

  512.         return;

  513.     while(program_info_length >= 2) {

  514.         uint8_t tag, len;

  515.         tag = get8(&p, p_end);

  516.         len = get8(&p, p_end);

  517.         if(len > program_info_length - 2)

  518.             //something else is broken, exit the program_descriptors_loop

  519.             break;

  520.         program_info_length -= len + 2;

  521.         if(tag == REGISTRATION_DESCRIPTOR && len >= 4) {

  522.             uint8_t bytes[4];

  523.             bytes[0] = get8(&p, p_end);

  524.             bytes[1] = get8(&p, p_end);

  525.             bytes[2] = get8(&p, p_end);

  526.             bytes[3] = get8(&p, p_end);

  527.             len -= 4;

  528.             if(bytes[0] == 'H' && bytes[1] == 'D' &&

  529.                bytes[2] == 'M' && bytes[3] == 'V')

  530.                 has_hdmv_descr = 1;

  531.         }

  532.         p += len;

  533.     }

  534.     p += program_info_length;

  535.     if (p >= p_end)

  536.         return;

  537.     for(;;) {

  538.         language[0] = 0;

  539.         st = 0;

  540.         stream_type = get8(&p, p_end);

  541.         if (stream_type < 0)

  542.             break;

  543.         pid = get16(&p, p_end) & 0x1fff;

  544.         if (pid < 0)

  545.             break;

  546.         desc_list_len = get16(&p, p_end) & 0xfff;

  547.         if (desc_list_len < 0)

  548.             break;

  549.         desc_list_end = p + desc_list_len;

  550.         if (desc_list_end > p_end)

  551.             break;

  552.         for(;;) {

  553.             desc_tag = get8(&p, desc_list_end);

  554.             if (desc_tag < 0)

  555.                 break;

  556.             if (stream_type == STREAM_TYPE_PRIVATE_DATA) {

  557.                 if((desc_tag == 0x6A) || (desc_tag == 0x7A)) {

  558.                     /*assume DVB AC-3 Audio*/

  559.                     stream_type = STREAM_TYPE_AUDIO_AC3;

  560.                 } else if(desc_tag == 0x7B) {

  561.                     /* DVB DTS audio */

  562.                     stream_type = STREAM_TYPE_AUDIO_DTS;

  563.                 }

  564.             }

  565.             desc_len = get8(&p, desc_list_end);

  566.             desc_end = p + desc_len;

  567.             if (desc_end > desc_list_end)

  568.                 break;

  569. #ifdef DEBUG_SI

  570.             av_log(ts->stream, AV_LOG_DEBUG, "tag: 0x%02x len=%d\n",

  571.                    desc_tag, desc_len);

  572. #endif

  573.             switch(desc_tag) {

  574.             case DVB_SUBT_DESCID:

  575.                 if (stream_type == STREAM_TYPE_PRIVATE_DATA)

  576.                     stream_type = STREAM_TYPE_SUBTITLE_DVB;

  577. 

  578.                 language[0] = get8(&p, desc_end);

  579.                 language[1] = get8(&p, desc_end);

  580.                 language[2] = get8(&p, desc_end);

  581.                 language[3] = 0;

  582.                 get8(&p, desc_end);

  583.                 comp_page = get16(&p, desc_end);

  584.                 anc_page = get16(&p, desc_end);

  585. 

  586.                 break;

  587.             case 0x0a: /* ISO 639 language descriptor */

  588.                 language[0] = get8(&p, desc_end);

  589.                 language[1] = get8(&p, desc_end);

  590.                 language[2] = get8(&p, desc_end);

  591.                 language[3] = 0;

  592.                 break;

  593.             case REGISTRATION_DESCRIPTOR: /*MPEG-2 Registration descriptor */

  594.                 {

  595.                     uint8_t bytes[4];

  596.                     bytes[0] = get8(&p, desc_end);

  597.                     bytes[1] = get8(&p, desc_end);

  598.                     bytes[2] = get8(&p, desc_end);

  599.                     bytes[3] = get8(&p, desc_end);

  600.                     if(bytes[0] == 'd' && bytes[1] == 'r' &&

  601.                        bytes[2] == 'a' && bytes[3] == 'c')

  602.                         has_dirac_descr = 1;

  603.                     break;

  604.                 }

  605.             default:

  606.                 break;

  607.             }

  608.             p = desc_end;

  609.         }

  610.         p = desc_list_end;

  611. 

  612. #ifdef DEBUG_SI

  613.         av_log(ts->stream, AV_LOG_DEBUG, "stream_type=%d pid=0x%x\n",

  614.                stream_type, pid);

  615. #endif

  616. 

  617.         /* now create ffmpeg stream */

  618.         switch(stream_type) {

  619.         case STREAM_TYPE_AUDIO_MPEG1:

  620.         case STREAM_TYPE_AUDIO_MPEG2:

  621.         case STREAM_TYPE_VIDEO_MPEG1:

  622.         case STREAM_TYPE_VIDEO_MPEG2:

  623.         case STREAM_TYPE_VIDEO_MPEG4:

  624.         case STREAM_TYPE_VIDEO_H264:

  625.         case STREAM_TYPE_VIDEO_VC1:

  626.         case STREAM_TYPE_VIDEO_DIRAC:

  627.         case STREAM_TYPE_AUDIO_AAC:

  628.         case STREAM_TYPE_AUDIO_AC3:

  629.         case STREAM_TYPE_AUDIO_DTS:

  630.         case STREAM_TYPE_AUDIO_HDMV_DTS:

  631.         case STREAM_TYPE_SUBTITLE_DVB:

  632.             if((stream_type == STREAM_TYPE_AUDIO_HDMV_DTS && !has_hdmv_descr)

  633.             || (stream_type == STREAM_TYPE_VIDEO_DIRAC    && !has_dirac_descr))

  634.                 break;

  635.             if(ts->pids[pid] && ts->pids[pid]->type == MPEGTS_PES){

  636.                 pes= ts->pids[pid]->u.pes_filter.opaque;

  637.                 st= pes->st;

  638.             }else{

  639.                 if (ts->pids[pid]) mpegts_close_filter(ts, ts->pids[pid]); //wrongly added sdt filter probably

  640.                 pes = add_pes_stream(ts, pid, pcr_pid, stream_type);

  641.                 if (pes)

  642.                     st = new_pes_av_stream(pes, 0);

  643.             }

  644.             add_pid_to_pmt(ts, h->id, pid);

  645.             if(st)

  646.                 av_program_add_stream_index(ts->stream, h->id, st->index);

  647.             break;

  648.         default:

  649.             /* we ignore the other streams */

  650.             break;

  651.         }

  652. 

  653.         if (st) {

  654.             if (language[0] != 0) {

  655.                 memcpy(st->language, language, 4);

  656.             }

  657. 

  658.             if (stream_type == STREAM_TYPE_SUBTITLE_DVB) {

  659.                 st->codec->sub_id = (anc_page << 16) | comp_page;

  660.             }

  661.         }

  662.     }

  663.     /* all parameters are there */

  664.     ts->stop_parse++;

  665.     mpegts_close_filter(ts, filter);

  666. }

  667. 

  668. static void pat_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)

  669. {

  670.     MpegTSContext *ts = filter->u.section_filter.opaque;

  671.     SectionHeader h1, *h = &h1;

  672.     const uint8_t *p, *p_end;

  673.     int sid, pmt_pid;

  674. 

  675. #ifdef DEBUG_SI

  676.     av_log(ts->stream, AV_LOG_DEBUG, "PAT:\n");

  677.     av_hex_dump_log(ts->stream, AV_LOG_DEBUG, (uint8_t *)section, section_len);

  678. #endif

  679.     p_end = section + section_len - 4;

  680.     p = section;

  681.     if (parse_section_header(h, &p, p_end) < 0)

  682.         return;

  683.     if (h->tid != PAT_TID)

  684.         return;

  685. 

  686.     clear_programs(ts);

  687.     for(;;) {

  688.         sid = get16(&p, p_end);

  689.         if (sid < 0)

  690.             break;

  691.         pmt_pid = get16(&p, p_end) & 0x1fff;

  692.         if (pmt_pid < 0)

  693.             break;

  694. #ifdef DEBUG_SI

  695.         av_log(ts->stream, AV_LOG_DEBUG, "sid=0x%x pid=0x%x\n", sid, pmt_pid);

  696. #endif

  697.         if (sid == 0x0000) {

  698.             /* NIT info */

  699.         } else {

  700.             av_new_program(ts->stream, sid);

  701.             ts->stop_parse--;

  702.             mpegts_open_section_filter(ts, pmt_pid, pmt_cb, ts, 1);

  703.             add_pat_entry(ts, sid);

  704.             add_pid_to_pmt(ts, sid, 0); //add pat pid to program

  705.             add_pid_to_pmt(ts, sid, pmt_pid);

  706.         }

  707.     }

  708.     /* not found */

  709.     ts->stop_parse++;

  710. 

  711.     mpegts_close_filter(ts, filter);

  712. }

  713. 

  714. static void mpegts_set_service(MpegTSContext *ts)

  715. {

  716.     mpegts_open_section_filter(ts, PAT_PID,

  717.                                                 pat_cb, ts, 1);

  718. }

  719. 

  720. static void sdt_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)

  721. {

  722.     MpegTSContext *ts = filter->u.section_filter.opaque;

  723.     SectionHeader h1, *h = &h1;

  724.     const uint8_t *p, *p_end, *desc_list_end, *desc_end;

  725.     int onid, val, sid, desc_list_len, desc_tag, desc_len, service_type;

  726.     char *name, *provider_name;

  727. 

  728. #ifdef DEBUG_SI

  729.     av_log(ts->stream, AV_LOG_DEBUG, "SDT:\n");

  730.     av_hex_dump_log(ts->stream, AV_LOG_DEBUG, (uint8_t *)section, section_len);

  731. #endif

  732. 

  733.     p_end = section + section_len - 4;

  734.     p = section;

  735.     if (parse_section_header(h, &p, p_end) < 0)

  736.         return;

  737.     if (h->tid != SDT_TID)

  738.         return;

  739.     onid = get16(&p, p_end);

  740.     if (onid < 0)

  741.         return;

  742.     val = get8(&p, p_end);

  743.     if (val < 0)

  744.         return;

  745.     for(;;) {

  746.         sid = get16(&p, p_end);

  747.         if (sid < 0)

  748.             break;

  749.         val = get8(&p, p_end);

  750.         if (val < 0)

  751.             break;

  752.         desc_list_len = get16(&p, p_end) & 0xfff;

  753.         if (desc_list_len < 0)

  754.             break;

  755.         desc_list_end = p + desc_list_len;

  756.         if (desc_list_end > p_end)

  757.             break;

  758.         for(;;) {

  759.             desc_tag = get8(&p, desc_list_end);

  760.             if (desc_tag < 0)

  761.                 break;

  762.             desc_len = get8(&p, desc_list_end);

  763.             desc_end = p + desc_len;

  764.             if (desc_end > desc_list_end)

  765.                 break;

  766. #ifdef DEBUG_SI

  767.             av_log(ts->stream, AV_LOG_DEBUG, "tag: 0x%02x len=%d\n",

  768.                    desc_tag, desc_len);

  769. #endif

  770.             switch(desc_tag) {

  771.             case 0x48:

  772.                 service_type = get8(&p, p_end);

  773.                 if (service_type < 0)

  774.                     break;

  775.                 provider_name = getstr8(&p, p_end);

  776.                 if (!provider_name)

  777.                     break;

  778.                 name = getstr8(&p, p_end);

  779.                 if (name) {

  780.                     AVProgram *program = av_new_program(ts->stream, sid);

  781.                     if(program)

  782.                         av_set_program_name(program, provider_name, name);

  783.                 }

  784.                 av_free(name);

  785.                 av_free(provider_name);

  786.                 break;

  787.             default:

  788.                 break;

  789.             }

  790.             p = desc_end;

  791.         }

  792.         p = desc_list_end;

  793.     }

  794. }

  795. 

  796. /* scan services in a transport stream by looking at the SDT */

  797. static void mpegts_scan_sdt(MpegTSContext *ts)

  798. {

  799.     mpegts_open_section_filter(ts, SDT_PID,

  800.                                                 sdt_cb, ts, 1);

  801. }

  802. 

  803. static int64_t get_pts(const uint8_t *p)

  804. {

  805.     int64_t pts = (int64_t)((p[0] >> 1) & 0x07) << 30;

  806.     pts |= (AV_RB16(p + 1) >> 1) << 15;

  807.     pts |=  AV_RB16(p + 3) >> 1;

  808.     return pts;

  809. }

  810. 

  811. /* return non zero if a packet could be constructed */

  812. static void mpegts_push_data(MpegTSFilter *filter,

  813.                              const uint8_t *buf, int buf_size, int is_start)

  814. {

  815.     PESContext *pes = filter->u.pes_filter.opaque;

  816.     MpegTSContext *ts = pes->ts;

  817.     const uint8_t *p;

  818.     int len, code;

  819. 

  820.     if(!ts->pkt)

  821.         return;

  822. 

  823.     if (is_start) {

  824.         pes->state = MPEGTS_HEADER;

  825.         pes->data_index = 0;

  826.     }

  827.     p = buf;

  828.     while (buf_size > 0) {

  829.         switch(pes->state) {

  830.         case MPEGTS_HEADER:

  831.             len = PES_START_SIZE - pes->data_index;

  832.             if (len > buf_size)

  833.                 len = buf_size;

  834.             memcpy(pes->header + pes->data_index, p, len);

  835.             pes->data_index += len;

  836.             p += len;

  837.             buf_size -= len;

  838.             if (pes->data_index == PES_START_SIZE) {

  839.                 /* we got all the PES or section header. We can now

  840.                    decide */

  841. #if 0

  842.                 av_hex_dump_log(pes->stream, AV_LOG_DEBUG, pes->header, pes->data_index);

  843. #endif

  844.                 if (pes->header[0] == 0x00 && pes->header[1] == 0x00 &&

  845.                     pes->header[2] == 0x01) {

  846.                     /* it must be an mpeg2 PES stream */

  847.                     code = pes->header[3] | 0x100;

  848.                     if (!((code >= 0x1c0 && code <= 0x1df) ||

  849.                           (code >= 0x1e0 && code <= 0x1ef) ||

  850.                           (code == 0x1bd) || (code == 0x1fd)))

  851.                         goto skip;

  852.                     if (!pes->st) {

  853.                         /* allocate stream */

  854.                         new_pes_av_stream(pes, code);

  855.                     }

  856.                     pes->state = MPEGTS_PESHEADER_FILL;

  857.                     pes->total_size = AV_RB16(pes->header + 4);

  858.                     /* NOTE: a zero total size means the PES size is

  859.                        unbounded */

  860.                     if (pes->total_size)

  861.                         pes->total_size += 6;

  862.                     pes->pes_header_size = pes->header[8] + 9;

  863.                 } else {

  864.                     /* otherwise, it should be a table */

  865.                     /* skip packet */

  866.                 skip:

  867.                     pes->state = MPEGTS_SKIP;

  868.                     continue;

  869.                 }

  870.             }

  871.             break;

  872.             /**********************************************/

  873.             /* PES packing parsing */

  874.         case MPEGTS_PESHEADER_FILL:

  875.             len = pes->pes_header_size - pes->data_index;

  876.             if (len > buf_size)

  877.                 len = buf_size;

  878.             memcpy(pes->header + pes->data_index, p, len);

  879.             pes->data_index += len;

  880.             p += len;

  881.             buf_size -= len;

  882.             if (pes->data_index == pes->pes_header_size) {

  883.                 const uint8_t *r;

  884.                 unsigned int flags;

  885. 

  886.                 flags = pes->header[7];

  887.                 r = pes->header + 9;

  888.                 pes->pts = AV_NOPTS_VALUE;

  889.                 pes->dts = AV_NOPTS_VALUE;

  890.                 if ((flags & 0xc0) == 0x80) {

  891.                     pes->pts = get_pts(r);

  892.                     r += 5;

  893.                 } else if ((flags & 0xc0) == 0xc0) {

  894.                     pes->pts = get_pts(r);

  895.                     r += 5;

  896.                     pes->dts = get_pts(r);

  897.                     r += 5;

  898.                 }

  899.                 /* we got the full header. We parse it and get the payload */

  900.                 pes->state = MPEGTS_PAYLOAD;

  901.             }

  902.             break;

  903.         case MPEGTS_PAYLOAD:

  904.             if (pes->total_size) {

  905.                 len = pes->total_size - pes->data_index;

  906.                 if (len > buf_size)

  907.                     len = buf_size;

  908.             } else {

  909.                 len = buf_size;

  910.             }

  911.             if (len > 0) {

  912.                 AVPacket *pkt = ts->pkt;

  913.                 if (pes->st && av_new_packet(pkt, len) == 0) {

  914.                     memcpy(pkt->data, p, len);

  915.                     pkt->stream_index = pes->st->index;

  916.                     pkt->pts = pes->pts;

  917.                     pkt->dts = pes->dts;

  918.                     /* reset pts values */

  919.                     pes->pts = AV_NOPTS_VALUE;

  920.                     pes->dts = AV_NOPTS_VALUE;

  921.                     ts->stop_parse = 1;

  922.                     return;

  923.                 }

  924.             }

  925.             buf_size = 0;

  926.             break;

  927.         case MPEGTS_SKIP:

  928.             buf_size = 0;

  929.             break;

  930.         }

  931.     }

  932. }

  933. 

  934. static AVStream* new_pes_av_stream(PESContext *pes, uint32_t code)

  935. {

  936.     AVStream *st;

  937.     int codec_type, codec_id;

  938. 

  939.     switch(pes->stream_type){

  940.     case STREAM_TYPE_AUDIO_MPEG1:

  941.     case STREAM_TYPE_AUDIO_MPEG2:

  942.         codec_type = CODEC_TYPE_AUDIO;

  943.         codec_id = CODEC_ID_MP3;

  944.         break;

  945.     case STREAM_TYPE_VIDEO_MPEG1:

  946.     case STREAM_TYPE_VIDEO_MPEG2:

  947.         codec_type = CODEC_TYPE_VIDEO;

  948.         codec_id = CODEC_ID_MPEG2VIDEO;

  949.         break;

  950.     case STREAM_TYPE_VIDEO_MPEG4:

  951.         codec_type = CODEC_TYPE_VIDEO;

  952.         codec_id = CODEC_ID_MPEG4;

  953.         break;

  954.     case STREAM_TYPE_VIDEO_H264:

  955.         codec_type = CODEC_TYPE_VIDEO;

  956.         codec_id = CODEC_ID_H264;

  957.         break;

  958.     case STREAM_TYPE_VIDEO_VC1:

  959.         codec_type = CODEC_TYPE_VIDEO;

  960.         codec_id = CODEC_ID_VC1;

  961.         break;

  962.     case STREAM_TYPE_VIDEO_DIRAC:

  963.         codec_type = CODEC_TYPE_VIDEO;

  964.         codec_id = CODEC_ID_DIRAC;

  965.         break;

  966.     case STREAM_TYPE_AUDIO_AAC:

  967.         codec_type = CODEC_TYPE_AUDIO;

  968.         codec_id = CODEC_ID_AAC;

  969.         break;

  970.     case STREAM_TYPE_AUDIO_AC3:

  971.         codec_type = CODEC_TYPE_AUDIO;

  972.         codec_id = CODEC_ID_AC3;

  973.         break;

  974.     case STREAM_TYPE_AUDIO_DTS:

  975.     case STREAM_TYPE_AUDIO_HDMV_DTS:

  976.         codec_type = CODEC_TYPE_AUDIO;

  977.         codec_id = CODEC_ID_DTS;

  978.         break;

  979.     case STREAM_TYPE_SUBTITLE_DVB:

  980.         codec_type = CODEC_TYPE_SUBTITLE;

  981.         codec_id = CODEC_ID_DVB_SUBTITLE;

  982.         break;

  983.     default:

  984.         if (code >= 0x1c0 && code <= 0x1df) {

  985.             codec_type = CODEC_TYPE_AUDIO;

  986.             codec_id = CODEC_ID_MP2;

  987.         } else if (code == 0x1bd) {

  988.             codec_type = CODEC_TYPE_AUDIO;

  989.             codec_id = CODEC_ID_AC3;

  990.         } else {

  991.             codec_type = CODEC_TYPE_VIDEO;

  992.             codec_id = CODEC_ID_PROBE;

  993.         }

  994.         break;

  995.     }

  996.     st = av_new_stream(pes->stream, pes->pid);

  997.     if (st) {

  998.         av_set_pts_info(st, 33, 1, 90000);

  999.         st->priv_data = pes;

  1000.         st->codec->codec_type = codec_type;

  1001.         st->codec->codec_id = codec_id;

  1002.         st->need_parsing = AVSTREAM_PARSE_FULL;

  1003.         pes->st = st;

  1004.     }

  1005.     return st;

  1006. }

  1007. 

  1008. 

  1009. static PESContext *add_pes_stream(MpegTSContext *ts, int pid, int pcr_pid, int stream_type)

  1010. {

  1011.     MpegTSFilter *tss;

  1012.     PESContext *pes;

  1013. 

  1014.     /* if no pid found, then add a pid context */

  1015.     pes = av_mallocz(sizeof(PESContext));

  1016.     if (!pes)

  1017.         return 0;

  1018.     pes->ts = ts;

  1019.     pes->stream = ts->stream;

  1020.     pes->pid = pid;

  1021.     pes->pcr_pid = pcr_pid;

  1022.     pes->stream_type = stream_type;

  1023.     tss = mpegts_open_pes_filter(ts, pid, mpegts_push_data, pes);

  1024.     if (!tss) {

  1025.         av_free(pes);

  1026.         return 0;

  1027.     }

  1028.     return pes;

  1029. }

  1030. 

  1031. /* handle one TS packet */

  1032. static void handle_packet(MpegTSContext *ts, const uint8_t *packet)

  1033. {

  1034.     AVFormatContext *s = ts->stream;

  1035.     MpegTSFilter *tss;

  1036.     int len, pid, cc, cc_ok, afc, is_start;

  1037.     const uint8_t *p, *p_end;

  1038. 

  1039.     pid = AV_RB16(packet + 1) & 0x1fff;

  1040.     if(pid && discard_pid(ts, pid))

  1041.         return;

  1042.     is_start = packet[1] & 0x40;

  1043.     tss = ts->pids[pid];

  1044.     if (ts->auto_guess && tss == NULL && is_start) {

  1045.         add_pes_stream(ts, pid, -1, 0);

  1046.         tss = ts->pids[pid];

  1047.     }

  1048.     if (!tss)

  1049.         return;

  1050. 

  1051.     /* continuity check (currently not used) */

  1052.     cc = (packet[3] & 0xf);

  1053.     cc_ok = (tss->last_cc < 0) || ((((tss->last_cc + 1) & 0x0f) == cc));

  1054.     tss->last_cc = cc;

  1055. 

  1056.     /* skip adaptation field */

  1057.     afc = (packet[3] >> 4) & 3;

  1058.     p = packet + 4;

  1059.     if (afc == 0) /* reserved value */

  1060.         return;

  1061.     if (afc == 2) /* adaptation field only */

  1062.         return;

  1063.     if (afc == 3) {

  1064.         /* skip adapation field */

  1065.         p += p[0] + 1;

  1066.     }

  1067.     /* if past the end of packet, ignore */

  1068.     p_end = packet + TS_PACKET_SIZE;

  1069.     if (p >= p_end)

  1070.         return;

  1071. 

  1072.     ts->pos47= url_ftell(ts->stream->pb) % ts->raw_packet_size;

  1073. 

  1074.     if (tss->type == MPEGTS_SECTION) {

  1075.         if (is_start) {

  1076.             /* pointer field present */

  1077.             len = *p++;

  1078.             if (p + len > p_end)

  1079.                 return;

  1080.             if (len && cc_ok) {

  1081.                 /* write remaining section bytes */

  1082.                 write_section_data(s, tss,

  1083.                                    p, len, 0);

  1084.                 /* check whether filter has been closed */

  1085.                 if (!ts->pids[pid])

  1086.                     return;

  1087.             }

  1088.             p += len;

  1089.             if (p < p_end) {

  1090.                 write_section_data(s, tss,

  1091.                                    p, p_end - p, 1);

  1092.             }

  1093.         } else {

  1094.             if (cc_ok) {

  1095.                 write_section_data(s, tss,

  1096.                                    p, p_end - p, 0);

  1097.             }

  1098.         }

  1099.     } else {

  1100.         tss->u.pes_filter.pes_cb(tss,

  1101.                                  p, p_end - p, is_start);

  1102.     }

  1103. }

  1104. 

  1105. /* XXX: try to find a better synchro over several packets (use

  1106.    get_packet_size() ?) */

  1107. static int mpegts_resync(ByteIOContext *pb)

  1108. {

  1109.     int c, i;

  1110. 

  1111.     for(i = 0;i < MAX_RESYNC_SIZE; i++) {

  1112.         c = url_fgetc(pb);

  1113.         if (c < 0)

  1114.             return -1;

  1115.         if (c == 0x47) {

  1116.             url_fseek(pb, -1, SEEK_CUR);

  1117.             return 0;

  1118.         }

  1119.     }

  1120.     /* no sync found */

  1121.     return -1;

  1122. }

  1123. 

  1124. /* return -1 if error or EOF. Return 0 if OK. */

  1125. static int read_packet(ByteIOContext *pb, uint8_t *buf, int raw_packet_size)

  1126. {

  1127.     int skip, len;

  1128. 

  1129.     for(;;) {

  1130.         len = get_buffer(pb, buf, TS_PACKET_SIZE);

  1131.         if (len != TS_PACKET_SIZE)

  1132.             return AVERROR(EIO);

  1133.         /* check paquet sync byte */

  1134.         if (buf[0] != 0x47) {

  1135.             /* find a new packet start */

  1136.             url_fseek(pb, -TS_PACKET_SIZE, SEEK_CUR);

  1137.             if (mpegts_resync(pb) < 0)

  1138.                 return AVERROR_INVALIDDATA;

  1139.             else

  1140.                 continue;

  1141.         } else {

  1142.             skip = raw_packet_size - TS_PACKET_SIZE;

  1143.             if (skip > 0)

  1144.                 url_fskip(pb, skip);

  1145.             break;

  1146.         }

  1147.     }

  1148.     return 0;

  1149. }

  1150. 

  1151. static int handle_packets(MpegTSContext *ts, int nb_packets)

  1152. {

  1153.     AVFormatContext *s = ts->stream;

  1154.     ByteIOContext *pb = s->pb;

  1155.     uint8_t packet[TS_PACKET_SIZE];

  1156.     int packet_num, ret;

  1157. 

  1158.     ts->stop_parse = 0;

  1159.     packet_num = 0;

  1160.     for(;;) {

  1161.         if (ts->stop_parse>0)

  1162.             break;

  1163.         packet_num++;

  1164.         if (nb_packets != 0 && packet_num >= nb_packets)

  1165.             break;

  1166.         ret = read_packet(pb, packet, ts->raw_packet_size);

  1167.         if (ret != 0)

  1168.             return ret;

  1169.         handle_packet(ts, packet);

  1170.     }

  1171.     return 0;

  1172. }

  1173. 

  1174. static int mpegts_probe(AVProbeData *p)

  1175. {

  1176. #if 1

  1177.     const int size= p->buf_size;

  1178.     int score, fec_score, dvhs_score;

  1179. #define CHECK_COUNT 10

  1180. 

  1181.     if (size < (TS_FEC_PACKET_SIZE * CHECK_COUNT))

  1182.         return -1;

  1183. 

  1184.     score    = analyze(p->buf, TS_PACKET_SIZE    *CHECK_COUNT, TS_PACKET_SIZE, NULL);

  1185.     dvhs_score  = analyze(p->buf, TS_DVHS_PACKET_SIZE    *CHECK_COUNT, TS_DVHS_PACKET_SIZE, NULL);

  1186.     fec_score= analyze(p->buf, TS_FEC_PACKET_SIZE*CHECK_COUNT, TS_FEC_PACKET_SIZE, NULL);

  1187. //    av_log(NULL, AV_LOG_DEBUG, "score: %d, dvhs_score: %d, fec_score: %d \n", score, dvhs_score, fec_score);

  1188. 

  1189. // we need a clear definition for the returned score otherwise things will become messy sooner or later

  1190.     if     (score > fec_score && score > dvhs_score && score > 6) return AVPROBE_SCORE_MAX + score     - CHECK_COUNT;

  1191.     else if(dvhs_score > score && dvhs_score > fec_score && dvhs_score > 6) return AVPROBE_SCORE_MAX + dvhs_score  - CHECK_COUNT;

  1192.     else if(                 fec_score > 6) return AVPROBE_SCORE_MAX + fec_score - CHECK_COUNT;

  1193.     else                                    return -1;

  1194. #else

  1195.     /* only use the extension for safer guess */

  1196.     if (match_ext(p->filename, "ts"))

  1197.         return AVPROBE_SCORE_MAX;

  1198.     else

  1199.         return 0;

  1200. #endif

  1201. }

  1202. 

  1203. /* return the 90 kHz PCR and the extension for the 27 MHz PCR. return

  1204.    (-1) if not available */

  1205. static int parse_pcr(int64_t *ppcr_high, int *ppcr_low,

  1206.                      const uint8_t *packet)

  1207. {

  1208.     int afc, len, flags;

  1209.     const uint8_t *p;

  1210.     unsigned int v;

  1211. 

  1212.     afc = (packet[3] >> 4) & 3;

  1213.     if (afc <= 1)

  1214.         return -1;

  1215.     p = packet + 4;

  1216.     len = p[0];

  1217.     p++;

  1218.     if (len == 0)

  1219.         return -1;

  1220.     flags = *p++;

  1221.     len--;

  1222.     if (!(flags & 0x10))

  1223.         return -1;

  1224.     if (len < 6)

  1225.         return -1;

  1226.     v = AV_RB32(p);

  1227.     *ppcr_high = ((int64_t)v << 1) | (p[4] >> 7);

  1228.     *ppcr_low = ((p[4] & 1) << 8) | p[5];

  1229.     return 0;

  1230. }

  1231. 

  1232. static int mpegts_read_header(AVFormatContext *s,

  1233.                               AVFormatParameters *ap)

  1234. {

  1235.     MpegTSContext *ts = s->priv_data;

  1236.     ByteIOContext *pb = s->pb;

  1237.     uint8_t buf[1024];

  1238.     int len;

  1239.     int64_t pos;

  1240. 

  1241.     if (ap) {

  1242.         ts->mpeg2ts_compute_pcr = ap->mpeg2ts_compute_pcr;

  1243.         if(ap->mpeg2ts_raw){

  1244.             av_log(s, AV_LOG_ERROR, "use mpegtsraw_demuxer!\n");

  1245.             return -1;

  1246.         }

  1247.     }

  1248. 

  1249.     /* read the first 1024 bytes to get packet size */

  1250.     pos = url_ftell(pb);

  1251.     len = get_buffer(pb, buf, sizeof(buf));

  1252.     if (len != sizeof(buf))

  1253.         goto fail;

  1254.     ts->raw_packet_size = get_packet_size(buf, sizeof(buf));

  1255.     if (ts->raw_packet_size <= 0)

  1256.         goto fail;

  1257.     ts->stream = s;

  1258.     ts->auto_guess = 0;

  1259. 

  1260.     if (s->iformat == &mpegts_demuxer) {

  1261.         /* normal demux */

  1262. 

  1263.         /* first do a scaning to get all the services */

  1264.         url_fseek(pb, pos, SEEK_SET);

  1265.         mpegts_scan_sdt(ts);

  1266. 

  1267.         mpegts_set_service(ts);

  1268. 

  1269.         handle_packets(ts, s->probesize);

  1270.         /* if could not find service, enable auto_guess */

  1271. 

  1272.         ts->auto_guess = 1;

  1273. 

  1274. #ifdef DEBUG_SI

  1275.         av_log(ts->stream, AV_LOG_DEBUG, "tuning done\n");

  1276. #endif

  1277.         s->ctx_flags |= AVFMTCTX_NOHEADER;

  1278.     } else {

  1279.         AVStream *st;

  1280.         int pcr_pid, pid, nb_packets, nb_pcrs, ret, pcr_l;

  1281.         int64_t pcrs[2], pcr_h;

  1282.         int packet_count[2];

  1283.         uint8_t packet[TS_PACKET_SIZE];

  1284. 

  1285.         /* only read packets */

  1286. 

  1287.         st = av_new_stream(s, 0);

  1288.         if (!st)

  1289.             goto fail;

  1290.         av_set_pts_info(st, 60, 1, 27000000);

  1291.         st->codec->codec_type = CODEC_TYPE_DATA;

  1292.         st->codec->codec_id = CODEC_ID_MPEG2TS;

  1293. 

  1294.         /* we iterate until we find two PCRs to estimate the bitrate */

  1295.         pcr_pid = -1;

  1296.         nb_pcrs = 0;

  1297.         nb_packets = 0;

  1298.         for(;;) {

  1299.             ret = read_packet(s->pb, packet, ts->raw_packet_size);

  1300.             if (ret < 0)

  1301.                 return -1;

  1302.             pid = AV_RB16(packet + 1) & 0x1fff;

  1303.             if ((pcr_pid == -1 || pcr_pid == pid) &&

  1304.                 parse_pcr(&pcr_h, &pcr_l, packet) == 0) {

  1305.                 pcr_pid = pid;

  1306.                 packet_count[nb_pcrs] = nb_packets;

  1307.                 pcrs[nb_pcrs] = pcr_h * 300 + pcr_l;

  1308.                 nb_pcrs++;

  1309.                 if (nb_pcrs >= 2)

  1310.                     break;

  1311.             }

  1312.             nb_packets++;

  1313.         }

  1314. 

  1315.         /* NOTE1: the bitrate is computed without the FEC */

  1316.         /* NOTE2: it is only the bitrate of the start of the stream */

  1317.         ts->pcr_incr = (pcrs[1] - pcrs[0]) / (packet_count[1] - packet_count[0]);

  1318.         ts->cur_pcr = pcrs[0] - ts->pcr_incr * packet_count[0];

  1319.         s->bit_rate = (TS_PACKET_SIZE * 8) * 27e6 / ts->pcr_incr;

  1320.         st->codec->bit_rate = s->bit_rate;

  1321.         st->start_time = ts->cur_pcr;

  1322. #if 0

  1323.         av_log(ts->stream, AV_LOG_DEBUG, "start=%0.3f pcr=%0.3f incr=%d\n",

  1324.                st->start_time / 1000000.0, pcrs[0] / 27e6, ts->pcr_incr);

  1325. #endif

  1326.     }

  1327. 

  1328.     url_fseek(pb, pos, SEEK_SET);

  1329.     return 0;

  1330.  fail:

  1331.     return -1;

  1332. }

  1333. 

  1334. #define MAX_PACKET_READAHEAD ((128 * 1024) / 188)

  1335. 

  1336. static int mpegts_raw_read_packet(AVFormatContext *s,

  1337.                                   AVPacket *pkt)

  1338. {

  1339.     MpegTSContext *ts = s->priv_data;

  1340.     int ret, i;

  1341.     int64_t pcr_h, next_pcr_h, pos;

  1342.     int pcr_l, next_pcr_l;

  1343.     uint8_t pcr_buf[12];

  1344. 

  1345.     if (av_new_packet(pkt, TS_PACKET_SIZE) < 0)

  1346.         return AVERROR(ENOMEM);

  1347.     pkt->pos= url_ftell(s->pb);

  1348.     ret = read_packet(s->pb, pkt->data, ts->raw_packet_size);

  1349.     if (ret < 0) {

  1350.         av_free_packet(pkt);

  1351.         return ret;

  1352.     }

  1353.     if (ts->mpeg2ts_compute_pcr) {

  1354.         /* compute exact PCR for each packet */

  1355.         if (parse_pcr(&pcr_h, &pcr_l, pkt->data) == 0) {

  1356.             /* we read the next PCR (XXX: optimize it by using a bigger buffer */

  1357.             pos = url_ftell(s->pb);

  1358.             for(i = 0; i < MAX_PACKET_READAHEAD; i++) {

  1359.                 url_fseek(s->pb, pos + i * ts->raw_packet_size, SEEK_SET);

  1360.                 get_buffer(s->pb, pcr_buf, 12);

  1361.                 if (parse_pcr(&next_pcr_h, &next_pcr_l, pcr_buf) == 0) {

  1362.                     /* XXX: not precise enough */

  1363.                     ts->pcr_incr = ((next_pcr_h - pcr_h) * 300 + (next_pcr_l - pcr_l)) /

  1364.                         (i + 1);

  1365.                     break;

  1366.                 }

  1367.             }

  1368.             url_fseek(s->pb, pos, SEEK_SET);

  1369.             /* no next PCR found: we use previous increment */

  1370.             ts->cur_pcr = pcr_h * 300 + pcr_l;

  1371.         }

  1372.         pkt->pts = ts->cur_pcr;

  1373.         pkt->duration = ts->pcr_incr;

  1374.         ts->cur_pcr += ts->pcr_incr;

  1375.     }

  1376.     pkt->stream_index = 0;

  1377.     return 0;

  1378. }

  1379. 

  1380. static int mpegts_read_packet(AVFormatContext *s,

  1381.                               AVPacket *pkt)

  1382. {

  1383.     MpegTSContext *ts = s->priv_data;

  1384. 

  1385.     ts->pkt = pkt;

  1386.     return handle_packets(ts, 0);

  1387. }

  1388. 

  1389. static int mpegts_read_close(AVFormatContext *s)

  1390. {

  1391.     MpegTSContext *ts = s->priv_data;

  1392.     int i;

  1393. 

  1394.     clear_programs(ts);

  1395. 

  1396.     for(i=0;i<NB_PID_MAX;i++)

  1397.         if (ts->pids[i]) mpegts_close_filter(ts, ts->pids[i]);

  1398. 

  1399.     return 0;

  1400. }

  1401. 

  1402. static int64_t mpegts_get_pcr(AVFormatContext *s, int stream_index,

  1403.                               int64_t *ppos, int64_t pos_limit)

  1404. {

  1405.     MpegTSContext *ts = s->priv_data;

  1406.     int64_t pos, timestamp;

  1407.     uint8_t buf[TS_PACKET_SIZE];

  1408.     int pcr_l, pcr_pid = ((PESContext*)s->streams[stream_index]->priv_data)->pcr_pid;

  1409.     const int find_next= 1;

  1410.     pos = ((*ppos  + ts->raw_packet_size - 1 - ts->pos47) / ts->raw_packet_size) * ts->raw_packet_size + ts->pos47;

  1411.     if (find_next) {

  1412.         for(;;) {

  1413.             url_fseek(s->pb, pos, SEEK_SET);

  1414.             if (get_buffer(s->pb, buf, TS_PACKET_SIZE) != TS_PACKET_SIZE)

  1415.                 return AV_NOPTS_VALUE;

  1416.             if ((pcr_pid < 0 || (AV_RB16(buf + 1) & 0x1fff) == pcr_pid) &&

  1417.                 parse_pcr(&timestamp, &pcr_l, buf) == 0) {

  1418.                 break;

  1419.             }

  1420.             pos += ts->raw_packet_size;

  1421.         }

  1422.     } else {

  1423.         for(;;) {

  1424.             pos -= ts->raw_packet_size;

  1425.             if (pos < 0)

  1426.                 return AV_NOPTS_VALUE;

  1427.             url_fseek(s->pb, pos, SEEK_SET);

  1428.             if (get_buffer(s->pb, buf, TS_PACKET_SIZE) != TS_PACKET_SIZE)

  1429.                 return AV_NOPTS_VALUE;

  1430.             if ((pcr_pid < 0 || (AV_RB16(buf + 1) & 0x1fff) == pcr_pid) &&

  1431.                 parse_pcr(&timestamp, &pcr_l, buf) == 0) {

  1432.                 break;

  1433.             }

  1434.         }

  1435.     }

  1436.     *ppos = pos;

  1437. 

  1438.     return timestamp;

  1439. }

  1440. 

  1441. static int read_seek(AVFormatContext *s, int stream_index, int64_t target_ts, int flags){

  1442.     MpegTSContext *ts = s->priv_data;

  1443.     uint8_t buf[TS_PACKET_SIZE];

  1444.     int64_t pos;

  1445. 

  1446.     if(av_seek_frame_binary(s, stream_index, target_ts, flags) < 0)

  1447.         return -1;

  1448. 

  1449.     pos= url_ftell(s->pb);

  1450. 

  1451.     for(;;) {

  1452.         url_fseek(s->pb, pos, SEEK_SET);

  1453.         if (get_buffer(s->pb, buf, TS_PACKET_SIZE) != TS_PACKET_SIZE)

  1454.             return -1;

  1455. //        pid = AV_RB16(buf + 1) & 0x1fff;

  1456.         if(buf[1] & 0x40) break;

  1457.         pos += ts->raw_packet_size;

  1458.     }

  1459.     url_fseek(s->pb, pos, SEEK_SET);

  1460. 

  1461.     return 0;

  1462. }

  1463. 

  1464. /**************************************************************/

  1465. /* parsing functions - called from other demuxers such as RTP */

  1466. 

  1467. MpegTSContext *mpegts_parse_open(AVFormatContext *s)

  1468. {

  1469.     MpegTSContext *ts;

  1470. 

  1471.     ts = av_mallocz(sizeof(MpegTSContext));

  1472.     if (!ts)

  1473.         return NULL;

  1474.     /* no stream case, currently used by RTP */

  1475.     ts->raw_packet_size = TS_PACKET_SIZE;

  1476.     ts->stream = s;

  1477.     ts->auto_guess = 1;

  1478.     return ts;

  1479. }

  1480. 

  1481. /* return the consumed length if a packet was output, or -1 if no

  1482.    packet is output */

  1483. int mpegts_parse_packet(MpegTSContext *ts, AVPacket *pkt,

  1484.                         const uint8_t *buf, int len)

  1485. {

  1486.     int len1;

  1487. 

  1488.     len1 = len;

  1489.     ts->pkt = pkt;

  1490.     ts->stop_parse = 0;

  1491.     for(;;) {

  1492.         if (ts->stop_parse>0)

  1493.             break;

  1494.         if (len < TS_PACKET_SIZE)

  1495.             return -1;

  1496.         if (buf[0] != 0x47) {

  1497.             buf++;

  1498.             len--;

  1499.         } else {

  1500.             handle_packet(ts, buf);

  1501.             buf += TS_PACKET_SIZE;

  1502.             len -= TS_PACKET_SIZE;

  1503.         }

  1504.     }

  1505.     return len1 - len;

  1506. }

  1507. 

  1508. void mpegts_parse_close(MpegTSContext *ts)

  1509. {

  1510.     int i;

  1511. 

  1512.     for(i=0;i<NB_PID_MAX;i++)

  1513.         av_free(ts->pids[i]);

  1514.     av_free(ts);

  1515. }

  1516. 

  1517. AVInputFormat mpegts_demuxer = {

  1518.     "mpegts",

  1519.     NULL_IF_CONFIG_SMALL("MPEG-2 transport stream format"),

  1520.     sizeof(MpegTSContext),

  1521.     mpegts_probe,

  1522.     mpegts_read_header,

  1523.     mpegts_read_packet,

  1524.     mpegts_read_close,

  1525.     read_seek,

  1526.     mpegts_get_pcr,

  1527.     .flags = AVFMT_SHOW_IDS|AVFMT_TS_DISCONT,

  1528. };

  1529. 

  1530. AVInputFormat mpegtsraw_demuxer = {

  1531.     "mpegtsraw",

  1532.     NULL_IF_CONFIG_SMALL("MPEG-2 raw transport stream format"),

  1533.     sizeof(MpegTSContext),

  1534.     NULL,

  1535.     mpegts_read_header,

  1536.     mpegts_raw_read_packet,

  1537.     mpegts_read_close,

  1538.     read_seek,

  1539.     mpegts_get_pcr,

  1540.     .flags = AVFMT_SHOW_IDS|AVFMT_TS_DISCONT,

  1541. };