Go to the documentation of this file.
22 #include "config_components.h"
52 #define MAX_RESYNC_SIZE 65536
54 #define MAX_MP4_DESCR_COUNT 16
56 #define MOD_UNLIKELY(modulus, dividend, divisor, prev_dividend) \
58 if ((prev_dividend) == 0 || (dividend) - (prev_dividend) != (divisor)) \
59 (modulus) = (dividend) % (divisor); \
60 (prev_dividend) = (dividend); \
63 #define PROBE_PACKET_MAX_BUF 8192
64 #define PROBE_PACKET_MARGIN 5
75 int is_start, int64_t
pos);
117 #define MAX_STREAMS_PER_PROGRAM 128
118 #define MAX_PIDS_PER_PROGRAM (MAX_STREAMS_PER_PROGRAM + 2)
185 #define MPEGTS_OPTIONS \
186 { "resync_size", "set size limit for looking up a new synchronization", offsetof(MpegTSContext, resync_size), AV_OPT_TYPE_INT, { .i64 = MAX_RESYNC_SIZE}, 0, INT_MAX, AV_OPT_FLAG_DECODING_PARAM }
201 {.i64 = 0}, 0, 1, 0 },
203 {.i64 = 0}, 0, 1, 0 },
218 {
"compute_pcr",
"compute exact PCR for each transport stream packet",
221 {
"ts_packetsize",
"output option carrying the raw packet size",
246 #define PES_START_SIZE 6
247 #define PES_HEADER_SIZE 9
248 #define MAX_PES_HEADER_SIZE (9 + 255)
280 if (ts->
prg[
i].
id == programid) {
343 if (p->
pids[
i] == pid)
353 for (
i = 0;
i <
s->nb_programs;
i++) {
355 if (
program->id == programid) {
356 int old_pcr_pid =
program->pcr_pid,
357 old_version =
program->pmt_version;
361 if (old_version != -1 && old_version !=
version) {
363 "detected PMT change (program=%d, version=%d/%d, pcr_pid=0x%x/0x%x)\n",
364 programid, old_version,
version, old_pcr_pid, pid);
382 int used = 0, discarded = 0;
398 for (j = 0; j < p->
nb_pids; j++) {
399 if (p->
pids[j] != pid)
413 return !used && discarded;
421 const uint8_t *buf,
int buf_size,
int is_start)
424 uint8_t *cur_section_buf =
NULL;
447 len = (
AV_RB16(cur_section_buf + 1) & 0xfff) + 3;
527 sec = &
filter->u.section_filter;
547 pes = &
filter->u.pes_filter;
587 memset(stat, 0, packet_size *
sizeof(*stat));
589 for (
i = 0;
i <
size - 3;
i++) {
590 if (buf[
i] == 0x47) {
591 int pid =
AV_RB16(buf+1) & 0x1FFF;
592 int asc = buf[
i + 3] & 0x30;
593 if (!
probe || pid == 0x1FFF || asc) {
594 int x =
i % packet_size;
597 if (stat[x] > best_score) {
598 best_score = stat[x];
604 return best_score -
FFMAX(stat_all - 10*best_score, 0)/10;
610 int score, fec_score, dvhs_score;
617 int max_iterations = 16;
629 buf_size, score, dvhs_score, fec_score);
631 margin =
mid_pred(score, fec_score, dvhs_score);
638 else if (dvhs_score > margin)
640 else if (fec_score > margin)
666 static inline int get8(
const uint8_t **pp,
const uint8_t *p_end)
679 static inline int get16(
const uint8_t **pp,
const uint8_t *p_end)
694 static char *
getstr8(
const uint8_t **pp,
const uint8_t *p_end)
708 const char *encodings[] = {
709 "ISO6937",
"ISO-8859-5",
"ISO-8859-6",
"ISO-8859-7",
710 "ISO-8859-8",
"ISO-8859-9",
"ISO-8859-10",
"ISO-8859-11",
711 "",
"ISO-8859-13",
"ISO-8859-14",
"ISO-8859-15",
"",
"",
"",
"",
712 "",
"UCS-2BE",
"KSC_5601",
"GB2312",
"UCS-2BE",
"UTF-8",
"",
"",
713 "",
"",
"",
"",
"",
"",
"",
""
717 size_t inlen =
len, outlen = inlen * 6 + 1;
718 if (
len >= 3 && p[0] == 0x10 && !p[1] && p[2] && p[2] <= 0
xf && p[2] != 0xc) {
720 snprintf(iso8859,
sizeof(iso8859),
"ISO-8859-%d", p[2]);
723 cd = iconv_open(
"UTF-8", iso8859);
724 }
else if (p[0] < 0x20) {
727 cd = iconv_open(
"UTF-8", encodings[*p]);
730 cd = iconv_open(
"UTF-8", encodings[0]);
732 if (cd == (iconv_t)-1)
739 if (iconv(cd, &in, &inlen, &
out, &outlen) == -1) {
762 const uint8_t **pp,
const uint8_t *p_end)
778 h->version = (
val >> 1) & 0x1f;
779 h->current_next =
val & 0x01;
787 h->last_sec_num =
val;
806 #if !CONFIG_LOAS_DEMUXER
893 uint32_t stream_type,
911 uint32_t stream_type, uint32_t prog_reg_desc)
932 "stream=%d stream_type=%x pid=%x prog_reg_desc=%.4s\n",
940 if ((prog_reg_desc ==
AV_RL32(
"HDMV") ||
941 prog_reg_desc ==
AV_RL32(
"HDPR")) &&
959 sub_st->
id = pes->
pid;
1058 const uint8_t *buf,
int buf_size)
1061 int au_start_flag = 0, au_end_flag = 0, ocr_flag = 0, idle_flag = 0;
1062 int padding_flag = 0, padding_bits = 0, inst_bitrate_flag = 0;
1063 int dts_flag = -1, cts_flag = -1;
1068 memcpy(buf_padded, buf, buf_padded_size);
1077 au_start_flag = au_end_flag = 1;
1087 if (!idle_flag && (!padding_flag || padding_bits != 0)) {
1095 if (au_start_flag) {
1113 if (inst_bitrate_flag)
1142 const uint8_t *buf,
int buf_size,
int is_start,
1166 while (buf_size > 0) {
1167 switch (pes->
state) {
1179 if (pes->
header[0] == 0x00 && pes->
header[1] == 0x00 &&
1180 pes->
header[2] == 0x01) {
1219 "pid=%x stream_type=%x probing\n",
1273 if ((
flags & 0xc0) == 0x80) {
1276 }
else if ((
flags & 0xc0) == 0xc0) {
1286 skip = (pes_ext >> 4) & 0xb;
1289 if ((pes_ext & 0x41) == 0x01 &&
1292 if ((
r[0] & 0x7f) > 0 && (
r[1] & 0x80) == 0)
1304 p += sl_header_bytes;
1305 buf_size -= sl_header_bytes;
1336 if (
f->last_pcr != -1 && !
f->discard) {
1341 int64_t pcr =
f->last_pcr / 300;
1351 pes->
pts = pes->
dts = pcr;
1353 pes->
dts > pcr + 3654 + 9000) {
1354 pes->
pts = pes->
dts = pcr + 3654 + 9000;
1356 pes->
dts > pcr + 10*90000) {
1357 pes->
pts = pes->
dts = pcr + 3654 + 9000;
1368 "Forcing DTS/PTS to be unset for a "
1369 "non-trustworthy PES packet for PID %d as "
1370 "PCR hasn't been received yet.\n",
1384 pes->
data_index + buf_size > max_packet_size) {
1392 buf_size > max_packet_size) {
1395 buf_size = max_packet_size;
1466 const uint8_t *buf,
unsigned size,
1467 Mp4Descr *descr,
int max_descr_count)
1469 if (
size > (1 << 30))
1479 d->active_descr =
NULL;
1480 d->max_descr_count = max_descr_count;
1488 (*len) -= new_off - *off;
1525 if (!(id_flags & 0x0020)) {
1539 if (
d->descr_count >=
d->max_descr_count)
1542 d->active_descr =
d->descr + (
d->descr_count++);
1544 d->active_descr->es_id = es_id;
1551 d->active_descr =
NULL;
1577 #define R8_CHECK_CLIP_MAX(dst, maxv) do { \
1578 descr->sl.dst = avio_r8(pb); \
1579 if (descr->sl.dst > maxv) { \
1580 descr->sl.dst = maxv; \
1581 return AVERROR_INVALIDDATA; \
1605 }
else if (!
d->predefined_SLConfigDescriptor_seen){
1607 d->predefined_SLConfigDescriptor_seen = 1;
1621 if (len < 0 || len1 >
len || len1 <= 0) {
1623 "Tag %x length violation new length %d bytes remaining %d\n",
1634 if (target_tag &&
tag != target_tag) {
1667 Mp4Descr *descr,
int *descr_count,
int max_descr_count)
1678 *descr_count =
d.descr_count;
1683 Mp4Descr *descr,
int *descr_count,
int max_descr_count)
1694 *descr_count =
d.descr_count;
1704 const uint8_t *p, *p_end;
1705 int mp4_descr_count = 0;
1710 p_end =
section + section_len - 4;
1719 mp4_read_od(
s, p, (
unsigned) (p_end - p), mp4_descr, &mp4_descr_count,
1725 for (
i = 0;
i < mp4_descr_count;
i++) {
1742 pes->
sl = mp4_descr[
i].
sl;
1745 mp4_descr[
i].dec_config_descr_len, 0,
1759 for (
i = 0;
i < mp4_descr_count;
i++)
1760 av_free(mp4_descr[
i].dec_config_descr);
1785 if (
f &&
f->last_pcr != -1)
1793 1, 0, 1, 1, 2, 2, 2, 3, 3
1797 1, 1, 1, 2, 2, 3, 4, 4, 5,
1808 { 0,6,1,2,3,4,5,7 },
1812 const uint8_t **pp,
const uint8_t *desc_list_end,
1813 Mp4Descr *mp4_descr,
int mp4_descr_count,
int pid,
1817 const uint8_t *desc_end;
1818 int desc_len, desc_tag, desc_es_id, ext_desc_tag,
channels, channel_config_code;
1822 desc_tag =
get8(pp, desc_list_end);
1825 desc_len =
get8(pp, desc_list_end);
1828 desc_end = *pp + desc_len;
1829 if (desc_end > desc_list_end)
1840 if (
get8(pp, desc_end) & 0x1) {
1845 desc_es_id =
get16(pp, desc_end);
1848 if (ts && ts->
pids[pid])
1850 for (
i = 0;
i < mp4_descr_count;
i++)
1851 if (mp4_descr[
i].dec_config_descr_len &&
1852 mp4_descr[
i].es_id == desc_es_id) {
1855 mp4_descr[
i].dec_config_descr_len, 0,
1868 if (
get16(pp, desc_end) < 0)
1870 if (mp4_descr_count > 0 &&
1890 uint8_t *extradata =
NULL;
1891 int language_count = desc_len / 5,
ret;
1893 if (desc_len > 0 && desc_len % 5 != 0)
1896 if (language_count > 0) {
1911 for (
i = 0;
i < language_count;
i++) {
1917 memcpy(extradata, *pp, 2);
1936 int language_count = desc_len / 8,
ret;
1938 if (desc_len > 0 && desc_len % 8 != 0)
1941 if (language_count > 1) {
1945 if (language_count > 0) {
1962 for (
i = 0;
i < language_count;
i++) {
1980 extradata[4] =
get8(pp, desc_end);
1981 memcpy(extradata, *pp, 4);
1994 for (
i = 0;
i + 4 <= desc_len;
i += 4) {
1999 switch (
get8(pp, desc_end)) {
2032 if (
get16(pp, desc_end) == 0xFFFF)
2034 if (
get8(pp, desc_end) == 0xFF) {
2041 ext_desc_tag =
get8(pp, desc_end);
2042 if (ext_desc_tag < 0)
2045 ext_desc_tag == 0x80) {
2055 channel_config_code =
get8(pp, desc_end);
2056 if (channel_config_code < 0)
2058 if (channel_config_code <= 0x8) {
2073 if (ext_desc_tag == 0x06) {
2080 if ((
flags & 0x80) == 0)
2083 switch ((
flags >> 2) & 0x1F) {
2113 int component_type_flag =
get8(pp, desc_end) & (1 << 7);
2114 if (component_type_flag) {
2115 int component_type =
get8(pp, desc_end);
2116 int service_type_mask = 0x38;
2117 int service_type = ((component_type & service_type_mask) >> 3);
2118 if (service_type == 0x02 ) {
2127 int component_type_flag =
get8(pp, desc_end) & (1 << 7);
2128 if (component_type_flag) {
2129 int component_type =
get8(pp, desc_end);
2130 int service_type_mask = 0x38;
2131 int service_type = ((component_type & service_type_mask) >> 3);
2132 if (service_type == 0x02 ) {
2150 int data_component_id =
get16(pp, desc_end);
2151 if (data_component_id < 0)
2154 switch (data_component_id) {
2158 if (actual_component_tag >= 0x30 &&
2159 actual_component_tag <= 0x37) {
2166 if (actual_component_tag == 0x87) {
2195 if (desc_end - *pp < 4)
2204 buf =
get16(pp, desc_end);
2206 dovi->
dv_level = (buf >> 3) & 0x3f;
2211 buf =
get16(pp, desc_end);
2212 dependency_pid = buf >> 3;
2214 if (desc_end - *pp >= 1) {
2215 buf =
get8(pp, desc_end);
2224 (uint8_t *)dovi, dovi_size);
2231 "rpu flag: %d, el flag: %d, bl flag: %d, dependency_pid: %d, compatibility id: %d\n",
2232 dovi->dv_version_major, dovi->dv_version_minor,
2233 dovi->dv_profile, dovi->dv_level,
2234 dovi->rpu_present_flag,
2235 dovi->el_present_flag,
2236 dovi->bl_present_flag,
2238 dovi->dv_bl_signal_compatibility_id);
2249 int stream_identifier,
int pmt_stream_idx,
struct Program *p)
2254 if (stream_identifier) {
2257 if (!found || pmt_stream_idx ==
i)
2261 found =
s->streams[p->
streams[pmt_stream_idx].
idx];
2266 "re-using existing %s stream %d (pid=0x%x) for new pid=0x%x\n",
2268 found->
index, found->
id, pid);
2276 const uint8_t **pp = &p;
2277 const uint8_t *desc_list_end;
2278 const uint8_t *desc_end;
2280 int desc_len, desc_tag;
2282 desc_list_len =
get16(pp, p_end);
2283 if (desc_list_len < 0)
2285 desc_list_len &= 0xfff;
2286 desc_list_end = p + desc_list_len;
2287 if (desc_list_end > p_end)
2291 desc_tag =
get8(pp, desc_list_end);
2294 desc_len =
get8(pp, desc_list_end);
2297 desc_end = *pp + desc_len;
2298 if (desc_end > desc_list_end)
2301 if (desc_tag == 0x52) {
2302 return get8(pp, desc_end);
2312 return !(stream_type == 0x13 ||
2313 (stream_type == 0x86 && prog_reg_desc ==
AV_RL32(
"CUEI")) );
2324 const uint8_t *p, *p_end, *desc_list_end;
2325 int program_info_length, pcr_pid, pid, stream_type;
2327 uint32_t prog_reg_desc = 0;
2328 int stream_identifier = -1;
2331 int mp4_descr_count = 0;
2338 p_end =
section + section_len - 4;
2344 if (!
h->current_next)
2350 h->id,
h->sec_num,
h->last_sec_num,
h->version,
h->tid);
2370 pcr_pid =
get16(&p, p_end);
2379 program_info_length =
get16(&p, p_end);
2380 if (program_info_length < 0)
2382 program_info_length &= 0xfff;
2383 while (program_info_length >= 2) {
2390 program_info_length -= 2;
2391 if (
len > program_info_length)
2394 program_info_length -=
len;
2402 prog_reg_desc = bytestream_get_le32(&p);
2407 p += program_info_length;
2421 stream_type =
get8(&p, p_end);
2422 if (stream_type < 0)
2424 pid =
get16(&p, p_end);
2463 if (pes && !pes->
st) {
2483 if (stream_type == 0x86 && prog_reg_desc ==
AV_RL32(
"CUEI")) {
2505 desc_list_len =
get16(&p, p_end);
2506 if (desc_list_len < 0)
2508 desc_list_len &= 0xfff;
2509 desc_list_end = p + desc_list_len;
2510 if (desc_list_end > p_end)
2514 desc_list_end, mp4_descr,
2515 mp4_descr_count, pid, ts) < 0)
2518 if (pes && prog_reg_desc ==
AV_RL32(
"HDMV") &&
2519 stream_type == 0x83 && pes->
sub_st) {
2528 if (!ts->
pids[pcr_pid])
2532 for (
i = 0;
i < mp4_descr_count;
i++)
2533 av_free(mp4_descr[
i].dec_config_descr);
2541 const uint8_t *p, *p_end;
2549 p_end =
section + section_len - 4;
2555 if (!
h->current_next)
2565 sid =
get16(&p, p_end);
2568 pmt_pid =
get16(&p, p_end);
2578 if (sid == 0x0000) {
2590 || fil->
pid != pmt_pid
2594 if (!ts->
pids[pmt_pid])
2598 unsigned prg_idx = prg - ts->
prg;
2602 if (prg_idx > nb_prg)
2604 if (prg_idx >= nb_prg)
2626 const uint8_t *p, *p_end;
2646 p_end =
section + section_len - 4;
2660 if (
h->id == 0xFFFF) {
2682 const uint8_t *p, *p_end, *desc_list_end, *desc_end;
2683 int onid,
val, sid, desc_list_len, desc_tag, desc_len, service_type;
2684 char *
name, *provider_name;
2689 p_end =
section + section_len - 4;
2695 if (!
h->current_next)
2702 onid =
get16(&p, p_end);
2709 sid =
get16(&p, p_end);
2715 desc_list_len =
get16(&p, p_end);
2716 if (desc_list_len < 0)
2718 desc_list_len &= 0xfff;
2719 desc_list_end = p + desc_list_len;
2720 if (desc_list_end > p_end)
2723 desc_tag =
get8(&p, desc_list_end);
2726 desc_len =
get8(&p, desc_list_end);
2727 desc_end = p + desc_len;
2728 if (desc_len < 0 || desc_end > desc_list_end)
2732 desc_tag, desc_len);
2736 service_type =
get8(&p, desc_end);
2737 if (service_type < 0)
2739 provider_name =
getstr8(&p, desc_end);
2763 static int parse_pcr(int64_t *ppcr_high,
int *ppcr_low,
2764 const uint8_t *packet);
2770 int len, pid, cc, expected_cc, cc_ok, afc, is_start, is_discontinuity,
2771 has_adaptation, has_payload;
2772 const uint8_t *p, *p_end;
2774 pid =
AV_RB16(packet + 1) & 0x1fff;
2775 is_start = packet[1] & 0x40;
2776 tss = ts->
pids[pid];
2779 tss = ts->
pids[pid];
2789 afc = (packet[3] >> 4) & 3;
2792 has_adaptation = afc & 2;
2793 has_payload = afc & 1;
2794 is_discontinuity = has_adaptation &&
2799 cc = (packet[3] & 0xf);
2800 expected_cc = has_payload ? (tss->
last_cc + 1) & 0x0f : tss->
last_cc;
2801 cc_ok = pid == 0x1FFF ||
2809 "Continuity check failed for pid %d expected %d got %d\n",
2810 pid, expected_cc, cc);
2817 if (packet[1] & 0x80) {
2826 if (has_adaptation) {
2829 if (
parse_pcr(&pcr_h, &pcr_l, packet) == 0)
2830 tss->
last_pcr = pcr_h * 300 + pcr_l;
2836 if (p >= p_end || !has_payload)
2848 if (
len > p_end - p)
2903 int64_t back =
FFMIN(seekback,
pos);
2906 if (current_packet[0] == 0x80 && current_packet[12] == 0x47 &&
pos >=
TS_PACKET_SIZE) {
2918 int new_packet_size,
ret;
2934 "max resync size reached, could not find sync byte\n");
2941 const uint8_t **
data)
2951 if ((*
data)[0] != 0x47) {
2977 const uint8_t *
data;
3006 if (nb_packets != 0 && packet_num >= nb_packets ||
3033 #define CHECK_COUNT 10
3034 #define CHECK_BLOCK 100
3044 score =
FFMAX3(score, dvhs_score, fec_score);
3046 maxscore =
FFMAX(maxscore, score);
3052 ff_dlog(0,
"TS score: %d %d\n", sumscore, maxscore);
3056 }
else if (check_count >=
CHECK_COUNT && sumscore > 6) {
3058 }
else if (check_count >=
CHECK_COUNT && maxscore > 6) {
3060 }
else if (sumscore > 6) {
3069 static int parse_pcr(int64_t *ppcr_high,
int *ppcr_low,
const uint8_t *packet)
3075 afc = (packet[3] >> 4) & 3;
3085 if (!(
flags & 0x10))
3090 *ppcr_high = ((int64_t) v << 1) | (p[4] >> 7);
3091 *ppcr_low = ((p[4] & 1) << 8) | p[5];
3108 int64_t
pos, probesize =
s->probesize;
3145 int pcr_pid, pid, nb_packets, nb_pcrs,
ret, pcr_l;
3146 int64_t pcrs[2], pcr_h;
3148 const uint8_t *
data;
3168 if ((pcr_pid == -1 || pcr_pid == pid) &&
3172 pcrs[nb_pcrs] = pcr_h * 300 + pcr_l;
3175 if (pcrs[1] - pcrs[0] > 0) {
3205 #define MAX_PACKET_READAHEAD ((128 * 1024) / 188)
3211 int64_t pcr_h, next_pcr_h,
pos;
3212 int pcr_l, next_pcr_l;
3213 uint8_t pcr_buf[12];
3214 const uint8_t *
data;
3234 if (
parse_pcr(&next_pcr_h, &next_pcr_l, pcr_buf) == 0) {
3237 ((next_pcr_h - pcr_h) * 300 + (next_pcr_l - pcr_l)) /
3244 ts->
cur_pcr = pcr_h * 300 + pcr_l;
3306 int64_t *ppos, int64_t pos_limit)
3309 int64_t
pos, timestamp;
3311 int pcr_l, pcr_pid =
3312 ((
PESContext *)
s->streams[stream_index]->priv_data)->pcr_pid;
3317 while(
pos < pos_limit) {
3322 if (buf[0] != 0x47) {
3328 if ((pcr_pid < 0 || (
AV_RB16(buf + 1) & 0x1fff) == pcr_pid) &&
3329 parse_pcr(×tamp, &pcr_l, buf) == 0) {
3340 int64_t *ppos, int64_t pos_limit)
3353 while(
pos < pos_limit) {
3403 const uint8_t *buf,
int len)
3413 if (buf[0] != 0x47) {
3447 .
name =
"mpegtsraw",
static int parse_MP4DecConfigDescrTag(MP4DescrParseContext *d, int64_t off, int len)
static int mpegts_set_stream_info(AVStream *st, PESContext *pes, uint32_t stream_type, uint32_t prog_reg_desc)
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
static int parse_mp4_descr_arr(MP4DescrParseContext *d, int64_t off, int len)
static int new_pes_packet(PESContext *pes, AVPacket *pkt)
AVBufferPool * av_buffer_pool_init(size_t size, AVBufferRef *(*alloc)(size_t size))
Allocate and initialize a buffer pool.
static void skip_bits_long(GetBitContext *s, int n)
Skips the specified number of bits.
#define AV_LOG_WARNING
Something somehow does not look correct.
uint8_t * extradata
Extra binary data needed for initializing the decoder, codec-dependent.
it s the only field you need to keep assuming you have a context There is some magic you don t need to care about around this just let it vf default minimum maximum flags name is the option name
#define MP4DecConfigDescrTag
Undefined Behavior In the C some operations are like signed integer dereferencing freed accessing outside allocated Undefined Behavior must not occur in a C program
static int get_bits_left(GetBitContext *gb)
Filter the word “frame” indicates either a video frame or a group of audio as stored in an AVFrame structure Format for each input and each output the list of supported formats For video that means pixel format For audio that means channel sample they are references to shared objects When the negotiation mechanism computes the intersection of the formats supported at each end of a all references to both lists are replaced with a reference to the intersection And when a single format is eventually chosen for a link amongst the remaining all references to the list are updated That means that if a filter requires that its input and output have the same format amongst a supported all it has to do is use a reference to the same list of formats query_formats can leave some formats unset and return AVERROR(EAGAIN) to cause the negotiation mechanism toagain later. That can be used by filters with complex requirements to use the format negotiated on one link to set the formats supported on another. Frame references ownership and permissions
AVStream * avformat_new_stream(AVFormatContext *s, const AVCodec *c)
Add a new stream to a media file.
int prefer_codec_framerate
#define AV_OPT_FLAG_READONLY
The option may not be set through the AVOptions API, only read.
enum AVMediaType codec_type
General type of the encoded data.
unsigned int nb_stream_indexes
@ AV_PKT_DATA_MPEGTS_STREAM_ID
MPEGTS stream ID as uint8_t, this is required to pass the stream ID information from the demuxer to t...
static int64_t ff_parse_pes_pts(const uint8_t *buf)
Parse MPEG-PES five-byte timestamp.
#define TS_DVHS_PACKET_SIZE
static void pmt_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
int ffio_read_indirect(AVIOContext *s, unsigned char *buf, int size, const unsigned char **data)
Read size bytes from AVIOContext, returning a pointer.
#define STREAM_TYPE_PRIVATE_DATA
int flags
copied to the AVPacket flags
#define AVERROR_EOF
End of file.
int avpriv_mpegts_parse_packet(MpegTSContext *ts, AVPacket *pkt, const uint8_t *buf, int len)
uint8_t * data
The data buffer.
static const uint8_t opus_default_extradata[30]
enum AVMediaType avcodec_get_type(enum AVCodecID codec_id)
Get the type of the given codec.
enum AVDiscard discard
Selects which packets can be discarded at will and do not need to be demuxed.
AVProgram * av_find_program_from_stream(AVFormatContext *ic, AVProgram *last, int s)
Find the programs which belong to a given stream.
#define STREAM_ID_EMM_STREAM
static void mpegts_close_filter(MpegTSContext *ts, MpegTSFilter *filter)
#define STREAM_ID_PADDING_STREAM
#define STREAM_ID_PROGRAM_STREAM_MAP
int pmt_found
have we found pmt for this program
static int get_bits_count(const GetBitContext *s)
static const StreamType METADATA_types[]
AVStream ** streams
A list of all streams in the file.
int ff_mp4_read_dec_config_descr(AVFormatContext *fc, AVStream *st, AVIOContext *pb)
static void mpegts_find_stream_type(AVStream *st, uint32_t stream_type, const StreamType *types)
int auto_guess
if true, all pids are analyzed to find streams
@ AV_CODEC_ID_DVB_TELETEXT
static void clear_avprogram(MpegTSContext *ts, unsigned int programid)
static char * getstr8(const uint8_t **pp, const uint8_t *p_end)
MpegTSSectionFilter section_filter
static const StreamType HLS_SAMPLE_ENC_types[]
#define AV_LOG_VERBOSE
Detailed information.
static AVBufferRef * buffer_pool_get(MpegTSContext *ts, int size)
#define fc(width, name, range_min, range_max)
int64_t duration
Duration of this packet in AVStream->time_base units, 0 if unknown.
uint32_t codec_tag
Additional information about the codec (corresponds to the AVI FOURCC).
filter_frame For filters that do not use the this method is called when a frame is pushed to the filter s input It can be called at any time except in a reentrant way If the input frame is enough to produce then the filter should push the output frames on the output link immediately As an exception to the previous rule if the input frame is enough to produce several output frames then the filter needs output only at least one per link The additional frames can be left buffered in the filter
int buf_size
Size of buf except extra allocated bytes.
void SetServiceCallback(void *opaque, int ret)
int av_read_frame(AVFormatContext *s, AVPacket *pkt)
Return the next frame of a stream.
int avcodec_is_open(AVCodecContext *s)
@ AV_CODEC_ID_HDMV_PGS_SUBTITLE
void ff_read_frame_flush(AVFormatContext *s)
Flush the frame reader.
static void add_pid_to_program(struct Program *p, unsigned int pid)
static int init_get_bits(GetBitContext *s, const uint8_t *buffer, int bit_size)
Initialize GetBitContext.
void av_packet_free(AVPacket **pkt)
Free the packet, if the packet is reference counted, it will be unreferenced first.
unsigned int nb_prg
structure to keep track of Program->pids mapping
struct Stream streams[MAX_STREAMS_PER_PROGRAM]
int pcr_pid
if -1 then all packets containing PCR are considered
void * av_memdup(const void *p, size_t size)
Duplicate a buffer with av_malloc().
static void skip_bits(GetBitContext *s, int n)
#define PROBE_PACKET_MAX_BUF
static const AVClass mpegtsraw_class
static unsigned int get_bits(GetBitContext *s, int n)
Read 1-25 bits.
MpegTSPESFilter pes_filter
#define METADATA_DESCRIPTOR
#define REGISTRATION_DESCRIPTOR
static int mpegts_read_close(AVFormatContext *s)
static int mpegts_raw_read_packet(AVFormatContext *s, AVPacket *pkt)
static AVStream * find_matching_stream(MpegTSContext *ts, int pid, unsigned int programid, int stream_identifier, int pmt_stream_idx, struct Program *p)
static void update_av_program_info(AVFormatContext *s, unsigned int programid, unsigned int pid, int version)
int PESCallback(MpegTSFilter *f, const uint8_t *buf, int len, int is_start, int64_t pos)
#define VIDEO_STREAM_DESCRIPTOR
#define STREAM_ID_DSMCC_STREAM
int av_add_index_entry(AVStream *st, int64_t pos, int64_t timestamp, int size, int distance, int flags)
Add an index entry into a sorted list.
static void pat_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
static int mp4_read_iods(AVFormatContext *s, const uint8_t *buf, unsigned size, Mp4Descr *descr, int *descr_count, int max_descr_count)
enum AVDiscard discard
selects which program to discard and which to feed to the caller
static av_cold int read_close(AVFormatContext *ctx)
static av_always_inline int64_t avio_tell(AVIOContext *s)
ftell() equivalent for AVIOContext.
struct AVCodecContext * avctx
The codec context used by avformat_find_stream_info, the parser, etc.
static double val(void *priv, double ch)
it s the only field you need to keep assuming you have a context There is some magic you don t need to care about around this just let it vf type
AVProgram * av_new_program(AVFormatContext *ac, int id)
@ AV_CODEC_ID_MP3
preferred ID for decoding MPEG audio layer 1, 2 or 3
@ AV_CODEC_ID_DVB_SUBTITLE
AVStream * sub_st
stream for the embedded AC3 stream in HDMV TrueHD
void ff_mp4_parse_es_descr(AVIOContext *pb, int *es_id)
uint8_t header[MAX_PES_HEADER_SIZE]
unsigned int avio_rb32(AVIOContext *s)
#define AV_LOG_TRACE
Extremely verbose debugging, useful for libav* development.
void avpriv_mpegts_parse_close(MpegTSContext *ts)
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
#define FF_ARRAY_ELEMS(a)
#define AV_PKT_FLAG_CORRUPT
The packet content is corrupted.
static const uint8_t opus_coupled_stream_cnt[9]
int ctx_flags
Flags signalling stream properties.
int ff_parse_mpeg2_descriptor(AVFormatContext *fc, AVStream *st, int stream_type, const uint8_t **pp, const uint8_t *desc_list_end, Mp4Descr *mp4_descr, int mp4_descr_count, int pid, MpegTSContext *ts)
Parse an MPEG-2 descriptor.
static int parse_pcr(int64_t *ppcr_high, int *ppcr_low, const uint8_t *packet)
AVBufferRef * av_buffer_pool_get(AVBufferPool *pool)
Allocate a new AVBuffer, reusing an old buffer from the pool when available.
@ AV_CODEC_ID_MPEG4SYSTEMS
FAKE codec to indicate a MPEG-4 Systems stream (only used by libavformat)
int av_new_packet(AVPacket *pkt, int size)
Allocate the payload of a packet and initialize its fields with default values.
static av_unused int64_t mpegts_get_pcr(AVFormatContext *s, int stream_index, int64_t *ppos, int64_t pos_limit)
static const AVClass mpegts_class
unsigned char * buf
Buffer must have AVPROBE_PADDING_SIZE of extra allocated bytes filled with zero.
#define FF_PROFILE_ARIB_PROFILE_C
#define FF_PROFILE_UNKNOWN
#define av_assert0(cond)
assert() equivalent, that is always enabled.
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
static MpegTSFilter * mpegts_open_filter(MpegTSContext *ts, unsigned int pid, enum MpegTSFilterType type)
#define STREAM_ID_TYPE_E_STREAM
static int parse_MP4IODescrTag(MP4DescrParseContext *d, int64_t off, int len)
static int skip_identical(const SectionHeader *h, MpegTSSectionFilter *tssf)
static const uint8_t opus_stream_cnt[9]
@ AVMEDIA_TYPE_DATA
Opaque data information usually continuous.
static int get8(const uint8_t **pp, const uint8_t *p_end)
static int discard_pid(MpegTSContext *ts, unsigned int pid)
discard_pid() decides if the pid is to be discarded according to caller's programs selection
@ AV_CODEC_ID_ARIB_CAPTION
int64_t cur_pcr
used to estimate the exact PCR
static void clear_programs(MpegTSContext *ts)
enum AVStreamParseType need_parsing
@ AVDISCARD_ALL
discard all
int64_t pcr_incr
used to estimate the exact PCR
AVBufferRef * buf
A reference to the reference-counted buffer where the packet data is stored.
AVCodecParameters * codecpar
Codec parameters associated with this stream.
#define LIBAVUTIL_VERSION_INT
static int read_header(FFV1Context *f)
Describe the class of an AVClass context structure.
uint8_t dv_bl_signal_compatibility_id
void av_buffer_unref(AVBufferRef **buf)
Free a given reference and automatically free the buffer if there are no more references to it.
int stop_parse
stop parsing loop
int64_t last_pos
to detect seek
static const StreamType DESC_types[]
int av_stream_add_side_data(AVStream *st, enum AVPacketSideDataType type, uint8_t *data, size_t size)
Wrap an existing array as stream side data.
const char * av_default_item_name(void *ptr)
Return the context name.
static unsigned int get_bits1(GetBitContext *s)
static void eit_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
void av_buffer_pool_uninit(AVBufferPool **ppool)
Mark the pool as being available for freeing.
enum MpegTSFilterType type
static MpegTSFilter * mpegts_open_pcr_filter(MpegTSContext *ts, unsigned int pid)
This structure contains the data a format has to probe a file.
static void seek_back(AVFormatContext *s, AVIOContext *pb, int64_t pos)
unsigned int * stream_index
@ AV_CODEC_ID_MPEG2TS
FAKE codec to indicate a raw MPEG-2 TS stream (only used by libavformat)
static PESContext * add_pes_stream(MpegTSContext *ts, int pid, int pcr_pid)
#define AV_DICT_DONT_OVERWRITE
Don't overwrite existing entries.
int ff_mp4_read_descr(AVFormatContext *fc, AVIOContext *pb, int *tag)
static MpegTSFilter * mpegts_open_section_filter(MpegTSContext *ts, unsigned int pid, SectionCallback *section_cb, void *opaque, int check_crc)
static MpegTSFilter * mpegts_open_pes_filter(MpegTSContext *ts, unsigned int pid, PESCallback *pes_cb, void *opaque)
static int init_MP4DescrParseContext(MP4DescrParseContext *d, AVFormatContext *s, const uint8_t *buf, unsigned size, Mp4Descr *descr, int max_descr_count)
#define MAX_PES_HEADER_SIZE
#define MAX_PACKET_READAHEAD
#define MAX_PIDS_PER_PROGRAM
unsigned int end_of_section_reached
Undefined Behavior In the C some operations are like signed integer dereferencing freed accessing outside allocated Undefined Behavior must not occur in a C it is not safe even if the output of undefined operations is unused The unsafety may seem nit picking but Optimizing compilers have in fact optimized code on the assumption that no undefined Behavior occurs Optimizing code based on wrong assumptions can and has in some cases lead to effects beyond the output of computations The signed integer overflow problem in speed critical code Code which is highly optimized and works with signed integers sometimes has the problem that often the output of the computation does not c
static int parse_MP4ODescrTag(MP4DescrParseContext *d, int64_t off, int len)
static int mpegts_push_data(MpegTSFilter *filter, const uint8_t *buf, int buf_size, int is_start, int64_t pos)
static void new_data_packet(const uint8_t *buffer, int len, AVPacket *pkt)
AVCodecID
Identify the syntax and semantics of the bitstream.
int extradata_size
Size of the extradata content in bytes.
static const StreamType SCTE_types[]
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification.
int seekable
A combination of AVIO_SEEKABLE_ flags or 0 when the stream is not seekable.
static void reset_pes_packet_state(PESContext *pes)
#define AV_NOPTS_VALUE
Undefined timestamp value.
int raw_packet_size
raw packet size, including FEC if present
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_WL32 unsigned int_TMPL AV_WL24 unsigned int_TMPL AV_WL16 uint64_t_TMPL AV_WB64 unsigned int_TMPL AV_RB32
static void finished_reading_packet(AVFormatContext *s, int raw_packet_size)
void avpriv_report_missing_feature(void *avc, const char *msg,...) av_printf_format(2
Log a generic warning message about a missing feature.
#define STREAM_ID_PRIVATE_STREAM_2
int profile
Codec-specific bitstream restrictions that the stream conforms to.
static int64_t mpegts_get_dts(AVFormatContext *s, int stream_index, int64_t *ppos, int64_t pos_limit)
static int mpegts_read_packet(AVFormatContext *s, AVPacket *pkt)
int ff_find_stream_index(const AVFormatContext *s, int id)
Find stream index based on format-specific stream ID.
static int parse_MP4ESDescrTag(MP4DescrParseContext *d, int64_t off, int len)
int64_t dts
Decompression timestamp in AVStream->time_base units; the time at which the packet is decompressed.
int avio_r8(AVIOContext *s)
int av_reallocp_array(void *ptr, size_t nmemb, size_t size)
Allocate, reallocate an array through a pointer to a pointer.
int ffio_ensure_seekback(AVIOContext *s, int64_t buf_size)
Ensures that the requested seekback buffer size will be available.
const AVCRC * av_crc_get_table(AVCRCId crc_id)
Get an initialized standard CRC table.
void SectionCallback(MpegTSFilter *f, const uint8_t *buf, int len)
it s the only field you need to keep assuming you have a context There is some magic you don t need to care about around this just let it vf offset
int pts_wrap_behavior
Options for behavior, when a wrap is detected.
int flags
A combination of AV_PKT_FLAG values.
AVPacket * av_packet_alloc(void)
Allocate an AVPacket and set its fields to default values.
int probe_packets
Number of packets to buffer for codec probing.
static int handle_packet(MpegTSContext *ts, const uint8_t *packet, int64_t pos)
#define AV_LOG_INFO
Standard information.
static void update_offsets(AVIOContext *pb, int64_t *off, int *len)
static uint64_t get_bits64(GetBitContext *s, int n)
Read 0-64 bits.
static int is_pes_stream(int stream_type, uint32_t prog_reg_desc)
#define FF_PROFILE_ARIB_PROFILE_A
#define ISO_639_LANGUAGE_DESCRIPTOR
#define i(width, name, range_min, range_max)
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
static int parse_stream_identifier_desc(const uint8_t *p, const uint8_t *p_end)
#define MAX_MP4_DESCR_COUNT
static struct Program * get_program(MpegTSContext *ts, unsigned int programid)
const AVInputFormat ff_mpegts_demuxer
MpegTSFilter * pids[NB_PID_MAX]
filters for various streams specified by PMT + for the PAT and PMT
void ffio_init_context(FFIOContext *s, unsigned char *buffer, int buffer_size, int write_flag, void *opaque, int(*read_packet)(void *opaque, uint8_t *buf, int buf_size), int(*write_packet)(void *opaque, uint8_t *buf, int buf_size), int64_t(*seek)(void *opaque, int64_t offset, int whence))
static int get16(const uint8_t **pp, const uint8_t *p_end)
static int parse_section_header(SectionHeader *h, const uint8_t **pp, const uint8_t *p_end)
#define xf(width, name, var, range_min, range_max, subs,...)
static int mpegts_resync(AVFormatContext *s, int seekback, const uint8_t *current_packet)
int8_t crc_validity[NB_PID_MAX]
#define AV_OPT_FLAG_DECODING_PARAM
a generic parameter which can be set by the user for demuxing or decoding
void * av_mallocz(size_t size)
Allocate a memory block with alignment suitable for all memory accesses (including vectors if availab...
New fields can be added to the end with minor version bumps.
static int handle_packets(MpegTSContext *ts, int64_t nb_packets)
Undefined Behavior In the C language
int disposition
Stream disposition - a combination of AV_DISPOSITION_* flags.
int id
Format-specific stream ID.
int ts_id
Transport stream id.
@ AV_PKT_DATA_DOVI_CONF
DOVI configuration ref: dolby-vision-bitstreams-within-the-iso-base-media-file-format-v2....
int64_t avio_seek(AVIOContext *s, int64_t offset, int whence)
fseek() equivalent for AVIOContext.
#define FFSWAP(type, a, b)
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
uint8_t * dec_config_descr
unsigned int avio_rb16(AVIOContext *s)
static int mp4_read_od(AVFormatContext *s, const uint8_t *buf, unsigned size, Mp4Descr *descr, int *descr_count, int max_descr_count)
static void scte_data_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
static void m4sl_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
#define AV_INPUT_BUFFER_PADDING_SIZE
Tag MUST be and< 10hcoeff half pel interpolation filter coefficients, hcoeff[0] are the 2 middle coefficients[1] are the next outer ones and so on, resulting in a filter like:...eff[2], hcoeff[1], hcoeff[0], hcoeff[0], hcoeff[1], hcoeff[2] ... the sign of the coefficients is not explicitly stored but alternates after each coeff and coeff[0] is positive, so ...,+,-,+,-,+,+,-,+,-,+,... hcoeff[0] is not explicitly stored but found by subtracting the sum of all stored coefficients with signs from 32 hcoeff[0]=32 - hcoeff[1] - hcoeff[2] - ... a good choice for hcoeff and htaps is htaps=6 hcoeff={40,-10, 2} an alternative which requires more computations at both encoder and decoder side and may or may not be better is htaps=8 hcoeff={42,-14, 6,-2}ref_frames minimum of the number of available reference frames and max_ref_frames for example the first frame after a key frame always has ref_frames=1spatial_decomposition_type wavelet type 0 is a 9/7 symmetric compact integer wavelet 1 is a 5/3 symmetric compact integer wavelet others are reserved stored as delta from last, last is reset to 0 if always_reset||keyframeqlog quality(logarithmic quantizer scale) stored as delta from last, last is reset to 0 if always_reset||keyframemv_scale stored as delta from last, last is reset to 0 if always_reset||keyframe FIXME check that everything works fine if this changes between framesqbias dequantization bias stored as delta from last, last is reset to 0 if always_reset||keyframeblock_max_depth maximum depth of the block tree stored as delta from last, last is reset to 0 if always_reset||keyframequant_table quantization tableHighlevel bitstream structure:==============================--------------------------------------------|Header|--------------------------------------------|------------------------------------|||Block0||||split?||||yes no||||......... intra?||||:Block01 :yes no||||:Block02 :....... ..........||||:Block03 ::y DC ::ref index:||||:Block04 ::cb DC ::motion x :||||......... :cr DC ::motion y :||||....... ..........|||------------------------------------||------------------------------------|||Block1|||...|--------------------------------------------|------------ ------------ ------------|||Y subbands||Cb subbands||Cr subbands||||--- ---||--- ---||--- ---|||||LL0||HL0||||LL0||HL0||||LL0||HL0|||||--- ---||--- ---||--- ---||||--- ---||--- ---||--- ---|||||LH0||HH0||||LH0||HH0||||LH0||HH0|||||--- ---||--- ---||--- ---||||--- ---||--- ---||--- ---|||||HL1||LH1||||HL1||LH1||||HL1||LH1|||||--- ---||--- ---||--- ---||||--- ---||--- ---||--- ---|||||HH1||HL2||||HH1||HL2||||HH1||HL2|||||...||...||...|||------------ ------------ ------------|--------------------------------------------Decoding process:=================------------|||Subbands|------------||||------------|Intra DC||||LL0 subband prediction ------------|\ Dequantization ------------------- \||Reference frames|\ IDWT|------- -------|Motion \|||Frame 0||Frame 1||Compensation . OBMC v -------|------- -------|--------------. \------> Frame n output Frame Frame<----------------------------------/|...|------------------- Range Coder:============Binary Range Coder:------------------- The implemented range coder is an adapted version based upon "Range encoding: an algorithm for removing redundancy from a digitised message." by G. N. N. Martin. The symbols encoded by the Snow range coder are bits(0|1). The associated probabilities are not fix but change depending on the symbol mix seen so far. bit seen|new state ---------+----------------------------------------------- 0|256 - state_transition_table[256 - old_state];1|state_transition_table[old_state];state_transition_table={ 0, 0, 0, 0, 0, 0, 0, 0, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 94, 95, 96, 97, 98, 99, 100, 101, 102, 103, 104, 105, 106, 107, 108, 109, 110, 111, 112, 113, 114, 114, 115, 116, 117, 118, 119, 120, 121, 122, 123, 124, 125, 126, 127, 128, 129, 130, 131, 132, 133, 133, 134, 135, 136, 137, 138, 139, 140, 141, 142, 143, 144, 145, 146, 147, 148, 149, 150, 151, 152, 152, 153, 154, 155, 156, 157, 158, 159, 160, 161, 162, 163, 164, 165, 166, 167, 168, 169, 170, 171, 171, 172, 173, 174, 175, 176, 177, 178, 179, 180, 181, 182, 183, 184, 185, 186, 187, 188, 189, 190, 190, 191, 192, 194, 194, 195, 196, 197, 198, 199, 200, 201, 202, 202, 204, 205, 206, 207, 208, 209, 209, 210, 211, 212, 213, 215, 215, 216, 217, 218, 219, 220, 220, 222, 223, 224, 225, 226, 227, 227, 229, 229, 230, 231, 232, 234, 234, 235, 236, 237, 238, 239, 240, 241, 242, 243, 244, 245, 246, 247, 248, 248, 0, 0, 0, 0, 0, 0, 0};FIXME Range Coding of integers:------------------------- FIXME Neighboring Blocks:===================left and top are set to the respective blocks unless they are outside of the image in which case they are set to the Null block top-left is set to the top left block unless it is outside of the image in which case it is set to the left block if this block has no larger parent block or it is at the left side of its parent block and the top right block is not outside of the image then the top right block is used for top-right else the top-left block is used Null block y, cb, cr are 128 level, ref, mx and my are 0 Motion Vector Prediction:=========================1. the motion vectors of all the neighboring blocks are scaled to compensate for the difference of reference frames scaled_mv=(mv *(256 *(current_reference+1)/(mv.reference+1))+128)> the median of the scaled left
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_RL32
#define TS_MAX_PACKET_SIZE
const char * av_get_media_type_string(enum AVMediaType media_type)
Return a string describing the media_type enum, NULL if media_type is unknown.
int index
stream index in AVFormatContext
#define R8_CHECK_CLIP_MAX(dst, maxv)
union MpegTSFilter::@302 u
static int probe(const AVProbeData *p)
static int mpegts_probe(const AVProbeData *p)
#define AV_OPT_FLAG_EXPORT
The option is intended for exporting values to the caller.
static void clear_program(struct Program *p)
#define AVIO_SEEKABLE_NORMAL
Seeking works like for a local file.
uint8_t * av_packet_new_side_data(AVPacket *pkt, enum AVPacketSideDataType type, size_t size)
Allocate new information of a packet.
the frame and frame reference mechanism is intended to as much as expensive copies of that data while still allowing the filters to produce correct results The data is stored in buffers represented by AVFrame structures Several references can point to the same frame buffer
uint32_t av_crc(const AVCRC *ctx, uint32_t crc, const uint8_t *buffer, size_t length)
Calculate the CRC of a block.
int avio_read(AVIOContext *s, unsigned char *buf, int size)
Read size bytes from AVIOContext into buf.
static int parse_MP4SLDescrTag(MP4DescrParseContext *d, int64_t off, int len)
MpegTSContext * avpriv_mpegts_parse_open(AVFormatContext *s)
static void mpegts_free(MpegTSContext *ts)
static const StreamType HDMV_types[]
int64_t avio_skip(AVIOContext *s, int64_t offset)
Skip given number of bytes forward.
static const StreamType ISO_types[]
static int read_probe(const AVProbeData *p)
static int read_sl_header(PESContext *pes, SLConfigDescr *sl, const uint8_t *buf, int buf_size)
A reference to a data buffer.
AVPacket * pkt
packet containing Audio/Video data
static int mpegts_read_header(AVFormatContext *s)
#define avpriv_request_sample(...)
int request_probe
stream probing state -1 -> probing finished 0 -> no probing requested rest -> perform probing with re...
#define STREAM_ID_ECM_STREAM
#define TS_FEC_PACKET_SIZE
enum AVCodecID codec_id
Specific type of the encoded data (the codec used).
#define MAX_STREAMS_PER_PROGRAM
This structure stores compressed data.
#define STREAM_ID_PROGRAM_STREAM_DIRECTORY
int av_dict_set(AVDictionary **pm, const char *key, const char *value, int flags)
Set the given entry in *pm, overwriting an existing entry.
int64_t pos
byte position in stream, -1 if unknown
int predefined_SLConfigDescriptor_seen
int stream_identifier
Stream Identifier This is the MPEG-TS stream identifier +1 0 means unknown.
static const AVOption raw_options[]
int need_context_update
Whether the internal avctx needs to be updated from codecpar (after a late change to codecpar)
#define flags(name, subs,...)
static const uint8_t opus_channel_map[8][8]
int64_t bit_rate
The average bitrate of the encoded data (in bits per second).
unsigned int pids[MAX_PIDS_PER_PROGRAM]
const AVInputFormat ff_mpegtsraw_demuxer
static int parse_mp4_descr(MP4DescrParseContext *d, int64_t off, int len, int target_tag)
#define AVERROR_INVALIDDATA
Invalid data found when processing input.
@ AV_CODEC_ID_HDMV_TEXT_SUBTITLE
SectionCallback * section_cb
#define MKTAG(a, b, c, d)
#define PROBE_PACKET_MARGIN
static int64_t read_timestamp(AVFormatContext *s, int stream_index, int64_t *ppos, int64_t pos_limit, int64_t(*read_timestamp)(struct AVFormatContext *, int, int64_t *, int64_t))
static uint64_t get_ts64(GetBitContext *gb, int bits)
int64_t start_time
Decoding: pts of the first frame of the stream in presentation order, in stream time base.
static int get_packet_size(AVFormatContext *s)
static int analyze(const uint8_t *buf, int size, int packet_size, int probe)
static void write_section_data(MpegTSContext *ts, MpegTSFilter *tss1, const uint8_t *buf, int buf_size, int is_start)
Assemble PES packets out of TS packets, and then call the "section_cb" function when they are complet...
void ff_reduce_index(AVFormatContext *s, int stream_index)
Ensure the index uses less memory than the maximum specified in AVFormatContext.max_index_size by dis...
static int read_packet(AVFormatContext *s, uint8_t *buf, int raw_packet_size, const uint8_t **data)
int mpeg2ts_compute_pcr
compute exact PCR for each transport stream packet
static const StreamType REGD_types[]
static const StreamType MISC_types[]
@ AV_CODEC_ID_MPEG2VIDEO
preferred ID for MPEG-1/2 video decoding
static struct Program * add_program(MpegTSContext *ts, unsigned int programid)
static const AVOption options[]
int64_t ts_packet_pos
position of first TS packet of this PES packet
int64_t pts_wrap_reference
Internal data to check for wrapping of the time stamp.
int avio_read_partial(AVIOContext *s, unsigned char *buf, int size)
Read size bytes from AVIOContext into buf.
static void BS_FUNC() skip(BSCTX *bc, unsigned int n)
Skip n bits in the buffer.
static void sdt_cb(MpegTSFilter *filter, const uint8_t *section, int section_len)
int fix_teletext_pts
fix dvb teletext pts
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_WL32 unsigned int_TMPL AV_WL24 unsigned int_TMPL AV_WL16 uint64_t_TMPL AV_WB64 unsigned int_TMPL AV_WB32 unsigned int_TMPL AV_WB24 unsigned int_TMPL AV_RB16
int avio_feof(AVIOContext *s)
Similar to feof() but also returns nonzero on read errors.
@ AV_CODEC_ID_SCTE_35
Contain timestamp estimated through PCR of program stream.
enum AVMediaType codec_type