1 /*
2  * This file is part of FFmpeg.
3  *
4  * FFmpeg is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Lesser General Public
6  * License as published by the Free Software Foundation; either
7  * version 2.1 of the License, or (at your option) any later version.
8  *
9  * FFmpeg is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * Lesser General Public License for more details.
13  *
14  * You should have received a copy of the GNU Lesser General Public
15  * License along with FFmpeg; if not, write to the Free Software
16  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
17  */
18 
19 #include "libavutil/attributes.h"
20 #include "libavutil/avassert.h"
21 
22 #include "bytestream.h"
23 #include "cbs.h"
24 #include "cbs_internal.h"
25 #include "cbs_h264.h"
26 #include "cbs_h265.h"
27 #include "h264.h"
28 #include "h264_sei.h"
29 #include "h2645_parse.h"
30 #include "hevc.h"
31 #include "hevc_sei.h"
32 
33 
cbs_read_ue_golomb(CodedBitstreamContext * ctx,GetBitContext * gbc,const char * name,const int * subscripts,uint32_t * write_to,uint32_t range_min,uint32_t range_max)34 static int cbs_read_ue_golomb(CodedBitstreamContext *ctx, GetBitContext *gbc,
35                               const char *name, const int *subscripts,
36                               uint32_t *write_to,
37                               uint32_t range_min, uint32_t range_max)
38 {
39     uint32_t value;
40     int position, i, j;
41     unsigned int k;
42     char bits[65];
43 
44     position = get_bits_count(gbc);
45 
46     for (i = 0; i < 32; i++) {
47         if (get_bits_left(gbc) < i + 1) {
48             av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid ue-golomb code at "
49                    "%s: bitstream ended.\n", name);
50             return AVERROR_INVALIDDATA;
51         }
52         k = get_bits1(gbc);
53         bits[i] = k ? '1' : '0';
54         if (k)
55             break;
56     }
57     if (i >= 32) {
58         av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid ue-golomb code at "
59                "%s: more than 31 zeroes.\n", name);
60         return AVERROR_INVALIDDATA;
61     }
62     value = 1;
63     for (j = 0; j < i; j++) {
64         k = get_bits1(gbc);
65         bits[i + j + 1] = k ? '1' : '0';
66         value = value << 1 | k;
67     }
68     bits[i + j + 1] = 0;
69     --value;
70 
71     if (ctx->trace_enable)
72         ff_cbs_trace_syntax_element(ctx, position, name, subscripts,
73                                     bits, value);
74 
75     if (value < range_min || value > range_max) {
76         av_log(ctx->log_ctx, AV_LOG_ERROR, "%s out of range: "
77                "%"PRIu32", but must be in [%"PRIu32",%"PRIu32"].\n",
78                name, value, range_min, range_max);
79         return AVERROR_INVALIDDATA;
80     }
81 
82     *write_to = value;
83     return 0;
84 }
85 
cbs_read_se_golomb(CodedBitstreamContext * ctx,GetBitContext * gbc,const char * name,const int * subscripts,int32_t * write_to,int32_t range_min,int32_t range_max)86 static int cbs_read_se_golomb(CodedBitstreamContext *ctx, GetBitContext *gbc,
87                               const char *name, const int *subscripts,
88                               int32_t *write_to,
89                               int32_t range_min, int32_t range_max)
90 {
91     int32_t value;
92     int position, i, j;
93     unsigned int k;
94     uint32_t v;
95     char bits[65];
96 
97     position = get_bits_count(gbc);
98 
99     for (i = 0; i < 32; i++) {
100         if (get_bits_left(gbc) < i + 1) {
101             av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid se-golomb code at "
102                    "%s: bitstream ended.\n", name);
103             return AVERROR_INVALIDDATA;
104         }
105         k = get_bits1(gbc);
106         bits[i] = k ? '1' : '0';
107         if (k)
108             break;
109     }
110     if (i >= 32) {
111         av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid se-golomb code at "
112                "%s: more than 31 zeroes.\n", name);
113         return AVERROR_INVALIDDATA;
114     }
115     v = 1;
116     for (j = 0; j < i; j++) {
117         k = get_bits1(gbc);
118         bits[i + j + 1] = k ? '1' : '0';
119         v = v << 1 | k;
120     }
121     bits[i + j + 1] = 0;
122     if (v & 1)
123         value = -(int32_t)(v / 2);
124     else
125         value = v / 2;
126 
127     if (ctx->trace_enable)
128         ff_cbs_trace_syntax_element(ctx, position, name, subscripts,
129                                     bits, value);
130 
131     if (value < range_min || value > range_max) {
132         av_log(ctx->log_ctx, AV_LOG_ERROR, "%s out of range: "
133                "%"PRId32", but must be in [%"PRId32",%"PRId32"].\n",
134                name, value, range_min, range_max);
135         return AVERROR_INVALIDDATA;
136     }
137 
138     *write_to = value;
139     return 0;
140 }
141 
cbs_write_ue_golomb(CodedBitstreamContext * ctx,PutBitContext * pbc,const char * name,const int * subscripts,uint32_t value,uint32_t range_min,uint32_t range_max)142 static int cbs_write_ue_golomb(CodedBitstreamContext *ctx, PutBitContext *pbc,
143                                const char *name, const int *subscripts,
144                                uint32_t value,
145                                uint32_t range_min, uint32_t range_max)
146 {
147     int len;
148 
149     if (value < range_min || value > range_max) {
150         av_log(ctx->log_ctx, AV_LOG_ERROR, "%s out of range: "
151                "%"PRIu32", but must be in [%"PRIu32",%"PRIu32"].\n",
152                name, value, range_min, range_max);
153         return AVERROR_INVALIDDATA;
154     }
155     av_assert0(value != UINT32_MAX);
156 
157     len = av_log2(value + 1);
158     if (put_bits_left(pbc) < 2 * len + 1)
159         return AVERROR(ENOSPC);
160 
161     if (ctx->trace_enable) {
162         char bits[65];
163         int i;
164 
165         for (i = 0; i < len; i++)
166             bits[i] = '0';
167         bits[len] = '1';
168         for (i = 0; i < len; i++)
169             bits[len + i + 1] = (value + 1) >> (len - i - 1) & 1 ? '1' : '0';
170         bits[len + len + 1] = 0;
171 
172         ff_cbs_trace_syntax_element(ctx, put_bits_count(pbc),
173                                     name, subscripts, bits, value);
174     }
175 
176     put_bits(pbc, len, 0);
177     if (len + 1 < 32)
178         put_bits(pbc, len + 1, value + 1);
179     else
180         put_bits32(pbc, value + 1);
181 
182     return 0;
183 }
184 
cbs_write_se_golomb(CodedBitstreamContext * ctx,PutBitContext * pbc,const char * name,const int * subscripts,int32_t value,int32_t range_min,int32_t range_max)185 static int cbs_write_se_golomb(CodedBitstreamContext *ctx, PutBitContext *pbc,
186                                const char *name, const int *subscripts,
187                                int32_t value,
188                                int32_t range_min, int32_t range_max)
189 {
190     int len;
191     uint32_t uvalue;
192 
193     if (value < range_min || value > range_max) {
194         av_log(ctx->log_ctx, AV_LOG_ERROR, "%s out of range: "
195                "%"PRId32", but must be in [%"PRId32",%"PRId32"].\n",
196                name, value, range_min, range_max);
197         return AVERROR_INVALIDDATA;
198     }
199     av_assert0(value != INT32_MIN);
200 
201     if (value == 0)
202         uvalue = 0;
203     else if (value > 0)
204         uvalue = 2 * (uint32_t)value - 1;
205     else
206         uvalue = 2 * (uint32_t)-value;
207 
208     len = av_log2(uvalue + 1);
209     if (put_bits_left(pbc) < 2 * len + 1)
210         return AVERROR(ENOSPC);
211 
212     if (ctx->trace_enable) {
213         char bits[65];
214         int i;
215 
216         for (i = 0; i < len; i++)
217             bits[i] = '0';
218         bits[len] = '1';
219         for (i = 0; i < len; i++)
220             bits[len + i + 1] = (uvalue + 1) >> (len - i - 1) & 1 ? '1' : '0';
221         bits[len + len + 1] = 0;
222 
223         ff_cbs_trace_syntax_element(ctx, put_bits_count(pbc),
224                                     name, subscripts, bits, value);
225     }
226 
227     put_bits(pbc, len, 0);
228     if (len + 1 < 32)
229         put_bits(pbc, len + 1, uvalue + 1);
230     else
231         put_bits32(pbc, uvalue + 1);
232 
233     return 0;
234 }
235 
236 // payload_extension_present() - true if we are before the last 1-bit
237 // in the payload structure, which must be in the last byte.
cbs_h265_payload_extension_present(GetBitContext * gbc,uint32_t payload_size,int cur_pos)238 static int cbs_h265_payload_extension_present(GetBitContext *gbc, uint32_t payload_size,
239                                               int cur_pos)
240 {
241     int bits_left = payload_size * 8 - cur_pos;
242     return (bits_left > 0 &&
243             (bits_left > 7 || show_bits(gbc, bits_left) & MAX_UINT_BITS(bits_left - 1)));
244 }
245 
246 #define HEADER(name) do { \
247         ff_cbs_trace_header(ctx, name); \
248     } while (0)
249 
250 #define CHECK(call) do { \
251         err = (call); \
252         if (err < 0) \
253             return err; \
254     } while (0)
255 
256 #define FUNC_NAME(rw, codec, name) cbs_ ## codec ## _ ## rw ## _ ## name
257 #define FUNC_H264(rw, name) FUNC_NAME(rw, h264, name)
258 #define FUNC_H265(rw, name) FUNC_NAME(rw, h265, name)
259 
260 #define SUBSCRIPTS(subs, ...) (subs > 0 ? ((int[subs + 1]){ subs, __VA_ARGS__ }) : NULL)
261 
262 #define u(width, name, range_min, range_max) \
263         xu(width, name, current->name, range_min, range_max, 0, )
264 #define ub(width, name) \
265         xu(width, name, current->name, 0, MAX_UINT_BITS(width), 0, )
266 #define flag(name) ub(1, name)
267 #define ue(name, range_min, range_max) \
268         xue(name, current->name, range_min, range_max, 0, )
269 #define i(width, name, range_min, range_max) \
270         xi(width, name, current->name, range_min, range_max, 0, )
271 #define ib(width, name) \
272         xi(width, name, current->name, MIN_INT_BITS(width), MAX_INT_BITS(width), 0, )
273 #define se(name, range_min, range_max) \
274         xse(name, current->name, range_min, range_max, 0, )
275 
276 #define us(width, name, range_min, range_max, subs, ...) \
277         xu(width, name, current->name, range_min, range_max, subs, __VA_ARGS__)
278 #define ubs(width, name, subs, ...) \
279         xu(width, name, current->name, 0, MAX_UINT_BITS(width), subs, __VA_ARGS__)
280 #define flags(name, subs, ...) \
281         xu(1, name, current->name, 0, 1, subs, __VA_ARGS__)
282 #define ues(name, range_min, range_max, subs, ...) \
283         xue(name, current->name, range_min, range_max, subs, __VA_ARGS__)
284 #define is(width, name, range_min, range_max, subs, ...) \
285         xi(width, name, current->name, range_min, range_max, subs, __VA_ARGS__)
286 #define ibs(width, name, subs, ...) \
287         xi(width, name, current->name, MIN_INT_BITS(width), MAX_INT_BITS(width), subs, __VA_ARGS__)
288 #define ses(name, range_min, range_max, subs, ...) \
289         xse(name, current->name, range_min, range_max, subs, __VA_ARGS__)
290 
291 #define fixed(width, name, value) do { \
292         av_unused uint32_t fixed_value = value; \
293         xu(width, name, fixed_value, value, value, 0, ); \
294     } while (0)
295 
296 
297 #define READ
298 #define READWRITE read
299 #define RWContext GetBitContext
300 
301 #define xu(width, name, var, range_min, range_max, subs, ...) do { \
302         uint32_t value; \
303         CHECK(ff_cbs_read_unsigned(ctx, rw, width, #name, \
304                                    SUBSCRIPTS(subs, __VA_ARGS__), \
305                                    &value, range_min, range_max)); \
306         var = value; \
307     } while (0)
308 #define xue(name, var, range_min, range_max, subs, ...) do { \
309         uint32_t value; \
310         CHECK(cbs_read_ue_golomb(ctx, rw, #name, \
311                                  SUBSCRIPTS(subs, __VA_ARGS__), \
312                                  &value, range_min, range_max)); \
313         var = value; \
314     } while (0)
315 #define xi(width, name, var, range_min, range_max, subs, ...) do { \
316         int32_t value; \
317         CHECK(ff_cbs_read_signed(ctx, rw, width, #name, \
318                                  SUBSCRIPTS(subs, __VA_ARGS__), \
319                                  &value, range_min, range_max)); \
320         var = value; \
321     } while (0)
322 #define xse(name, var, range_min, range_max, subs, ...) do { \
323         int32_t value; \
324         CHECK(cbs_read_se_golomb(ctx, rw, #name, \
325                                  SUBSCRIPTS(subs, __VA_ARGS__), \
326                                  &value, range_min, range_max)); \
327         var = value; \
328     } while (0)
329 
330 
331 #define infer(name, value) do { \
332         current->name = value; \
333     } while (0)
334 
cbs_h2645_read_more_rbsp_data(GetBitContext * gbc)335 static int cbs_h2645_read_more_rbsp_data(GetBitContext *gbc)
336 {
337     int bits_left = get_bits_left(gbc);
338     if (bits_left > 8)
339         return 1;
340     if (bits_left == 0)
341         return 0;
342     if (show_bits(gbc, bits_left) & MAX_UINT_BITS(bits_left - 1))
343         return 1;
344     return 0;
345 }
346 
347 #define more_rbsp_data(var) ((var) = cbs_h2645_read_more_rbsp_data(rw))
348 
349 #define byte_alignment(rw) (get_bits_count(rw) % 8)
350 
351 #define allocate(name, size) do { \
352         name ## _ref = av_buffer_allocz(size + \
353                                         AV_INPUT_BUFFER_PADDING_SIZE); \
354         if (!name ## _ref) \
355             return AVERROR(ENOMEM); \
356         name = name ## _ref->data; \
357     } while (0)
358 
359 #define FUNC(name) FUNC_H264(READWRITE, name)
360 #include "cbs_h264_syntax_template.c"
361 #undef FUNC
362 
363 #define FUNC(name) FUNC_H265(READWRITE, name)
364 #include "cbs_h265_syntax_template.c"
365 #undef FUNC
366 
367 #undef READ
368 #undef READWRITE
369 #undef RWContext
370 #undef xu
371 #undef xi
372 #undef xue
373 #undef xse
374 #undef infer
375 #undef more_rbsp_data
376 #undef byte_alignment
377 #undef allocate
378 
379 
380 #define WRITE
381 #define READWRITE write
382 #define RWContext PutBitContext
383 
384 #define xu(width, name, var, range_min, range_max, subs, ...) do { \
385         uint32_t value = var; \
386         CHECK(ff_cbs_write_unsigned(ctx, rw, width, #name, \
387                                     SUBSCRIPTS(subs, __VA_ARGS__), \
388                                     value, range_min, range_max)); \
389     } while (0)
390 #define xue(name, var, range_min, range_max, subs, ...) do { \
391         uint32_t value = var; \
392         CHECK(cbs_write_ue_golomb(ctx, rw, #name, \
393                                   SUBSCRIPTS(subs, __VA_ARGS__), \
394                                   value, range_min, range_max)); \
395     } while (0)
396 #define xi(width, name, var, range_min, range_max, subs, ...) do { \
397         int32_t value = var; \
398         CHECK(ff_cbs_write_signed(ctx, rw, width, #name, \
399                                   SUBSCRIPTS(subs, __VA_ARGS__), \
400                                   value, range_min, range_max)); \
401     } while (0)
402 #define xse(name, var, range_min, range_max, subs, ...) do { \
403         int32_t value = var; \
404         CHECK(cbs_write_se_golomb(ctx, rw, #name, \
405                                   SUBSCRIPTS(subs, __VA_ARGS__), \
406                                   value, range_min, range_max)); \
407     } while (0)
408 
409 #define infer(name, value) do { \
410         if (current->name != (value)) { \
411             av_log(ctx->log_ctx, AV_LOG_ERROR, \
412                    "%s does not match inferred value: " \
413                    "%"PRId64", but should be %"PRId64".\n", \
414                    #name, (int64_t)current->name, (int64_t)(value)); \
415             return AVERROR_INVALIDDATA; \
416         } \
417     } while (0)
418 
419 #define more_rbsp_data(var) (var)
420 
421 #define byte_alignment(rw) (put_bits_count(rw) % 8)
422 
423 #define allocate(name, size) do { \
424         if (!name) { \
425             av_log(ctx->log_ctx, AV_LOG_ERROR, "%s must be set " \
426                    "for writing.\n", #name); \
427             return AVERROR_INVALIDDATA; \
428         } \
429     } while (0)
430 
431 #define FUNC(name) FUNC_H264(READWRITE, name)
432 #include "cbs_h264_syntax_template.c"
433 #undef FUNC
434 
435 #define FUNC(name) FUNC_H265(READWRITE, name)
436 #include "cbs_h265_syntax_template.c"
437 #undef FUNC
438 
439 #undef WRITE
440 #undef READWRITE
441 #undef RWContext
442 #undef xu
443 #undef xi
444 #undef xue
445 #undef xse
446 #undef u
447 #undef i
448 #undef flag
449 #undef ue
450 #undef se
451 #undef infer
452 #undef more_rbsp_data
453 #undef byte_alignment
454 #undef allocate
455 
456 
cbs_h2645_fragment_add_nals(CodedBitstreamContext * ctx,CodedBitstreamFragment * frag,const H2645Packet * packet)457 static int cbs_h2645_fragment_add_nals(CodedBitstreamContext *ctx,
458                                        CodedBitstreamFragment *frag,
459                                        const H2645Packet *packet)
460 {
461     int err, i;
462 
463     for (i = 0; i < packet->nb_nals; i++) {
464         const H2645NAL *nal = &packet->nals[i];
465         AVBufferRef *ref;
466         size_t size = nal->size;
467 
468         if (nal->nuh_layer_id > 0)
469             continue;
470 
471         // Remove trailing zeroes.
472         while (size > 0 && nal->data[size - 1] == 0)
473             --size;
474         if (size == 0) {
475             av_log(ctx->log_ctx, AV_LOG_VERBOSE, "Discarding empty 0 NAL unit\n");
476             continue;
477         }
478 
479         ref = (nal->data == nal->raw_data) ? frag->data_ref
480                                            : packet->rbsp.rbsp_buffer_ref;
481 
482         err = ff_cbs_insert_unit_data(frag, -1, nal->type,
483                             (uint8_t*)nal->data, size, ref);
484         if (err < 0)
485             return err;
486     }
487 
488     return 0;
489 }
490 
cbs_h2645_split_fragment(CodedBitstreamContext * ctx,CodedBitstreamFragment * frag,int header)491 static int cbs_h2645_split_fragment(CodedBitstreamContext *ctx,
492                                     CodedBitstreamFragment *frag,
493                                     int header)
494 {
495     enum AVCodecID codec_id = ctx->codec->codec_id;
496     CodedBitstreamH2645Context *priv = ctx->priv_data;
497     GetByteContext gbc;
498     int err;
499 
500     av_assert0(frag->data && frag->nb_units == 0);
501     if (frag->data_size == 0)
502         return 0;
503 
504     if (header && frag->data[0] && codec_id == AV_CODEC_ID_H264) {
505         // AVCC header.
506         size_t size, start, end;
507         int i, count, version;
508 
509         priv->mp4 = 1;
510 
511         bytestream2_init(&gbc, frag->data, frag->data_size);
512 
513         if (bytestream2_get_bytes_left(&gbc) < 6)
514             return AVERROR_INVALIDDATA;
515 
516         version = bytestream2_get_byte(&gbc);
517         if (version != 1) {
518             av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid AVCC header: "
519                    "first byte %u.\n", version);
520             return AVERROR_INVALIDDATA;
521         }
522 
523         bytestream2_skip(&gbc, 3);
524         priv->nal_length_size = (bytestream2_get_byte(&gbc) & 3) + 1;
525 
526         // SPS array.
527         count = bytestream2_get_byte(&gbc) & 0x1f;
528         start = bytestream2_tell(&gbc);
529         for (i = 0; i < count; i++) {
530             if (bytestream2_get_bytes_left(&gbc) < 2 * (count - i))
531                 return AVERROR_INVALIDDATA;
532             size = bytestream2_get_be16(&gbc);
533             if (bytestream2_get_bytes_left(&gbc) < size)
534                 return AVERROR_INVALIDDATA;
535             bytestream2_skip(&gbc, size);
536         }
537         end = bytestream2_tell(&gbc);
538 
539         err = ff_h2645_packet_split(&priv->read_packet,
540                                     frag->data + start, end - start,
541                                     ctx->log_ctx, 1, 2, AV_CODEC_ID_H264, 1, 1);
542         if (err < 0) {
543             av_log(ctx->log_ctx, AV_LOG_ERROR, "Failed to split AVCC SPS array.\n");
544             return err;
545         }
546         err = cbs_h2645_fragment_add_nals(ctx, frag, &priv->read_packet);
547         if (err < 0)
548             return err;
549 
550         // PPS array.
551         count = bytestream2_get_byte(&gbc);
552         start = bytestream2_tell(&gbc);
553         for (i = 0; i < count; i++) {
554             if (bytestream2_get_bytes_left(&gbc) < 2 * (count - i))
555                 return AVERROR_INVALIDDATA;
556             size = bytestream2_get_be16(&gbc);
557             if (bytestream2_get_bytes_left(&gbc) < size)
558                 return AVERROR_INVALIDDATA;
559             bytestream2_skip(&gbc, size);
560         }
561         end = bytestream2_tell(&gbc);
562 
563         err = ff_h2645_packet_split(&priv->read_packet,
564                                     frag->data + start, end - start,
565                                     ctx->log_ctx, 1, 2, AV_CODEC_ID_H264, 1, 1);
566         if (err < 0) {
567             av_log(ctx->log_ctx, AV_LOG_ERROR, "Failed to split AVCC PPS array.\n");
568             return err;
569         }
570         err = cbs_h2645_fragment_add_nals(ctx, frag, &priv->read_packet);
571         if (err < 0)
572             return err;
573 
574         if (bytestream2_get_bytes_left(&gbc) > 0) {
575             av_log(ctx->log_ctx, AV_LOG_WARNING, "%u bytes left at end of AVCC "
576                    "header.\n", bytestream2_get_bytes_left(&gbc));
577         }
578 
579     } else if (header && frag->data[0] && codec_id == AV_CODEC_ID_HEVC) {
580         // HVCC header.
581         size_t size, start, end;
582         int i, j, nb_arrays, nal_unit_type, nb_nals, version;
583 
584         priv->mp4 = 1;
585 
586         bytestream2_init(&gbc, frag->data, frag->data_size);
587 
588         if (bytestream2_get_bytes_left(&gbc) < 23)
589             return AVERROR_INVALIDDATA;
590 
591         version = bytestream2_get_byte(&gbc);
592         if (version != 1) {
593             av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid HVCC header: "
594                    "first byte %u.\n", version);
595             return AVERROR_INVALIDDATA;
596         }
597 
598         bytestream2_skip(&gbc, 20);
599         priv->nal_length_size = (bytestream2_get_byte(&gbc) & 3) + 1;
600 
601         nb_arrays = bytestream2_get_byte(&gbc);
602         for (i = 0; i < nb_arrays; i++) {
603             nal_unit_type = bytestream2_get_byte(&gbc) & 0x3f;
604             nb_nals = bytestream2_get_be16(&gbc);
605 
606             start = bytestream2_tell(&gbc);
607             for (j = 0; j < nb_nals; j++) {
608                 if (bytestream2_get_bytes_left(&gbc) < 2)
609                     return AVERROR_INVALIDDATA;
610                 size = bytestream2_get_be16(&gbc);
611                 if (bytestream2_get_bytes_left(&gbc) < size)
612                     return AVERROR_INVALIDDATA;
613                 bytestream2_skip(&gbc, size);
614             }
615             end = bytestream2_tell(&gbc);
616 
617             err = ff_h2645_packet_split(&priv->read_packet,
618                                         frag->data + start, end - start,
619                                         ctx->log_ctx, 1, 2, AV_CODEC_ID_HEVC, 1, 1);
620             if (err < 0) {
621                 av_log(ctx->log_ctx, AV_LOG_ERROR, "Failed to split "
622                        "HVCC array %d (%d NAL units of type %d).\n",
623                        i, nb_nals, nal_unit_type);
624                 return err;
625             }
626             err = cbs_h2645_fragment_add_nals(ctx, frag, &priv->read_packet);
627             if (err < 0)
628                 return err;
629         }
630 
631     } else {
632         // Annex B, or later MP4 with already-known parameters.
633 
634         err = ff_h2645_packet_split(&priv->read_packet,
635                                     frag->data, frag->data_size,
636                                     ctx->log_ctx,
637                                     priv->mp4, priv->nal_length_size,
638                                     codec_id, 1, 1);
639         if (err < 0)
640             return err;
641 
642         err = cbs_h2645_fragment_add_nals(ctx, frag, &priv->read_packet);
643         if (err < 0)
644             return err;
645     }
646 
647     return 0;
648 }
649 
650 #define cbs_h2645_replace_ps(h26n, ps_name, ps_var, id_element) \
651 static int cbs_h26 ## h26n ## _replace_ ## ps_var(CodedBitstreamContext *ctx, \
652                                                   CodedBitstreamUnit *unit)  \
653 { \
654     CodedBitstreamH26 ## h26n ## Context *priv = ctx->priv_data; \
655     H26 ## h26n ## Raw ## ps_name *ps_var = unit->content; \
656     unsigned int id = ps_var->id_element; \
657     int err; \
658     if (id >= FF_ARRAY_ELEMS(priv->ps_var)) { \
659         av_log(ctx->log_ctx, AV_LOG_ERROR, "Invalid " #ps_name \
660                " id : %d.\n", id); \
661         return AVERROR_INVALIDDATA; \
662     } \
663     err = ff_cbs_make_unit_refcounted(ctx, unit); \
664     if (err < 0) \
665         return err; \
666     if (priv->ps_var[id] == priv->active_ ## ps_var) \
667         priv->active_ ## ps_var = NULL ; \
668     av_buffer_unref(&priv->ps_var ## _ref[id]); \
669     av_assert0(unit->content_ref); \
670     priv->ps_var ## _ref[id] = av_buffer_ref(unit->content_ref); \
671     if (!priv->ps_var ## _ref[id]) \
672         return AVERROR(ENOMEM); \
673     priv->ps_var[id] = (H26 ## h26n ## Raw ## ps_name *)priv->ps_var ## _ref[id]->data; \
674     if (!unit->content_ref) \
675         memcpy(priv->ps_var[id], ps_var, sizeof(*ps_var)); \
676     return 0; \
677 }
678 
679 cbs_h2645_replace_ps(4, SPS, sps, seq_parameter_set_id)
680 cbs_h2645_replace_ps(4, PPS, pps, pic_parameter_set_id)
681 cbs_h2645_replace_ps(5, VPS, vps, vps_video_parameter_set_id)
682 cbs_h2645_replace_ps(5, SPS, sps, sps_seq_parameter_set_id)
683 cbs_h2645_replace_ps(5, PPS, pps, pps_pic_parameter_set_id)
684 
cbs_h264_read_nal_unit(CodedBitstreamContext * ctx,CodedBitstreamUnit * unit)685 static int cbs_h264_read_nal_unit(CodedBitstreamContext *ctx,
686                                   CodedBitstreamUnit *unit)
687 {
688     GetBitContext gbc;
689     int err;
690 
691     err = init_get_bits(&gbc, unit->data, 8 * unit->data_size);
692     if (err < 0)
693         return err;
694 
695     err = ff_cbs_alloc_unit_content2(ctx, unit);
696     if (err < 0)
697         return err;
698 
699     switch (unit->type) {
700     case H264_NAL_SPS:
701         {
702             H264RawSPS *sps = unit->content;
703 
704             err = cbs_h264_read_sps(ctx, &gbc, sps);
705             if (err < 0)
706                 return err;
707 
708             err = cbs_h264_replace_sps(ctx, unit);
709             if (err < 0)
710                 return err;
711         }
712         break;
713 
714     case H264_NAL_SPS_EXT:
715         {
716             err = cbs_h264_read_sps_extension(ctx, &gbc, unit->content);
717             if (err < 0)
718                 return err;
719         }
720         break;
721 
722     case H264_NAL_PPS:
723         {
724             H264RawPPS *pps = unit->content;
725 
726             err = cbs_h264_read_pps(ctx, &gbc, pps);
727             if (err < 0)
728                 return err;
729 
730             err = cbs_h264_replace_pps(ctx, unit);
731             if (err < 0)
732                 return err;
733         }
734         break;
735 
736     case H264_NAL_SLICE:
737     case H264_NAL_IDR_SLICE:
738     case H264_NAL_AUXILIARY_SLICE:
739         {
740             H264RawSlice *slice = unit->content;
741             int pos, len;
742 
743             err = cbs_h264_read_slice_header(ctx, &gbc, &slice->header);
744             if (err < 0)
745                 return err;
746 
747             if (!cbs_h2645_read_more_rbsp_data(&gbc))
748                 return AVERROR_INVALIDDATA;
749 
750             pos = get_bits_count(&gbc);
751             len = unit->data_size;
752 
753             slice->data_size = len - pos / 8;
754             slice->data_ref  = av_buffer_ref(unit->data_ref);
755             if (!slice->data_ref)
756                 return AVERROR(ENOMEM);
757             slice->data = unit->data + pos / 8;
758             slice->data_bit_start = pos % 8;
759         }
760         break;
761 
762     case H264_NAL_AUD:
763         {
764             err = cbs_h264_read_aud(ctx, &gbc, unit->content);
765             if (err < 0)
766                 return err;
767         }
768         break;
769 
770     case H264_NAL_SEI:
771         {
772             err = cbs_h264_read_sei(ctx, &gbc, unit->content);
773             if (err < 0)
774                 return err;
775         }
776         break;
777 
778     case H264_NAL_FILLER_DATA:
779         {
780             err = cbs_h264_read_filler(ctx, &gbc, unit->content);
781             if (err < 0)
782                 return err;
783         }
784         break;
785 
786     case H264_NAL_END_SEQUENCE:
787     case H264_NAL_END_STREAM:
788         {
789             err = (unit->type == H264_NAL_END_SEQUENCE ?
790                    cbs_h264_read_end_of_sequence :
791                    cbs_h264_read_end_of_stream)(ctx, &gbc, unit->content);
792             if (err < 0)
793                 return err;
794         }
795         break;
796 
797     default:
798         return AVERROR(ENOSYS);
799     }
800 
801     return 0;
802 }
803 
cbs_h265_read_nal_unit(CodedBitstreamContext * ctx,CodedBitstreamUnit * unit)804 static int cbs_h265_read_nal_unit(CodedBitstreamContext *ctx,
805                                   CodedBitstreamUnit *unit)
806 {
807     GetBitContext gbc;
808     int err;
809 
810     err = init_get_bits(&gbc, unit->data, 8 * unit->data_size);
811     if (err < 0)
812         return err;
813 
814     err = ff_cbs_alloc_unit_content2(ctx, unit);
815     if (err < 0)
816         return err;
817 
818     switch (unit->type) {
819     case HEVC_NAL_VPS:
820         {
821             H265RawVPS *vps = unit->content;
822 
823             err = cbs_h265_read_vps(ctx, &gbc, vps);
824             if (err < 0)
825                 return err;
826 
827             err = cbs_h265_replace_vps(ctx, unit);
828             if (err < 0)
829                 return err;
830         }
831         break;
832     case HEVC_NAL_SPS:
833         {
834             H265RawSPS *sps = unit->content;
835 
836             err = cbs_h265_read_sps(ctx, &gbc, sps);
837             if (err < 0)
838                 return err;
839 
840             err = cbs_h265_replace_sps(ctx, unit);
841             if (err < 0)
842                 return err;
843         }
844         break;
845 
846     case HEVC_NAL_PPS:
847         {
848             H265RawPPS *pps = unit->content;
849 
850             err = cbs_h265_read_pps(ctx, &gbc, pps);
851             if (err < 0)
852                 return err;
853 
854             err = cbs_h265_replace_pps(ctx, unit);
855             if (err < 0)
856                 return err;
857         }
858         break;
859 
860     case HEVC_NAL_TRAIL_N:
861     case HEVC_NAL_TRAIL_R:
862     case HEVC_NAL_TSA_N:
863     case HEVC_NAL_TSA_R:
864     case HEVC_NAL_STSA_N:
865     case HEVC_NAL_STSA_R:
866     case HEVC_NAL_RADL_N:
867     case HEVC_NAL_RADL_R:
868     case HEVC_NAL_RASL_N:
869     case HEVC_NAL_RASL_R:
870     case HEVC_NAL_BLA_W_LP:
871     case HEVC_NAL_BLA_W_RADL:
872     case HEVC_NAL_BLA_N_LP:
873     case HEVC_NAL_IDR_W_RADL:
874     case HEVC_NAL_IDR_N_LP:
875     case HEVC_NAL_CRA_NUT:
876         {
877             H265RawSlice *slice = unit->content;
878             int pos, len;
879 
880             err = cbs_h265_read_slice_segment_header(ctx, &gbc, &slice->header);
881             if (err < 0)
882                 return err;
883 
884             if (!cbs_h2645_read_more_rbsp_data(&gbc))
885                 return AVERROR_INVALIDDATA;
886 
887             pos = get_bits_count(&gbc);
888             len = unit->data_size;
889 
890             slice->data_size = len - pos / 8;
891             slice->data_ref  = av_buffer_ref(unit->data_ref);
892             if (!slice->data_ref)
893                 return AVERROR(ENOMEM);
894             slice->data = unit->data + pos / 8;
895             slice->data_bit_start = pos % 8;
896         }
897         break;
898 
899     case HEVC_NAL_AUD:
900         {
901             err = cbs_h265_read_aud(ctx, &gbc, unit->content);
902             if (err < 0)
903                 return err;
904         }
905         break;
906 
907     case HEVC_NAL_SEI_PREFIX:
908     case HEVC_NAL_SEI_SUFFIX:
909         {
910             err = cbs_h265_read_sei(ctx, &gbc, unit->content,
911                                     unit->type == HEVC_NAL_SEI_PREFIX);
912 
913             if (err < 0)
914                 return err;
915         }
916         break;
917 
918     default:
919         return AVERROR(ENOSYS);
920     }
921 
922     return 0;
923 }
924 
cbs_h2645_write_slice_data(CodedBitstreamContext * ctx,PutBitContext * pbc,const uint8_t * data,size_t data_size,int data_bit_start)925 static int cbs_h2645_write_slice_data(CodedBitstreamContext *ctx,
926                                       PutBitContext *pbc, const uint8_t *data,
927                                       size_t data_size, int data_bit_start)
928 {
929     size_t rest  = data_size - (data_bit_start + 7) / 8;
930     const uint8_t *pos = data + data_bit_start / 8;
931 
932     av_assert0(data_bit_start >= 0 &&
933                data_size > data_bit_start / 8);
934 
935     if (data_size * 8 + 8 > put_bits_left(pbc))
936         return AVERROR(ENOSPC);
937 
938     if (!rest)
939         goto rbsp_stop_one_bit;
940 
941     // First copy the remaining bits of the first byte
942     // The above check ensures that we do not accidentally
943     // copy beyond the rbsp_stop_one_bit.
944     if (data_bit_start % 8)
945         put_bits(pbc, 8 - data_bit_start % 8,
946                  *pos++ & MAX_UINT_BITS(8 - data_bit_start % 8));
947 
948     if (put_bits_count(pbc) % 8 == 0) {
949         // If the writer is aligned at this point,
950         // memcpy can be used to improve performance.
951         // This happens normally for CABAC.
952         flush_put_bits(pbc);
953         memcpy(put_bits_ptr(pbc), pos, rest);
954         skip_put_bytes(pbc, rest);
955     } else {
956         // If not, we have to copy manually.
957         // rbsp_stop_one_bit forces us to special-case
958         // the last byte.
959         uint8_t temp;
960         int i;
961 
962         for (; rest > 4; rest -= 4, pos += 4)
963             put_bits32(pbc, AV_RB32(pos));
964 
965         for (; rest > 1; rest--, pos++)
966             put_bits(pbc, 8, *pos);
967 
968     rbsp_stop_one_bit:
969         temp = rest ? *pos : *pos & MAX_UINT_BITS(8 - data_bit_start % 8);
970 
971         av_assert0(temp);
972         i = ff_ctz(*pos);
973         temp = temp >> i;
974         i = rest ? (8 - i) : (8 - i - data_bit_start % 8);
975         put_bits(pbc, i, temp);
976         if (put_bits_count(pbc) % 8)
977             put_bits(pbc, 8 - put_bits_count(pbc) % 8, 0);
978     }
979 
980     return 0;
981 }
982 
cbs_h264_write_nal_unit(CodedBitstreamContext * ctx,CodedBitstreamUnit * unit,PutBitContext * pbc)983 static int cbs_h264_write_nal_unit(CodedBitstreamContext *ctx,
984                                    CodedBitstreamUnit *unit,
985                                    PutBitContext *pbc)
986 {
987     int err;
988 
989     switch (unit->type) {
990     case H264_NAL_SPS:
991         {
992             H264RawSPS *sps = unit->content;
993 
994             err = cbs_h264_write_sps(ctx, pbc, sps);
995             if (err < 0)
996                 return err;
997 
998             err = cbs_h264_replace_sps(ctx, unit);
999             if (err < 0)
1000                 return err;
1001         }
1002         break;
1003 
1004     case H264_NAL_SPS_EXT:
1005         {
1006             H264RawSPSExtension *sps_ext = unit->content;
1007 
1008             err = cbs_h264_write_sps_extension(ctx, pbc, sps_ext);
1009             if (err < 0)
1010                 return err;
1011         }
1012         break;
1013 
1014     case H264_NAL_PPS:
1015         {
1016             H264RawPPS *pps = unit->content;
1017 
1018             err = cbs_h264_write_pps(ctx, pbc, pps);
1019             if (err < 0)
1020                 return err;
1021 
1022             err = cbs_h264_replace_pps(ctx, unit);
1023             if (err < 0)
1024                 return err;
1025         }
1026         break;
1027 
1028     case H264_NAL_SLICE:
1029     case H264_NAL_IDR_SLICE:
1030     case H264_NAL_AUXILIARY_SLICE:
1031         {
1032             H264RawSlice *slice = unit->content;
1033 
1034             err = cbs_h264_write_slice_header(ctx, pbc, &slice->header);
1035             if (err < 0)
1036                 return err;
1037 
1038             if (slice->data) {
1039                 err = cbs_h2645_write_slice_data(ctx, pbc, slice->data,
1040                                                  slice->data_size,
1041                                                  slice->data_bit_start);
1042                 if (err < 0)
1043                     return err;
1044             } else {
1045                 // No slice data - that was just the header.
1046                 // (Bitstream may be unaligned!)
1047             }
1048         }
1049         break;
1050 
1051     case H264_NAL_AUD:
1052         {
1053             err = cbs_h264_write_aud(ctx, pbc, unit->content);
1054             if (err < 0)
1055                 return err;
1056         }
1057         break;
1058 
1059     case H264_NAL_SEI:
1060         {
1061             err = cbs_h264_write_sei(ctx, pbc, unit->content);
1062             if (err < 0)
1063                 return err;
1064         }
1065         break;
1066 
1067     case H264_NAL_FILLER_DATA:
1068         {
1069             err = cbs_h264_write_filler(ctx, pbc, unit->content);
1070             if (err < 0)
1071                 return err;
1072         }
1073         break;
1074 
1075     case H264_NAL_END_SEQUENCE:
1076         {
1077             err = cbs_h264_write_end_of_sequence(ctx, pbc, unit->content);
1078             if (err < 0)
1079                 return err;
1080         }
1081         break;
1082 
1083     case H264_NAL_END_STREAM:
1084         {
1085             err = cbs_h264_write_end_of_stream(ctx, pbc, unit->content);
1086             if (err < 0)
1087                 return err;
1088         }
1089         break;
1090 
1091     default:
1092         av_log(ctx->log_ctx, AV_LOG_ERROR, "Write unimplemented for "
1093                "NAL unit type %"PRIu32".\n", unit->type);
1094         return AVERROR_PATCHWELCOME;
1095     }
1096 
1097     return 0;
1098 }
1099 
cbs_h265_write_nal_unit(CodedBitstreamContext * ctx,CodedBitstreamUnit * unit,PutBitContext * pbc)1100 static int cbs_h265_write_nal_unit(CodedBitstreamContext *ctx,
1101                                    CodedBitstreamUnit *unit,
1102                                    PutBitContext *pbc)
1103 {
1104     int err;
1105 
1106     switch (unit->type) {
1107     case HEVC_NAL_VPS:
1108         {
1109             H265RawVPS *vps = unit->content;
1110 
1111             err = cbs_h265_write_vps(ctx, pbc, vps);
1112             if (err < 0)
1113                 return err;
1114 
1115             err = cbs_h265_replace_vps(ctx, unit);
1116             if (err < 0)
1117                 return err;
1118         }
1119         break;
1120 
1121     case HEVC_NAL_SPS:
1122         {
1123             H265RawSPS *sps = unit->content;
1124 
1125             err = cbs_h265_write_sps(ctx, pbc, sps);
1126             if (err < 0)
1127                 return err;
1128 
1129             err = cbs_h265_replace_sps(ctx, unit);
1130             if (err < 0)
1131                 return err;
1132         }
1133         break;
1134 
1135     case HEVC_NAL_PPS:
1136         {
1137             H265RawPPS *pps = unit->content;
1138 
1139             err = cbs_h265_write_pps(ctx, pbc, pps);
1140             if (err < 0)
1141                 return err;
1142 
1143             err = cbs_h265_replace_pps(ctx, unit);
1144             if (err < 0)
1145                 return err;
1146         }
1147         break;
1148 
1149     case HEVC_NAL_TRAIL_N:
1150     case HEVC_NAL_TRAIL_R:
1151     case HEVC_NAL_TSA_N:
1152     case HEVC_NAL_TSA_R:
1153     case HEVC_NAL_STSA_N:
1154     case HEVC_NAL_STSA_R:
1155     case HEVC_NAL_RADL_N:
1156     case HEVC_NAL_RADL_R:
1157     case HEVC_NAL_RASL_N:
1158     case HEVC_NAL_RASL_R:
1159     case HEVC_NAL_BLA_W_LP:
1160     case HEVC_NAL_BLA_W_RADL:
1161     case HEVC_NAL_BLA_N_LP:
1162     case HEVC_NAL_IDR_W_RADL:
1163     case HEVC_NAL_IDR_N_LP:
1164     case HEVC_NAL_CRA_NUT:
1165         {
1166             H265RawSlice *slice = unit->content;
1167 
1168             err = cbs_h265_write_slice_segment_header(ctx, pbc, &slice->header);
1169             if (err < 0)
1170                 return err;
1171 
1172             if (slice->data) {
1173                 err = cbs_h2645_write_slice_data(ctx, pbc, slice->data,
1174                                                  slice->data_size,
1175                                                  slice->data_bit_start);
1176                 if (err < 0)
1177                     return err;
1178             } else {
1179                 // No slice data - that was just the header.
1180             }
1181         }
1182         break;
1183 
1184     case HEVC_NAL_AUD:
1185         {
1186             err = cbs_h265_write_aud(ctx, pbc, unit->content);
1187             if (err < 0)
1188                 return err;
1189         }
1190         break;
1191 
1192     case HEVC_NAL_SEI_PREFIX:
1193     case HEVC_NAL_SEI_SUFFIX:
1194         {
1195             err = cbs_h265_write_sei(ctx, pbc, unit->content,
1196                                      unit->type == HEVC_NAL_SEI_PREFIX);
1197 
1198             if (err < 0)
1199                 return err;
1200         }
1201         break;
1202 
1203     default:
1204         av_log(ctx->log_ctx, AV_LOG_ERROR, "Write unimplemented for "
1205                "NAL unit type %"PRIu32".\n", unit->type);
1206         return AVERROR_PATCHWELCOME;
1207     }
1208 
1209     return 0;
1210 }
1211 
cbs_h2645_assemble_fragment(CodedBitstreamContext * ctx,CodedBitstreamFragment * frag)1212 static int cbs_h2645_assemble_fragment(CodedBitstreamContext *ctx,
1213                                        CodedBitstreamFragment *frag)
1214 {
1215     uint8_t *data;
1216     size_t max_size, dp, sp;
1217     int err, i, zero_run;
1218 
1219     for (i = 0; i < frag->nb_units; i++) {
1220         // Data should already all have been written when we get here.
1221         av_assert0(frag->units[i].data);
1222     }
1223 
1224     max_size = 0;
1225     for (i = 0; i < frag->nb_units; i++) {
1226         // Start code + content with worst-case emulation prevention.
1227         max_size += 4 + frag->units[i].data_size * 3 / 2;
1228     }
1229 
1230     data = av_realloc(NULL, max_size + AV_INPUT_BUFFER_PADDING_SIZE);
1231     if (!data)
1232         return AVERROR(ENOMEM);
1233 
1234     dp = 0;
1235     for (i = 0; i < frag->nb_units; i++) {
1236         CodedBitstreamUnit *unit = &frag->units[i];
1237 
1238         if (unit->data_bit_padding > 0) {
1239             if (i < frag->nb_units - 1)
1240                 av_log(ctx->log_ctx, AV_LOG_WARNING, "Probably invalid "
1241                        "unaligned padding on non-final NAL unit.\n");
1242             else
1243                 frag->data_bit_padding = unit->data_bit_padding;
1244         }
1245 
1246         if ((ctx->codec->codec_id == AV_CODEC_ID_H264 &&
1247              (unit->type == H264_NAL_SPS ||
1248               unit->type == H264_NAL_PPS)) ||
1249             (ctx->codec->codec_id == AV_CODEC_ID_HEVC &&
1250              (unit->type == HEVC_NAL_VPS ||
1251               unit->type == HEVC_NAL_SPS ||
1252               unit->type == HEVC_NAL_PPS)) ||
1253             i == 0 /* (Assume this is the start of an access unit.) */) {
1254             // zero_byte
1255             data[dp++] = 0;
1256         }
1257         // start_code_prefix_one_3bytes
1258         data[dp++] = 0;
1259         data[dp++] = 0;
1260         data[dp++] = 1;
1261 
1262         zero_run = 0;
1263         for (sp = 0; sp < unit->data_size; sp++) {
1264             if (zero_run < 2) {
1265                 if (unit->data[sp] == 0)
1266                     ++zero_run;
1267                 else
1268                     zero_run = 0;
1269             } else {
1270                 if ((unit->data[sp] & ~3) == 0) {
1271                     // emulation_prevention_three_byte
1272                     data[dp++] = 3;
1273                 }
1274                 zero_run = unit->data[sp] == 0;
1275             }
1276             data[dp++] = unit->data[sp];
1277         }
1278     }
1279 
1280     av_assert0(dp <= max_size);
1281     err = av_reallocp(&data, dp + AV_INPUT_BUFFER_PADDING_SIZE);
1282     if (err)
1283         return err;
1284     memset(data + dp, 0, AV_INPUT_BUFFER_PADDING_SIZE);
1285 
1286     frag->data_ref = av_buffer_create(data, dp + AV_INPUT_BUFFER_PADDING_SIZE,
1287                                       NULL, NULL, 0);
1288     if (!frag->data_ref) {
1289         av_freep(&data);
1290         return AVERROR(ENOMEM);
1291     }
1292 
1293     frag->data = data;
1294     frag->data_size = dp;
1295 
1296     return 0;
1297 }
1298 
cbs_h264_flush(CodedBitstreamContext * ctx)1299 static void cbs_h264_flush(CodedBitstreamContext *ctx)
1300 {
1301     CodedBitstreamH264Context *h264 = ctx->priv_data;
1302 
1303     for (int i = 0; i < FF_ARRAY_ELEMS(h264->sps); i++) {
1304         av_buffer_unref(&h264->sps_ref[i]);
1305         h264->sps[i] = NULL;
1306     }
1307     for (int i = 0; i < FF_ARRAY_ELEMS(h264->pps); i++) {
1308         av_buffer_unref(&h264->pps_ref[i]);
1309         h264->pps[i] = NULL;
1310     }
1311 
1312     h264->active_sps = NULL;
1313     h264->active_pps = NULL;
1314     h264->last_slice_nal_unit_type = 0;
1315 }
1316 
cbs_h264_close(CodedBitstreamContext * ctx)1317 static void cbs_h264_close(CodedBitstreamContext *ctx)
1318 {
1319     CodedBitstreamH264Context *h264 = ctx->priv_data;
1320     int i;
1321 
1322     ff_h2645_packet_uninit(&h264->common.read_packet);
1323 
1324     for (i = 0; i < FF_ARRAY_ELEMS(h264->sps); i++)
1325         av_buffer_unref(&h264->sps_ref[i]);
1326     for (i = 0; i < FF_ARRAY_ELEMS(h264->pps); i++)
1327         av_buffer_unref(&h264->pps_ref[i]);
1328 }
1329 
cbs_h265_flush(CodedBitstreamContext * ctx)1330 static void cbs_h265_flush(CodedBitstreamContext *ctx)
1331 {
1332     CodedBitstreamH265Context *h265 = ctx->priv_data;
1333 
1334     for (int i = 0; i < FF_ARRAY_ELEMS(h265->vps); i++) {
1335         av_buffer_unref(&h265->vps_ref[i]);
1336         h265->vps[i] = NULL;
1337     }
1338     for (int i = 0; i < FF_ARRAY_ELEMS(h265->sps); i++) {
1339         av_buffer_unref(&h265->sps_ref[i]);
1340         h265->sps[i] = NULL;
1341     }
1342     for (int i = 0; i < FF_ARRAY_ELEMS(h265->pps); i++) {
1343         av_buffer_unref(&h265->pps_ref[i]);
1344         h265->pps[i] = NULL;
1345     }
1346 
1347     h265->active_vps = NULL;
1348     h265->active_sps = NULL;
1349     h265->active_pps = NULL;
1350 }
1351 
cbs_h265_close(CodedBitstreamContext * ctx)1352 static void cbs_h265_close(CodedBitstreamContext *ctx)
1353 {
1354     CodedBitstreamH265Context *h265 = ctx->priv_data;
1355     int i;
1356 
1357     ff_h2645_packet_uninit(&h265->common.read_packet);
1358 
1359     for (i = 0; i < FF_ARRAY_ELEMS(h265->vps); i++)
1360         av_buffer_unref(&h265->vps_ref[i]);
1361     for (i = 0; i < FF_ARRAY_ELEMS(h265->sps); i++)
1362         av_buffer_unref(&h265->sps_ref[i]);
1363     for (i = 0; i < FF_ARRAY_ELEMS(h265->pps); i++)
1364         av_buffer_unref(&h265->pps_ref[i]);
1365 }
1366 
cbs_h264_free_sei_payload(H264RawSEIPayload * payload)1367 static void cbs_h264_free_sei_payload(H264RawSEIPayload *payload)
1368 {
1369     switch (payload->payload_type) {
1370     case H264_SEI_TYPE_BUFFERING_PERIOD:
1371     case H264_SEI_TYPE_PIC_TIMING:
1372     case H264_SEI_TYPE_PAN_SCAN_RECT:
1373     case H264_SEI_TYPE_RECOVERY_POINT:
1374     case H264_SEI_TYPE_DISPLAY_ORIENTATION:
1375     case H264_SEI_TYPE_MASTERING_DISPLAY_COLOUR_VOLUME:
1376     case H264_SEI_TYPE_ALTERNATIVE_TRANSFER:
1377         break;
1378     case H264_SEI_TYPE_USER_DATA_REGISTERED:
1379         av_buffer_unref(&payload->payload.user_data_registered.data_ref);
1380         break;
1381     case H264_SEI_TYPE_USER_DATA_UNREGISTERED:
1382         av_buffer_unref(&payload->payload.user_data_unregistered.data_ref);
1383         break;
1384     default:
1385         av_buffer_unref(&payload->payload.other.data_ref);
1386         break;
1387     }
1388 }
1389 
cbs_h264_free_sei(void * opaque,uint8_t * content)1390 static void cbs_h264_free_sei(void *opaque, uint8_t *content)
1391 {
1392     H264RawSEI *sei = (H264RawSEI*)content;
1393     int i;
1394     for (i = 0; i < sei->payload_count; i++)
1395         cbs_h264_free_sei_payload(&sei->payload[i]);
1396     av_freep(&content);
1397 }
1398 
1399 static const CodedBitstreamUnitTypeDescriptor cbs_h264_unit_types[] = {
1400     CBS_UNIT_TYPE_POD(H264_NAL_SPS,     H264RawSPS),
1401     CBS_UNIT_TYPE_POD(H264_NAL_SPS_EXT, H264RawSPSExtension),
1402 
1403     CBS_UNIT_TYPE_INTERNAL_REF(H264_NAL_PPS, H264RawPPS, slice_group_id),
1404 
1405     {
1406         .nb_unit_types  = 3,
1407         .unit_types     = {
1408             H264_NAL_IDR_SLICE,
1409             H264_NAL_SLICE,
1410             H264_NAL_AUXILIARY_SLICE,
1411         },
1412         .content_type   = CBS_CONTENT_TYPE_INTERNAL_REFS,
1413         .content_size   = sizeof(H264RawSlice),
1414         .nb_ref_offsets = 1,
1415         .ref_offsets    = { offsetof(H264RawSlice, data) },
1416     },
1417 
1418     CBS_UNIT_TYPE_POD(H264_NAL_AUD,          H264RawAUD),
1419     CBS_UNIT_TYPE_POD(H264_NAL_FILLER_DATA,  H264RawFiller),
1420     CBS_UNIT_TYPE_POD(H264_NAL_END_SEQUENCE, H264RawNALUnitHeader),
1421     CBS_UNIT_TYPE_POD(H264_NAL_END_STREAM,   H264RawNALUnitHeader),
1422 
1423     CBS_UNIT_TYPE_COMPLEX(H264_NAL_SEI, H264RawSEI, &cbs_h264_free_sei),
1424 
1425     CBS_UNIT_TYPE_END_OF_LIST
1426 };
1427 
cbs_h265_free_sei_payload(H265RawSEIPayload * payload)1428 static void cbs_h265_free_sei_payload(H265RawSEIPayload *payload)
1429 {
1430     switch (payload->payload_type) {
1431     case HEVC_SEI_TYPE_BUFFERING_PERIOD:
1432     case HEVC_SEI_TYPE_PICTURE_TIMING:
1433     case HEVC_SEI_TYPE_PAN_SCAN_RECT:
1434     case HEVC_SEI_TYPE_RECOVERY_POINT:
1435     case HEVC_SEI_TYPE_DISPLAY_ORIENTATION:
1436     case HEVC_SEI_TYPE_ACTIVE_PARAMETER_SETS:
1437     case HEVC_SEI_TYPE_DECODED_PICTURE_HASH:
1438     case HEVC_SEI_TYPE_TIME_CODE:
1439     case HEVC_SEI_TYPE_MASTERING_DISPLAY_INFO:
1440     case HEVC_SEI_TYPE_CONTENT_LIGHT_LEVEL_INFO:
1441     case HEVC_SEI_TYPE_ALTERNATIVE_TRANSFER_CHARACTERISTICS:
1442     case HEVC_SEI_TYPE_ALPHA_CHANNEL_INFO:
1443         break;
1444     case HEVC_SEI_TYPE_USER_DATA_REGISTERED_ITU_T_T35:
1445         av_buffer_unref(&payload->payload.user_data_registered.data_ref);
1446         break;
1447     case HEVC_SEI_TYPE_USER_DATA_UNREGISTERED:
1448         av_buffer_unref(&payload->payload.user_data_unregistered.data_ref);
1449         break;
1450     default:
1451         av_buffer_unref(&payload->payload.other.data_ref);
1452         break;
1453     }
1454     av_buffer_unref(&payload->extension_data.data_ref);
1455 }
1456 
cbs_h265_free_sei(void * opaque,uint8_t * content)1457 static void cbs_h265_free_sei(void *opaque, uint8_t *content)
1458 {
1459     H265RawSEI *sei = (H265RawSEI*)content;
1460     int i;
1461     for (i = 0; i < sei->payload_count; i++)
1462         cbs_h265_free_sei_payload(&sei->payload[i]);
1463     av_freep(&content);
1464 }
1465 
1466 static const CodedBitstreamUnitTypeDescriptor cbs_h265_unit_types[] = {
1467     CBS_UNIT_TYPE_INTERNAL_REF(HEVC_NAL_VPS, H265RawVPS, extension_data.data),
1468     CBS_UNIT_TYPE_INTERNAL_REF(HEVC_NAL_SPS, H265RawSPS, extension_data.data),
1469     CBS_UNIT_TYPE_INTERNAL_REF(HEVC_NAL_PPS, H265RawPPS, extension_data.data),
1470 
1471     CBS_UNIT_TYPE_POD(HEVC_NAL_AUD, H265RawAUD),
1472 
1473     {
1474         // Slices of non-IRAP pictures.
1475         .nb_unit_types         = CBS_UNIT_TYPE_RANGE,
1476         .unit_type_range_start = HEVC_NAL_TRAIL_N,
1477         .unit_type_range_end   = HEVC_NAL_RASL_R,
1478 
1479         .content_type   = CBS_CONTENT_TYPE_INTERNAL_REFS,
1480         .content_size   = sizeof(H265RawSlice),
1481         .nb_ref_offsets = 1,
1482         .ref_offsets    = { offsetof(H265RawSlice, data) },
1483     },
1484 
1485     {
1486         // Slices of IRAP pictures.
1487         .nb_unit_types         = CBS_UNIT_TYPE_RANGE,
1488         .unit_type_range_start = HEVC_NAL_BLA_W_LP,
1489         .unit_type_range_end   = HEVC_NAL_CRA_NUT,
1490 
1491         .content_type   = CBS_CONTENT_TYPE_INTERNAL_REFS,
1492         .content_size   = sizeof(H265RawSlice),
1493         .nb_ref_offsets = 1,
1494         .ref_offsets    = { offsetof(H265RawSlice, data) },
1495     },
1496 
1497     {
1498         .nb_unit_types  = 2,
1499         .unit_types     = {
1500             HEVC_NAL_SEI_PREFIX,
1501             HEVC_NAL_SEI_SUFFIX
1502         },
1503         .content_type   = CBS_CONTENT_TYPE_COMPLEX,
1504         .content_size   = sizeof(H265RawSEI),
1505         .content_free   = &cbs_h265_free_sei,
1506     },
1507 
1508     CBS_UNIT_TYPE_END_OF_LIST
1509 };
1510 
1511 const CodedBitstreamType ff_cbs_type_h264 = {
1512     .codec_id          = AV_CODEC_ID_H264,
1513 
1514     .priv_data_size    = sizeof(CodedBitstreamH264Context),
1515 
1516     .unit_types        = cbs_h264_unit_types,
1517 
1518     .split_fragment    = &cbs_h2645_split_fragment,
1519     .read_unit         = &cbs_h264_read_nal_unit,
1520     .write_unit        = &cbs_h264_write_nal_unit,
1521     .assemble_fragment = &cbs_h2645_assemble_fragment,
1522 
1523     .flush             = &cbs_h264_flush,
1524     .close             = &cbs_h264_close,
1525 };
1526 
1527 const CodedBitstreamType ff_cbs_type_h265 = {
1528     .codec_id          = AV_CODEC_ID_HEVC,
1529 
1530     .priv_data_size    = sizeof(CodedBitstreamH265Context),
1531 
1532     .unit_types        = cbs_h265_unit_types,
1533 
1534     .split_fragment    = &cbs_h2645_split_fragment,
1535     .read_unit         = &cbs_h265_read_nal_unit,
1536     .write_unit        = &cbs_h265_write_nal_unit,
1537     .assemble_fragment = &cbs_h2645_assemble_fragment,
1538 
1539     .flush             = &cbs_h265_flush,
1540     .close             = &cbs_h265_close,
1541 };
1542 
ff_cbs_h264_add_sei_message(CodedBitstreamFragment * au,H264RawSEIPayload * payload)1543 int ff_cbs_h264_add_sei_message(CodedBitstreamFragment *au,
1544                                 H264RawSEIPayload *payload)
1545 {
1546     H264RawSEI *sei = NULL;
1547     int err, i;
1548 
1549     // Find an existing SEI NAL unit to add to.
1550     for (i = 0; i < au->nb_units; i++) {
1551         if (au->units[i].type == H264_NAL_SEI) {
1552             sei = au->units[i].content;
1553             if (sei->payload_count < H264_MAX_SEI_PAYLOADS)
1554                 break;
1555 
1556             sei = NULL;
1557         }
1558     }
1559 
1560     if (!sei) {
1561         // Need to make a new SEI NAL unit.  Insert it before the first
1562         // slice data NAL unit; if no slice data, add at the end.
1563         AVBufferRef *sei_ref;
1564 
1565         sei = av_mallocz(sizeof(*sei));
1566         if (!sei) {
1567             err = AVERROR(ENOMEM);
1568             goto fail;
1569         }
1570 
1571         sei->nal_unit_header.nal_unit_type = H264_NAL_SEI;
1572         sei->nal_unit_header.nal_ref_idc   = 0;
1573 
1574         sei_ref = av_buffer_create((uint8_t*)sei, sizeof(*sei),
1575                                    &cbs_h264_free_sei, NULL, 0);
1576         if (!sei_ref) {
1577             av_freep(&sei);
1578             err = AVERROR(ENOMEM);
1579             goto fail;
1580         }
1581 
1582         for (i = 0; i < au->nb_units; i++) {
1583             if (au->units[i].type == H264_NAL_SLICE ||
1584                 au->units[i].type == H264_NAL_IDR_SLICE)
1585                 break;
1586         }
1587 
1588         err = ff_cbs_insert_unit_content(au, i, H264_NAL_SEI,
1589                                          sei, sei_ref);
1590         av_buffer_unref(&sei_ref);
1591         if (err < 0)
1592             goto fail;
1593     }
1594 
1595     memcpy(&sei->payload[sei->payload_count], payload, sizeof(*payload));
1596     ++sei->payload_count;
1597 
1598     return 0;
1599 fail:
1600     cbs_h264_free_sei_payload(payload);
1601     return err;
1602 }
1603 
ff_cbs_h264_delete_sei_message(CodedBitstreamFragment * au,CodedBitstreamUnit * nal,int position)1604 void ff_cbs_h264_delete_sei_message(CodedBitstreamFragment *au,
1605                                     CodedBitstreamUnit *nal,
1606                                     int position)
1607 {
1608     H264RawSEI *sei = nal->content;
1609 
1610     av_assert0(nal->type == H264_NAL_SEI);
1611     av_assert0(position >= 0 && position < sei->payload_count);
1612 
1613     if (position == 0 && sei->payload_count == 1) {
1614         // Deleting NAL unit entirely.
1615         int i;
1616 
1617         for (i = 0; i < au->nb_units; i++) {
1618             if (&au->units[i] == nal)
1619                 break;
1620         }
1621 
1622         ff_cbs_delete_unit(au, i);
1623     } else {
1624         cbs_h264_free_sei_payload(&sei->payload[position]);
1625 
1626         --sei->payload_count;
1627         memmove(sei->payload + position,
1628                 sei->payload + position + 1,
1629                 (sei->payload_count - position) * sizeof(*sei->payload));
1630     }
1631 }
1632