42 #define MAX_RESYNC_SIZE 65536
44 #define MAX_PES_PAYLOAD 200*1024
46 #define MAX_MP4_DESCR_COUNT 16
88 #define MAX_PIDS_PER_PROGRAM 64
159 #define PES_START_SIZE 6
160 #define PES_HEADER_SIZE 9
161 #define MAX_PES_HEADER_SIZE (9 + 255)
191 for(i=0; i<ts->
nb_prg; i++)
192 if(ts->
prg[i].
id == programid)
219 for(i=0; i<ts->
nb_prg; i++) {
220 if(ts->
prg[i].
id == programid) {
244 int used = 0, discarded = 0;
257 for(i=0; i<ts->
nb_prg; i++) {
260 if(p->
pids[j] != pid)
274 return !used && discarded;
282 const uint8_t *buf,
int buf_size,
int is_start)
403 memset(stat, 0, packet_size*
sizeof(
int));
405 for(x=i=0; i<size-3; i++){
406 if(buf[i] == 0x47 && !(buf[i+1] & 0x80) && (buf[i+3] & 0x30)){
408 if(stat[x] > best_score){
415 if(x == packet_size) x= 0;
424 int score, fec_score, dvhs_score;
432 av_dlog(
NULL,
"score: %d, dvhs_score: %d, fec_score: %d \n",
433 score, dvhs_score, fec_score);
435 if (score > fec_score && score > dvhs_score)
return TS_PACKET_SIZE;
468 if ((p + 1) >= p_end)
484 len =
get8(&p, p_end);
487 if ((p + len) > p_end)
504 val =
get8(pp, p_end);
509 val =
get16(pp, p_end);
513 val =
get8(pp, p_end);
516 h->
version = (val >> 1) & 0x1f;
517 val =
get8(pp, p_end);
521 val =
get8(pp, p_end);
592 uint32_t stream_type,
const StreamType *types)
604 uint32_t stream_type, uint32_t prog_reg_desc)
615 "stream=%d stream_type=%x pid=%x prog_reg_desc=%.4s\n",
621 if (prog_reg_desc ==
AV_RL32(
"HDMV") &&
632 memcpy(sub_pes, pes,
sizeof(*sub_pes));
640 sub_st->
id = pes->
pid;
692 int au_start_flag = 0, au_end_flag = 0, ocr_flag = 0, idle_flag = 0;
693 int padding_flag = 0, padding_bits = 0, inst_bitrate_flag = 0;
694 int dts_flag = -1, cts_flag = -1;
703 au_start_flag = au_end_flag = 1;
713 if (!idle_flag && (!padding_flag || padding_bits != 0)) {
739 if (inst_bitrate_flag)
756 const uint8_t *buf,
int buf_size,
int is_start,
777 while (buf_size > 0) {
793 code = pes->
header[3] | 0x100;
822 if (code != 0x1bc && code != 0x1bf &&
823 code != 0x1f0 && code != 0x1f1 &&
824 code != 0x1ff && code != 0x1f2 &&
874 unsigned int flags, pes_ext, skip;
880 if ((flags & 0xc0) == 0x80) {
883 }
else if ((flags & 0xc0) == 0xc0) {
893 skip = (pes_ext >> 4) & 0xb;
896 if ((pes_ext & 0x41) == 0x01 &&
899 if ((r[0] & 0x7f) > 0 && (r[1] & 0x80) == 0)
910 p += sl_header_bytes;
911 buf_size -= sl_header_bytes;
916 if (buf_size > 0 && pes->
buffer) {
1012 (*len) -= new_off - *
off;
1047 if (!(id_flags & 0x0020)) {
1124 if (len < 0 || len1 > len || len1 <= 0) {
1125 av_log(d->
s,
AV_LOG_ERROR,
"Tag %x length violation new length %d bytes remaining %d\n", tag, len1, len);
1134 if (target_tag && tag != target_tag) {
1164 Mp4Descr *descr,
int *descr_count,
int max_descr_count)
1177 Mp4Descr *descr,
int *descr_count,
int max_descr_count)
1197 int mp4_descr_count = 0;
1201 p_end = section + section_len - 4;
1216 for (i = 0; i < mp4_descr_count; i++) {
1231 pes->
sl = mp4_descr[i].
sl;
1253 for (i = 0; i < mp4_descr_count; i++)
1254 av_free(mp4_descr[i].dec_config_descr);
1259 Mp4Descr *mp4_descr,
int mp4_descr_count,
int pid,
1263 int desc_len, desc_tag, desc_es_id;
1267 desc_tag =
get8(pp, desc_list_end);
1270 desc_len =
get8(pp, desc_list_end);
1273 desc_end = *pp + desc_len;
1274 if (desc_end > desc_list_end)
1277 av_dlog(fc,
"tag: 0x%02x len=%d\n", desc_tag, desc_len);
1285 desc_es_id =
get16(pp, desc_end);
1286 if (ts && ts->
pids[pid])
1288 for (i = 0; i < mp4_descr_count; i++)
1289 if (mp4_descr[i].dec_config_descr_len &&
1290 mp4_descr[i].es_id == desc_es_id) {
1303 get16(pp, desc_end);
1316 language[0] =
get8(pp, desc_end);
1317 language[1] =
get8(pp, desc_end);
1318 language[2] =
get8(pp, desc_end);
1323 language[0] =
get8(pp, desc_end);
1324 language[1] =
get8(pp, desc_end);
1325 language[2] =
get8(pp, desc_end);
1328 switch(
get8(pp, desc_end)) {
1352 for (i = 0; i + 4 <= desc_len; i += 4) {
1353 language[i + 0] =
get8(pp, desc_end);
1354 language[i + 1] =
get8(pp, desc_end);
1355 language[i + 2] =
get8(pp, desc_end);
1356 language[i + 3] =
',';
1357 switch (
get8(pp, desc_end)) {
1364 language[i - 1] = 0;
1388 const uint8_t *p, *p_end, *desc_list_end;
1389 int program_info_length, pcr_pid, pid, stream_type;
1391 uint32_t prog_reg_desc = 0;
1394 int mp4_descr_count = 0;
1400 p_end = section + section_len - 4;
1415 pcr_pid =
get16(&p, p_end);
1423 program_info_length =
get16(&p, p_end);
1424 if (program_info_length < 0)
1426 program_info_length &= 0xfff;
1427 while(program_info_length >= 2) {
1429 tag =
get8(&p, p_end);
1430 len =
get8(&p, p_end);
1432 av_dlog(ts->
stream,
"program tag: 0x%02x len=%d\n", tag, len);
1434 if(len > program_info_length - 2)
1437 program_info_length -= len + 2;
1444 }
else if (tag == 0x05 && len >= 4) {
1445 prog_reg_desc = bytestream_get_le32(&p);
1450 p += program_info_length;
1461 stream_type =
get8(&p, p_end);
1462 if (stream_type < 0)
1464 pid =
get16(&p, p_end);
1477 }
else if (stream_type != 0x13) {
1505 desc_list_len =
get16(&p, p_end);
1506 if (desc_list_len < 0)
1508 desc_list_len &= 0xfff;
1509 desc_list_end = p + desc_list_len;
1510 if (desc_list_end > p_end)
1514 mp4_descr, mp4_descr_count, pid, ts) < 0)
1517 if (pes && prog_reg_desc ==
AV_RL32(
"HDMV") && stream_type == 0x83 && pes->
sub_st) {
1526 for (i = 0; i < mp4_descr_count; i++)
1527 av_free(mp4_descr[i].dec_config_descr);
1541 p_end = section + section_len - 4;
1553 sid =
get16(&p, p_end);
1556 pmt_pid =
get16(&p, p_end);
1563 if (sid == 0x0000) {
1567 if (ts->
pids[pmt_pid])
1582 const uint8_t *p, *p_end, *desc_list_end, *desc_end;
1583 int onid, val, sid, desc_list_len, desc_tag, desc_len, service_type;
1584 char *
name, *provider_name;
1589 p_end = section + section_len - 4;
1599 onid =
get16(&p, p_end);
1602 val =
get8(&p, p_end);
1606 sid =
get16(&p, p_end);
1609 val =
get8(&p, p_end);
1612 desc_list_len =
get16(&p, p_end);
1613 if (desc_list_len < 0)
1615 desc_list_len &= 0xfff;
1616 desc_list_end = p + desc_list_len;
1617 if (desc_list_end > p_end)
1620 desc_tag =
get8(&p, desc_list_end);
1623 desc_len =
get8(&p, desc_list_end);
1624 desc_end = p + desc_len;
1625 if (desc_end > desc_list_end)
1629 desc_tag, desc_len);
1633 service_type =
get8(&p, p_end);
1634 if (service_type < 0)
1636 provider_name =
getstr8(&p, p_end);
1664 int len, pid, cc, expected_cc, cc_ok, afc, is_start, is_discontinuity,
1665 has_adaptation, has_payload;
1669 pid =
AV_RB16(packet + 1) & 0x1fff;
1672 is_start = packet[1] & 0x40;
1673 tss = ts->
pids[pid];
1676 tss = ts->
pids[pid];
1681 afc = (packet[3] >> 4) & 3;
1684 has_adaptation = afc & 2;
1685 has_payload = afc & 1;
1686 is_discontinuity = has_adaptation
1688 && (packet[5] & 0x80);
1691 cc = (packet[3] & 0xf);
1692 expected_cc = has_payload ? (tss->
last_cc + 1) & 0x0f : tss->
last_cc;
1693 cc_ok = pid == 0x1FFF
1696 || expected_cc == cc;
1701 "Continuity check failed for pid %d expected %d got %d\n",
1702 pid, expected_cc, cc);
1712 if (has_adaptation) {
1728 if (p + len > p_end)
1792 if ((*data)[0] != 0x47) {
1819 int packet_num, ret = 0;
1845 if (nb_packets != 0 && packet_num >= nb_packets)
1862 int score, fec_score, dvhs_score;
1864 #define CHECK_COUNT 10
1872 av_dlog(
NULL,
"score: %d, dvhs_score: %d, fec_score: %d \n",
1873 score, dvhs_score, fec_score);
1877 else if(dvhs_score > score && dvhs_score > fec_score && dvhs_score > 6)
return AVPROBE_SCORE_MAX + dvhs_score - CHECK_COUNT;
1891 afc = (packet[3] >> 4) & 3;
1901 if (!(flags & 0x10))
1906 *ppcr_high = ((int64_t)v << 1) | (p[4] >> 7);
1907 *ppcr_low = ((p[4] & 1) << 8) | p[5];
1922 if (len !=
sizeof(buf))
1930 if (s->
iformat == &ff_mpegts_demuxer) {
1951 int pcr_pid, pid, nb_packets, nb_pcrs, ret, pcr_l;
1952 int64_t pcrs[2], pcr_h;
1953 int packet_count[2];
1974 pid =
AV_RB16(data + 1) & 0x1fff;
1975 if ((pcr_pid == -1 || pcr_pid == pid) &&
1979 packet_count[nb_pcrs] = nb_packets;
1980 pcrs[nb_pcrs] = pcr_h * 300 + pcr_l;
1992 ts->
pcr_incr = (pcrs[1] - pcrs[0]) / (packet_count[1] - packet_count[0]);
2007 #define MAX_PACKET_READAHEAD ((128 * 1024) / 188)
2014 int64_t pcr_h, next_pcr_h, pos;
2015 int pcr_l, next_pcr_l;
2027 if (data != pkt->
data)
2038 if (
parse_pcr(&next_pcr_h, &next_pcr_l, pcr_buf) == 0) {
2040 ts->
pcr_incr = ((next_pcr_h - pcr_h) * 300 + (next_pcr_l - pcr_l)) /
2047 ts->
cur_pcr = pcr_h * 300 + pcr_l;
2081 if (!ret && pkt->
size < 0)
2104 int64_t *ppos, int64_t pos_limit)
2107 int64_t pos, timestamp;
2110 const int find_next= 1;
2117 if ((pcr_pid < 0 || (
AV_RB16(buf + 1) & 0x1fff) == pcr_pid) &&
2118 parse_pcr(×tamp, &pcr_l, buf) == 0) {
2131 if ((pcr_pid < 0 || (
AV_RB16(buf + 1) & 0x1fff) == pcr_pid) &&
2132 parse_pcr(×tamp, &pcr_l, buf) == 0) {
2157 if(buf[1] & 0x40)
break;
2197 if (buf[0] != 0x47) {
2229 .
name =
"mpegtsraw",
2238 .priv_class = &mpegtsraw_class,