FFmpeg coverage

Directory: ../../../ffmpeg/
File: src/libavutil/buffer.c
Date: 2026-05-01 22:15:40
Exec Total Coverage
Lines: 206 224 92.0%
Functions: 23 23 100.0%
Branches: 76 98 77.6%
Line Branch Exec Source
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 <stdatomic.h>
20 #include <stdint.h>
21 #include <string.h>
22
23 #include "avassert.h"
24 #include "buffer_internal.h"
25 #include "common.h"
26 #include "mem.h"
27 #include "thread.h"
28
29 5004161 static AVBufferRef *buffer_create(AVBuffer *buf, uint8_t *data, size_t size,
30 void (*free)(void *opaque, uint8_t *data),
31 void *opaque, int flags)
32 {
33 5004161 AVBufferRef *ref = NULL;
34
35 5004161 buf->data = data;
36 5004161 buf->size = size;
37
2/2
✓ Branch 0 taken 4994663 times.
✓ Branch 1 taken 9498 times.
 5004161 buf->free = free ? free : av_buffer_default_free;
38 5004161 buf->opaque = opaque;
39
40 5004161 atomic_init(&buf->refcount, 1);
41
42 5004161 buf->flags = flags;
43
44 5004161 ref = av_mallocz(sizeof(*ref));
45
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5004161 times.
 5004161 if (!ref)
46 ✗ return NULL;
47
48 5004161 ref->buffer = buf;
49 5004161 ref->data = data;
50 5004161 ref->size = size;
51
52 5004161 return ref;
53 }
54
55 3665052 AVBufferRef *av_buffer_create(uint8_t *data, size_t size,
56 void (*free)(void *opaque, uint8_t *data),
57 void *opaque, int flags)
58 {
59 AVBufferRef *ret;
60 3665052 AVBuffer *buf = av_mallocz(sizeof(*buf));
61
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3665052 times.
 3665052 if (!buf)
62 ✗ return NULL;
63
64 3665052 ret = buffer_create(buf, data, size, free, opaque, flags);
65
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3665052 times.
 3665052 if (!ret) {
66 ✗ av_free(buf);
67 ✗ return NULL;
68 }
69 3665052 return ret;
70 }
71
72 2035128 void av_buffer_default_free(void *opaque, uint8_t *data)
73 {
74 2035128 av_free(data);
75 2035128 }
76
77 527859 AVBufferRef *av_buffer_alloc(size_t size)
78 {
79 527859 AVBufferRef *ret = NULL;
80 527859 uint8_t *data = NULL;
81
82 527859 data = av_malloc(size);
83
2/2
✓ Branch 0 taken 3 times.
✓ Branch 1 taken 527856 times.
 527859 if (!data)
84 3 return NULL;
85
86 527856 ret = av_buffer_create(data, size, av_buffer_default_free, NULL, 0);
87
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 527856 times.
 527856 if (!ret)
88 ✗ av_freep(&data);
89
90 527856 return ret;
91 }
92
93 21807 AVBufferRef *av_buffer_allocz(size_t size)
94 {
95 21807 AVBufferRef *ret = av_buffer_alloc(size);
96
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 21806 times.
 21807 if (!ret)
97 1 return NULL;
98
99 21806 memset(ret->data, 0, size);
100 21806 return ret;
101 }
102
103 5429198 AVBufferRef *av_buffer_ref(const AVBufferRef *buf)
104 {
105 5429198 AVBufferRef *ret = av_mallocz(sizeof(*ret));
106
107
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 5429197 times.
 5429198 if (!ret)
108 1 return NULL;
109
110 5429197 *ret = *buf;
111
112 5429197 atomic_fetch_add_explicit(&buf->buffer->refcount, 1, memory_order_relaxed);
113
114 5429197 return ret;
115 }
116
117 10433358 static void buffer_replace(AVBufferRef **dst, AVBufferRef **src)
118 {
119 AVBuffer *b;
120
121 10433358 b = (*dst)->buffer;
122
123
2/2
✓ Branch 0 taken 6410 times.
✓ Branch 1 taken 10426948 times.
 10433358 if (src) {
124 6410 **dst = **src;
125 6410 av_freep(src);
126 } else
127 10426948 av_freep(dst);
128
129
2/2
✓ Branch 0 taken 5004161 times.
✓ Branch 1 taken 5429197 times.
 10433358 if (atomic_fetch_sub_explicit(&b->refcount, 1, memory_order_acq_rel) == 1) {
130 /* b->free below might already free the structure containing *b,
131 * so we have to read the flag now to avoid use-after-free. */
132 5004161 int free_avbuffer = !(b->flags_internal & BUFFER_FLAG_NO_FREE);
133 5004161 b->free(b->opaque, b->data);
134
2/2
✓ Branch 0 taken 3665052 times.
✓ Branch 1 taken 1339109 times.
 5004161 if (free_avbuffer)
135 3665052 av_free(b);
136 }
137 10433358 }
138
139 106566667 void av_buffer_unref(AVBufferRef **buf)
140 {
141
3/4
✓ Branch 0 taken 106566667 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 96139719 times.
✓ Branch 3 taken 10426948 times.
 106566667 if (!buf || !*buf)
142 96139719 return;
143
144 10426948 buffer_replace(buf, NULL);
145 }
146
147 2741362 int av_buffer_is_writable(const AVBufferRef *buf)
148 {
149
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 2741361 times.
 2741362 if (buf->buffer->flags & AV_BUFFER_FLAG_READONLY)
150 1 return 0;
151
152 2741361 return atomic_load(&buf->buffer->refcount) == 1;
153 }
154
155 1 void *av_buffer_get_opaque(const AVBufferRef *buf)
156 {
157 1 return buf->buffer->opaque;
158 }
159
160 142431 int av_buffer_get_ref_count(const AVBufferRef *buf)
161 {
162 142431 return atomic_load(&buf->buffer->refcount);
163 }
164
165 223 int av_buffer_make_writable(AVBufferRef **pbuf)
166 {
167 223 AVBufferRef *newbuf, *buf = *pbuf;
168
169
2/2
✓ Branch 1 taken 26 times.
✓ Branch 2 taken 197 times.
 223 if (av_buffer_is_writable(buf))
170 26 return 0;
171
172 197 newbuf = av_buffer_alloc(buf->size);
173
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 197 times.
 197 if (!newbuf)
174 ✗ return AVERROR(ENOMEM);
175
176 197 memcpy(newbuf->data, buf->data, buf->size);
177
178 197 buffer_replace(pbuf, &newbuf);
179
180 197 return 0;
181 }
182
183 1507749 int av_buffer_realloc(AVBufferRef **pbuf, size_t size)
184 {
185 1507749 AVBufferRef *buf = *pbuf;
186 uint8_t *tmp;
187 int ret;
188
189
2/2
✓ Branch 0 taken 1497730 times.
✓ Branch 1 taken 10019 times.
 1507749 if (!buf) {
190 /* allocate a new buffer with av_realloc(), so it will be reallocatable
191 * later */
192 1497730 uint8_t *data = av_realloc(NULL, size);
193
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 1497729 times.
 1497730 if (!data)
194 1 return AVERROR(ENOMEM);
195
196 1497729 buf = av_buffer_create(data, size, av_buffer_default_free, NULL, 0);
197
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1497729 times.
 1497729 if (!buf) {
198 ✗ av_freep(&data);
199 ✗ return AVERROR(ENOMEM);
200 }
201
202 1497729 buf->buffer->flags_internal |= BUFFER_FLAG_REALLOCATABLE;
203 1497729 *pbuf = buf;
204
205 1497729 return 0;
206
2/2
✓ Branch 0 taken 37 times.
✓ Branch 1 taken 9982 times.
 10019 } else if (buf->size == size)
207 37 return 0;
208
209
4/4
✓ Branch 0 taken 3906 times.
✓ Branch 1 taken 6076 times.
✓ Branch 2 taken 3768 times.
✓ Branch 3 taken 138 times.
 13888 if (!(buf->buffer->flags_internal & BUFFER_FLAG_REALLOCATABLE) ||
210
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 3768 times.
 7674 !av_buffer_is_writable(buf) || buf->data != buf->buffer->data) {
211 /* cannot realloc, allocate a new reallocable buffer and copy data */
212 6214 AVBufferRef *new = NULL;
213
214 6214 ret = av_buffer_realloc(&new, size);
215
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 6213 times.
 6214 if (ret < 0)
216 1 return ret;
217
218 6213 memcpy(new->data, buf->data, FFMIN(size, buf->size));
219
220 6213 buffer_replace(pbuf, &new);
221 6213 return 0;
222 }
223
224 3768 tmp = av_realloc(buf->buffer->data, size);
225
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3768 times.
 3768 if (!tmp)
226 ✗ return AVERROR(ENOMEM);
227
228 3768 buf->buffer->data = buf->data = tmp;
229 3768 buf->buffer->size = buf->size = size;
230 3768 return 0;
231 }
232
233 3261031 int av_buffer_replace(AVBufferRef **pdst, const AVBufferRef *src)
234 {
235 3261031 AVBufferRef *dst = *pdst;
236 AVBufferRef *tmp;
237
238
2/2
✓ Branch 0 taken 276478 times.
✓ Branch 1 taken 2984553 times.
 3261031 if (!src) {
239 276478 av_buffer_unref(pdst);
240 276478 return 0;
241 }
242
243
4/4
✓ Branch 0 taken 12628 times.
✓ Branch 1 taken 2971925 times.
✓ Branch 2 taken 75 times.
✓ Branch 3 taken 12553 times.
 2984553 if (dst && dst->buffer == src->buffer) {
244 /* make sure the data pointers match */
245 75 dst->data = src->data;
246 75 dst->size = src->size;
247 75 return 0;
248 }
249
250 2984478 tmp = av_buffer_ref(src);
251
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2984478 times.
 2984478 if (!tmp)
252 ✗ return AVERROR(ENOMEM);
253
254 2984478 av_buffer_unref(pdst);
255 2984478 *pdst = tmp;
256 2984478 return 0;
257 }
258
259 1 AVBufferPool *av_buffer_pool_init2(size_t size, void *opaque,
260 AVBufferRef* (*alloc)(void *opaque, size_t size),
261 void (*pool_free)(void *opaque))
262 {
263 1 AVBufferPool *pool = av_mallocz(sizeof(*pool));
264
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
 1 if (!pool)
265 ✗ return NULL;
266
267
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 1 times.
 1 if (ff_mutex_init(&pool->mutex, NULL)) {
268 ✗ av_free(pool);
269 ✗ return NULL;
270 }
271
272 1 pool->size = size;
273 1 pool->opaque = opaque;
274 1 pool->alloc2 = alloc;
275 1 pool->alloc = av_buffer_alloc; // fallback
276 1 pool->pool_free = pool_free;
277
278 1 atomic_init(&pool->refcount, 1);
279
280 1 return pool;
281 }
282
283 113627 AVBufferPool *av_buffer_pool_init(size_t size, AVBufferRef* (*alloc)(size_t size))
284 {
285 113627 AVBufferPool *pool = av_mallocz(sizeof(*pool));
286
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 113626 times.
 113627 if (!pool)
287 1 return NULL;
288
289
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 113626 times.
 113626 if (ff_mutex_init(&pool->mutex, NULL)) {
290 ✗ av_free(pool);
291 ✗ return NULL;
292 }
293
294 113626 pool->size = size;
295
2/2
✓ Branch 0 taken 13761 times.
✓ Branch 1 taken 99865 times.
 113626 pool->alloc = alloc ? alloc : av_buffer_alloc;
296
297 113626 atomic_init(&pool->refcount, 1);
298
299 113626 return pool;
300 }
301
302 227254 static void buffer_pool_flush(AVBufferPool *pool)
303 {
304
2/2
✓ Branch 0 taken 181446 times.
✓ Branch 1 taken 227254 times.
 408700 while (pool->pool) {
305 181446 BufferPoolEntry *buf = pool->pool;
306 181446 pool->pool = buf->next;
307
308 181446 buf->free(buf->opaque, buf->data);
309 181446 av_freep(&buf);
310 }
311 227254 }
312
313 /*
314 * This function gets called when the pool has been uninited and
315 * all the buffers returned to it.
316 */
317 113627 static void buffer_pool_free(AVBufferPool *pool)
318 {
319 113627 buffer_pool_flush(pool);
320 113627 ff_mutex_destroy(&pool->mutex);
321
322
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 113626 times.
 113627 if (pool->pool_free)
323 1 pool->pool_free(pool->opaque);
324
325 113627 av_freep(&pool);
326 113627 }
327
328 746035 void av_buffer_pool_uninit(AVBufferPool **ppool)
329 {
330 AVBufferPool *pool;
331
332
3/4
✓ Branch 0 taken 746035 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 632408 times.
✓ Branch 3 taken 113627 times.
 746035 if (!ppool || !*ppool)
333 632408 return;
334 113627 pool = *ppool;
335 113627 *ppool = NULL;
336
337 113627 ff_mutex_lock(&pool->mutex);
338 113627 buffer_pool_flush(pool);
339 113627 ff_mutex_unlock(&pool->mutex);
340
341
2/2
✓ Branch 0 taken 84098 times.
✓ Branch 1 taken 29529 times.
 113627 if (atomic_fetch_sub_explicit(&pool->refcount, 1, memory_order_acq_rel) == 1)
342 84098 buffer_pool_free(pool);
343 }
344
345 1520555 static void pool_release_buffer(void *opaque, uint8_t *data)
346 {
347 1520555 BufferPoolEntry *buf = opaque;
348 1520555 AVBufferPool *pool = buf->pool;
349
350 1520555 ff_mutex_lock(&pool->mutex);
351 1520555 buf->next = pool->pool;
352 1520555 pool->pool = buf;
353 1520555 ff_mutex_unlock(&pool->mutex);
354
355
2/2
✓ Branch 0 taken 29529 times.
✓ Branch 1 taken 1491026 times.
 1520555 if (atomic_fetch_sub_explicit(&pool->refcount, 1, memory_order_acq_rel) == 1)
356 29529 buffer_pool_free(pool);
357 1520555 }
358
359 /* allocate a new buffer and override its free() callback so that
360 * it is returned to the pool on free */
361 181446 static AVBufferRef *pool_alloc_buffer(AVBufferPool *pool)
362 {
363 BufferPoolEntry *buf;
364 AVBufferRef *ret;
365
366
1/4
✗ Branch 0 not taken.
✓ Branch 1 taken 181446 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
 181446 av_assert0(pool->alloc || pool->alloc2);
367
368
2/2
✓ Branch 0 taken 1 times.
✓ Branch 1 taken 181445 times.
 181446 ret = pool->alloc2 ? pool->alloc2(pool->opaque, pool->size) :
369 181445 pool->alloc(pool->size);
370
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 181446 times.
 181446 if (!ret)
371 ✗ return NULL;
372
373 181446 buf = av_mallocz(sizeof(*buf));
374
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 181446 times.
 181446 if (!buf) {
375 ✗ av_buffer_unref(&ret);
376 ✗ return NULL;
377 }
378
379 181446 buf->data = ret->buffer->data;
380 181446 buf->opaque = ret->buffer->opaque;
381 181446 buf->free = ret->buffer->free;
382 181446 buf->pool = pool;
383
384 181446 ret->buffer->opaque = buf;
385 181446 ret->buffer->free = pool_release_buffer;
386
387 181446 return ret;
388 }
389
390 1520555 AVBufferRef *av_buffer_pool_get(AVBufferPool *pool)
391 {
392 AVBufferRef *ret;
393 BufferPoolEntry *buf;
394
395 1520555 ff_mutex_lock(&pool->mutex);
396 1520555 buf = pool->pool;
397
2/2
✓ Branch 0 taken 1339109 times.
✓ Branch 1 taken 181446 times.
 1520555 if (buf) {
398 1339109 memset(&buf->buffer, 0, sizeof(buf->buffer));
399 1339109 ret = buffer_create(&buf->buffer, buf->data, pool->size,
400 pool_release_buffer, buf, 0);
401
1/2
✓ Branch 0 taken 1339109 times.
✗ Branch 1 not taken.
 1339109 if (ret) {
402 1339109 pool->pool = buf->next;
403 1339109 buf->next = NULL;
404 1339109 buf->buffer.flags_internal |= BUFFER_FLAG_NO_FREE;
405 }
406 } else {
407 181446 ret = pool_alloc_buffer(pool);
408 }
409 1520555 ff_mutex_unlock(&pool->mutex);
410
411
1/2
✓ Branch 0 taken 1520555 times.
✗ Branch 1 not taken.
 1520555 if (ret)
412 1520555 atomic_fetch_add_explicit(&pool->refcount, 1, memory_order_relaxed);
413
414 1520555 return ret;
415 }
416
417 1 void *av_buffer_pool_buffer_get_opaque(const AVBufferRef *ref)
418 {
419 1 BufferPoolEntry *buf = ref->buffer->opaque;
420
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
 1 av_assert0(buf);
421 1 return buf->opaque;
422 }
423