FFmpegKit iOS / macOS / tvOS API 6.0
Loading...
Searching...
No Matches
fftools_thread_queue.h
Go to the documentation of this file.
1/*
2 * This file is part of FFmpeg.
3 * Copyright (c) 2023 ARTHENICA LTD
4 *
5 * FFmpeg is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2.1 of the License, or (at your option) any later version.
9 *
10 * FFmpeg is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General Public
16 * License along with FFmpeg; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
18 */
19
20/*
21 * This file is the modified version of thread_queue.h file living in ffmpeg source code under the fftools folder. We
22 * manually update it each time we depend on a new ffmpeg version. Below you can see the list of changes applied
23 * by us to develop ffmpeg-kit library.
24 *
25 * ffmpeg-kit changes by ARTHENICA LTD
26 *
27 * 07.2023
28 * --------------------------------------------------------
29 * - FFmpeg 6.0 changes migrated
30 */
31
32#ifndef FFTOOLS_THREAD_QUEUE_H
33#define FFTOOLS_THREAD_QUEUE_H
34
35#include <string.h>
36
37#include "fftools_objpool.h"
38
39typedef struct ThreadQueue ThreadQueue;
40
52ThreadQueue *tq_alloc(unsigned int nb_streams, size_t queue_size,
53 ObjPool *obj_pool, void (*obj_move)(void *dst, void *src));
54void tq_free(ThreadQueue **tq);
55
68int tq_send(ThreadQueue *tq, unsigned int stream_idx, void *data);
72void tq_send_finish(ThreadQueue *tq, unsigned int stream_idx);
73
88int tq_receive(ThreadQueue *tq, int *stream_idx, void *data);
92void tq_receive_finish(ThreadQueue *tq, unsigned int stream_idx);
93
94#endif // FFTOOLS_THREAD_QUEUE_H
__thread int nb_streams
void tq_send_finish(ThreadQueue *tq, unsigned int stream_idx)
int tq_send(ThreadQueue *tq, unsigned int stream_idx, void *data)
ThreadQueue * tq_alloc(unsigned int nb_streams, size_t queue_size, ObjPool *obj_pool, void(*obj_move)(void *dst, void *src))
int tq_receive(ThreadQueue *tq, int *stream_idx, void *data)
void tq_free(ThreadQueue **tq)
void tq_receive_finish(ThreadQueue *tq, unsigned int stream_idx)
void(* obj_move)(void *dst, void *src)