FFmpeg
mpegtsenc.c
Go to the documentation of this file.
1 /*
2  * MPEG-2 transport stream (aka DVB) muxer
3  * Copyright (c) 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/avassert.h"
23 #include "libavutil/bswap.h"
24 #include "libavutil/crc.h"
25 #include "libavutil/dict.h"
26 #include "libavutil/intreadwrite.h"
27 #include "libavutil/mathematics.h"
28 #include "libavutil/mem.h"
29 #include "libavutil/opt.h"
30 
31 #include "libavcodec/ac3_parser_internal.h"
32 #include "libavcodec/bytestream.h"
33 #include "libavcodec/defs.h"
34 #include "libavcodec/h264.h"
35 #include "libavcodec/hevc/hevc.h"
36 #include "libavcodec/vvc.h"
37 #include "libavcodec/startcode.h"
38 
39 #include "avformat.h"
40 #include "avio_internal.h"
41 #include "internal.h"
42 #include "mpegts.h"
43 #include "mux.h"
44 
45 #define PCR_TIME_BASE 27000000
46 
47 /* write DVB SI sections */
48 
49 #define DVB_PRIVATE_NETWORK_START 0xff01
50 
51 /*********************************************/
52 /* mpegts section writer */
53 
54 typedef struct MpegTSSection {
55  int pid;
56  int cc;
57  int discontinuity;
58  void (*write_packet)(struct MpegTSSection *s, const uint8_t *packet);
59  void *opaque;
60 } MpegTSSection;
61 
62 typedef struct MpegTSService {
63  MpegTSSection pmt; /* MPEG-2 PMT table context */
64  int sid; /* service ID */
65  uint8_t name[256];
66  uint8_t provider_name[256];
67  int pcr_pid;
68  AVProgram *program;
69 } MpegTSService;
70 
71 // service_type values as defined in ETSI 300 468
72 enum {
73  MPEGTS_SERVICE_TYPE_DIGITAL_TV = 0x01,
74  MPEGTS_SERVICE_TYPE_DIGITAL_RADIO = 0x02,
75  MPEGTS_SERVICE_TYPE_TELETEXT = 0x03,
76  MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_RADIO = 0x0A,
77  MPEGTS_SERVICE_TYPE_MPEG2_DIGITAL_HDTV = 0x11,
78  MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_SDTV = 0x16,
79  MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_HDTV = 0x19,
80  MPEGTS_SERVICE_TYPE_HEVC_DIGITAL_HDTV = 0x1F,
81 };
82 typedef struct MpegTSWrite {
83  const AVClass *av_class;
84  MpegTSSection pat; /* MPEG-2 PAT table */
85  MpegTSSection sdt; /* MPEG-2 SDT table context */
86  MpegTSSection nit; /* MPEG-2 NIT table context */
87  MpegTSService **services;
88  AVPacket *pkt;
89  int64_t sdt_period; /* SDT period in PCR time base */
90  int64_t pat_period; /* PAT/PMT period in PCR time base */
91  int64_t nit_period; /* NIT period in PCR time base */
92  int nb_services;
93  int64_t first_pcr;
94  int first_dts_checked;
95  int64_t next_pcr;
96  int mux_rate; ///< set to 1 when VBR
97  int pes_payload_size;
98  int64_t total_size;
99 
100  int transport_stream_id;
101  int original_network_id;
102  int service_id;
103  int service_type;
104 
105  int pmt_start_pid;
106  int start_pid;
107  int m2ts_mode;
108  int m2ts_video_pid;
109  int m2ts_audio_pid;
110  int m2ts_pgssub_pid;
111  int m2ts_textsub_pid;
112 
113  int pcr_period_ms;
114 #define MPEGTS_FLAG_REEMIT_PAT_PMT 0x01
115 #define MPEGTS_FLAG_AAC_LATM 0x02
116 #define MPEGTS_FLAG_PAT_PMT_AT_FRAMES 0x04
117 #define MPEGTS_FLAG_SYSTEM_B 0x08
118 #define MPEGTS_FLAG_DISCONT 0x10
119 #define MPEGTS_FLAG_NIT 0x20
120 #define MPEGTS_FLAG_OMIT_RAI 0x40
121  int flags;
122  int copyts;
123  int tables_version;
124  int64_t pat_period_us;
125  int64_t sdt_period_us;
126  int64_t nit_period_us;
127  int64_t last_pat_ts;
128  int64_t last_sdt_ts;
129  int64_t last_nit_ts;
130 
131  uint8_t provider_name[256];
132 
133  int omit_video_pes_length;
134 } MpegTSWrite;
135 
136 /* a PES packet header is generated every DEFAULT_PES_HEADER_FREQ packets */
137 #define DEFAULT_PES_HEADER_FREQ 16
138 #define DEFAULT_PES_PAYLOAD_SIZE ((DEFAULT_PES_HEADER_FREQ - 1) * 184 + 170)
139 
140 /* The section length is 12 bits. The first 2 are set to 0, the remaining
141  * 10 bits should not exceed 1021. */
142 #define SECTION_LENGTH 1020
143 
144 /* NOTE: 4 bytes must be left at the end for the crc32 */
145 static void mpegts_write_section(MpegTSSection *s, uint8_t *buf, int len)
146 {
147  unsigned int crc;
148  unsigned char packet[TS_PACKET_SIZE];
149  const unsigned char *buf_ptr;
150  unsigned char *q;
151  int first, b, len1, left;
152 
153  crc = av_bswap32(av_crc(av_crc_get_table(AV_CRC_32_IEEE),
154  -1, buf, len - 4));
155 
156  buf[len - 4] = (crc >> 24) & 0xff;
157  buf[len - 3] = (crc >> 16) & 0xff;
158  buf[len - 2] = (crc >> 8) & 0xff;
159  buf[len - 1] = crc & 0xff;
160 
161  /* send each packet */
162  buf_ptr = buf;
163  while (len > 0) {
164  first = buf == buf_ptr;
165  q = packet;
166  *q++ = SYNC_BYTE;
167  b = s->pid >> 8;
168  if (first)
169  b |= 0x40;
170  *q++ = b;
171  *q++ = s->pid;
172  s->cc = s->cc + 1 & 0xf;
173  *q++ = 0x10 | s->cc;
174  if (s->discontinuity) {
175  q[-1] |= 0x20;
176  *q++ = 1;
177  *q++ = 0x80;
178  s->discontinuity = 0;
179  }
180  if (first)
181  *q++ = 0; /* 0 offset */
182  len1 = TS_PACKET_SIZE - (q - packet);
183  if (len1 > len)
184  len1 = len;
185  memcpy(q, buf_ptr, len1);
186  q += len1;
187  /* add known padding data */
188  left = TS_PACKET_SIZE - (q - packet);
189  if (left > 0)
190  memset(q, STUFFING_BYTE, left);
191 
192  s->write_packet(s, packet);
193 
194  buf_ptr += len1;
195  len -= len1;
196  }
197 }
198 
199 static inline void put16(uint8_t **q_ptr, int val)
200 {
201  uint8_t *q;
202  q = *q_ptr;
203  *q++ = val >> 8;
204  *q++ = val;
205  *q_ptr = q;
206 }
207 
208 static int mpegts_write_section1(MpegTSSection *s, int tid, int id,
209  int version, int sec_num, int last_sec_num,
210  uint8_t *buf, int len)
211 {
212  uint8_t section[1024], *q;
213  unsigned int tot_len;
214  /* reserved_future_use field must be set to 1 for SDT and NIT */
215  unsigned int flags = (tid == SDT_TID || tid == NIT_TID) ? 0xf000 : 0xb000;
216 
217  tot_len = 3 + 5 + len + 4;
218  /* check if not too big */
219  if (tot_len > 1024)
220  return AVERROR_INVALIDDATA;
221 
222  q = section;
223  *q++ = tid;
224  put16(&q, flags | (len + 5 + 4)); /* 5 byte header + 4 byte CRC */
225  put16(&q, id);
226  *q++ = 0xc1 | (version << 1); /* current_next_indicator = 1 */
227  *q++ = sec_num;
228  *q++ = last_sec_num;
229  memcpy(q, buf, len);
230 
231  mpegts_write_section(s, section, tot_len);
232  return 0;
233 }
234 
235 /*********************************************/
236 /* mpegts writer */
237 
238 #define DEFAULT_PROVIDER_NAME "FFmpeg"
239 #define DEFAULT_SERVICE_NAME "Service"
240 
241 /* we retransmit the SI info at this rate */
242 #define SDT_RETRANS_TIME 500
243 #define PAT_RETRANS_TIME 100
244 #define PCR_RETRANS_TIME 20
245 #define NIT_RETRANS_TIME 500
246 
247 typedef struct MpegTSWriteStream {
248  int pid; /* stream associated pid */
249  int cc;
250  int discontinuity;
251  int payload_size;
252  int first_timestamp_checked; ///< first pts/dts check needed
253  int prev_payload_key;
254  int64_t payload_pts;
255  int64_t payload_dts;
256  int payload_flags;
257  uint8_t *payload;
258  AVFormatContext *amux;
259  int data_st_warning;
260 
261  int64_t pcr_period; /* PCR period in PCR time base */
262  int64_t last_pcr;
263 
264  /* For Opus */
265  int opus_queued_samples;
266  int opus_pending_trim_start;
267 
268  DVBAC3Descriptor *dvb_ac3_desc;
269 } MpegTSWriteStream;
270 
271 static void mpegts_write_pat(AVFormatContext *s)
272 {
273  MpegTSWrite *ts = s->priv_data;
274  MpegTSService *service;
275  uint8_t data[SECTION_LENGTH], *q;
276  int i;
277 
278  q = data;
279  if (ts->flags & MPEGTS_FLAG_NIT) {
280  put16(&q, 0x0000);
281  put16(&q, NIT_PID);
282  }
283  for (i = 0; i < ts->nb_services; i++) {
284  service = ts->services[i];
285  put16(&q, service->sid);
286  put16(&q, 0xe000 | service->pmt.pid);
287  }
288  mpegts_write_section1(&ts->pat, PAT_TID, ts->transport_stream_id, ts->tables_version, 0, 0,
289  data, q - data);
290 }
291 
292 static void putbuf(uint8_t **q_ptr, const uint8_t *buf, size_t len)
293 {
294  memcpy(*q_ptr, buf, len);
295  *q_ptr += len;
296 }
297 
298 static int put_arib_caption_descriptor(AVFormatContext *s, uint8_t **q_ptr,
299  AVCodecParameters *codecpar)
300 {
301  uint8_t stream_identifier;
302  uint16_t data_component_id;
303  uint8_t *q = *q_ptr;
304 
305  switch (codecpar->profile) {
306  case AV_PROFILE_ARIB_PROFILE_A:
307  stream_identifier = 0x30;
308  data_component_id = 0x0008;
309  break;
310  case AV_PROFILE_ARIB_PROFILE_C:
311  stream_identifier = 0x87;
312  data_component_id = 0x0012;
313  break;
314  default:
315  av_log(s, AV_LOG_ERROR,
316  "Unset/unknown ARIB caption profile %d utilized!\n",
317  codecpar->profile);
318  return AVERROR_INVALIDDATA;
319  }
320 
321  // stream_identifier_descriptor
322  *q++ = STREAM_IDENTIFIER_DESCRIPTOR; // descriptor_tag
323  *q++ = 1; // descriptor_length
324  *q++ = stream_identifier; // component_tag: stream_identifier
325 
326  // data_component_descriptor, defined in ARIB STD-B10, part 2, 6.2.20
327  *q++ = DATA_COMPONENT_DESCRIPTOR; // descriptor_tag: ARIB data coding type descriptor
328  *q++ = 3; // descriptor_length
329  put16(&q, data_component_id); // data_component_id
330  // additional_arib_caption_info: defined in ARIB STD-B24, fascicle 1, Part 3, 9.6.1
331  // Here we utilize a pre-defined set of values defined in ARIB TR-B14,
332  // Fascicle 2, 4.2.8.5 for PMT usage, with the reserved bits in the middle
333  // set to 1 (as that is what every broadcaster seems to be doing in
334  // production).
335  *q++ = 0x3D; // DMF('0011'), Reserved('11'), Timing('01')
336 
337  *q_ptr = q;
338 
339  return 0;
340 }
341 
342 static void put_registration_descriptor(uint8_t **q_ptr, uint32_t tag)
343 {
344  uint8_t *q = *q_ptr;
345  *q++ = REGISTRATION_DESCRIPTOR;
346  *q++ = 4;
347  *q++ = tag;
348  *q++ = tag >> 8;
349  *q++ = tag >> 16;
350  *q++ = tag >> 24;
351  *q_ptr = q;
352 }
353 
354 static int get_dvb_stream_type(AVFormatContext *s, AVStream *st)
355 {
356  MpegTSWrite *ts = s->priv_data;
357  MpegTSWriteStream *ts_st = st->priv_data;
358  int stream_type;
359 
360  switch (st->codecpar->codec_id) {
361  case AV_CODEC_ID_MPEG1VIDEO:
362  case AV_CODEC_ID_MPEG2VIDEO:
363  stream_type = STREAM_TYPE_VIDEO_MPEG2;
364  break;
365  case AV_CODEC_ID_MPEG4:
366  stream_type = STREAM_TYPE_VIDEO_MPEG4;
367  break;
368  case AV_CODEC_ID_H264:
369  stream_type = STREAM_TYPE_VIDEO_H264;
370  break;
371  case AV_CODEC_ID_HEVC:
372  stream_type = STREAM_TYPE_VIDEO_HEVC;
373  break;
374  case AV_CODEC_ID_VVC:
375  stream_type = STREAM_TYPE_VIDEO_VVC;
376  break;
377  case AV_CODEC_ID_CAVS:
378  stream_type = STREAM_TYPE_VIDEO_CAVS;
379  break;
380  case AV_CODEC_ID_AVS2:
381  stream_type = STREAM_TYPE_VIDEO_AVS2;
382  break;
383  case AV_CODEC_ID_AVS3:
384  stream_type = STREAM_TYPE_VIDEO_AVS3;
385  break;
386  case AV_CODEC_ID_DIRAC:
387  stream_type = STREAM_TYPE_VIDEO_DIRAC;
388  break;
389  case AV_CODEC_ID_VC1:
390  stream_type = STREAM_TYPE_VIDEO_VC1;
391  break;
392  case AV_CODEC_ID_MP2:
393  case AV_CODEC_ID_MP3:
394  if ( st->codecpar->sample_rate > 0
395  && st->codecpar->sample_rate < 32000) {
396  stream_type = STREAM_TYPE_AUDIO_MPEG2;
397  } else {
398  stream_type = STREAM_TYPE_AUDIO_MPEG1;
399  }
400  break;
401  case AV_CODEC_ID_AAC:
402  stream_type = (ts->flags & MPEGTS_FLAG_AAC_LATM)
403  ? STREAM_TYPE_AUDIO_AAC_LATM
404  : STREAM_TYPE_AUDIO_AAC;
405  break;
406  case AV_CODEC_ID_AAC_LATM:
407  stream_type = STREAM_TYPE_AUDIO_AAC_LATM;
408  break;
409  case AV_CODEC_ID_AC3:
410  stream_type = (ts->flags & MPEGTS_FLAG_SYSTEM_B)
411  ? STREAM_TYPE_PRIVATE_DATA
412  : STREAM_TYPE_ATSC_AUDIO_AC3;
413  break;
414  case AV_CODEC_ID_EAC3:
415  stream_type = (ts->flags & MPEGTS_FLAG_SYSTEM_B)
416  ? STREAM_TYPE_PRIVATE_DATA
417  : STREAM_TYPE_ATSC_AUDIO_EAC3;
418  break;
419  case AV_CODEC_ID_DTS:
420  stream_type = STREAM_TYPE_BLURAY_AUDIO_DTS; // should be STREAM_TYPE_PRIVATE_DATA (ETSI TS 101 154), needs a DTS_descriptor() (ETSI EN 300 468)
421  break;
422  case AV_CODEC_ID_TRUEHD:
423  stream_type = STREAM_TYPE_BLURAY_AUDIO_TRUEHD; // should be STREAM_TYPE_PRIVATE_DATA (ETSI TS 101 154), needs a DTS-HD_descriptor() (ETSI EN 300 468)
424  break;
425  case AV_CODEC_ID_OPUS:
426  stream_type = STREAM_TYPE_PRIVATE_DATA;
427  break;
428  case AV_CODEC_ID_TIMED_ID3:
429  stream_type = STREAM_TYPE_METADATA;
430  break;
431  case AV_CODEC_ID_SMPTE_2038:
432  stream_type = STREAM_TYPE_PRIVATE_DATA;
433  break;
434  case AV_CODEC_ID_DVB_SUBTITLE:
435  case AV_CODEC_ID_DVB_TELETEXT:
436  case AV_CODEC_ID_ARIB_CAPTION:
437  stream_type = STREAM_TYPE_PRIVATE_DATA;
438  break;
439  case AV_CODEC_ID_SMPTE_KLV:
440  if (st->codecpar->profile == AV_PROFILE_KLVA_SYNC) {
441  stream_type = STREAM_TYPE_METADATA;
442  } else {
443  stream_type = STREAM_TYPE_PRIVATE_DATA;
444  }
445  break;
446  default:
447  av_log_once(s, AV_LOG_WARNING, AV_LOG_DEBUG, &ts_st->data_st_warning,
448  "Stream %d, codec %s, is muxed as a private data stream "
449  "and may not be recognized upon reading.\n", st->index,
450  avcodec_get_name(st->codecpar->codec_id));
451  stream_type = STREAM_TYPE_PRIVATE_DATA;
452  break;
453  }
454 
455  return stream_type;
456 }
457 
458 static int get_m2ts_stream_type(AVFormatContext *s, AVStream *st)
459 {
460  int stream_type;
461  MpegTSWriteStream *ts_st = st->priv_data;
462 
463  switch (st->codecpar->codec_id) {
464  case AV_CODEC_ID_MPEG2VIDEO:
465  stream_type = STREAM_TYPE_VIDEO_MPEG2;
466  break;
467  case AV_CODEC_ID_H264:
468  stream_type = STREAM_TYPE_VIDEO_H264;
469  break;
470  case AV_CODEC_ID_VC1:
471  stream_type = STREAM_TYPE_VIDEO_VC1;
472  break;
473  case AV_CODEC_ID_HEVC:
474  stream_type = STREAM_TYPE_VIDEO_HEVC;
475  break;
476  case AV_CODEC_ID_PCM_BLURAY:
477  stream_type = STREAM_TYPE_BLURAY_AUDIO_PCM_BLURAY;
478  break;
479  case AV_CODEC_ID_AC3:
480  stream_type = STREAM_TYPE_BLURAY_AUDIO_AC3;
481  break;
482  case AV_CODEC_ID_DTS:
483  stream_type = (st->codecpar->ch_layout.nb_channels > 6) ?
484  STREAM_TYPE_BLURAY_AUDIO_DTS_HD :
485  STREAM_TYPE_BLURAY_AUDIO_DTS;
486  break;
487  case AV_CODEC_ID_TRUEHD:
488  stream_type = STREAM_TYPE_BLURAY_AUDIO_TRUEHD;
489  break;
490  case AV_CODEC_ID_EAC3:
491  stream_type = STREAM_TYPE_BLURAY_AUDIO_EAC3;
492  break;
493  case AV_CODEC_ID_HDMV_PGS_SUBTITLE:
494  stream_type = STREAM_TYPE_BLURAY_SUBTITLE_PGS;
495  break;
496  case AV_CODEC_ID_HDMV_TEXT_SUBTITLE:
497  stream_type = STREAM_TYPE_BLURAY_SUBTITLE_TEXT;
498  break;
499  default:
500  av_log_once(s, AV_LOG_WARNING, AV_LOG_DEBUG, &ts_st->data_st_warning,
501  "Stream %d, codec %s, is muxed as a private data stream "
502  "and may not be recognized upon reading.\n", st->index,
503  avcodec_get_name(st->codecpar->codec_id));
504  stream_type = STREAM_TYPE_PRIVATE_DATA;
505  break;
506  }
507 
508  return stream_type;
509 }
510 
511 static int mpegts_write_pmt(AVFormatContext *s, MpegTSService *service)
512 {
513  MpegTSWrite *ts = s->priv_data;
514  uint8_t data[SECTION_LENGTH], *q, *desc_length_ptr, *program_info_length_ptr;
515  int val, stream_type, i, err = 0;
516 
517  q = data;
518  put16(&q, 0xe000 | service->pcr_pid);
519 
520  program_info_length_ptr = q;
521  q += 2; /* patched after */
522 
523  /* put program info here */
524  if (ts->m2ts_mode) {
525  put_registration_descriptor(&q, MKTAG('H', 'D', 'M', 'V'));
526  *q++ = 0x88; // descriptor_tag - hdmv_copy_control_descriptor
527  *q++ = 0x04; // descriptor_length
528  put16(&q, 0x0fff); // CA_System_ID
529  *q++ = 0xfc; // private_data_byte
530  *q++ = 0xfc; // private_data_byte
531  }
532 
533  val = 0xf000 | (q - program_info_length_ptr - 2);
534  program_info_length_ptr[0] = val >> 8;
535  program_info_length_ptr[1] = val;
536 
537  for (i = 0; i < s->nb_streams; i++) {
538  AVStream *st = s->streams[i];
539  MpegTSWriteStream *ts_st = st->priv_data;
540  AVDictionaryEntry *lang = av_dict_get(st->metadata, "language", NULL, 0);
541  const char default_language[] = "und";
542  const char *language = lang && strlen(lang->value) >= 3 ? lang->value : default_language;
543  enum AVCodecID codec_id = st->codecpar->codec_id;
544 
545  if (s->nb_programs) {
546  int k, found = 0;
547  AVProgram *program = service->program;
548 
549  for (k = 0; k < program->nb_stream_indexes; k++)
550  if (program->stream_index[k] == i) {
551  found = 1;
552  break;
553  }
554 
555  if (!found)
556  continue;
557  }
558 
559  if (q - data > SECTION_LENGTH - 32) {
560  err = 1;
561  break;
562  }
563 
564  stream_type = ts->m2ts_mode ? get_m2ts_stream_type(s, st) : get_dvb_stream_type(s, st);
565 
566  *q++ = stream_type;
567  put16(&q, 0xe000 | ts_st->pid);
568  desc_length_ptr = q;
569  q += 2; /* patched after */
570 
571  /* write optional descriptors here */
572  switch (st->codecpar->codec_type) {
573  case AVMEDIA_TYPE_AUDIO:
574  if (codec_id == AV_CODEC_ID_AC3)
575  put_registration_descriptor(&q, MKTAG('A', 'C', '-', '3'));
576  if (codec_id == AV_CODEC_ID_EAC3)
577  put_registration_descriptor(&q, MKTAG('E', 'A', 'C', '3'));
578  if (ts->flags & MPEGTS_FLAG_SYSTEM_B) {
579  if (codec_id == AV_CODEC_ID_AC3) {
580  DVBAC3Descriptor *dvb_ac3_desc = ts_st->dvb_ac3_desc;
581 
582  *q++= AC3_DESCRIPTOR; // AC3 descriptor see A038 DVB SI
583  if (dvb_ac3_desc) {
584  int len = 1 +
585  !!(dvb_ac3_desc->component_type_flag) +
586  !!(dvb_ac3_desc->bsid_flag) +
587  !!(dvb_ac3_desc->mainid_flag) +
588  !!(dvb_ac3_desc->asvc_flag);
589 
590  *q++ = len;
591  *q++ = dvb_ac3_desc->component_type_flag << 7 | dvb_ac3_desc->bsid_flag << 6 |
592  dvb_ac3_desc->mainid_flag << 5 | dvb_ac3_desc->asvc_flag << 4;
593 
594  if (dvb_ac3_desc->component_type_flag) *q++ = dvb_ac3_desc->component_type;
595  if (dvb_ac3_desc->bsid_flag) *q++ = dvb_ac3_desc->bsid;
596  if (dvb_ac3_desc->mainid_flag) *q++ = dvb_ac3_desc->mainid;
597  if (dvb_ac3_desc->asvc_flag) *q++ = dvb_ac3_desc->asvc;
598  } else {
599  *q++=1; // 1 byte, all flags sets to 0
600  *q++=0; // omit all fields...
601  }
602  } else if (codec_id == AV_CODEC_ID_EAC3) {
603  *q++= ENHANCED_AC3_DESCRIPTOR; // EAC3 descriptor see A038 DVB SI
604  *q++=1; // 1 byte, all flags sets to 0
605  *q++=0; // omit all fields...
606  }
607  }
608  if (codec_id == AV_CODEC_ID_S302M)
609  put_registration_descriptor(&q, MKTAG('B', 'S', 'S', 'D'));
610  if (codec_id == AV_CODEC_ID_OPUS) {
611  int ch = st->codecpar->ch_layout.nb_channels;
612 
613  /* 6 bytes registration descriptor, 4 bytes Opus audio descriptor */
614  if (q - data > SECTION_LENGTH - 6 - 4) {
615  err = 1;
616  break;
617  }
618 
619  put_registration_descriptor(&q, MKTAG('O', 'p', 'u', 's'));
620 
621  *q++ = EXTENSION_DESCRIPTOR; /* DVB extension descriptor */
622  *q++ = 2;
623  *q++ = 0x80;
624 
625  if (st->codecpar->extradata && st->codecpar->extradata_size >= 19) {
626  if (st->codecpar->extradata[18] == 0 && ch <= 2) {
627  /* RTP mapping family */
628  *q++ = ch;
629  } else if (st->codecpar->extradata[18] == 1 && ch <= 8 &&
630  st->codecpar->extradata_size >= 21 + ch) {
631  static const uint8_t coupled_stream_counts[9] = {
632  1, 0, 1, 1, 2, 2, 2, 3, 3
633  };
634  static const uint8_t channel_map_a[8][8] = {
635  {0},
636  {0, 1},
637  {0, 2, 1},
638  {0, 1, 2, 3},
639  {0, 4, 1, 2, 3},
640  {0, 4, 1, 2, 3, 5},
641  {0, 4, 1, 2, 3, 5, 6},
642  {0, 6, 1, 2, 3, 4, 5, 7},
643  };
644  static const uint8_t channel_map_b[8][8] = {
645  {0},
646  {0, 1},
647  {0, 1, 2},
648  {0, 1, 2, 3},
649  {0, 1, 2, 3, 4},
650  {0, 1, 2, 3, 4, 5},
651  {0, 1, 2, 3, 4, 5, 6},
652  {0, 1, 2, 3, 4, 5, 6, 7},
653  };
654  /* Vorbis mapping family */
655 
656  if (st->codecpar->extradata[19] == ch - coupled_stream_counts[ch] &&
657  st->codecpar->extradata[20] == coupled_stream_counts[ch] &&
658  memcmp(&st->codecpar->extradata[21], channel_map_a[ch - 1], ch) == 0) {
659  *q++ = ch;
660  } else if (ch >= 2 && st->codecpar->extradata[19] == ch &&
661  st->codecpar->extradata[20] == 0 &&
662  memcmp(&st->codecpar->extradata[21], channel_map_b[ch - 1], ch) == 0) {
663  *q++ = ch | 0x80;
664  } else {
665  /* Unsupported, could write an extended descriptor here */
666  av_log(s, AV_LOG_ERROR, "Unsupported Opus Vorbis-style channel mapping");
667  *q++ = 0xff;
668  }
669  } else {
670  /* Unsupported */
671  av_log(s, AV_LOG_ERROR, "Unsupported Opus channel mapping for family %d", st->codecpar->extradata[18]);
672  *q++ = 0xff;
673  }
674  } else if (ch <= 2) {
675  /* Assume RTP mapping family */
676  *q++ = ch;
677  } else {
678  /* Unsupported */
679  av_log(s, AV_LOG_ERROR, "Unsupported Opus channel mapping");
680  *q++ = 0xff;
681  }
682  }
683 
684  if (language != default_language ||
685  st->disposition & (AV_DISPOSITION_CLEAN_EFFECTS |
686  AV_DISPOSITION_HEARING_IMPAIRED |
687  AV_DISPOSITION_VISUAL_IMPAIRED)) {
688  const char *p, *next;
689  uint8_t *len_ptr;
690 
691  *q++ = ISO_639_LANGUAGE_DESCRIPTOR;
692  len_ptr = q++;
693  *len_ptr = 0;
694 
695  for (p = next = language; next && *len_ptr < 255 / 4 * 4; p = next + 1) {
696  if (q - data > SECTION_LENGTH - 4) {
697  err = 1;
698  break;
699  }
700  next = strchr(p, ',');
701  if (strlen(p) != 3 && (!next || next != p + 3))
702  continue; /* not a 3-letter code */
703 
704  *q++ = *p++;
705  *q++ = *p++;
706  *q++ = *p++;
707 
708  if (st->disposition & AV_DISPOSITION_CLEAN_EFFECTS)
709  *q++ = 0x01;
710  else if (st->disposition & AV_DISPOSITION_HEARING_IMPAIRED)
711  *q++ = 0x02;
712  else if (st->disposition & AV_DISPOSITION_VISUAL_IMPAIRED)
713  *q++ = 0x03;
714  else
715  *q++ = 0; /* undefined type */
716 
717  *len_ptr += 4;
718  }
719 
720  if (*len_ptr == 0)
721  q -= 2; /* no language codes were written */
722  }
723  break;
724  case AVMEDIA_TYPE_SUBTITLE:
725  if (codec_id == AV_CODEC_ID_DVB_SUBTITLE) {
726  uint8_t *len_ptr;
727  int extradata_copied = 0;
728 
729  *q++ = SUBTITLING_DESCRIPTOR; /* subtitling_descriptor */
730  len_ptr = q++;
731 
732  while (strlen(language) >= 3) {
733  if (sizeof(data) - (q - data) < 8) { /* 8 bytes per DVB subtitle substream data */
734  err = 1;
735  break;
736  }
737  *q++ = *language++;
738  *q++ = *language++;
739  *q++ = *language++;
740  /* Skip comma */
741  if (*language != '\0')
742  language++;
743 
744  if (st->codecpar->extradata_size - extradata_copied >= 5) {
745  *q++ = st->codecpar->extradata[extradata_copied + 4]; /* subtitling_type */
746  memcpy(q, st->codecpar->extradata + extradata_copied, 4); /* composition_page_id and ancillary_page_id */
747  extradata_copied += 5;
748  q += 4;
749  } else {
750  /* subtitling_type:
751  * 0x10 - normal with no monitor aspect ratio criticality
752  * 0x20 - for the hard of hearing with no monitor aspect ratio criticality */
753  *q++ = (st->disposition & AV_DISPOSITION_HEARING_IMPAIRED) ? 0x20 : 0x10;
754  if ((st->codecpar->extradata_size == 4) && (extradata_copied == 0)) {
755  /* support of old 4-byte extradata format */
756  memcpy(q, st->codecpar->extradata, 4); /* composition_page_id and ancillary_page_id */
757  extradata_copied += 4;
758  q += 4;
759  } else {
760  put16(&q, 1); /* composition_page_id */
761  put16(&q, 1); /* ancillary_page_id */
762  }
763  }
764  }
765 
766  *len_ptr = q - len_ptr - 1;
767  } else if (codec_id == AV_CODEC_ID_DVB_TELETEXT) {
768  uint8_t *len_ptr = NULL;
769  int extradata_copied = 0;
770 
771  /* The descriptor tag. teletext_descriptor */
772  *q++ = TELETEXT_DESCRIPTOR;
773  len_ptr = q++;
774 
775  while (strlen(language) >= 3 && q - data < sizeof(data) - 6) {
776  *q++ = *language++;
777  *q++ = *language++;
778  *q++ = *language++;
779  /* Skip comma */
780  if (*language != '\0')
781  language++;
782 
783  if (st->codecpar->extradata_size - 1 > extradata_copied) {
784  memcpy(q, st->codecpar->extradata + extradata_copied, 2);
785  extradata_copied += 2;
786  q += 2;
787  } else {
788  /* The Teletext descriptor:
789  * teletext_type: This 5-bit field indicates the type of Teletext page indicated. (0x01 Initial Teletext page)
790  * teletext_magazine_number: This is a 3-bit field which identifies the magazine number.
791  * teletext_page_number: This is an 8-bit field giving two 4-bit hex digits identifying the page number. */
792  *q++ = 0x08;
793  *q++ = 0x00;
794  }
795  }
796 
797  *len_ptr = q - len_ptr - 1;
798  } else if (codec_id == AV_CODEC_ID_ARIB_CAPTION) {
799  if (put_arib_caption_descriptor(s, &q, st->codecpar) < 0)
800  break;
801  }
802  break;
803  case AVMEDIA_TYPE_VIDEO:
804  if (stream_type == STREAM_TYPE_VIDEO_DIRAC) {
805  put_registration_descriptor(&q, MKTAG('d', 'r', 'a', 'c'));
806  } else if (stream_type == STREAM_TYPE_VIDEO_VC1) {
807  put_registration_descriptor(&q, MKTAG('V', 'C', '-', '1'));
808  } else if (stream_type == STREAM_TYPE_VIDEO_HEVC && s->strict_std_compliance <= FF_COMPLIANCE_NORMAL) {
809  put_registration_descriptor(&q, MKTAG('H', 'E', 'V', 'C'));
810  } else if (stream_type == STREAM_TYPE_VIDEO_CAVS || stream_type == STREAM_TYPE_VIDEO_AVS2 ||
811  stream_type == STREAM_TYPE_VIDEO_AVS3) {
812  put_registration_descriptor(&q, MKTAG('A', 'V', 'S', 'V'));
813  }
814  break;
815  case AVMEDIA_TYPE_DATA:
816  if (codec_id == AV_CODEC_ID_SMPTE_KLV) {
817  put_registration_descriptor(&q, MKTAG('K', 'L', 'V', 'A'));
818  } else if (codec_id == AV_CODEC_ID_SMPTE_2038) {
819  put_registration_descriptor(&q, MKTAG('V', 'A', 'N', 'C'));
820  } else if (codec_id == AV_CODEC_ID_TIMED_ID3) {
821  const char *tag = "ID3 ";
822  *q++ = METADATA_DESCRIPTOR;
823  *q++ = 13;
824  put16(&q, 0xffff); /* metadata application format */
825  putbuf(&q, tag, strlen(tag));
826  *q++ = 0xff; /* metadata format */
827  putbuf(&q, tag, strlen(tag));
828  *q++ = 0; /* metadata service ID */
829  *q++ = 0xF; /* metadata_locator_record_flag|MPEG_carriage_flags|reserved */
830  }
831  break;
832  }
833 
834  val = 0xf000 | (q - desc_length_ptr - 2);
835  desc_length_ptr[0] = val >> 8;
836  desc_length_ptr[1] = val;
837  }
838 
839  if (err)
840  av_log(s, AV_LOG_ERROR,
841  "The PMT section cannot fit stream %d and all following streams.\n"
842  "Try reducing the number of languages in the audio streams "
843  "or the total number of streams.\n", i);
844 
845  mpegts_write_section1(&service->pmt, PMT_TID, service->sid, ts->tables_version, 0, 0,
846  data, q - data);
847  return 0;
848 }
849 
850 static void mpegts_write_sdt(AVFormatContext *s)
851 {
852  MpegTSWrite *ts = s->priv_data;
853  MpegTSService *service;
854  uint8_t data[SECTION_LENGTH], *q, *desc_list_len_ptr, *desc_len_ptr;
855  int i, running_status, free_ca_mode, val;
856 
857  q = data;
858  put16(&q, ts->original_network_id);
859  *q++ = 0xff;
860  for (i = 0; i < ts->nb_services; i++) {
861  service = ts->services[i];
862  put16(&q, service->sid);
863  *q++ = 0xfc | 0x00; /* currently no EIT info */
864  desc_list_len_ptr = q;
865  q += 2;
866  running_status = 4; /* running */
867  free_ca_mode = 0;
868 
869  /* write only one descriptor for the service name and provider */
870  *q++ = SERVICE_DESCRIPTOR;
871  desc_len_ptr = q;
872  q++;
873  *q++ = ts->service_type;
874  putbuf(&q, service->provider_name, service->provider_name[0] + 1);
875  putbuf(&q, service->name, service->name[0] + 1);
876  desc_len_ptr[0] = q - desc_len_ptr - 1;
877 
878  /* fill descriptor length */
879  val = (running_status << 13) | (free_ca_mode << 12) |
880  (q - desc_list_len_ptr - 2);
881  desc_list_len_ptr[0] = val >> 8;
882  desc_list_len_ptr[1] = val;
883  }
884  mpegts_write_section1(&ts->sdt, SDT_TID, ts->transport_stream_id, ts->tables_version, 0, 0,
885  data, q - data);
886 }
887 
888 static void mpegts_write_nit(AVFormatContext *s)
889 {
890  MpegTSWrite *ts = s->priv_data;
891  uint8_t data[SECTION_LENGTH], *q, *desc_len_ptr, *loop_len_ptr;
892 
893  q = data;
894 
895  //network_descriptors_length
896  put16(&q, 0xf000 | (ts->provider_name[0] + 2));
897 
898  //network_name_descriptor
899  *q++ = NETWORK_NAME_DESCRIPTOR;
900  putbuf(&q, ts->provider_name, ts->provider_name[0] + 1);
901 
902  //transport_stream_loop_length
903  loop_len_ptr = q;
904  q += 2;
905 
906  put16(&q, ts->transport_stream_id);
907  put16(&q, ts->original_network_id);
908 
909  //transport_descriptors_length
910  desc_len_ptr = q;
911  q += 2;
912 
913  //service_list_descriptor
914  *q++ = SERVICE_LIST_DESCRIPTOR;
915  *q++ = 3 * ts->nb_services;
916  for (int i = 0; i < ts->nb_services; i++) {
917  put16(&q, ts->services[i]->sid);
918  *q++ = ts->service_type;
919  }
920 
921  //calculate lengths
922  put16(&desc_len_ptr, 0xf000 | q - (desc_len_ptr + 2));
923  put16(&loop_len_ptr, 0xf000 | q - (loop_len_ptr + 2));
924 
925  mpegts_write_section1(&ts->nit, NIT_TID, ts->original_network_id, ts->tables_version, 0, 0,
926  data, q - data);
927 }
928 
929 /* This stores a string in buf with the correct encoding and also sets the
930  * first byte as the length. !str is accepted for an empty string.
931  * If the string is already encoded, invalid UTF-8 or has no multibyte sequence
932  * then we keep it as is, otherwise we signal UTF-8 encoding. */
933 static int encode_str8(uint8_t *buf, const char *str)
934 {
935  size_t str_len;
936  if (!str)
937  str = "";
938  str_len = strlen(str);
939  if (str[0] && (unsigned)str[0] >= 0x20) { /* Make sure the string is not already encoded. */
940  const uint8_t *q = str;
941  int has_multibyte = 0;
942  while (*q) {
943  uint32_t code;
944  GET_UTF8(code, *q++, goto invalid;) /* Is it valid UTF-8? */
945  has_multibyte |= (code > 127); /* Does it have multibyte UTF-8 chars in it? */
946  }
947  if (has_multibyte) { /* If we have multibyte chars and valid UTF-8, then encode as such! */
948  if (str_len > 254)
949  return AVERROR(EINVAL);
950  buf[0] = str_len + 1;
951  buf[1] = 0x15;
952  memcpy(&buf[2], str, str_len);
953  return 0;
954  }
955  }
956 invalid:
957  /* Otherwise let's just encode the string as is! */
958  if (str_len > 255)
959  return AVERROR(EINVAL);
960  buf[0] = str_len;
961  memcpy(&buf[1], str, str_len);
962  return 0;
963 }
964 
965 static int64_t get_pcr(const MpegTSWrite *ts)
966 {
967  return av_rescale(ts->total_size + 11, 8 * PCR_TIME_BASE, ts->mux_rate) +
968  ts->first_pcr;
969 }
970 
971 static void write_packet(AVFormatContext *s, const uint8_t *packet)
972 {
973  MpegTSWrite *ts = s->priv_data;
974  if (ts->m2ts_mode) {
975  int64_t pcr = get_pcr(s->priv_data);
976  uint32_t tp_extra_header = pcr % 0x3fffffff;
977  tp_extra_header = AV_RB32(&tp_extra_header);
978  avio_write(s->pb, (unsigned char *) &tp_extra_header,
979  sizeof(tp_extra_header));
980  }
981  avio_write(s->pb, packet, TS_PACKET_SIZE);
982  ts->total_size += TS_PACKET_SIZE;
983 }
984 
985 static void section_write_packet(MpegTSSection *s, const uint8_t *packet)
986 {
987  AVFormatContext *ctx = s->opaque;
988  write_packet(ctx, packet);
989 }
990 
991 static MpegTSService *mpegts_add_service(AVFormatContext *s, int sid,
992  const AVDictionary *metadata,
993  AVProgram *program)
994 {
995  MpegTSWrite *ts = s->priv_data;
996  MpegTSService *service;
997  AVDictionaryEntry *title, *provider;
998  char default_service_name[32];
999  const char *service_name;
1000  const char *provider_name;
1001 
1002  title = av_dict_get(metadata, "service_name", NULL, 0);
1003  if (!title)
1004  title = av_dict_get(metadata, "title", NULL, 0);
1005  snprintf(default_service_name, sizeof(default_service_name), "%s%02d", DEFAULT_SERVICE_NAME, ts->nb_services + 1);
1006  service_name = title ? title->value : default_service_name;
1007  provider = av_dict_get(metadata, "service_provider", NULL, 0);
1008  provider_name = provider ? provider->value : DEFAULT_PROVIDER_NAME;
1009 
1010  service = av_mallocz(sizeof(MpegTSService));
1011  if (!service)
1012  return NULL;
1013  service->pmt.pid = ts->pmt_start_pid + ts->nb_services;
1014  service->sid = sid;
1015  service->pcr_pid = 0x1fff;
1016  if (encode_str8(service->provider_name, provider_name) < 0 ||
1017  encode_str8(service->name, service_name) < 0) {
1018  av_log(s, AV_LOG_ERROR, "Too long service or provider name\n");
1019  goto fail;
1020  }
1021  if (av_dynarray_add_nofree(&ts->services, &ts->nb_services, service) < 0)
1022  goto fail;
1023 
1024  service->pmt.write_packet = section_write_packet;
1025  service->pmt.opaque = s;
1026  service->pmt.cc = 15;
1027  service->pmt.discontinuity= ts->flags & MPEGTS_FLAG_DISCONT;
1028  service->program = program;
1029 
1030  return service;
1031 fail:
1032  av_free(service);
1033  return NULL;
1034 }
1035 
1036 static void enable_pcr_generation_for_stream(AVFormatContext *s, AVStream *pcr_st)
1037 {
1038  MpegTSWrite *ts = s->priv_data;
1039  MpegTSWriteStream *ts_st = pcr_st->priv_data;
1040 
1041  if (ts->mux_rate > 1 || ts->pcr_period_ms >= 0) {
1042  int pcr_period_ms = ts->pcr_period_ms == -1 ? PCR_RETRANS_TIME : ts->pcr_period_ms;
1043  ts_st->pcr_period = av_rescale(pcr_period_ms, PCR_TIME_BASE, 1000);
1044  } else {
1045  /* By default, for VBR we select the highest multiple of frame duration which is less than 100 ms. */
1046  int64_t frame_period = 0;
1047  if (pcr_st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO) {
1048  int frame_size = av_get_audio_frame_duration2(pcr_st->codecpar, 0);
1049  if (!frame_size) {
1050  av_log(s, AV_LOG_WARNING, "frame size not set\n");
1051  frame_size = 512;
1052  }
1053  frame_period = av_rescale_rnd(frame_size, PCR_TIME_BASE, pcr_st->codecpar->sample_rate, AV_ROUND_UP);
1054  } else if (pcr_st->avg_frame_rate.num) {
1055  frame_period = av_rescale_rnd(pcr_st->avg_frame_rate.den, PCR_TIME_BASE, pcr_st->avg_frame_rate.num, AV_ROUND_UP);
1056  }
1057  if (frame_period > 0 && frame_period <= PCR_TIME_BASE / 10)
1058  ts_st->pcr_period = frame_period * (PCR_TIME_BASE / 10 / frame_period);
1059  else
1060  ts_st->pcr_period = 1;
1061  }
1062 
1063  // output a PCR as soon as possible
1064  ts_st->last_pcr = ts->first_pcr - ts_st->pcr_period;
1065 }
1066 
1067 static void select_pcr_streams(AVFormatContext *s)
1068 {
1069  MpegTSWrite *ts = s->priv_data;
1070 
1071  for (int i = 0; i < ts->nb_services; i++) {
1072  MpegTSService *service = ts->services[i];
1073  AVStream *pcr_st = NULL;
1074  AVProgram *program = service->program;
1075  int nb_streams = program ? program->nb_stream_indexes : s->nb_streams;
1076 
1077  for (int j = 0; j < nb_streams; j++) {
1078  AVStream *st = s->streams[program ? program->stream_index[j] : j];
1079  if (!pcr_st ||
1080  pcr_st->codecpar->codec_type != AVMEDIA_TYPE_VIDEO && st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO)
1081  {
1082  pcr_st = st;
1083  }
1084  }
1085 
1086  if (pcr_st) {
1087  MpegTSWriteStream *ts_st = pcr_st->priv_data;
1088  service->pcr_pid = ts_st->pid;
1089  enable_pcr_generation_for_stream(s, pcr_st);
1090  av_log(s, AV_LOG_VERBOSE, "service %i using PCR in pid=%i, pcr_period=%"PRId64"ms\n",
1091  service->sid, service->pcr_pid, av_rescale(ts_st->pcr_period, 1000, PCR_TIME_BASE));
1092  }
1093  }
1094 }
1095 
1096 static int mpegts_init(AVFormatContext *s)
1097 {
1098  MpegTSWrite *ts = s->priv_data;
1099  AVDictionaryEntry *provider;
1100  const char *provider_name;
1101  int i, j;
1102  int ret;
1103 
1104  if (ts->m2ts_mode == -1) {
1105  if (av_match_ext(s->url, "m2ts")) {
1106  ts->m2ts_mode = 1;
1107  } else {
1108  ts->m2ts_mode = 0;
1109  }
1110  }
1111 
1112  ts->m2ts_video_pid = M2TS_VIDEO_PID;
1113  ts->m2ts_audio_pid = M2TS_AUDIO_START_PID;
1114  ts->m2ts_pgssub_pid = M2TS_PGSSUB_START_PID;
1115  ts->m2ts_textsub_pid = M2TS_TEXTSUB_PID;
1116 
1117  if (ts->m2ts_mode) {
1118  ts->pmt_start_pid = M2TS_PMT_PID;
1119  if (s->nb_programs > 1) {
1120  av_log(s, AV_LOG_ERROR, "Only one program is allowed in m2ts mode!\n");
1121  return AVERROR(EINVAL);
1122  }
1123  }
1124 
1125  if (s->max_delay < 0) /* Not set by the caller */
1126  s->max_delay = 0;
1127 
1128  // round up to a whole number of TS packets
1129  ts->pes_payload_size = (ts->pes_payload_size + 14 + 183) / 184 * 184 - 14;
1130 
1131  if (!s->nb_programs) {
1132  /* allocate a single DVB service */
1133  if (!mpegts_add_service(s, ts->service_id, s->metadata, NULL))
1134  return AVERROR(ENOMEM);
1135  } else {
1136  for (i = 0; i < s->nb_programs; i++) {
1137  AVProgram *program = s->programs[i];
1138  if (!mpegts_add_service(s, program->id, program->metadata, program))
1139  return AVERROR(ENOMEM);
1140  }
1141  }
1142 
1143  ts->pat.pid = PAT_PID;
1144  /* Initialize at 15 so that it wraps and is equal to 0 for the
1145  * first packet we write. */
1146  ts->pat.cc = 15;
1147  ts->pat.discontinuity= ts->flags & MPEGTS_FLAG_DISCONT;
1148  ts->pat.write_packet = section_write_packet;
1149  ts->pat.opaque = s;
1150 
1151  ts->sdt.pid = SDT_PID;
1152  ts->sdt.cc = 15;
1153  ts->sdt.discontinuity= ts->flags & MPEGTS_FLAG_DISCONT;
1154  ts->sdt.write_packet = section_write_packet;
1155  ts->sdt.opaque = s;
1156 
1157  ts->nit.pid = NIT_PID;
1158  ts->nit.cc = 15;
1159  ts->nit.discontinuity= ts->flags & MPEGTS_FLAG_DISCONT;
1160  ts->nit.write_packet = section_write_packet;
1161  ts->nit.opaque = s;
1162 
1163  ts->pkt = ffformatcontext(s)->pkt;
1164 
1165  /* assign pids to each stream */
1166  for (i = 0; i < s->nb_streams; i++) {
1167  AVStream *st = s->streams[i];
1168  MpegTSWriteStream *ts_st;
1169 
1170  ts_st = av_mallocz(sizeof(MpegTSWriteStream));
1171  if (!ts_st) {
1172  return AVERROR(ENOMEM);
1173  }
1174  st->priv_data = ts_st;
1175 
1176  avpriv_set_pts_info(st, 33, 1, 90000);
1177 
1178  ts_st->payload = av_mallocz(ts->pes_payload_size);
1179  if (!ts_st->payload) {
1180  return AVERROR(ENOMEM);
1181  }
1182 
1183  /* MPEG pid values < 16 are reserved. Applications which set st->id in
1184  * this range are assigned a calculated pid. */
1185  if (st->id < 16) {
1186  if (ts->m2ts_mode) {
1187  switch (st->codecpar->codec_type) {
1188  case AVMEDIA_TYPE_VIDEO:
1189  ts_st->pid = ts->m2ts_video_pid++;
1190  break;
1191  case AVMEDIA_TYPE_AUDIO:
1192  ts_st->pid = ts->m2ts_audio_pid++;
1193  break;
1194  case AVMEDIA_TYPE_SUBTITLE:
1195  switch (st->codecpar->codec_id) {
1196  case AV_CODEC_ID_HDMV_PGS_SUBTITLE:
1197  ts_st->pid = ts->m2ts_pgssub_pid++;
1198  break;
1199  case AV_CODEC_ID_HDMV_TEXT_SUBTITLE:
1200  ts_st->pid = ts->m2ts_textsub_pid++;
1201  break;
1202  }
1203  break;
1204  }
1205  if (ts->m2ts_video_pid > M2TS_VIDEO_PID + 1 ||
1206  ts->m2ts_audio_pid > M2TS_AUDIO_START_PID + 32 ||
1207  ts->m2ts_pgssub_pid > M2TS_PGSSUB_START_PID + 32 ||
1208  ts->m2ts_textsub_pid > M2TS_TEXTSUB_PID + 1 ||
1209  ts_st->pid < 16) {
1210  av_log(s, AV_LOG_ERROR, "Cannot automatically assign PID for stream %d\n", st->index);
1211  return AVERROR(EINVAL);
1212  }
1213  } else {
1214  ts_st->pid = ts->start_pid + i;
1215  }
1216  } else {
1217  ts_st->pid = st->id;
1218  }
1219  if (ts_st->pid >= 0x1FFF) {
1220  av_log(s, AV_LOG_ERROR,
1221  "Invalid stream id %d, must be less than 8191\n", st->id);
1222  return AVERROR(EINVAL);
1223  }
1224  for (j = 0; j < ts->nb_services; j++) {
1225  if (ts->services[j]->pmt.pid > LAST_OTHER_PID) {
1226  av_log(s, AV_LOG_ERROR,
1227  "Invalid PMT PID %d, must be less than %d\n", ts->services[j]->pmt.pid, LAST_OTHER_PID + 1);
1228  return AVERROR(EINVAL);
1229  }
1230  if (ts_st->pid == ts->services[j]->pmt.pid) {
1231  av_log(s, AV_LOG_ERROR, "PID %d cannot be both elementary and PMT PID\n", ts_st->pid);
1232  return AVERROR(EINVAL);
1233  }
1234  }
1235  for (j = 0; j < i; j++) {
1236  MpegTSWriteStream *ts_st_prev = s->streams[j]->priv_data;
1237  if (ts_st_prev->pid == ts_st->pid) {
1238  av_log(s, AV_LOG_ERROR, "Duplicate stream id %d\n", ts_st->pid);
1239  return AVERROR(EINVAL);
1240  }
1241  }
1242  ts_st->payload_pts = AV_NOPTS_VALUE;
1243  ts_st->payload_dts = AV_NOPTS_VALUE;
1244  ts_st->cc = 15;
1245  ts_st->discontinuity = ts->flags & MPEGTS_FLAG_DISCONT;
1246  if (st->codecpar->codec_id == AV_CODEC_ID_AAC &&
1247  st->codecpar->extradata_size > 0) {
1248  AVStream *ast;
1249  ts_st->amux = avformat_alloc_context();
1250  if (!ts_st->amux) {
1251  return AVERROR(ENOMEM);
1252  }
1253  ts_st->amux->oformat =
1254  av_guess_format((ts->flags & MPEGTS_FLAG_AAC_LATM) ? "latm" : "adts",
1255  NULL, NULL);
1256  if (!ts_st->amux->oformat) {
1257  return AVERROR(EINVAL);
1258  }
1259  if (!(ast = avformat_new_stream(ts_st->amux, NULL))) {
1260  return AVERROR(ENOMEM);
1261  }
1262  ret = avcodec_parameters_copy(ast->codecpar, st->codecpar);
1263  if (ret != 0)
1264  return ret;
1265  ast->time_base = st->time_base;
1266  ret = avformat_write_header(ts_st->amux, NULL);
1267  if (ret < 0)
1268  return ret;
1269  }
1270  if (st->codecpar->codec_id == AV_CODEC_ID_OPUS) {
1271  ts_st->opus_pending_trim_start = st->codecpar->initial_padding * 48000 / st->codecpar->sample_rate;
1272  }
1273  }
1274 
1275  if (ts->copyts < 1)
1276  ts->first_pcr = av_rescale(s->max_delay, PCR_TIME_BASE, AV_TIME_BASE);
1277 
1278  select_pcr_streams(s);
1279 
1280  ts->last_pat_ts = AV_NOPTS_VALUE;
1281  ts->last_sdt_ts = AV_NOPTS_VALUE;
1282  ts->last_nit_ts = AV_NOPTS_VALUE;
1283  ts->pat_period = av_rescale(ts->pat_period_us, PCR_TIME_BASE, AV_TIME_BASE);
1284  ts->sdt_period = av_rescale(ts->sdt_period_us, PCR_TIME_BASE, AV_TIME_BASE);
1285  ts->nit_period = av_rescale(ts->nit_period_us, PCR_TIME_BASE, AV_TIME_BASE);
1286 
1287  /* assign provider name */
1288  provider = av_dict_get(s->metadata, "service_provider", NULL, 0);
1289  provider_name = provider ? provider->value : DEFAULT_PROVIDER_NAME;
1290  if (encode_str8(ts->provider_name, provider_name) < 0) {
1291  av_log(s, AV_LOG_ERROR, "Too long provider name\n");
1292  return AVERROR(EINVAL);
1293  }
1294 
1295  if (ts->mux_rate == 1)
1296  av_log(s, AV_LOG_VERBOSE, "muxrate VBR, ");
1297  else
1298  av_log(s, AV_LOG_VERBOSE, "muxrate %d, ", ts->mux_rate);
1299  av_log(s, AV_LOG_VERBOSE,
1300  "sdt every %"PRId64" ms, pat/pmt every %"PRId64" ms",
1301  av_rescale(ts->sdt_period, 1000, PCR_TIME_BASE),
1302  av_rescale(ts->pat_period, 1000, PCR_TIME_BASE));
1303  if (ts->flags & MPEGTS_FLAG_NIT)
1304  av_log(s, AV_LOG_VERBOSE, ", nit every %"PRId64" ms", av_rescale(ts->nit_period, 1000, PCR_TIME_BASE));
1305  av_log(s, AV_LOG_VERBOSE, "\n");
1306 
1307  return 0;
1308 }
1309 
1310 /* send SDT, NIT, PAT and PMT tables regularly */
1311 static void retransmit_si_info(AVFormatContext *s, int force_pat, int force_sdt, int force_nit, int64_t pcr)
1312 {
1313  MpegTSWrite *ts = s->priv_data;
1314  int i;
1315 
1316  if ((pcr != AV_NOPTS_VALUE && ts->last_sdt_ts == AV_NOPTS_VALUE) ||
1317  (pcr != AV_NOPTS_VALUE && pcr - ts->last_sdt_ts >= ts->sdt_period) ||
1318  force_sdt
1319  ) {
1320  if (pcr != AV_NOPTS_VALUE)
1321  ts->last_sdt_ts = FFMAX(pcr, ts->last_sdt_ts);
1322  mpegts_write_sdt(s);
1323  }
1324  if ((pcr != AV_NOPTS_VALUE && ts->last_pat_ts == AV_NOPTS_VALUE) ||
1325  (pcr != AV_NOPTS_VALUE && pcr - ts->last_pat_ts >= ts->pat_period) ||
1326  force_pat) {
1327  if (pcr != AV_NOPTS_VALUE)
1328  ts->last_pat_ts = FFMAX(pcr, ts->last_pat_ts);
1329  mpegts_write_pat(s);
1330  for (i = 0; i < ts->nb_services; i++)
1331  mpegts_write_pmt(s, ts->services[i]);
1332  }
1333  if ((pcr != AV_NOPTS_VALUE && ts->last_nit_ts == AV_NOPTS_VALUE) ||
1334  (pcr != AV_NOPTS_VALUE && pcr - ts->last_nit_ts >= ts->nit_period) ||
1335  force_nit
1336  ) {
1337  if (pcr != AV_NOPTS_VALUE)
1338  ts->last_nit_ts = FFMAX(pcr, ts->last_nit_ts);
1339  if (ts->flags & MPEGTS_FLAG_NIT)
1340  mpegts_write_nit(s);
1341  }
1342 }
1343 
1344 static int write_pcr_bits(uint8_t *buf, int64_t pcr)
1345 {
1346  int64_t pcr_low = pcr % SYSTEM_CLOCK_FREQUENCY_DIVISOR, pcr_high = pcr / SYSTEM_CLOCK_FREQUENCY_DIVISOR;
1347 
1348  *buf++ = pcr_high >> 25;
1349  *buf++ = pcr_high >> 17;
1350  *buf++ = pcr_high >> 9;
1351  *buf++ = pcr_high >> 1;
1352  *buf++ = pcr_high << 7 | pcr_low >> 8 | 0x7e;
1353  *buf++ = pcr_low;
1354 
1355  return 6;
1356 }
1357 
1358 /* Write a single null transport stream packet */
1359 static void mpegts_insert_null_packet(AVFormatContext *s)
1360 {
1361  uint8_t *q;
1362  uint8_t buf[TS_PACKET_SIZE];
1363 
1364  q = buf;
1365  *q++ = SYNC_BYTE;
1366  *q++ = 0x00 | (NULL_PID >> 8);
1367  *q++ = NULL_PID & 0xff;
1368  *q++ = 0x10;
1369  memset(q, STUFFING_BYTE, TS_PACKET_SIZE - (q - buf)); /* data_bytes may be assigned any value */
1370  write_packet(s, buf);
1371 }
1372 
1373 /* Write a single transport stream packet with a PCR and no payload */
1374 static void mpegts_insert_pcr_only(AVFormatContext *s, AVStream *st)
1375 {
1376  MpegTSWrite *ts = s->priv_data;
1377  MpegTSWriteStream *ts_st = st->priv_data;
1378  uint8_t *q;
1379  uint8_t buf[TS_PACKET_SIZE];
1380 
1381  q = buf;
1382  *q++ = SYNC_BYTE;
1383  *q++ = ts_st->pid >> 8;
1384  *q++ = ts_st->pid;
1385  *q++ = 0x20 | ts_st->cc; /* Adaptation only */
1386  /* Continuity Count field does not increment (see 13818-1 section 2.4.3.3) */
1387  *q++ = TS_PACKET_SIZE - 5; /* Adaptation Field Length */
1388  *q++ = 0x10; /* Adaptation flags: PCR present */
1389  if (ts_st->discontinuity) {
1390  q[-1] |= 0x80;
1391  ts_st->discontinuity = 0;
1392  }
1393 
1394  /* PCR coded into 6 bytes */
1395  q += write_pcr_bits(q, get_pcr(ts));
1396 
1397  /* stuffing bytes */
1398  memset(q, STUFFING_BYTE, TS_PACKET_SIZE - (q - buf));
1399  write_packet(s, buf);
1400 }
1401 
1402 static void write_pts(uint8_t *q, int fourbits, int64_t pts)
1403 {
1404  int val;
1405 
1406  val = fourbits << 4 | (((pts >> 30) & 0x07) << 1) | 1;
1407  *q++ = val;
1408  val = (((pts >> 15) & 0x7fff) << 1) | 1;
1409  *q++ = val >> 8;
1410  *q++ = val;
1411  val = (((pts) & 0x7fff) << 1) | 1;
1412  *q++ = val >> 8;
1413  *q++ = val;
1414 }
1415 
1416 /* Set an adaptation field flag in an MPEG-TS packet*/
1417 static void set_af_flag(uint8_t *pkt, int flag)
1418 {
1419  // expect at least one flag to set
1420  av_assert0(flag);
1421 
1422  if ((pkt[3] & 0x20) == 0) {
1423  // no AF yet, set adaptation field flag
1424  pkt[3] |= 0x20;
1425  // 1 byte length, no flags
1426  pkt[4] = 1;
1427  pkt[5] = 0;
1428  }
1429  pkt[5] |= flag;
1430 }
1431 
1432 /* Extend the adaptation field by size bytes */
1433 static void extend_af(uint8_t *pkt, int size)
1434 {
1435  // expect already existing adaptation field
1436  av_assert0(pkt[3] & 0x20);
1437  pkt[4] += size;
1438 }
1439 
1440 /* Get a pointer to MPEG-TS payload (right after TS packet header) */
1441 static uint8_t *get_ts_payload_start(uint8_t *pkt)
1442 {
1443  if (pkt[3] & 0x20)
1444  return pkt + 5 + pkt[4];
1445  else
1446  return pkt + 4;
1447 }
1448 
1449 static int get_pes_stream_id(AVFormatContext *s, AVStream *st, int stream_id, int *async)
1450 {
1451  MpegTSWrite *ts = s->priv_data;
1452  *async = 0;
1453  if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
1454  if (st->codecpar->codec_id == AV_CODEC_ID_DIRAC)
1455  return STREAM_ID_EXTENDED_STREAM_ID;
1456  else
1457  return STREAM_ID_VIDEO_STREAM_0;
1458  } else if (st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO &&
1459  (st->codecpar->codec_id == AV_CODEC_ID_MP2 ||
1460  st->codecpar->codec_id == AV_CODEC_ID_MP3 ||
1461  st->codecpar->codec_id == AV_CODEC_ID_AAC)) {
1462  return STREAM_ID_AUDIO_STREAM_0;
1463  } else if (st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO &&
1464  st->codecpar->codec_id == AV_CODEC_ID_AC3 &&
1465  ts->m2ts_mode) {
1466  return STREAM_ID_EXTENDED_STREAM_ID;
1467  } else if (st->codecpar->codec_type == AVMEDIA_TYPE_DATA &&
1468  st->codecpar->codec_id == AV_CODEC_ID_TIMED_ID3) {
1469  return STREAM_ID_PRIVATE_STREAM_1;
1470  } else if (st->codecpar->codec_type == AVMEDIA_TYPE_DATA) {
1471  if (st->codecpar->codec_id == AV_CODEC_ID_SMPTE_KLV &&
1472  stream_id == STREAM_ID_PRIVATE_STREAM_1) /* asynchronous KLV */
1473  *async = 1;
1474  return stream_id != -1 ? stream_id : STREAM_ID_METADATA_STREAM;
1475  } else {
1476  return STREAM_ID_PRIVATE_STREAM_1;
1477  }
1478 }
1479 
1480 /* Add a PES header to the front of the payload, and segment into an integer
1481  * number of TS packets. The final TS packet is padded using an oversized
1482  * adaptation header to exactly fill the last TS packet.
1483  * NOTE: 'payload' contains a complete PES payload. */
1484 static void mpegts_write_pes(AVFormatContext *s, AVStream *st,
1485  const uint8_t *payload, int payload_size,
1486  int64_t pts, int64_t dts, int key, int stream_id)
1487 {
1488  MpegTSWriteStream *ts_st = st->priv_data;
1489  MpegTSWrite *ts = s->priv_data;
1490  uint8_t buf[TS_PACKET_SIZE];
1491  uint8_t *q;
1492  int val, is_start, len, header_len, write_pcr, flags;
1493  int afc_len, stuffing_len;
1494  int is_dvb_subtitle = (st->codecpar->codec_id == AV_CODEC_ID_DVB_SUBTITLE);
1495  int is_dvb_teletext = (st->codecpar->codec_id == AV_CODEC_ID_DVB_TELETEXT);
1496  int64_t delay = av_rescale(s->max_delay, 90000, AV_TIME_BASE);
1497  int force_pat = st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO && key && !ts_st->prev_payload_key;
1498  int force_sdt = 0;
1499  int force_nit = 0;
1500 
1501  av_assert0(ts_st->payload != buf || st->codecpar->codec_type != AVMEDIA_TYPE_VIDEO);
1502  if (ts->flags & MPEGTS_FLAG_PAT_PMT_AT_FRAMES && st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
1503  force_pat = 1;
1504  }
1505 
1506  if (ts->flags & MPEGTS_FLAG_REEMIT_PAT_PMT) {
1507  force_pat = 1;
1508  force_sdt = 1;
1509  force_nit = 1;
1510  ts->flags &= ~MPEGTS_FLAG_REEMIT_PAT_PMT;
1511  }
1512 
1513  is_start = 1;
1514  while (payload_size > 0) {
1515  int64_t pcr = AV_NOPTS_VALUE;
1516  if (ts->mux_rate > 1)
1517  pcr = get_pcr(ts);
1518  else if (dts != AV_NOPTS_VALUE)
1519  pcr = (dts - delay) * SYSTEM_CLOCK_FREQUENCY_DIVISOR;
1520 
1521  retransmit_si_info(s, force_pat, force_sdt, force_nit, pcr);
1522  force_pat = 0;
1523  force_sdt = 0;
1524  force_nit = 0;
1525 
1526  write_pcr = 0;
1527  if (ts->mux_rate > 1) {
1528  /* Send PCR packets for all PCR streams if needed */
1529  pcr = get_pcr(ts);
1530  if (pcr >= ts->next_pcr) {
1531  int64_t next_pcr = INT64_MAX;
1532  for (int i = 0; i < s->nb_streams; i++) {
1533  /* Make the current stream the last, because for that we
1534  * can insert the pcr into the payload later */
1535  int st2_index = i < st->index ? i : (i + 1 == s->nb_streams ? st->index : i + 1);
1536  AVStream *st2 = s->streams[st2_index];
1537  MpegTSWriteStream *ts_st2 = st2->priv_data;
1538  if (ts_st2->pcr_period) {
1539  if (pcr - ts_st2->last_pcr >= ts_st2->pcr_period) {
1540  ts_st2->last_pcr = FFMAX(pcr - ts_st2->pcr_period, ts_st2->last_pcr + ts_st2->pcr_period);
1541  if (st2 != st) {
1542  mpegts_insert_pcr_only(s, st2);
1543  pcr = get_pcr(ts);
1544  } else {
1545  write_pcr = 1;
1546  }
1547  }
1548  next_pcr = FFMIN(next_pcr, ts_st2->last_pcr + ts_st2->pcr_period);
1549  }
1550  }
1551  ts->next_pcr = next_pcr;
1552  }
1553  if (dts != AV_NOPTS_VALUE && (dts - pcr / SYSTEM_CLOCK_FREQUENCY_DIVISOR) > delay) {
1554  /* pcr insert gets priority over null packet insert */
1555  if (write_pcr)
1556  mpegts_insert_pcr_only(s, st);
1557  else
1558  mpegts_insert_null_packet(s);
1559  /* recalculate write_pcr and possibly retransmit si_info */
1560  continue;
1561  }
1562  } else if (ts_st->pcr_period && pcr != AV_NOPTS_VALUE) {
1563  if (pcr - ts_st->last_pcr >= ts_st->pcr_period && is_start) {
1564  ts_st->last_pcr = FFMAX(pcr - ts_st->pcr_period, ts_st->last_pcr + ts_st->pcr_period);
1565  write_pcr = 1;
1566  }
1567  }
1568 
1569  /* prepare packet header */
1570  q = buf;
1571  *q++ = SYNC_BYTE;
1572  val = ts_st->pid >> 8;
1573  if (ts->m2ts_mode && st->codecpar->codec_id == AV_CODEC_ID_AC3)
1574  val |= 0x20;
1575  if (is_start)
1576  val |= 0x40;
1577  *q++ = val;
1578  *q++ = ts_st->pid;
1579  ts_st->cc = ts_st->cc + 1 & 0xf;
1580  *q++ = 0x10 | ts_st->cc; // payload indicator + CC
1581  if (ts_st->discontinuity) {
1582  set_af_flag(buf, 0x80);
1583  q = get_ts_payload_start(buf);
1584  ts_st->discontinuity = 0;
1585  }
1586  if (!(ts->flags & MPEGTS_FLAG_OMIT_RAI) &&
1587  key && is_start && pts != AV_NOPTS_VALUE &&
1588  !is_dvb_teletext /* adaptation+payload forbidden for teletext (ETSI EN 300 472 V1.3.1 4.1) */) {
1589  // set Random Access for key frames
1590  if (ts_st->pcr_period)
1591  write_pcr = 1;
1592  set_af_flag(buf, 0x40);
1593  q = get_ts_payload_start(buf);
1594  }
1595  if (write_pcr) {
1596  set_af_flag(buf, 0x10);
1597  q = get_ts_payload_start(buf);
1598  // add 11, pcr references the last byte of program clock reference base
1599  if (dts != AV_NOPTS_VALUE && dts < pcr / SYSTEM_CLOCK_FREQUENCY_DIVISOR)
1600  av_log(s, AV_LOG_WARNING, "dts < pcr, TS is invalid\n");
1601  extend_af(buf, write_pcr_bits(q, pcr));
1602  q = get_ts_payload_start(buf);
1603  }
1604  if (is_start) {
1605  int pes_extension = 0;
1606  int pes_header_stuffing_bytes = 0;
1607  int async;
1608  /* write PES header */
1609  *q++ = 0x00;
1610  *q++ = 0x00;
1611  *q++ = 0x01;
1612  *q++ = stream_id = get_pes_stream_id(s, st, stream_id, &async);
1613  if (async)
1614  pts = dts = AV_NOPTS_VALUE;
1615 
1616  header_len = 0;
1617 
1618  if (stream_id != STREAM_ID_PROGRAM_STREAM_MAP &&
1619  stream_id != STREAM_ID_PADDING_STREAM &&
1620  stream_id != STREAM_ID_PRIVATE_STREAM_2 &&
1621  stream_id != STREAM_ID_ECM_STREAM &&
1622  stream_id != STREAM_ID_EMM_STREAM &&
1623  stream_id != STREAM_ID_PROGRAM_STREAM_DIRECTORY &&
1624  stream_id != STREAM_ID_DSMCC_STREAM &&
1625  stream_id != STREAM_ID_TYPE_E_STREAM) {
1626 
1627  flags = 0;
1628  if (pts != AV_NOPTS_VALUE) {
1629  header_len += 5;
1630  flags |= 0x80;
1631  }
1632  if (dts != AV_NOPTS_VALUE && pts != AV_NOPTS_VALUE && dts != pts) {
1633  header_len += 5;
1634  flags |= 0x40;
1635  }
1636  if (st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO &&
1637  st->codecpar->codec_id == AV_CODEC_ID_DIRAC) {
1638  /* set PES_extension_flag */
1639  pes_extension = 1;
1640  flags |= 0x01;
1641 
1642  /* One byte for PES2 extension flag +
1643  * one byte for extension length +
1644  * one byte for extension id */
1645  header_len += 3;
1646  }
1647  /* for Blu-ray AC3 Audio the PES Extension flag should be as follow
1648  * otherwise it will not play sound on blu-ray
1649  */
1650  if (ts->m2ts_mode &&
1651  st->codecpar->codec_type == AVMEDIA_TYPE_AUDIO &&
1652  st->codecpar->codec_id == AV_CODEC_ID_AC3) {
1653  /* set PES_extension_flag */
1654  pes_extension = 1;
1655  flags |= 0x01;
1656  header_len += 3;
1657  }
1658  if (is_dvb_teletext) {
1659  pes_header_stuffing_bytes = 0x24 - header_len;
1660  header_len = 0x24;
1661  }
1662  len = payload_size + header_len + 3;
1663  /* 3 extra bytes should be added to DVB subtitle payload: 0x20 0x00 at the beginning and trailing 0xff */
1664  if (is_dvb_subtitle) {
1665  len += 3;
1666  payload_size++;
1667  }
1668  if (len > 0xffff)
1669  len = 0;
1670  if (ts->omit_video_pes_length && st->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
1671  len = 0;
1672  }
1673  *q++ = len >> 8;
1674  *q++ = len;
1675  val = 0x80;
1676  /* data alignment indicator is required for subtitle and data streams */
1677  if (st->codecpar->codec_type == AVMEDIA_TYPE_SUBTITLE || st->codecpar->codec_type == AVMEDIA_TYPE_DATA)
1678  val |= 0x04;
1679  *q++ = val;
1680  *q++ = flags;
1681  *q++ = header_len;
1682  if (pts != AV_NOPTS_VALUE) {
1683  write_pts(q, flags >> 6, pts);
1684  q += 5;
1685  }
1686  if (dts != AV_NOPTS_VALUE && pts != AV_NOPTS_VALUE && dts != pts) {
1687  write_pts(q, 1, dts);
1688  q += 5;
1689  }
1690  if (pes_extension && st->codecpar->codec_id == AV_CODEC_ID_DIRAC) {
1691  flags = 0x01; /* set PES_extension_flag_2 */
1692  *q++ = flags;
1693  *q++ = 0x80 | 0x01; /* marker bit + extension length */
1694  /* Set the stream ID extension flag bit to 0 and
1695  * write the extended stream ID. */
1696  *q++ = 0x00 | 0x60;
1697  }
1698  /* For Blu-ray AC3 Audio Setting extended flags */
1699  if (ts->m2ts_mode &&
1700  pes_extension &&
1701  st->codecpar->codec_id == AV_CODEC_ID_AC3) {
1702  flags = 0x01; /* set PES_extension_flag_2 */
1703  *q++ = flags;
1704  *q++ = 0x80 | 0x01; /* marker bit + extension length */
1705  *q++ = 0x00 | 0x71; /* for AC3 Audio (specifically on blue-rays) */
1706  }
1707 
1708 
1709  if (is_dvb_subtitle) {
1710  /* First two fields of DVB subtitles PES data:
1711  * data_identifier: for DVB subtitle streams shall be coded with the value 0x20
1712  * subtitle_stream_id: for DVB subtitle stream shall be identified by the value 0x00 */
1713  *q++ = 0x20;
1714  *q++ = 0x00;
1715  }
1716  if (is_dvb_teletext) {
1717  memset(q, STUFFING_BYTE, pes_header_stuffing_bytes);
1718  q += pes_header_stuffing_bytes;
1719  }
1720  } else {
1721  len = payload_size;
1722  *q++ = len >> 8;
1723  *q++ = len;
1724  }
1725  is_start = 0;
1726  }
1727  /* header size */
1728  header_len = q - buf;
1729  /* data len */
1730  len = TS_PACKET_SIZE - header_len;
1731  if (len > payload_size)
1732  len = payload_size;
1733  stuffing_len = TS_PACKET_SIZE - header_len - len;
1734  if (stuffing_len > 0) {
1735  /* add stuffing with AFC */
1736  if (buf[3] & 0x20) {
1737  /* stuffing already present: increase its size */
1738  afc_len = buf[4] + 1;
1739  memmove(buf + 4 + afc_len + stuffing_len,
1740  buf + 4 + afc_len,
1741  header_len - (4 + afc_len));
1742  buf[4] += stuffing_len;
1743  memset(buf + 4 + afc_len, STUFFING_BYTE, stuffing_len);
1744  } else {
1745  /* add stuffing */
1746  memmove(buf + 4 + stuffing_len, buf + 4, header_len - 4);
1747  buf[3] |= 0x20;
1748  buf[4] = stuffing_len - 1;
1749  if (stuffing_len >= 2) {
1750  buf[5] = 0x00;
1751  memset(buf + 6, STUFFING_BYTE, stuffing_len - 2);
1752  }
1753  }
1754  }
1755 
1756  if (is_dvb_subtitle && payload_size == len) {
1757  memcpy(buf + TS_PACKET_SIZE - len, payload, len - 1);
1758  buf[TS_PACKET_SIZE - 1] = 0xff; /* end_of_PES_data_field_marker: an 8-bit field with fixed contents 0xff for DVB subtitle */
1759  } else {
1760  memcpy(buf + TS_PACKET_SIZE - len, payload, len);
1761  }
1762 
1763  payload += len;
1764  payload_size -= len;
1765  write_packet(s, buf);
1766  }
1767  ts_st->prev_payload_key = key;
1768 }
1769 
1770 static int check_h26x_startcode(AVFormatContext *s, const AVStream *st, const AVPacket *pkt, const char *codec)
1771 {
1772  if (pkt->size < 5 || AV_RB32(pkt->data) != 0x0000001 && AV_RB24(pkt->data) != 0x000001) {
1773  if (!st->nb_frames) {
1774  av_log(s, AV_LOG_ERROR, "%s bitstream malformed, "
1775  "no startcode found, use the video bitstream filter '%s_mp4toannexb' to fix it "
1776  "('-bsf:v %s_mp4toannexb' option with ffmpeg)\n", codec, codec, codec);
1777  return AVERROR_INVALIDDATA;
1778  }
1779  av_log(s, AV_LOG_WARNING, "%s bitstream error, startcode missing, size %d", codec, pkt->size);
1780  if (pkt->size)
1781  av_log(s, AV_LOG_WARNING, " data %08"PRIX32, AV_RB32(pkt->data));
1782  av_log(s, AV_LOG_WARNING, "\n");
1783  }
1784  return 0;
1785 }
1786 
1787 int ff_check_h264_startcode(AVFormatContext *s, const AVStream *st, const AVPacket *pkt)
1788 {
1789  return check_h26x_startcode(s, st, pkt, "h264");
1790 }
1791 
1792 /* Based on GStreamer's gst-plugins-base/ext/ogg/gstoggstream.c
1793  * Released under the LGPL v2.1+, written by
1794  * Vincent Penquerc'h <vincent.penquerch@collabora.co.uk>
1795  */
1796 static int opus_get_packet_samples(AVFormatContext *s, AVPacket *pkt)
1797 {
1798  static const int durations[32] = {
1799  480, 960, 1920, 2880, /* Silk NB */
1800  480, 960, 1920, 2880, /* Silk MB */
1801  480, 960, 1920, 2880, /* Silk WB */
1802  480, 960, /* Hybrid SWB */
1803  480, 960, /* Hybrid FB */
1804  120, 240, 480, 960, /* CELT NB */
1805  120, 240, 480, 960, /* CELT NB */
1806  120, 240, 480, 960, /* CELT NB */
1807  120, 240, 480, 960, /* CELT NB */
1808  };
1809  int toc, frame_duration, nframes, duration;
1810 
1811  if (pkt->size < 1)
1812  return 0;
1813 
1814  toc = pkt->data[0];
1815 
1816  frame_duration = durations[toc >> 3];
1817  switch (toc & 3) {
1818  case 0:
1819  nframes = 1;
1820  break;
1821  case 1:
1822  nframes = 2;
1823  break;
1824  case 2:
1825  nframes = 2;
1826  break;
1827  case 3:
1828  if (pkt->size < 2)
1829  return 0;
1830  nframes = pkt->data[1] & 63;
1831  break;
1832  }
1833 
1834  duration = nframes * frame_duration;
1835  if (duration > 5760) {
1836  av_log(s, AV_LOG_WARNING,
1837  "Opus packet duration > 120 ms, invalid");
1838  return 0;
1839  }
1840 
1841  return duration;
1842 }
1843 
1844 static uint8_t *h26x_prefix_aud(const uint8_t *aud, const int aud_size,
1845  const uint8_t *extra_data, const int extra_size, AVPacket *pkt, int *size)
1846 {
1847  const int sz = 4; //start code size
1848  uint8_t *data = av_malloc(pkt->size + sz + aud_size + extra_size);
1849  if (!data)
1850  return NULL;
1851  AV_WB32(data, 0x00000001);
1852  memcpy(data + sz, aud, aud_size);
1853  memcpy(data + sz + aud_size, extra_data, extra_size);
1854  memcpy(data + sz + aud_size + extra_size, pkt->data, pkt->size);
1855  *size = pkt->size + sz + aud_size + extra_size;
1856  return data;
1857 }
1858 
1859 #define H264_NAL_TYPE(state) (state & 0x1f)
1860 #define HEVC_NAL_TYPE(state) ((state & 0x7e) >> 1)
1861 #define VVC_NAL_TYPE(state) ((state >> 11) & 0x1f)
1862 static int mpegts_write_packet_internal(AVFormatContext *s, AVPacket *pkt)
1863 {
1864  AVStream *st = s->streams[pkt->stream_index];
1865  int size = pkt->size;
1866  const uint8_t *buf = pkt->data;
1867  uint8_t *data = NULL;
1868  MpegTSWrite *ts = s->priv_data;
1869  MpegTSWriteStream *ts_st = st->priv_data;
1870  const int64_t delay = av_rescale(s->max_delay, 90000, AV_TIME_BASE) * 2;
1871  const int64_t max_audio_delay = av_rescale(s->max_delay, 90000, AV_TIME_BASE) / 2;
1872  int64_t dts = pkt->dts, pts = pkt->pts;
1873  int opus_samples = 0;
1874  size_t side_data_size;
1875  uint8_t *side_data = NULL;
1876  int stream_id = -1;
1877 
1878  side_data = av_packet_get_side_data(pkt,
1879  AV_PKT_DATA_MPEGTS_STREAM_ID,
1880  &side_data_size);
1881  if (side_data)
1882  stream_id = side_data[0];
1883 
1884  if (!ts->first_dts_checked && dts != AV_NOPTS_VALUE) {
1885  ts->first_pcr += dts * SYSTEM_CLOCK_FREQUENCY_DIVISOR;
1886  ts->first_dts_checked = 1;
1887  }
1888 
1889  if (ts->copyts < 1) {
1890  if (pts != AV_NOPTS_VALUE)
1891  pts += delay;
1892  if (dts != AV_NOPTS_VALUE)
1893  dts += delay;
1894  }
1895 
1896  if (!ts_st->first_timestamp_checked && (pts == AV_NOPTS_VALUE || dts == AV_NOPTS_VALUE)) {
1897  av_log(s, AV_LOG_ERROR, "first pts and dts value must be set\n");
1898  return AVERROR_INVALIDDATA;
1899  }
1900  ts_st->first_timestamp_checked = 1;
1901 
1902  if (st->codecpar->codec_id == AV_CODEC_ID_H264) {
1903  const uint8_t *p = buf, *buf_end = p + size;
1904  const uint8_t *found_aud = NULL, *found_aud_end = NULL;
1905  int nal_type;
1906  uint32_t state = -1;
1907  int extradd = (pkt->flags & AV_PKT_FLAG_KEY) ? st->codecpar->extradata_size : 0;
1908  int ret = ff_check_h264_startcode(s, st, pkt);
1909  if (ret < 0)
1910  return ret;
1911 
1912  if (extradd && AV_RB24(st->codecpar->extradata) > 1)
1913  extradd = 0;
1914 
1915  /* Ensure that all pictures are prefixed with an AUD, and that
1916  * IDR pictures are also prefixed with SPS and PPS. SPS and PPS
1917  * are assumed to be available in 'extradata' if not found in-band. */
1918  do {
1919  p = avpriv_find_start_code(p, buf_end, &state);
1920  nal_type = H264_NAL_TYPE(state);
1921  av_log(s, AV_LOG_TRACE, "nal %"PRId32"\n", nal_type);
1922  if (nal_type == H264_NAL_SPS)
1923  extradd = 0;
1924  if (nal_type == H264_NAL_AUD) {
1925  found_aud = p - 4; // start of the 0x000001 start code.
1926  found_aud_end = p + 1; // first byte past the AUD.
1927  if (found_aud < buf)
1928  found_aud = buf;
1929  if (buf_end < found_aud_end)
1930  found_aud_end = buf_end;
1931  }
1932  } while (p < buf_end
1933  && nal_type != H264_NAL_IDR_SLICE
1934  && nal_type != H264_NAL_SLICE
1935  && (extradd > 0 || !found_aud));
1936  if (nal_type != H264_NAL_IDR_SLICE)
1937  extradd = 0;
1938 
1939  if (!found_aud) {
1940  /* Prefix 'buf' with the missing AUD, and extradata if needed. */
1941  const uint8_t aud[] = {
1942  H264_NAL_AUD,
1943  0xf0, // any slice type (0xe) + rbsp stop one bit
1944  };
1945  buf = data = h26x_prefix_aud(aud, FF_ARRAY_ELEMS(aud),
1946  st->codecpar->extradata, extradd, pkt, &size);
1947  if (!data)
1948  return AVERROR(ENOMEM);
1949  } else if (extradd != 0) {
1950  /* Move the AUD up to the beginning of the frame, where the H.264
1951  * spec requires it to appear. Emit the extradata after it. */
1952  PutByteContext pb;
1953  const int new_pkt_size = pkt->size + 1 + extradd;
1954  data = av_malloc(new_pkt_size);
1955  if (!data)
1956  return AVERROR(ENOMEM);
1957  bytestream2_init_writer(&pb, data, new_pkt_size);
1958  bytestream2_put_byte(&pb, 0x00);
1959  bytestream2_put_buffer(&pb, found_aud, found_aud_end - found_aud);
1960  bytestream2_put_buffer(&pb, st->codecpar->extradata, extradd);
1961  bytestream2_put_buffer(&pb, pkt->data, found_aud - pkt->data);
1962  bytestream2_put_buffer(&pb, found_aud_end, buf_end - found_aud_end);
1963  av_assert0(new_pkt_size == bytestream2_tell_p(&pb));
1964  buf = data;
1965  size = new_pkt_size;
1966  }
1967  } else if (st->codecpar->codec_id == AV_CODEC_ID_AAC) {
1968  if (pkt->size < 2) {
1969  av_log(s, AV_LOG_ERROR, "AAC packet too short\n");
1970  return AVERROR_INVALIDDATA;
1971  }
1972  if ((AV_RB16(pkt->data) & 0xfff0) != 0xfff0) {
1973  int ret;
1974  AVPacket *pkt2 = ts->pkt;
1975 
1976  if (!ts_st->amux) {
1977  av_log(s, AV_LOG_ERROR, "AAC bitstream not in ADTS format "
1978  "and extradata missing\n");
1979  } else {
1980  av_packet_unref(pkt2);
1981  pkt2->data = pkt->data;
1982  pkt2->size = pkt->size;
1983  av_assert0(pkt->dts != AV_NOPTS_VALUE);
1984  pkt2->dts = av_rescale_q(pkt->dts, st->time_base, ts_st->amux->streams[0]->time_base);
1985 
1986  ret = avio_open_dyn_buf(&ts_st->amux->pb);
1987  if (ret < 0)
1988  return ret;
1989 
1990  ret = av_write_frame(ts_st->amux, pkt2);
1991  if (ret < 0) {
1992  ffio_free_dyn_buf(&ts_st->amux->pb);
1993  return ret;
1994  }
1995  size = avio_close_dyn_buf(ts_st->amux->pb, &data);
1996  ts_st->amux->pb = NULL;
1997  buf = data;
1998  }
1999  }
2000  } else if (st->codecpar->codec_id == AV_CODEC_ID_HEVC) {
2001  const uint8_t *p = buf, *buf_end = p + size;
2002  uint32_t state = -1;
2003  int nal_type;
2004  int extradd = (pkt->flags & AV_PKT_FLAG_KEY) ? st->codecpar->extradata_size : 0;
2005  int ret = check_h26x_startcode(s, st, pkt, "hevc");
2006  if (ret < 0)
2007  return ret;
2008 
2009  if (extradd && AV_RB24(st->codecpar->extradata) > 1)
2010  extradd = 0;
2011 
2012  do {
2013  p = avpriv_find_start_code(p, buf_end, &state);
2014  nal_type = HEVC_NAL_TYPE(state);
2015  av_log(s, AV_LOG_TRACE, "nal %"PRId32"\n", nal_type);
2016  if (nal_type == HEVC_NAL_VPS)
2017  extradd = 0;
2018  } while (p < buf_end && nal_type != HEVC_NAL_AUD && nal_type >= HEVC_NAL_VPS);
2019 
2020  if (nal_type < HEVC_NAL_BLA_W_LP || nal_type >= HEVC_NAL_RSV_VCL24)
2021  extradd = 0;
2022  if (nal_type != HEVC_NAL_AUD) { // AUD NAL
2023  const uint8_t aud[] = {
2024  (HEVC_NAL_AUD << 1),
2025  0x01,
2026  0x50, // any slice type (0x4) + rbsp stop one bit
2027  };
2028  buf = data = h26x_prefix_aud(aud, FF_ARRAY_ELEMS(aud),
2029  st->codecpar->extradata, extradd, pkt, &size);
2030  if (!data)
2031  return AVERROR(ENOMEM);
2032  }
2033  } else if (st->codecpar->codec_id == AV_CODEC_ID_VVC) {
2034  const uint8_t *p = buf, *buf_end = p + size;
2035  uint32_t state = -1;
2036  uint32_t nal_type = -1;
2037  int extradd = (pkt->flags & AV_PKT_FLAG_KEY) ? st->codecpar->extradata_size : 0;
2038  int ret = check_h26x_startcode(s, st, pkt, "vvc");
2039  if (ret < 0)
2040  return ret;
2041 
2042  if (extradd && AV_RB24(st->codecpar->extradata) > 1)
2043  extradd = 0;
2044 
2045  do {
2046  p = avpriv_find_start_code(p, buf_end, &state);
2047  // state contains byte behind start code, p points 2 bytes behind start code
2048  nal_type = VVC_NAL_TYPE(state);
2049  av_log(s, AV_LOG_TRACE, "nal %"PRId32"\n", nal_type );
2050  if (nal_type == VVC_VPS_NUT)
2051  extradd = 0;
2052  } while (p < buf_end && nal_type != VVC_AUD_NUT && nal_type >= VVC_OPI_NUT);
2053 
2054  if (nal_type >= VVC_OPI_NUT)
2055  extradd = 0;
2056  if (nal_type != VVC_AUD_NUT) { // AUD NAL
2057  const uint8_t aud[] = {
2058  0, // forbidden_zero_bit, nuh_reserved_zero_bit, nuh_layer_id
2059  (VVC_AUD_NUT << 3) | 1, // nal_unit_type, nuh_temporal_id_plus1(1)
2060  (pkt->flags & AV_PKT_FLAG_KEY) << 7 | 0x28, // aud_irap_or_gdr_flag, aud_pic_type(2), rbsp_stop_one_bit
2061  };
2062  buf = data = h26x_prefix_aud(aud, FF_ARRAY_ELEMS(aud), st->codecpar->extradata, extradd, pkt, &size);
2063  if (!data)
2064  return AVERROR(ENOMEM);
2065  }
2066  } else if (st->codecpar->codec_id == AV_CODEC_ID_OPUS) {
2067  if (pkt->size < 2) {
2068  av_log(s, AV_LOG_ERROR, "Opus packet too short\n");
2069  return AVERROR_INVALIDDATA;
2070  }
2071 
2072  /* Add Opus control header */
2073  if ((AV_RB16(pkt->data) >> 5) != 0x3ff) {
2074  uint8_t *side_data;
2075  size_t side_data_size;
2076  int i, n;
2077  int ctrl_header_size;
2078  int trim_start = 0, trim_end = 0;
2079 
2080  opus_samples = opus_get_packet_samples(s, pkt);
2081 
2082  side_data = av_packet_get_side_data(pkt,
2083  AV_PKT_DATA_SKIP_SAMPLES,
2084  &side_data_size);
2085 
2086  if (side_data && side_data_size >= 10) {
2087  trim_end = AV_RL32(side_data + 4) * 48000 / st->codecpar->sample_rate;
2088  }
2089 
2090  ctrl_header_size = pkt->size + 2 + pkt->size / 255 + 1;
2091  if (ts_st->opus_pending_trim_start)
2092  ctrl_header_size += 2;
2093  if (trim_end)
2094  ctrl_header_size += 2;
2095 
2096  data = av_malloc(ctrl_header_size);
2097  if (!data)
2098  return AVERROR(ENOMEM);
2099 
2100  data[0] = 0x7f;
2101  data[1] = 0xe0;
2102  if (ts_st->opus_pending_trim_start)
2103  data[1] |= 0x10;
2104  if (trim_end)
2105  data[1] |= 0x08;
2106 
2107  n = pkt->size;
2108  i = 2;
2109  do {
2110  data[i] = FFMIN(n, 255);
2111  n -= 255;
2112  i++;
2113  } while (n >= 0);
2114 
2115  av_assert0(2 + pkt->size / 255 + 1 == i);
2116 
2117  if (ts_st->opus_pending_trim_start) {
2118  trim_start = FFMIN(ts_st->opus_pending_trim_start, opus_samples);
2119  AV_WB16(data + i, trim_start);
2120  i += 2;
2121  ts_st->opus_pending_trim_start -= trim_start;
2122  }
2123  if (trim_end) {
2124  trim_end = FFMIN(trim_end, opus_samples - trim_start);
2125  AV_WB16(data + i, trim_end);
2126  i += 2;
2127  }
2128 
2129  memcpy(data + i, pkt->data, pkt->size);
2130  buf = data;
2131  size = ctrl_header_size;
2132  } else {
2133  /* TODO: Can we get TS formatted data here? If so we will
2134  * need to count the samples of that too! */
2135  av_log(s, AV_LOG_WARNING, "Got MPEG-TS formatted Opus data, unhandled");
2136  }
2137  } else if (st->codecpar->codec_id == AV_CODEC_ID_AC3 && !ts_st->dvb_ac3_desc) {
2138  AC3HeaderInfo *hdr = NULL;
2139 
2140  if (avpriv_ac3_parse_header(&hdr, pkt->data, pkt->size) >= 0) {
2141  uint8_t number_of_channels_flag;
2142  uint8_t service_type_flag;
2143  uint8_t full_service_flag = 1;
2144  DVBAC3Descriptor *dvb_ac3_desc;
2145 
2146  dvb_ac3_desc = av_mallocz(sizeof(*dvb_ac3_desc));
2147  if (!dvb_ac3_desc) {
2148  av_free(hdr);
2149  return AVERROR(ENOMEM);
2150  }
2151 
2152  service_type_flag = hdr->bitstream_mode;
2153  switch (hdr->channel_mode) {
2154  case AC3_CHMODE_DUALMONO:
2155  number_of_channels_flag = 1;
2156  break;
2157  case AC3_CHMODE_MONO:
2158  number_of_channels_flag = 0;
2159  break;
2160  case AC3_CHMODE_STEREO:
2161  if (hdr->dolby_surround_mode == AC3_DSURMOD_ON)
2162  number_of_channels_flag = 3;
2163  else
2164  number_of_channels_flag = 2;
2165  break;
2166  case AC3_CHMODE_3F:
2167  case AC3_CHMODE_2F1R:
2168  case AC3_CHMODE_3F1R:
2169  case AC3_CHMODE_2F2R:
2170  case AC3_CHMODE_3F2R:
2171  number_of_channels_flag = 4;
2172  break;
2173  default: /* reserved */
2174  number_of_channels_flag = 7;
2175  break;
2176  }
2177 
2178  if (service_type_flag == 1 || service_type_flag == 4 ||
2179  (service_type_flag == 7 && !number_of_channels_flag))
2180  full_service_flag = 0;
2181 
2182  dvb_ac3_desc->component_type_flag = 1;
2183  dvb_ac3_desc->component_type = (full_service_flag << 6) |
2184  ((service_type_flag & 0x7) << 3) |
2185  (number_of_channels_flag & 0x7);
2186  dvb_ac3_desc->bsid_flag = 1;
2187  dvb_ac3_desc->bsid = hdr->bitstream_id;
2188  dvb_ac3_desc->mainid_flag = 0;
2189  dvb_ac3_desc->asvc_flag = 0;
2190 
2191  ts_st->dvb_ac3_desc = dvb_ac3_desc;
2192  }
2193  av_free(hdr);
2194  } else if (st->codecpar->codec_id == AV_CODEC_ID_PCM_BLURAY && ts->m2ts_mode) {
2195  mpegts_write_pes(s, st, buf, size, pts, dts,
2196  pkt->flags & AV_PKT_FLAG_KEY, stream_id);
2197  return 0;
2198  }
2199 
2200  if (ts_st->payload_size && (ts_st->payload_size + size > ts->pes_payload_size ||
2201  (dts != AV_NOPTS_VALUE && ts_st->payload_dts != AV_NOPTS_VALUE &&
2202  dts - ts_st->payload_dts >= max_audio_delay) ||
2203  ts_st->opus_queued_samples + opus_samples >= 5760 /* 120ms */)) {
2204  mpegts_write_pes(s, st, ts_st->payload, ts_st->payload_size,
2205  ts_st->payload_pts, ts_st->payload_dts,
2206  ts_st->payload_flags & AV_PKT_FLAG_KEY, stream_id);
2207  ts_st->payload_size = 0;
2208  ts_st->opus_queued_samples = 0;
2209  }
2210 
2211  if (st->codecpar->codec_type != AVMEDIA_TYPE_AUDIO || size > ts->pes_payload_size) {
2212  av_assert0(!ts_st->payload_size);
2213  // for video and subtitle, write a single pes packet
2214  mpegts_write_pes(s, st, buf, size, pts, dts,
2215  pkt->flags & AV_PKT_FLAG_KEY, stream_id);
2216  ts_st->opus_queued_samples = 0;
2217  av_free(data);
2218  return 0;
2219  }
2220 
2221  if (!ts_st->payload_size) {
2222  ts_st->payload_pts = pts;
2223  ts_st->payload_dts = dts;
2224  ts_st->payload_flags = pkt->flags;
2225  }
2226 
2227  memcpy(ts_st->payload + ts_st->payload_size, buf, size);
2228  ts_st->payload_size += size;
2229  ts_st->opus_queued_samples += opus_samples;
2230 
2231  av_free(data);
2232 
2233  return 0;
2234 }
2235 
2236 static void mpegts_write_flush(AVFormatContext *s)
2237 {
2238  MpegTSWrite *ts = s->priv_data;
2239  int i;
2240 
2241  /* flush current packets */
2242  for (i = 0; i < s->nb_streams; i++) {
2243  AVStream *st = s->streams[i];
2244  MpegTSWriteStream *ts_st = st->priv_data;
2245  if (ts_st->payload_size > 0) {
2246  mpegts_write_pes(s, st, ts_st->payload, ts_st->payload_size,
2247  ts_st->payload_pts, ts_st->payload_dts,
2248  ts_st->payload_flags & AV_PKT_FLAG_KEY, -1);
2249  ts_st->payload_size = 0;
2250  ts_st->opus_queued_samples = 0;
2251  }
2252  }
2253 
2254  if (ts->m2ts_mode) {
2255  int packets = (avio_tell(s->pb) / (TS_PACKET_SIZE + 4)) % 32;
2256  while (packets++ < 32)
2257  mpegts_insert_null_packet(s);
2258  }
2259 }
2260 
2261 static int mpegts_write_packet(AVFormatContext *s, AVPacket *pkt)
2262 {
2263  if (!pkt) {
2264  mpegts_write_flush(s);
2265  return 1;
2266  } else {
2267  return mpegts_write_packet_internal(s, pkt);
2268  }
2269 }
2270 
2271 static int mpegts_write_end(AVFormatContext *s)
2272 {
2273  if (s->pb)
2274  mpegts_write_flush(s);
2275 
2276  return 0;
2277 }
2278 
2279 static void mpegts_deinit(AVFormatContext *s)
2280 {
2281  MpegTSWrite *ts = s->priv_data;
2282  MpegTSService *service;
2283  int i;
2284 
2285  for (i = 0; i < s->nb_streams; i++) {
2286  AVStream *st = s->streams[i];
2287  MpegTSWriteStream *ts_st = st->priv_data;
2288  if (ts_st) {
2289  av_freep(&ts_st->dvb_ac3_desc);
2290  av_freep(&ts_st->payload);
2291  if (ts_st->amux) {
2292  avformat_free_context(ts_st->amux);
2293  ts_st->amux = NULL;
2294  }
2295  }
2296  }
2297 
2298  for (i = 0; i < ts->nb_services; i++) {
2299  service = ts->services[i];
2300  av_freep(&service);
2301  }
2302  av_freep(&ts->services);
2303 }
2304 
2305 static int mpegts_check_bitstream(AVFormatContext *s, AVStream *st,
2306  const AVPacket *pkt)
2307 {
2308  const struct Entry {
2309  enum AVCodecID id;
2310  const char *bsf_name;
2311  uint8_t mask;
2312  uint8_t value;
2313  } list[] = {
2314  { AV_CODEC_ID_H264, "h264_mp4toannexb", 0xff, 0x01 /* configurationVersion in AVCDecoderConfigurationRecord */},
2315  { AV_CODEC_ID_HEVC, "hevc_mp4toannexb", 0xff, 0x01 /* configurationVersion in HEVCDecoderConfigurationRecord */},
2316  { AV_CODEC_ID_VVC, "vvc_mp4toannexb", 0xf8, 0xf8 /* reserved '11111'b in VVCDecoderConfigurationRecord */},
2317  };
2318 
2319  for (int i = 0; i < FF_ARRAY_ELEMS(list); i++) {
2320  const struct Entry *e = list + i;
2321  if (e->id == st->codecpar->codec_id &&
2322  pkt->size >= 5 && AV_RB32(pkt->data) != 0x0000001 &&
2323  (AV_RB24(pkt->data) != 0x000001 ||
2324  (st->codecpar->extradata_size > 0 &&
2325  ((st->codecpar->extradata[0] & e->mask) == e->value))))
2326  return ff_stream_add_bitstream_filter(st, e->bsf_name, NULL);
2327  }
2328  return 1;
2329 }
2330 
2331 #define OFFSET(x) offsetof(MpegTSWrite, x)
2332 #define ENC AV_OPT_FLAG_ENCODING_PARAM
2333 static const AVOption options[] = {
2334  { "mpegts_transport_stream_id", "Set transport_stream_id field.",
2335  OFFSET(transport_stream_id), AV_OPT_TYPE_INT, { .i64 = 0x0001 }, 0x0001, 0xffff, ENC },
2336  { "mpegts_original_network_id", "Set original_network_id field.",
2337  OFFSET(original_network_id), AV_OPT_TYPE_INT, { .i64 = DVB_PRIVATE_NETWORK_START }, 0x0001, 0xffff, ENC },
2338  { "mpegts_service_id", "Set service_id field.",
2339  OFFSET(service_id), AV_OPT_TYPE_INT, { .i64 = 0x0001 }, 0x0001, 0xffff, ENC },
2340  { "mpegts_service_type", "Set service_type field.",
2341  OFFSET(service_type), AV_OPT_TYPE_INT, { .i64 = 0x01 }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2342  { "digital_tv", "Digital Television.",
2343  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_DIGITAL_TV }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2344  { "digital_radio", "Digital Radio.",
2345  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_DIGITAL_RADIO }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2346  { "teletext", "Teletext.",
2347  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_TELETEXT }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2348  { "advanced_codec_digital_radio", "Advanced Codec Digital Radio.",
2349  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_RADIO }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2350  { "mpeg2_digital_hdtv", "MPEG2 Digital HDTV.",
2351  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_MPEG2_DIGITAL_HDTV }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2352  { "advanced_codec_digital_sdtv", "Advanced Codec Digital SDTV.",
2353  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_SDTV }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2354  { "advanced_codec_digital_hdtv", "Advanced Codec Digital HDTV.",
2355  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_HDTV }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2356  { "hevc_digital_hdtv", "HEVC Digital Television Service.",
2357  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_SERVICE_TYPE_HEVC_DIGITAL_HDTV }, 0x01, 0xff, ENC, .unit = "mpegts_service_type" },
2358  { "mpegts_pmt_start_pid", "Set the first pid of the PMT.",
2359  OFFSET(pmt_start_pid), AV_OPT_TYPE_INT, { .i64 = 0x1000 }, FIRST_OTHER_PID, LAST_OTHER_PID, ENC },
2360  { "mpegts_start_pid", "Set the first pid.",
2361  OFFSET(start_pid), AV_OPT_TYPE_INT, { .i64 = 0x0100 }, FIRST_OTHER_PID, LAST_OTHER_PID, ENC },
2362  { "mpegts_m2ts_mode", "Enable m2ts mode.", OFFSET(m2ts_mode), AV_OPT_TYPE_BOOL, { .i64 = -1 }, -1, 1, ENC },
2363  { "muxrate", NULL, OFFSET(mux_rate), AV_OPT_TYPE_INT, { .i64 = 1 }, 0, INT_MAX, ENC },
2364  { "pes_payload_size", "Minimum PES packet payload in bytes",
2365  OFFSET(pes_payload_size), AV_OPT_TYPE_INT, { .i64 = DEFAULT_PES_PAYLOAD_SIZE }, 0, INT_MAX, ENC },
2366  { "mpegts_flags", "MPEG-TS muxing flags", OFFSET(flags), AV_OPT_TYPE_FLAGS, { .i64 = 0 }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2367  { "resend_headers", "Reemit PAT/PMT before writing the next packet",
2368  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_REEMIT_PAT_PMT }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2369  { "latm", "Use LATM packetization for AAC",
2370  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_AAC_LATM }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2371  { "pat_pmt_at_frames", "Reemit PAT and PMT at each video frame",
2372  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_PAT_PMT_AT_FRAMES}, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2373  { "system_b", "Conform to System B (DVB) instead of System A (ATSC)",
2374  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_SYSTEM_B }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2375  { "initial_discontinuity", "Mark initial packets as discontinuous",
2376  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_DISCONT }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2377  { "nit", "Enable NIT transmission",
2378  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_NIT}, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2379  { "omit_rai", "Disable writing of random access indicator",
2380  0, AV_OPT_TYPE_CONST, { .i64 = MPEGTS_FLAG_OMIT_RAI }, 0, INT_MAX, ENC, .unit = "mpegts_flags" },
2381  { "mpegts_copyts", "don't offset dts/pts", OFFSET(copyts), AV_OPT_TYPE_BOOL, { .i64 = -1 }, -1, 1, ENC },
2382  { "tables_version", "set PAT, PMT, SDT and NIT version", OFFSET(tables_version), AV_OPT_TYPE_INT, { .i64 = 0 }, 0, 31, ENC },
2383  { "omit_video_pes_length", "Omit the PES packet length for video packets",
2384  OFFSET(omit_video_pes_length), AV_OPT_TYPE_BOOL, { .i64 = 1 }, 0, 1, ENC },
2385  { "pcr_period", "PCR retransmission time in milliseconds",
2386  OFFSET(pcr_period_ms), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, ENC },
2387  { "pat_period", "PAT/PMT retransmission time limit in seconds",
2388  OFFSET(pat_period_us), AV_OPT_TYPE_DURATION, { .i64 = PAT_RETRANS_TIME * 1000LL }, 0, INT64_MAX, ENC },
2389  { "sdt_period", "SDT retransmission time limit in seconds",
2390  OFFSET(sdt_period_us), AV_OPT_TYPE_DURATION, { .i64 = SDT_RETRANS_TIME * 1000LL }, 0, INT64_MAX, ENC },
2391  { "nit_period", "NIT retransmission time limit in seconds",
2392  OFFSET(nit_period_us), AV_OPT_TYPE_DURATION, { .i64 = NIT_RETRANS_TIME * 1000LL }, 0, INT64_MAX, ENC },
2393  { NULL },
2394 };
2395 
2396 static const AVClass mpegts_muxer_class = {
2397  .class_name = "MPEGTS muxer",
2398  .item_name = av_default_item_name,
2399  .option = options,
2400  .version = LIBAVUTIL_VERSION_INT,
2401 };
2402 
2403 const FFOutputFormat ff_mpegts_muxer = {
2404  .p.name = "mpegts",
2405  .p.long_name = NULL_IF_CONFIG_SMALL("MPEG-TS (MPEG-2 Transport Stream)"),
2406  .p.mime_type = "video/MP2T",
2407  .p.extensions = "ts,m2t,m2ts,mts",
2408  .priv_data_size = sizeof(MpegTSWrite),
2409  .p.audio_codec = AV_CODEC_ID_MP2,
2410  .p.video_codec = AV_CODEC_ID_MPEG2VIDEO,
2411  .init = mpegts_init,
2412  .write_packet = mpegts_write_packet,
2413  .write_trailer = mpegts_write_end,
2414  .deinit = mpegts_deinit,
2415  .check_bitstream = mpegts_check_bitstream,
2416  .p.flags = AVFMT_VARIABLE_FPS | AVFMT_NODIMENSIONS,
2417  .flags_internal = FF_OFMT_FLAG_ALLOW_FLUSH,
2418  .p.priv_class = &mpegts_muxer_class,
2419 };
HEVC_NAL_AUD
@ HEVC_NAL_AUD
Definition: hevc.h:64
flags
const SwsFlags flags[]
Definition: swscale.c:61
MPEGTS_SERVICE_TYPE_HEVC_DIGITAL_HDTV
@ MPEGTS_SERVICE_TYPE_HEVC_DIGITAL_HDTV
Definition: mpegtsenc.c:80
AC3_CHMODE_3F
@ AC3_CHMODE_3F
Definition: ac3defs.h:71
av_packet_unref
void av_packet_unref(AVPacket *pkt)
Wipe the packet.
Definition: packet.c:432
AV_ROUND_UP
@ AV_ROUND_UP
Round toward +infinity.
Definition: mathematics.h:134
H264_NAL_IDR_SLICE
@ H264_NAL_IDR_SLICE
Definition: h264.h:39
DEFAULT_PROVIDER_NAME
#define DEFAULT_PROVIDER_NAME
Definition: mpegtsenc.c:238
H264_NAL_SPS
@ H264_NAL_SPS
Definition: h264.h:41
AVMEDIA_TYPE_SUBTITLE
@ AVMEDIA_TYPE_SUBTITLE
Definition: avutil.h:203
AV_LOG_WARNING
#define AV_LOG_WARNING
Something somehow does not look correct.
Definition: log.h:216
MpegTSService::pcr_pid
int pcr_pid
Definition: mpegtsenc.c:67
AV_PROFILE_KLVA_SYNC
#define AV_PROFILE_KLVA_SYNC
Definition: defs.h:191
AVCodecParameters::extradata
uint8_t * extradata
Extra binary data needed for initializing the decoder, codec-dependent.
Definition: codec_par.h:69
AV_CODEC_ID_AC3
@ AV_CODEC_ID_AC3
Definition: codec_id.h:453
program
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
Definition: undefined.txt:6
MpegTSWrite::last_sdt_ts
int64_t last_sdt_ts
Definition: mpegtsenc.c:128
AC3HeaderInfo::dolby_surround_mode
int dolby_surround_mode
Definition: ac3_parser_internal.h:52
AVOutputFormat::name
const char * name
Definition: avformat.h:506
AVERROR
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
MPEGTS_FLAG_AAC_LATM
#define MPEGTS_FLAG_AAC_LATM
Definition: mpegtsenc.c:115
opt.h
SYSTEM_CLOCK_FREQUENCY_DIVISOR
#define SYSTEM_CLOCK_FREQUENCY_DIVISOR
Definition: mpegts.h:38
AV_CODEC_ID_PCM_BLURAY
@ AV_CODEC_ID_PCM_BLURAY
Definition: codec_id.h:360
PAT_PID
#define PAT_PID
Definition: mpegts.h:41
AVCodecParameters::codec_type
enum AVMediaType codec_type
General type of the encoded data.
Definition: codec_par.h:51
mpegts.h
MpegTSService::provider_name
uint8_t provider_name[256]
Definition: mpegtsenc.c:66
AVFMT_NODIMENSIONS
#define AVFMT_NODIMENSIONS
Format does not need width/height.
Definition: avformat.h:482
section_write_packet
static void section_write_packet(MpegTSSection *s, const uint8_t *packet)
Definition: mpegtsenc.c:985
H264_NAL_AUD
@ H264_NAL_AUD
Definition: h264.h:43
h26x_prefix_aud
static uint8_t * h26x_prefix_aud(const uint8_t *aud, const int aud_size, const uint8_t *extra_data, const int extra_size, AVPacket *pkt, int *size)
Definition: mpegtsenc.c:1844
STREAM_TYPE_AUDIO_AAC
#define STREAM_TYPE_AUDIO_AAC
Definition: mpeg.h:55
MpegTSWriteStream::discontinuity
int discontinuity
Definition: mpegtsenc.c:250
AVCodecParameters
This struct describes the properties of an encoded stream.
Definition: codec_par.h:47
check_h26x_startcode
static int check_h26x_startcode(AVFormatContext *s, const AVStream *st, const AVPacket *pkt, const char *codec)
Definition: mpegtsenc.c:1770
MpegTSWriteStream::pid
int pid
Definition: mpegtsenc.c:248
ffformatcontext
static av_always_inline FFFormatContext * ffformatcontext(AVFormatContext *s)
Definition: internal.h:123
STREAM_TYPE_VIDEO_VC1
#define STREAM_TYPE_VIDEO_VC1
Definition: mpegts.h:151
STREAM_TYPE_PRIVATE_DATA
#define STREAM_TYPE_PRIVATE_DATA
Definition: mpeg.h:54
avformat_new_stream
AVStream * avformat_new_stream(AVFormatContext *s, const struct AVCodec *c)
Add a new stream to a media file.
AVStream::priv_data
void * priv_data
Definition: avformat.h:769
AVFMT_VARIABLE_FPS
#define AVFMT_VARIABLE_FPS
Format allows variable fps.
Definition: avformat.h:481
MpegTSWriteStream::payload_dts
int64_t payload_dts
Definition: mpegtsenc.c:255
mpegts_write_flush
static void mpegts_write_flush(AVFormatContext *s)
Definition: mpegtsenc.c:2236
STREAM_ID_EMM_STREAM
#define STREAM_ID_EMM_STREAM
Definition: mpegts.h:189
HEVC_NAL_TYPE
#define HEVC_NAL_TYPE(state)
Definition: mpegtsenc.c:1860
MpegTSWrite::pmt_start_pid
int pmt_start_pid
Definition: mpegtsenc.c:105
MpegTSService::program
AVProgram * program
Definition: mpegtsenc.c:68
MpegTSWriteStream
Definition: mpegtsenc.c:247
STREAM_ID_PADDING_STREAM
#define STREAM_ID_PADDING_STREAM
Definition: mpegts.h:184
MpegTSWriteStream::first_timestamp_checked
int first_timestamp_checked
first pts/dts check needed
Definition: mpegtsenc.c:252
AV_CODEC_ID_DIRAC
@ AV_CODEC_ID_DIRAC
Definition: codec_id.h:168
int64_t
long long int64_t
Definition: coverity.c:34
metadata
Stream codec metadata
Definition: ogg-flac-chained-meta.txt:2
STREAM_ID_PROGRAM_STREAM_MAP
#define STREAM_ID_PROGRAM_STREAM_MAP
Definition: mpegts.h:182
MpegTSWrite::m2ts_mode
int m2ts_mode
Definition: mpegtsenc.c:107
M2TS_AUDIO_START_PID
#define M2TS_AUDIO_START_PID
Definition: mpegts.h:76
mask
int mask
Definition: mediacodecdec_common.c:154
AV_CODEC_ID_MPEG4
@ AV_CODEC_ID_MPEG4
Definition: codec_id.h:64
set_af_flag
static void set_af_flag(uint8_t *pkt, int flag)
Definition: mpegtsenc.c:1417
NIT_TID
#define NIT_TID
Definition: mpegts.h:89
MpegTSWrite::pcr_period_ms
int pcr_period_ms
Definition: mpegtsenc.c:113
SECTION_LENGTH
#define SECTION_LENGTH
Definition: mpegtsenc.c:142
STREAM_TYPE_AUDIO_MPEG1
#define STREAM_TYPE_AUDIO_MPEG1
Definition: mpeg.h:51
AVFormatContext::streams
AVStream ** streams
A list of all streams in the file.
Definition: avformat.h:1332
mpegts_deinit
static void mpegts_deinit(AVFormatContext *s)
Definition: mpegtsenc.c:2279
STREAM_TYPE_VIDEO_VVC
#define STREAM_TYPE_VIDEO_VVC
Definition: mpeg.h:59
AVPacket::data
uint8_t * data
Definition: packet.h:552
AV_CODEC_ID_DVB_TELETEXT
@ AV_CODEC_ID_DVB_TELETEXT
Definition: codec_id.h:568
NIT_PID
#define NIT_PID
Definition: mpegts.h:46
AVOption
AVOption.
Definition: opt.h:429
NULL_PID
#define NULL_PID
Definition: mpegts.h:70
b
#define b
Definition: input.c:42
AVStream::avg_frame_rate
AVRational avg_frame_rate
Average framerate.
Definition: avformat.h:833
get_pcr
static int64_t get_pcr(const MpegTSWrite *ts)
Definition: mpegtsenc.c:965
mpegts_check_bitstream
static int mpegts_check_bitstream(AVFormatContext *s, AVStream *st, const AVPacket *pkt)
Definition: mpegtsenc.c:2305
AV_CODEC_ID_AVS2
@ AV_CODEC_ID_AVS2
Definition: codec_id.h:248
data
const char data[16]
Definition: mxf.c:149
AV_OPT_TYPE_DURATION
@ AV_OPT_TYPE_DURATION
Underlying C type is int64_t.
Definition: opt.h:319
DVBAC3Descriptor::component_type
uint8_t component_type
Definition: mpegts.h:271
NIT_RETRANS_TIME
#define NIT_RETRANS_TIME
Definition: mpegtsenc.c:245
MpegTSWrite::nit_period_us
int64_t nit_period_us
Definition: mpegtsenc.c:126
AV_LOG_VERBOSE
#define AV_LOG_VERBOSE
Detailed information.
Definition: log.h:226
MPEGTS_SERVICE_TYPE_TELETEXT
@ MPEGTS_SERVICE_TYPE_TELETEXT
Definition: mpegtsenc.c:75
MpegTSWriteStream::payload_pts
int64_t payload_pts
Definition: mpegtsenc.c:254
MPEGTS_FLAG_PAT_PMT_AT_FRAMES
#define MPEGTS_FLAG_PAT_PMT_AT_FRAMES
Definition: mpegtsenc.c:116
mathematics.h
AVDictionary
Definition: dict.c:32
FFMAX
#define FFMAX(a, b)
Definition: macros.h:47
FIRST_OTHER_PID
#define FIRST_OTHER_PID
Definition: mpegts.h:65
AV_PROFILE_ARIB_PROFILE_C
#define AV_PROFILE_ARIB_PROFILE_C
Definition: defs.h:189
MpegTSSection::opaque
void * opaque
Definition: mpegtsenc.c:59
AVChannelLayout::nb_channels
int nb_channels
Number of channels in this layout.
Definition: channel_layout.h:329
AV_CODEC_ID_HDMV_PGS_SUBTITLE
@ AV_CODEC_ID_HDMV_PGS_SUBTITLE
Definition: codec_id.h:567
VVC_AUD_NUT
@ VVC_AUD_NUT
Definition: vvc.h:49
opus_get_packet_samples
static int opus_get_packet_samples(AVFormatContext *s, AVPacket *pkt)
Definition: mpegtsenc.c:1796
MpegTSWrite::nit_period
int64_t nit_period
Definition: mpegtsenc.c:91
AV_CODEC_ID_TRUEHD
@ AV_CODEC_ID_TRUEHD
Definition: codec_id.h:494
AV_PKT_FLAG_KEY
#define AV_PKT_FLAG_KEY
The packet contains a keyframe.
Definition: packet.h:607
mpegts_write_end
static int mpegts_write_end(AVFormatContext *s)
Definition: mpegtsenc.c:2271
MpegTSWrite::av_class
const AVClass * av_class
Definition: mpegtsenc.c:83
FFOutputFormat::p
AVOutputFormat p
The public AVOutputFormat.
Definition: mux.h:65
ENHANCED_AC3_DESCRIPTOR
#define ENHANCED_AC3_DESCRIPTOR
Definition: mpegts.h:216
av_malloc
#define av_malloc(s)
Definition: tableprint_vlc.h:31
STREAM_TYPE_AUDIO_MPEG2
#define STREAM_TYPE_AUDIO_MPEG2
Definition: mpeg.h:52
put_registration_descriptor
static void put_registration_descriptor(uint8_t **q_ptr, uint32_t tag)
Definition: mpegtsenc.c:342
MpegTSSection::pid
int pid
Definition: mpegtsenc.c:55
NETWORK_NAME_DESCRIPTOR
#define NETWORK_NAME_DESCRIPTOR
Definition: mpegts.h:209
crc.h
mpegts_write_packet
static int mpegts_write_packet(AVFormatContext *s, AVPacket *pkt)
Definition: mpegtsenc.c:2261
AV_PROFILE_ARIB_PROFILE_A
#define AV_PROFILE_ARIB_PROFILE_A
Definition: defs.h:188
OFFSET
#define OFFSET(x)
Definition: mpegtsenc.c:2331
METADATA_DESCRIPTOR
#define METADATA_DESCRIPTOR
Definition: mpegts.h:203
avpriv_set_pts_info
void avpriv_set_pts_info(AVStream *st, int pts_wrap_bits, unsigned int pts_num, unsigned int pts_den)
Set the time base and wrapping info for a given stream.
Definition: avformat.c:777
REGISTRATION_DESCRIPTOR
#define REGISTRATION_DESCRIPTOR
Definition: mpegts.h:198
mpegts_write_pes
static void mpegts_write_pes(AVFormatContext *s, AVStream *st, const uint8_t *payload, int payload_size, int64_t pts, int64_t dts, int key, int stream_id)
Definition: mpegtsenc.c:1484
MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_RADIO
@ MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_RADIO
Definition: mpegtsenc.c:76
STREAM_TYPE_VIDEO_AVS2
#define STREAM_TYPE_VIDEO_AVS2
Definition: mpegts.h:149
STREAM_TYPE_VIDEO_AVS3
#define STREAM_TYPE_VIDEO_AVS3
Definition: mpegts.h:150
fail
#define fail()
Definition: checkasm.h:196
STREAM_ID_DSMCC_STREAM
#define STREAM_ID_DSMCC_STREAM
Definition: mpegts.h:190
MpegTSWriteStream::last_pcr
int64_t last_pcr
Definition: mpegtsenc.c:262
get_m2ts_stream_type
static int get_m2ts_stream_type(AVFormatContext *s, AVStream *st)
Definition: mpegtsenc.c:458
AC3HeaderInfo
Definition: ac3_parser_internal.h:34
AC3_CHMODE_3F1R
@ AC3_CHMODE_3F1R
Definition: ac3defs.h:73
STREAM_TYPE_ATSC_AUDIO_EAC3
#define STREAM_TYPE_ATSC_AUDIO_EAC3
Definition: mpegts.h:170
avio_tell
static av_always_inline int64_t avio_tell(AVIOContext *s)
ftell() equivalent for AVIOContext.
Definition: avio.h:494
get_dvb_stream_type
static int get_dvb_stream_type(AVFormatContext *s, AVStream *st)
Definition: mpegtsenc.c:354
val
static double val(void *priv, double ch)
Definition: aeval.c:77
MpegTSSection::write_packet
void(* write_packet)(struct MpegTSSection *s, const uint8_t *packet)
Definition: mpegtsenc.c:58
DVBAC3Descriptor::asvc_flag
uint8_t asvc_flag
Definition: mpegts.h:269
AC3HeaderInfo::channel_mode
uint8_t channel_mode
Definition: ac3_parser_internal.h:43
DEFAULT_SERVICE_NAME
#define DEFAULT_SERVICE_NAME
Definition: mpegtsenc.c:239
pts
static int64_t pts
Definition: transcode_aac.c:644
SDT_PID
#define SDT_PID
Definition: mpegts.h:47
H264_NAL_TYPE
#define H264_NAL_TYPE(state)
Definition: mpegtsenc.c:1859
AV_CODEC_ID_MP3
@ AV_CODEC_ID_MP3
preferred ID for decoding MPEG audio layer 1, 2 or 3
Definition: codec_id.h:451
MpegTSWrite::pat_period
int64_t pat_period
Definition: mpegtsenc.c:90
MpegTSWrite::provider_name
uint8_t provider_name[256]
Definition: mpegtsenc.c:131
AVRational::num
int num
Numerator.
Definition: rational.h:59
STREAM_ID_METADATA_STREAM
#define STREAM_ID_METADATA_STREAM
Definition: mpegts.h:192
MpegTSWrite::total_size
int64_t total_size
Definition: mpegtsenc.c:98
AV_CODEC_ID_DVB_SUBTITLE
@ AV_CODEC_ID_DVB_SUBTITLE
Definition: codec_id.h:562
GET_UTF8
#define GET_UTF8(val, GET_BYTE, ERROR)
Convert a UTF-8 character (up to 4 bytes) to its 32-bit UCS-4 encoded form.
Definition: common.h:488
AV_DISPOSITION_CLEAN_EFFECTS
#define AV_DISPOSITION_CLEAN_EFFECTS
The audio stream contains music and sound effects without voice.
Definition: avformat.h:662
MpegTSWrite::last_nit_ts
int64_t last_nit_ts
Definition: mpegtsenc.c:129
avio_close_dyn_buf
int avio_close_dyn_buf(AVIOContext *s, uint8_t **pbuffer)
Return the written size and a pointer to the buffer.
Definition: aviobuf.c:1407
SUBTITLING_DESCRIPTOR
#define SUBTITLING_DESCRIPTOR
Definition: mpegts.h:214
first
trying all byte sequences megabyte in length and selecting the best looking sequence will yield cases to try But first
Definition: rate_distortion.txt:12
avassert.h
AV_LOG_TRACE
#define AV_LOG_TRACE
Extremely verbose debugging, useful for libav* development.
Definition: log.h:236
pkt
AVPacket * pkt
Definition: movenc.c:60
AV_LOG_ERROR
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
Definition: log.h:210
STREAM_TYPE_BLURAY_AUDIO_AC3
#define STREAM_TYPE_BLURAY_AUDIO_AC3
Definition: mpegts.h:156
MpegTSWrite::next_pcr
int64_t next_pcr
Definition: mpegtsenc.c:95
FF_ARRAY_ELEMS
#define FF_ARRAY_ELEMS(a)
Definition: sinewin_tablegen.c:29
select_pcr_streams
static void select_pcr_streams(AVFormatContext *s)
Definition: mpegtsenc.c:1067
STREAM_ID_EXTENDED_STREAM_ID
#define STREAM_ID_EXTENDED_STREAM_ID
Definition: mpegts.h:193
MpegTSWrite::original_network_id
int original_network_id
Definition: mpegtsenc.c:101
duration
int64_t duration
Definition: movenc.c:65
MpegTSWrite::start_pid
int start_pid
Definition: mpegtsenc.c:106
bytestream2_init_writer
static av_always_inline void bytestream2_init_writer(PutByteContext *p, uint8_t *buf, int buf_size)
Definition: bytestream.h:147
write_pcr_bits
static int write_pcr_bits(uint8_t *buf, int64_t pcr)
Definition: mpegtsenc.c:1344
avio_open_dyn_buf
int avio_open_dyn_buf(AVIOContext **s)
Open a write only memory stream.
Definition: aviobuf.c:1362
av_dict_get
AVDictionaryEntry * av_dict_get(const AVDictionary *m, const char *key, const AVDictionaryEntry *prev, int flags)
Get a dictionary entry with matching key.
Definition: dict.c:60
AV_CODEC_ID_S302M
@ AV_CODEC_ID_S302M
Definition: codec_id.h:362
STREAM_TYPE_VIDEO_MPEG4
#define STREAM_TYPE_VIDEO_MPEG4
Definition: mpeg.h:56
H264_NAL_SLICE
@ H264_NAL_SLICE
Definition: h264.h:35
intreadwrite.h
s
#define s(width, name)
Definition: cbs_vp9.c:198
MPEGTS_FLAG_SYSTEM_B
#define MPEGTS_FLAG_SYSTEM_B
Definition: mpegtsenc.c:117
MpegTSService::name
uint8_t name[256]
Definition: mpegtsenc.c:65
TELETEXT_DESCRIPTOR
#define TELETEXT_DESCRIPTOR
Definition: mpegts.h:213
bytestream2_tell_p
static av_always_inline int bytestream2_tell_p(const PutByteContext *p)
Definition: bytestream.h:197
frame_size
int frame_size
Definition: mxfenc.c:2446
bytestream2_put_buffer
static av_always_inline unsigned int bytestream2_put_buffer(PutByteContext *p, const uint8_t *src, unsigned int size)
Definition: bytestream.h:286
AVMEDIA_TYPE_AUDIO
@ AVMEDIA_TYPE_AUDIO
Definition: avutil.h:201
STUFFING_BYTE
#define STUFFING_BYTE
Definition: mpegts.h:37
AV_CODEC_ID_MP2
@ AV_CODEC_ID_MP2
Definition: codec_id.h:450
HEVC_NAL_VPS
@ HEVC_NAL_VPS
Definition: hevc.h:61
av_match_ext
int av_match_ext(const char *filename, const char *extensions)
Return a positive value if the given filename has one of the given extensions, 0 otherwise.
Definition: format.c:41
STREAM_TYPE_BLURAY_AUDIO_TRUEHD
#define STREAM_TYPE_BLURAY_AUDIO_TRUEHD
Definition: mpegts.h:158
av_assert0
#define av_assert0(cond)
assert() equivalent, that is always enabled.
Definition: avassert.h:41
options
static const AVOption options[]
Definition: mpegtsenc.c:2333
SYNC_BYTE
#define SYNC_BYTE
Definition: mpegts.h:36
AV_LOG_DEBUG
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
Definition: log.h:231
ctx
AVFormatContext * ctx
Definition: movenc.c:49
hevc.h
STREAM_ID_TYPE_E_STREAM
#define STREAM_ID_TYPE_E_STREAM
Definition: mpegts.h:191
nb_streams
static int nb_streams
Definition: ffprobe.c:334
av_rescale_q
int64_t av_rescale_q(int64_t a, AVRational bq, AVRational cq)
Rescale a 64-bit integer by 2 rational numbers.
Definition: mathematics.c:142
PMT_TID
#define PMT_TID
Definition: mpegts.h:85
mpegts_init
static int mpegts_init(AVFormatContext *s)
Definition: mpegtsenc.c:1096
MpegTSWriteStream::cc
int cc
Definition: mpegtsenc.c:249
extend_af
static void extend_af(uint8_t *pkt, int size)
Definition: mpegtsenc.c:1433
codec_id
enum AVCodecID codec_id
Definition: vaapi_decode.c:410
LAST_OTHER_PID
#define LAST_OTHER_PID
Definition: mpegts.h:66
key
const char * key
Definition: hwcontext_opencl.c:189
AVMEDIA_TYPE_DATA
@ AVMEDIA_TYPE_DATA
Opaque data information usually continuous.
Definition: avutil.h:202
DVBAC3Descriptor::component_type_flag
uint8_t component_type_flag
Definition: mpegts.h:266
AV_CODEC_ID_H264
@ AV_CODEC_ID_H264
Definition: codec_id.h:79
MpegTSWrite::sdt_period
int64_t sdt_period
Definition: mpegtsenc.c:89
avformat_write_header
av_warn_unused_result int avformat_write_header(AVFormatContext *s, AVDictionary **options)
Allocate the stream private data and write the stream header to an output media file.
Definition: mux.c:467
AV_CODEC_ID_ARIB_CAPTION
@ AV_CODEC_ID_ARIB_CAPTION
Definition: codec_id.h:586
MpegTSWrite::first_dts_checked
int first_dts_checked
Definition: mpegtsenc.c:94
retransmit_si_info
static void retransmit_si_info(AVFormatContext *s, int force_pat, int force_sdt, int force_nit, int64_t pcr)
Definition: mpegtsenc.c:1311
MpegTSWrite::m2ts_textsub_pid
int m2ts_textsub_pid
Definition: mpegtsenc.c:111
mpegts_insert_null_packet
static void mpegts_insert_null_packet(AVFormatContext *s)
Definition: mpegtsenc.c:1359
AV_CODEC_ID_AVS3
@ AV_CODEC_ID_AVS3
Definition: codec_id.h:250
AVFormatContext
Format I/O context.
Definition: avformat.h:1264
internal.h
AVStream::codecpar
AVCodecParameters * codecpar
Codec parameters associated with this stream.
Definition: avformat.h:767
LIBAVUTIL_VERSION_INT
#define LIBAVUTIL_VERSION_INT
Definition: version.h:85
AVClass
Describe the class of an AVClass context structure.
Definition: log.h:76
M2TS_VIDEO_PID
#define M2TS_VIDEO_PID
Definition: mpegts.h:75
PCR_TIME_BASE
#define PCR_TIME_BASE
Definition: mpegtsenc.c:45
AVStream::time_base
AVRational time_base
This is the fundamental unit of time (in seconds) in terms of which frame timestamps are represented.
Definition: avformat.h:783
STREAM_TYPE_ATSC_AUDIO_AC3
#define STREAM_TYPE_ATSC_AUDIO_AC3
Definition: mpegts.h:169
NULL
#define NULL
Definition: coverity.c:32
mpegts_write_section
static void mpegts_write_section(MpegTSSection *s, uint8_t *buf, int len)
Definition: mpegtsenc.c:145
AV_CODEC_ID_TIMED_ID3
@ AV_CODEC_ID_TIMED_ID3
Definition: codec_id.h:601
AV_WB16
#define AV_WB16(p, v)
Definition: intreadwrite.h:401
MpegTSWrite::nb_services
int nb_services
Definition: mpegtsenc.c:92
STREAM_ID_PRIVATE_STREAM_1
#define STREAM_ID_PRIVATE_STREAM_1
Definition: mpegts.h:183
M2TS_TEXTSUB_PID
#define M2TS_TEXTSUB_PID
Definition: mpegts.h:78
MpegTSWrite::tables_version
int tables_version
Definition: mpegtsenc.c:123
MpegTSWrite::nit
MpegTSSection nit
Definition: mpegtsenc.c:86
av_default_item_name
const char * av_default_item_name(void *ptr)
Return the context name.
Definition: log.c:240
AVFormatContext::pb
AVIOContext * pb
I/O context.
Definition: avformat.h:1306
list
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 list
Definition: filter_design.txt:25
M2TS_PGSSUB_START_PID
#define M2TS_PGSSUB_START_PID
Definition: mpegts.h:77
options
Definition: swscale.c:43
AVStream::metadata
AVDictionary * metadata
Definition: avformat.h:824
avpriv_find_start_code
const uint8_t * avpriv_find_start_code(const uint8_t *p, const uint8_t *end, uint32_t *state)
FFOutputFormat
Definition: mux.h:61
MpegTSService::sid
int sid
Definition: mpegtsenc.c:64
AV_CODEC_ID_SMPTE_KLV
@ AV_CODEC_ID_SMPTE_KLV
Definition: codec_id.h:599
av_write_frame
int av_write_frame(AVFormatContext *s, AVPacket *pkt)
Write a packet to an output media file.
Definition: mux.c:1176
AVCodecParameters::ch_layout
AVChannelLayout ch_layout
Audio only.
Definition: codec_par.h:180
MpegTSWrite::m2ts_pgssub_pid
int m2ts_pgssub_pid
Definition: mpegtsenc.c:110
EXTENSION_DESCRIPTOR
#define EXTENSION_DESCRIPTOR
Definition: mpegts.h:218
MPEGTS_FLAG_REEMIT_PAT_PMT
#define MPEGTS_FLAG_REEMIT_PAT_PMT
Definition: mpegtsenc.c:114
MpegTSWrite::sdt_period_us
int64_t sdt_period_us
Definition: mpegtsenc.c:125
MpegTSWrite::service_type
int service_type
Definition: mpegtsenc.c:103
AVCodecParameters::sample_rate
int sample_rate
Audio only.
Definition: codec_par.h:184
AV_CODEC_ID_MPEG1VIDEO
@ AV_CODEC_ID_MPEG1VIDEO
Definition: codec_id.h:53
AVStream::nb_frames
int64_t nb_frames
number of frames in this stream if known or 0
Definition: avformat.h:805
AVCodecID
AVCodecID
Identify the syntax and semantics of the bitstream.
Definition: codec_id.h:49
AV_CODEC_ID_EAC3
@ AV_CODEC_ID_EAC3
Definition: codec_id.h:490
AVCodecParameters::extradata_size
int extradata_size
Size of the extradata content in bytes.
Definition: codec_par.h:73
AV_WB32
#define AV_WB32(p, v)
Definition: intreadwrite.h:415
enable_pcr_generation_for_stream
static void enable_pcr_generation_for_stream(AVFormatContext *s, AVStream *pcr_st)
Definition: mpegtsenc.c:1036
SDT_TID
#define SDT_TID
Definition: mpegts.h:91
AV_CODEC_ID_AAC
@ AV_CODEC_ID_AAC
Definition: codec_id.h:452
M2TS_PMT_PID
#define M2TS_PMT_PID
Definition: mpegts.h:73
MpegTSWrite::copyts
int copyts
Definition: mpegtsenc.c:122
PutByteContext
Definition: bytestream.h:37
MpegTSWriteStream::amux
AVFormatContext * amux
Definition: mpegtsenc.c:258
startcode.h
aud
static int FUNC() aud(CodedBitstreamContext *ctx, RWContext *rw, H264RawAUD *current)
Definition: cbs_h264_syntax_template.c:875
av_rescale_rnd
int64_t av_rescale_rnd(int64_t a, int64_t b, int64_t c, enum AVRounding rnd)
Rescale a 64-bit integer with specified rounding.
Definition: mathematics.c:58
ac3_parser_internal.h
AC3_CHMODE_STEREO
@ AC3_CHMODE_STEREO
Definition: ac3defs.h:70
MPEGTS_SERVICE_TYPE_DIGITAL_TV
@ MPEGTS_SERVICE_TYPE_DIGITAL_TV
Definition: mpegtsenc.c:73
AVPacket::size
int size
Definition: packet.h:553
NULL_IF_CONFIG_SMALL
#define NULL_IF_CONFIG_SMALL(x)
Return NULL if CONFIG_SMALL is true, otherwise the argument without modification.
Definition: internal.h:94
avformat_alloc_context
AVFormatContext * avformat_alloc_context(void)
Allocate an AVFormatContext.
Definition: options.c:162
FF_OFMT_FLAG_ALLOW_FLUSH
#define FF_OFMT_FLAG_ALLOW_FLUSH
This flag indicates that the muxer stores data internally and supports flushing it.
Definition: mux.h:38
SERVICE_LIST_DESCRIPTOR
#define SERVICE_LIST_DESCRIPTOR
Definition: mpegts.h:210
STREAM_TYPE_VIDEO_HEVC
#define STREAM_TYPE_VIDEO_HEVC
Definition: mpeg.h:58
VVC_VPS_NUT
@ VVC_VPS_NUT
Definition: vvc.h:43
MpegTSWriteStream::data_st_warning
int data_st_warning
Definition: mpegtsenc.c:259
DVBAC3Descriptor::bsid_flag
uint8_t bsid_flag
Definition: mpegts.h:267
mpegts_write_packet_internal
static int mpegts_write_packet_internal(AVFormatContext *s, AVPacket *pkt)
Definition: mpegtsenc.c:1862
av_bswap32
#define av_bswap32
Definition: bswap.h:47
VVC_NAL_TYPE
#define VVC_NAL_TYPE(state)
Definition: mpegtsenc.c:1861
MpegTSWriteStream::opus_queued_samples
int opus_queued_samples
Definition: mpegtsenc.c:265
AV_CODEC_ID_DTS
@ AV_CODEC_ID_DTS
Definition: codec_id.h:454
size
int size
Definition: twinvq_data.h:10344
mpegts_write_pat
static void mpegts_write_pat(AVFormatContext *s)
Definition: mpegtsenc.c:271
AV_NOPTS_VALUE
#define AV_NOPTS_VALUE
Undefined timestamp value.
Definition: avutil.h:247
AV_RB32
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
Definition: bytestream.h:96
STREAM_ID_PRIVATE_STREAM_2
#define STREAM_ID_PRIVATE_STREAM_2
Definition: mpegts.h:185
av_get_audio_frame_duration2
int av_get_audio_frame_duration2(AVCodecParameters *par, int frame_bytes)
This function is the same as av_get_audio_frame_duration(), except it works with AVCodecParameters in...
Definition: utils.c:803
AVCodecParameters::profile
int profile
Codec-specific bitstream restrictions that the stream conforms to.
Definition: codec_par.h:128
AV_CODEC_ID_OPUS
@ AV_CODEC_ID_OPUS
Definition: codec_id.h:510
ff_mpegts_muxer
const FFOutputFormat ff_mpegts_muxer
Definition: mpegtsenc.c:2403
mpegts_add_service
static MpegTSService * mpegts_add_service(AVFormatContext *s, int sid, const AVDictionary *metadata, AVProgram *program)
Definition: mpegtsenc.c:991
STREAM_IDENTIFIER_DESCRIPTOR
#define STREAM_IDENTIFIER_DESCRIPTOR
Definition: mpegts.h:212
MpegTSWrite::last_pat_ts
int64_t last_pat_ts
Definition: mpegtsenc.c:127
AV_DISPOSITION_HEARING_IMPAIRED
#define AV_DISPOSITION_HEARING_IMPAIRED
The stream is intended for hearing impaired audiences.
Definition: avformat.h:654
MpegTSWrite::m2ts_video_pid
int m2ts_video_pid
Definition: mpegtsenc.c:108
AVPacket::dts
int64_t dts
Decompression timestamp in AVStream->time_base units; the time at which the packet is decompressed.
Definition: packet.h:551
avio_write
void avio_write(AVIOContext *s, const unsigned char *buf, int size)
Definition: aviobuf.c:201
FF_COMPLIANCE_NORMAL
#define FF_COMPLIANCE_NORMAL
Definition: defs.h:60
STREAM_TYPE_VIDEO_MPEG2
#define STREAM_TYPE_VIDEO_MPEG2
Definition: mpeg.h:50
AV_CODEC_ID_VVC
@ AV_CODEC_ID_VVC
Definition: codec_id.h:252
av_crc_get_table
const AVCRC * av_crc_get_table(AVCRCId crc_id)
Get an initialized standard CRC table.
Definition: crc.c:374
MpegTSWrite::sdt
MpegTSSection sdt
Definition: mpegtsenc.c:85
PCR_RETRANS_TIME
#define PCR_RETRANS_TIME
Definition: mpegtsenc.c:244
MpegTSWrite::services
MpegTSService ** services
Definition: mpegtsenc.c:87
write_packet
static void write_packet(AVFormatContext *s, const uint8_t *packet)
Definition: mpegtsenc.c:971
AC3HeaderInfo::bitstream_mode
uint8_t bitstream_mode
Definition: ac3_parser_internal.h:42
AVPacket::flags
int flags
A combination of AV_PKT_FLAG values.
Definition: packet.h:558
MpegTSWriteStream::prev_payload_key
int prev_payload_key
Definition: mpegtsenc.c:253
MpegTSWrite::pes_payload_size
int pes_payload_size
Definition: mpegtsenc.c:97
MPEGTS_SERVICE_TYPE_MPEG2_DIGITAL_HDTV
@ MPEGTS_SERVICE_TYPE_MPEG2_DIGITAL_HDTV
Definition: mpegtsenc.c:77
version
version
Definition: libkvazaar.c:315
STREAM_TYPE_AUDIO_AAC_LATM
#define STREAM_TYPE_AUDIO_AAC_LATM
Definition: mpegts.h:131
vvc.h
HEVC_NAL_RSV_VCL24
@ HEVC_NAL_RSV_VCL24
Definition: hevc.h:53
DATA_COMPONENT_DESCRIPTOR
#define DATA_COMPONENT_DESCRIPTOR
Definition: mpegts.h:228
avcodec_get_name
const char * avcodec_get_name(enum AVCodecID id)
Get the name of a codec.
Definition: utils.c:406
STREAM_TYPE_VIDEO_DIRAC
#define STREAM_TYPE_VIDEO_DIRAC
Definition: mpegts.h:152
ISO_639_LANGUAGE_DESCRIPTOR
#define ISO_639_LANGUAGE_DESCRIPTOR
Definition: mpegts.h:199
i
#define i(width, name, range_min, range_max)
Definition: cbs_h2645.c:256
AVPacket::pts
int64_t pts
Presentation timestamp in AVStream->time_base units; the time at which the decompressed packet will b...
Definition: packet.h:545
code
and forward the test the status of outputs and forward it to the corresponding return FFERROR_NOT_READY If the filters stores internally one or a few frame for some it can consider them to be part of the FIFO and delay acknowledging a status change accordingly Example code
Definition: filter_design.txt:178
avio_internal.h
av_packet_get_side_data
uint8_t * av_packet_get_side_data(const AVPacket *pkt, enum AVPacketSideDataType type, size_t *size)
Get side information from packet.
Definition: packet.c:253
put16
static void put16(uint8_t **q_ptr, int val)
Definition: mpegtsenc.c:199
SDT_RETRANS_TIME
#define SDT_RETRANS_TIME
Definition: mpegtsenc.c:242
mpegts_write_section1
static int mpegts_write_section1(MpegTSSection *s, int tid, int id, int version, int sec_num, int last_sec_num, uint8_t *buf, int len)
Definition: mpegtsenc.c:208
AV_CODEC_ID_SMPTE_2038
@ AV_CODEC_ID_SMPTE_2038
Definition: codec_id.h:603
MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_SDTV
@ MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_SDTV
Definition: mpegtsenc.c:78
STREAM_TYPE_BLURAY_SUBTITLE_TEXT
#define STREAM_TYPE_BLURAY_SUBTITLE_TEXT
Definition: mpegts.h:165
AV_TIME_BASE
#define AV_TIME_BASE
Internal time base represented as integer.
Definition: avutil.h:253
PAT_TID
#define PAT_TID
Definition: mpegts.h:83
AV_CODEC_ID_CAVS
@ AV_CODEC_ID_CAVS
Definition: codec_id.h:139
AC3_CHMODE_DUALMONO
@ AC3_CHMODE_DUALMONO
Definition: ac3defs.h:68
avpriv_ac3_parse_header
int avpriv_ac3_parse_header(AC3HeaderInfo **phdr, const uint8_t *buf, size_t size)
Definition: ac3_parser.c:490
AV_CODEC_ID_HEVC
@ AV_CODEC_ID_HEVC
Definition: codec_id.h:228
value
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 value
Definition: writing_filters.txt:86
MpegTSWrite::m2ts_audio_pid
int m2ts_audio_pid
Definition: mpegtsenc.c:109
FFMIN
#define FFMIN(a, b)
Definition: macros.h:49
MPEGTS_FLAG_NIT
#define MPEGTS_FLAG_NIT
Definition: mpegtsenc.c:119
putbuf
static void putbuf(uint8_t **q_ptr, const uint8_t *buf, size_t len)
Definition: mpegtsenc.c:292
write_pts
static void write_pts(uint8_t *q, int fourbits, int64_t pts)
Definition: mpegtsenc.c:1402
ENC
#define ENC
Definition: mpegtsenc.c:2332
av_mallocz
void * av_mallocz(size_t size)
Allocate a memory block with alignment suitable for all memory accesses (including vectors if availab...
Definition: mem.c:256
AV_PKT_DATA_MPEGTS_STREAM_ID
@ 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...
Definition: packet.h:212
AVProgram
New fields can be added to the end with minor version bumps.
Definition: avformat.h:1188
AV_CODEC_ID_VC1
@ AV_CODEC_ID_VC1
Definition: codec_id.h:122
MPEGTS_FLAG_DISCONT
#define MPEGTS_FLAG_DISCONT
Definition: mpegtsenc.c:118
len
int len
Definition: vorbis_enc_data.h:426
STREAM_TYPE_BLURAY_AUDIO_DTS_HD
#define STREAM_TYPE_BLURAY_AUDIO_DTS_HD
Definition: mpegts.h:160
DVBAC3Descriptor::asvc
uint8_t asvc
Definition: mpegts.h:274
av_rescale
int64_t av_rescale(int64_t a, int64_t b, int64_t c)
Rescale a 64-bit integer with rounding to nearest.
Definition: mathematics.c:129
MpegTSWrite
Definition: mpegtsenc.c:82
MpegTSWriteStream::opus_pending_trim_start
int opus_pending_trim_start
Definition: mpegtsenc.c:266
AV_CRC_32_IEEE
@ AV_CRC_32_IEEE
Definition: crc.h:52
MpegTSWrite::service_id
int service_id
Definition: mpegtsenc.c:102
SERVICE_DESCRIPTOR
#define SERVICE_DESCRIPTOR
Definition: mpegts.h:211
PAT_RETRANS_TIME
#define PAT_RETRANS_TIME
Definition: mpegtsenc.c:243
AC3_CHMODE_MONO
@ AC3_CHMODE_MONO
Definition: ac3defs.h:69
mpegts_write_pmt
static int mpegts_write_pmt(AVFormatContext *s, MpegTSService *service)
Definition: mpegtsenc.c:511
AC3_CHMODE_3F2R
@ AC3_CHMODE_3F2R
Definition: ac3defs.h:75
MpegTSWriteStream::payload_size
int payload_size
Definition: mpegtsenc.c:251
AC3_CHMODE_2F1R
@ AC3_CHMODE_2F1R
Definition: ac3defs.h:72
MpegTSWrite::flags
int flags
Definition: mpegtsenc.c:121
MpegTSWrite::first_pcr
int64_t first_pcr
Definition: mpegtsenc.c:93
language
Undefined Behavior In the C language
Definition: undefined.txt:3
MpegTSWriteStream::dvb_ac3_desc
DVBAC3Descriptor * dvb_ac3_desc
Definition: mpegtsenc.c:268
AVStream::disposition
int disposition
Stream disposition - a combination of AV_DISPOSITION_* flags.
Definition: avformat.h:813
AV_DISPOSITION_VISUAL_IMPAIRED
#define AV_DISPOSITION_VISUAL_IMPAIRED
The stream is intended for visually impaired audiences.
Definition: avformat.h:658
STREAM_ID_VIDEO_STREAM_0
#define STREAM_ID_VIDEO_STREAM_0
Definition: mpegts.h:187
tag
uint32_t tag
Definition: movenc.c:1907
ffio_free_dyn_buf
void ffio_free_dyn_buf(AVIOContext **s)
Free a dynamic buffer.
Definition: aviobuf.c:1435
AVStream::id
int id
Format-specific stream ID.
Definition: avformat.h:756
ret
ret
Definition: filter_design.txt:187
AVStream
Stream structure.
Definition: avformat.h:744
bswap.h
AVClass::class_name
const char * class_name
The name of the class; usually it is the same name as the context structure type to which the AVClass...
Definition: log.h:81
AVFormatContext::oformat
const struct AVOutputFormat * oformat
The output container format.
Definition: avformat.h:1283
AC3_CHMODE_2F2R
@ AC3_CHMODE_2F2R
Definition: ac3defs.h:74
STREAM_TYPE_BLURAY_AUDIO_EAC3
#define STREAM_TYPE_BLURAY_AUDIO_EAC3
Definition: mpegts.h:159
MpegTSSection
Definition: mpegtsenc.c:54
AC3_DESCRIPTOR
#define AC3_DESCRIPTOR
Definition: mpegts.h:215
avformat.h
dict.h
flag
#define flag(name)
Definition: cbs_av1.c:495
id
enum AVCodecID id
Definition: dts2pts.c:367
left
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
Definition: snow.txt:386
AV_RL32
uint64_t_TMPL AV_WL64 unsigned int_TMPL AV_RL32
Definition: bytestream.h:92
MpegTSWrite::pkt
AVPacket * pkt
Definition: mpegtsenc.c:88
STREAM_TYPE_BLURAY_AUDIO_PCM_BLURAY
#define STREAM_TYPE_BLURAY_AUDIO_PCM_BLURAY
Definition: mpegts.h:155
av_dynarray_add_nofree
int av_dynarray_add_nofree(void *tab_ptr, int *nb_ptr, void *elem)
Add an element to a dynamic array.
Definition: mem.c:315
AC3_DSURMOD_ON
@ AC3_DSURMOD_ON
Definition: ac3defs.h:82
AVStream::index
int index
stream index in AVFormatContext
Definition: avformat.h:750
MpegTSWrite::pat
MpegTSSection pat
Definition: mpegtsenc.c:84
STREAM_TYPE_VIDEO_H264
#define STREAM_TYPE_VIDEO_H264
Definition: mpeg.h:57
MPEGTS_SERVICE_TYPE_DIGITAL_RADIO
@ MPEGTS_SERVICE_TYPE_DIGITAL_RADIO
Definition: mpegtsenc.c:74
mpegts_write_sdt
static void mpegts_write_sdt(AVFormatContext *s)
Definition: mpegtsenc.c:850
av_crc
uint32_t av_crc(const AVCRC *ctx, uint32_t crc, const uint8_t *buffer, size_t length)
Calculate the CRC of a block.
Definition: crc.c:392
AVRational::den
int den
Denominator.
Definition: rational.h:60
mpegts_write_nit
static void mpegts_write_nit(AVFormatContext *s)
Definition: mpegtsenc.c:888
AV_OPT_TYPE_INT
@ AV_OPT_TYPE_INT
Underlying C type is int.
Definition: opt.h:259
defs.h
MpegTSSection::cc
int cc
Definition: mpegtsenc.c:56
avformat_free_context
void avformat_free_context(AVFormatContext *s)
Free an AVFormatContext and all its streams.
Definition: avformat.c:141
STREAM_TYPE_VIDEO_CAVS
#define STREAM_TYPE_VIDEO_CAVS
Definition: mpeg.h:60
MpegTSWriteStream::payload
uint8_t * payload
Definition: mpegtsenc.c:257
AV_PKT_DATA_SKIP_SAMPLES
@ AV_PKT_DATA_SKIP_SAMPLES
Recommmends skipping the specified number of samples.
Definition: packet.h:153
MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_HDTV
@ MPEGTS_SERVICE_TYPE_ADVANCED_CODEC_DIGITAL_HDTV
Definition: mpegtsenc.c:79
MpegTSWriteStream::pcr_period
int64_t pcr_period
Definition: mpegtsenc.c:261
AVPacket::stream_index
int stream_index
Definition: packet.h:554
DVBAC3Descriptor
Definition: mpegts.h:265
MpegTSService::pmt
MpegTSSection pmt
Definition: mpegtsenc.c:63
mpegts_muxer_class
static const AVClass mpegts_muxer_class
Definition: mpegtsenc.c:2396
av_log_once
void av_log_once(void *avcl, int initial_level, int subsequent_level, int *state, const char *fmt,...)
Definition: log.c:449
MpegTSWriteStream::payload_flags
int payload_flags
Definition: mpegtsenc.c:256
VVC_OPI_NUT
@ VVC_OPI_NUT
Definition: vvc.h:41
AC3HeaderInfo::bitstream_id
uint8_t bitstream_id
Definition: ac3_parser_internal.h:41
AVMEDIA_TYPE_VIDEO
@ AVMEDIA_TYPE_VIDEO
Definition: avutil.h:200
av_guess_format
const AVOutputFormat * av_guess_format(const char *short_name, const char *filename, const char *mime_type)
Return the output format in the list of registered output formats which best matches the provided par...
Definition: format.c:79
mem.h
STREAM_ID_AUDIO_STREAM_0
#define STREAM_ID_AUDIO_STREAM_0
Definition: mpegts.h:186
state
static struct @510 state
DVBAC3Descriptor::mainid
uint8_t mainid
Definition: mpegts.h:273
FFFormatContext::pkt
AVPacket * pkt
Used to hold temporary packets for the generic demuxing code.
Definition: internal.h:111
MpegTSService
Definition: mpegtsenc.c:62
STREAM_TYPE_METADATA
#define STREAM_TYPE_METADATA
Definition: mpegts.h:139
MpegTSWrite::transport_stream_id
int transport_stream_id
Definition: mpegtsenc.c:100
STREAM_ID_ECM_STREAM
#define STREAM_ID_ECM_STREAM
Definition: mpegts.h:188
DVBAC3Descriptor::bsid
uint8_t bsid
Definition: mpegts.h:272
av_free
#define av_free(p)
Definition: tableprint_vlc.h:34
AVDictionaryEntry
Definition: dict.h:90
AVCodecParameters::codec_id
enum AVCodecID codec_id
Specific type of the encoded data (the codec used).
Definition: codec_par.h:55
AVPacket
This structure stores compressed data.
Definition: packet.h:529
AV_OPT_TYPE_BOOL
@ AV_OPT_TYPE_BOOL
Underlying C type is int.
Definition: opt.h:327
STREAM_ID_PROGRAM_STREAM_DIRECTORY
#define STREAM_ID_PROGRAM_STREAM_DIRECTORY
Definition: mpegts.h:194
MpegTSWrite::pat_period_us
int64_t pat_period_us
Definition: mpegtsenc.c:124
av_freep
#define av_freep(p)
Definition: tableprint_vlc.h:35
get_pes_stream_id
static int get_pes_stream_id(AVFormatContext *s, AVStream *st, int stream_id, int *async)
Definition: mpegtsenc.c:1449
AV_OPT_TYPE_FLAGS
@ AV_OPT_TYPE_FLAGS
Underlying C type is unsigned int.
Definition: opt.h:255
bytestream.h
h264.h
MpegTSWrite::omit_video_pes_length
int omit_video_pes_length
Definition: mpegtsenc.c:133
av_log
#define av_log(a,...)
Definition: tableprint_vlc.h:27
AV_CODEC_ID_AAC_LATM
@ AV_CODEC_ID_AAC_LATM
Definition: codec_id.h:499
AVERROR_INVALIDDATA
#define AVERROR_INVALIDDATA
Invalid data found when processing input.
Definition: error.h:61
get_ts_payload_start
static uint8_t * get_ts_payload_start(uint8_t *pkt)
Definition: mpegtsenc.c:1441
STREAM_TYPE_BLURAY_AUDIO_DTS
#define STREAM_TYPE_BLURAY_AUDIO_DTS
Definition: mpegts.h:157
AV_CODEC_ID_HDMV_TEXT_SUBTITLE
@ AV_CODEC_ID_HDMV_TEXT_SUBTITLE
Definition: codec_id.h:584
TS_PACKET_SIZE
#define TS_PACKET_SIZE
Definition: mpegts.h:29
mpegts_insert_pcr_only
static void mpegts_insert_pcr_only(AVFormatContext *s, AVStream *st)
Definition: mpegtsenc.c:1374
MKTAG
#define MKTAG(a, b, c, d)
Definition: macros.h:55
DVB_PRIVATE_NETWORK_START
#define DVB_PRIVATE_NETWORK_START
Definition: mpegtsenc.c:49
AVDictionaryEntry::value
char * value
Definition: dict.h:92
AV_RB24
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_RB24
Definition: bytestream.h:97
DEFAULT_PES_PAYLOAD_SIZE
#define DEFAULT_PES_PAYLOAD_SIZE
Definition: mpegtsenc.c:138
STREAM_TYPE_BLURAY_SUBTITLE_PGS
#define STREAM_TYPE_BLURAY_SUBTITLE_PGS
Definition: mpegts.h:164
AV_CODEC_ID_MPEG2VIDEO
@ AV_CODEC_ID_MPEG2VIDEO
preferred ID for MPEG-1/2 video decoding
Definition: codec_id.h:54
AV_OPT_TYPE_CONST
@ AV_OPT_TYPE_CONST
Special option type for declaring named constants.
Definition: opt.h:299
snprintf
#define snprintf
Definition: snprintf.h:34
AVCodecParameters::initial_padding
int initial_padding
Audio only.
Definition: codec_par.h:203
ff_stream_add_bitstream_filter
int ff_stream_add_bitstream_filter(AVStream *st, const char *name, const char *args)
Add a bitstream filter to a stream.
Definition: mux.c:1294
DVBAC3Descriptor::mainid_flag
uint8_t mainid_flag
Definition: mpegts.h:268
MpegTSSection::discontinuity
int discontinuity
Definition: mpegtsenc.c:57
MPEGTS_FLAG_OMIT_RAI
#define MPEGTS_FLAG_OMIT_RAI
Definition: mpegtsenc.c:120
encode_str8
static int encode_str8(uint8_t *buf, const char *str)
Definition: mpegtsenc.c:933
avcodec_parameters_copy
int avcodec_parameters_copy(AVCodecParameters *dst, const AVCodecParameters *src)
Copy the contents of src to dst.
Definition: codec_par.c:106
MpegTSWrite::mux_rate
int mux_rate
set to 1 when VBR
Definition: mpegtsenc.c:96
AV_RB16
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
Definition: bytestream.h:98
ff_check_h264_startcode
int ff_check_h264_startcode(AVFormatContext *s, const AVStream *st, const AVPacket *pkt)
Check presence of H264 startcode.
Definition: mpegtsenc.c:1787
put_arib_caption_descriptor
static int put_arib_caption_descriptor(AVFormatContext *s, uint8_t **q_ptr, AVCodecParameters *codecpar)
Definition: mpegtsenc.c:298
mux.h
Generated on Sat Jul 12 2025 19:23:06 for FFmpeg by   doxygen 1.8.17