ffmpeg_transcoder.cc

Go to the documentation of this file.

/*
 * Copyright (C) 2017-2026 Norbert Schlia (nschlia@oblivion-software.de)
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
 *
 * On Debian systems, the complete text of the GNU General Public License
 * Version 3 can be found in `/usr/share/common-licenses/GPL-3'.
 */
 
#ifdef __cplusplus
extern "C" {
#endif
// Disable annoying warnings outside our code
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wconversion"
#pragma GCC diagnostic ignored "-Wsign-conversion"
#include <libswscale/swscale.h>
#include <libavutil/imgutils.h>
#include <libavutil/opt.h>
#include <libavutil/audio_fifo.h>
#include <libavfilter/avfilter.h>
#include <libavfilter/buffersink.h>
#include <libavfilter/buffersrc.h>
#include <libavcodec/avcodec.h>
#include <libavformat/avformat.h>
#include <libavformat/avio.h>
#include <libavutil/file.h>
#include <libswresample/swresample.h>
#pragma GCC diagnostic pop
#ifdef __cplusplus
}
#endif
 
#include "ffmpeg_transcoder.h"
#include "ffmpeg_dictionary.h"
#include "buffer.h"
#include "wave.h"
#include "aiff.h"
#include "logging.h"
#include "ffmpegfs.h"
 
#include <unistd.h>
#include <filesystem>
#include <thread>
 
#define FRAME_SEEK_THRESHOLD    25  
const std::vector<FFmpeg_Transcoder::PRORES_BITRATE> FFmpeg_Transcoder::m_prores_bitrate =
{
    // SD
    {   720,    486,    { { 24, false }                   },    {   10,     23,     34,     50,     75,     113     }   },
    {   720,    486,    { { 60, true }, {   30, false }   },    {   12,     29,     42,     63,     94,     141     }   },
 
    {   720,    576,    { { 50, true }, {   25, false }   },    {   12,     28,     41,     61,     92,     138     }   },
 
    {   960,    720,    { { 24, false }                   },    {   15,     35,     50,     75,     113,    170     }   },
    {   960,    720,    { { 25, false }                   },    {   16,     36,     52,     79,     118,    177     }   },
    {   960,    720,    { { 30, false }                   },    {   19,     44,     63,     94,     141,    212     }   },
    {   960,    720,    { { 50, false }                   },    {   32,     73,     105,    157,    236,    354     }   },
    {   960,    720,    { { 60, false }                   },    {   38,     87,     126,    189,    283,    424     }   },
    // HD
    {   1280,   720,    { { 24, false }                   },    {   18,     41,     59,     88,     132,    198     }   },
    {   1280,   720,    { { 25, false }                   },    {   19,     42,     61,     92,     138,    206     }   },
    {   1280,   720,    { { 30, false }                   },    {   23,     51,     73,     110,    165,    247     }   },
    {   1280,   720,    { { 50, false }                   },    {   38,     84,     122,    184,    275,    413     }   },
    {   1280,   720,    { { 60, false }                   },    {   45,     101,    147,    220,    330,    495     }   },
 
    {   1280,   1080,   { { 24, false }                   },    {   31,     70,     101,    151,    226,    339     }   },
    {   1280,   1080,   { { 60, true }, {   30, false }   },    {   38,     87,     126,    189,    283,    424     }   },
 
    {   1440,   1080,   { { 24, false }                   },    {   31,     70,     101,    151,    226,    339     }   },
    {   1440,   1080,   { { 50, true }, {   25, false }   },    {   32,     73,     105,    157,    236,    354     }   },
    {   1440,   1080,   { { 60, true }, {   30, false }   },    {   38,     87,     126,    189,    283,    424     }   },
    // Full HD
    {   1920,   1080,   { { 24, false }                   },    {   36,     82,     117,    176,    264,    396     }   },
    {   1920,   1080,   { { 50, true }, {   25, false }   },    {   38,     85,     122,    184,    275,    413     }   },
    {   1920,   1080,   { { 60, true }, {   30, false }   },    {   45,     102,    147,    220,    330,    495     }   },
    {   1920,   1080,   { { 50, false }                   },    {   76,     170,    245,    367,    551,    826     }   },
    {   1920,   1080,   { { 60, false }                   },    {   91,     204,    293,    440,    660,    990     }   },
    // 2K
    {   2048,   1080,   { { 24, false }                   },    {   41,     93,     134,    201,    302,    453     }   },
    {   2048,   1080,   { { 25, false }                   },    {   43,     97,     140,    210,    315,    472     }   },
    {   2048,   1080,   { { 30, false }                   },    {   52,     116,    168,    251,    377,    566     }   },
    {   2048,   1080,   { { 50, false }                   },    {   86,     194,    280,    419,    629,    944     }   },
    {   2048,   1080,   { { 60, false }                   },    {   103,    232,    335,    503,    754,    1131    }   },
    // 2K
    {   2048,   1556,   { { 24, false }                   },    {   56,     126,    181,    272,    407,    611     }   },
    {   2048,   1556,   { { 25, false }                   },    {   58,     131,    189,    283,    425,    637     }   },
    {   2048,   1556,   { { 30, false }                   },    {   70,     157,    226,    340,    509,    764     }   },
    {   2048,   1556,   { { 50, false }                   },    {   117,    262,    377,    567,    850,    1275    }   },
    {   2048,   1556,   { { 60, false }                   },    {   140,    314,    452,    679,    1019,   1528    }   },
    // QFHD
    {   3840,   2160,   { { 24, false }                   },    {   145,    328,    471,    707,    1061,   1591    }   },
    {   3840,   2160,   { { 25, false }                   },    {   151,    342,    492,    737,    1106,   1659    }   },
    {   3840,   2160,   { { 30, false }                   },    {   182,    410,    589,    884,    1326,   1989    }   },
    {   3840,   2160,   { { 50, false }                   },    {   303,    684,    983,    1475,   2212,   3318    }   },
    {   3840,   2160,   { { 60, false }                   },    {   363,    821,    1178,   1768,   2652,   3977    }   },
    // 4K
    {   4096,   2160,   { { 24, false }                   },    {   155,    350,    503,    754,    1131,   1697    }   },
    {   4096,   2160,   { { 25, false }                   },    {   162,    365,    524,    786,    1180,   1769    }   },
    {   4096,   2160,   { { 30, false }                   },    {   194,    437,    629,    943,    1414,   2121    }   },
    {   4096,   2160,   { { 50, false }                   },    {   323,    730,    1049,   1573,   2359,   3539    }   },
    {   4096,   2160,   { { 60, false }                   },    {   388,    875,    1257,   1886,   2828,   4242    }   },
    // 5K
    {   5120,   2700,   { { 24, false }                   },    {   243,    547,    786,    1178,   1768,   2652    }   },
    {   5120,   2700,   { { 25, false }                   },    {   253,    570,    819,    1229,   1843,   2765    }   },
    {   5120,   2700,   { { 30, false }                   },    {   304,    684,    982,    1473,   2210,   3314    }   },
    {   5120,   2700,   { { 50, false }                   },    {   507,    1140,   1638,   2458,   3686,   5530    }   },
    {   5120,   2700,   { { 60, false }                   },    {   608,    1367,   1964,   2946,   4419,   6629    }   },
    // 6K
    {   6144,   3240,   { { 24, false }                   },    {   350,    788,    1131,   1697,   2545,   3818    }   },
    {   6144,   3240,   { { 25, false }                   },    {   365,    821,    1180,   1769,   2654,   3981    }   },
    {   6144,   3240,   { { 30, false }                   },    {   437,    985,    1414,   2121,   3182,   4772    }   },
    {   6144,   3240,   { { 50, false }                   },    {   730,    1643,   2359,   3539,   5308,   7962    }   },
    {   6144,   3240,   { { 60, false }                   },    {   875,    1969,   2828,   4242,   6364,   9545    }   },
    // 8K
    {   8192,   4320,   { { 24, false }                   },    {   622,    1400,   2011,   3017,   4525,   6788    }   },
    {   8192,   4320,   { { 25, false }                   },    {   649,    1460,   2097,   3146,   4719,   7078    }   },
    {   8192,   4320,   { { 30, false }                   },    {   778,    1750,   2514,   3771,   5657,   8485    }   },
    {   8192,   4320,   { { 50, false }                   },    {   1298,   2920,   4194,   6291,   9437,   14156   }   },
    {   8192,   4320,   { { 60, false }                   },    {   1556,   3500,   5028,   7542,   11313,  16970   }   }
};
 
const FFmpeg_Transcoder::DEVICETYPE_MAP FFmpeg_Transcoder::m_devicetype_map =
{
    { AV_HWDEVICE_TYPE_VAAPI,           AV_PIX_FMT_NV12 },          
    #if 0
    { AV_HWDEVICE_TYPE_CUDA,            AV_PIX_FMT_CUDA },          
    { AV_HWDEVICE_TYPE_VDPAU,           AV_PIX_FMT_YUV420P },       
    { AV_HWDEVICE_TYPE_QSV,             AV_PIX_FMT_QSV },           
    { AV_HWDEVICE_TYPE_OPENCL,          AV_PIX_FMT_OPENCL },        
    #if HAVE_VULKAN_HWACCEL
    { AV_HWDEVICE_TYPE_VULKAN,          AV_PIX_FMT_VULKAN },        
    #endif // HAVE_VULKAN_HWACCEL
    #if __APPLE__
    { AV_HWDEVICE_TYPE_VIDEOTOOLBOX,    AV_PIX_FMT_VIDEOTOOLBOX },  
    #endif // __APPLE__
    #if __ANDROID__
    { AV_HWDEVICE_TYPE_MEDIACODEC,      AV_PIX_FMT_MEDIACODEC },    
    #endif // __ANDROID__
    #if _WIN32
    { AV_HWDEVICE_TYPE_DRM,             AV_PIX_FMT_DRM_PRIME },     
    { AV_HWDEVICE_TYPE_DXVA2,           AV_PIX_FMT_DXVA2_VLD },     
    { AV_HWDEVICE_TYPE_D3D11VA,         AV_PIX_FMT_D3D11VA_VLD },   
    #endif // _WIN32
    #endif
};
 
FFmpeg_Transcoder::StreamRef::StreamRef() :
    m_codec_ctx(nullptr),
    m_stream(nullptr),
    m_stream_idx(INVALID_STREAM),
    m_start_time(0)
{
 
}
FFmpeg_Transcoder::StreamRef::~StreamRef()
{
    reset();
}
 
template< typename T >
struct av_context_deleter       
{
    void operator ()( T * p) const
    {
        avcodec_free_context(&p);
    }
};
 
void FFmpeg_Transcoder::StreamRef::set_codec_ctx(AVCodecContext *codec_ctx)
{
    if (codec_ctx != nullptr)
    {
        std::shared_ptr<AVCodecContext> sp(codec_ctx, av_context_deleter<AVCodecContext>());
 
        m_codec_ctx = sp;
    }
    else
    {
        m_codec_ctx.reset();
    }
}
 
void FFmpeg_Transcoder::StreamRef::reset()
{
    m_codec_ctx.reset();
}
 
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wmissing-field-initializers"
FFmpeg_Transcoder::FFmpeg_Transcoder()
    : m_fileio(nullptr)
    , m_last_seek_frame_no(0)
    , m_have_seeked(false)
    , m_skip_next_frame(false)
    , m_is_video(false)
    , m_cur_sample_fmt(AV_SAMPLE_FMT_NONE)
    , m_cur_sample_rate(-1)
    , m_buffer_sink_context(nullptr)
    , m_buffer_source_context(nullptr)
    , m_filter_graph(nullptr)
    , m_pts(AV_NOPTS_VALUE)
    , m_pos(AV_NOPTS_VALUE)
    , m_current_segment(1)
    , m_insert_keyframe(true)
    , m_copy_audio(false)
    , m_copy_video(false)
    , m_cur_audio_ts(0)
    , m_cur_video_ts(0)
    , m_current_format(nullptr)
    , m_buffer(nullptr)
    , m_reset_pts(0)
    , m_fake_frame_no(0)
    , m_hwaccel_enc_mode(HWACCELMODE::NONE)
    , m_hwaccel_dec_mode(HWACCELMODE::NONE)
    , m_hwaccel_enable_enc_buffering(false)
    , m_hwaccel_enable_dec_buffering(false)
    , m_hwaccel_enc_device_ctx(nullptr)
    , m_hwaccel_dec_device_ctx(nullptr)
    , m_enc_hw_pix_fmt(AV_PIX_FMT_NONE)
    , m_dec_hw_pix_fmt(AV_PIX_FMT_NONE)
    , m_active_stream_msk(0)
    , m_inhibit_stream_msk(0)
{
#pragma GCC diagnostic pop
    Logging::trace(nullptr, "The FFmpeg trancoder is ready to initialise.");
 
    std::memset(&m_mtime, 0, sizeof(m_mtime));
 
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
    av_channel_layout_default(&m_cur_ch_layout, params.m_audiochannels);
#else // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    m_cur_channel_layout = static_cast<uint64_t>(av_get_default_channel_layout(params.m_audiochannels));
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
 
    // Initialise ID3v1.1 tag structure
    init_id3v1(&m_out.m_id3v1);
}
 
FFmpeg_Transcoder::~FFmpeg_Transcoder()
{
    // Close files and resample context
    closeio();
 
    Logging::trace(nullptr, "The FFmpeg transcoder object was destroyed.");
}
 
bool FFmpeg_Transcoder::is_video() const
{
    bool is_video = false;
 
    if (m_in.m_video.m_codec_ctx != nullptr && m_in.m_video.m_stream != nullptr)
    {
        is_video = !is_album_art(m_in.m_video.m_codec_ctx->codec_id, &m_in.m_video.m_stream->r_frame_rate);
    }
 
    return is_video;
}
 
bool FFmpeg_Transcoder::is_open() const
{
    return (m_in.m_format_ctx != nullptr);
}
 
int FFmpeg_Transcoder::open_input_file(LPVIRTUALFILE virtualfile, std::shared_ptr<FileIO> fio)
{
    FFmpeg_Dictionary opt;
    int ret;
 
    if (virtualfile == nullptr)
    {
        Logging::error(filename(), "INTERNAL ERROR: FFmpeg_Transcoder::open_input_file()! virtualfile is NULL.");
        return AVERROR(EINVAL);
    }
 
    m_virtualfile       = virtualfile;
 
    m_mtime             = m_virtualfile->m_st.st_mtime;
    m_current_format    = params.current_format(m_virtualfile);
 
    if (is_open())
    {
        Logging::warning(filename(), "The file is already open.");
        return 0;
    }
 
    // This allows selecting if the demuxer should consider all streams to be
    // found after the first PMT and add further streams during decoding or if it rather
    // should scan all that are within the analyze-duration and other limits
    ret = dict_set_with_check(opt.address(), "scan_all_pmts", "1", AV_DICT_DONT_OVERWRITE);
    if (ret < 0)
    {
        return ret;
    }
 
    // avioflags direct: Reduce buffering.
    //ret = dict_set_with_check(opt.address(), "avioflags", "direct", AV_DICT_DONT_OVERWRITE);
    //if (ret < 0)
    //{
    //    return ret;
    //}
 
    // analyzeduration: Defaults to 5,000,000 microseconds = 5 seconds.
    ret = dict_set_with_check(opt.address(), "analyzeduration", "15000000", 0);    // <<== honored: 15 seconds
    if (ret < 0)
    {
        return ret;
    }
 
    // probesize: 5000000 by default.
    ret = dict_set_with_check(opt.address(), "probesize", "15000000", 0);          // <<== honoured: ~15 MB
    if (ret < 0)
    {
        return ret;
    }
 
    // using own I/O
    if (fio == nullptr)
    {
        // Open new file io
        m_fileio = FileIO::alloc(m_virtualfile->m_type);
    }
    else
    {
        // Use already open file io
        m_fileio = fio;
    }
 
    if (m_fileio == nullptr)
    {
        int orgerrno = errno;
        Logging::error(filename(), "Error opening file: (%1) %2", errno, strerror(errno));
        return AVERROR(orgerrno);
    }
 
    ret = m_fileio->openio(m_virtualfile);
    if (ret)
    {
        return AVERROR(ret);
    }
 
    ret = m_in.m_format_ctx.alloc_input_context();
    if (ret < 0)
    {
        Logging::error(filename(), "Out of memory opening file: format context could not be allocated.");
        return ret;
    }
 
    unsigned char *iobuffer = static_cast<unsigned char *>(av_malloc(m_fileio->bufsize() + FF_INPUT_BUFFER_PADDING_SIZE));
    if (iobuffer == nullptr)
    {
        Logging::error(filename(), "Out of memory opening file: I/O buffer could not be allocated.");
        m_in.m_format_ctx.reset();
        return AVERROR(ENOMEM);
    }
 
    AVIOContext * pb = avio_alloc_context(
                iobuffer,
                static_cast<int>(m_fileio->bufsize()),
                0,
                static_cast<void *>(m_fileio.get()),
                input_read,
                nullptr,    // input_write
                seek);      // input_seek
    if (pb == nullptr)
    {
        Logging::error(filename(), "Out of memory opening file: I/O context could not be allocated.");
        av_freep(&iobuffer);
        m_in.m_format_ctx.reset();
        return AVERROR(ENOMEM);
    }
    m_in.m_format_ctx->pb = pb;
    m_in.m_format_ctx.set_custom_io();
 
#if IF_DECLARED_CONST
    const AVInputFormat * infmt = nullptr;
#else // !IF_DECLARED_CONST
    AVInputFormat * infmt = nullptr;
#endif // !IF_DECLARED_CONST
 
#ifdef USE_LIBVCD
    if (m_virtualfile->m_type == VIRTUALTYPE::VCD)
    {
        Logging::debug(filename(), "To avoid misdetection, forcing MPEG format for VCD source.");
        infmt = av_find_input_format("mpeg");
    }
#endif // USE_LIBVCD
#ifdef USE_LIBDVD
    if (m_virtualfile->m_type == VIRTUALTYPE::DVD)
    {
        Logging::debug(filename(), "To avoid misdetection, forcing MPEG format for DVD source.");
        infmt = av_find_input_format("mpeg");
    }
#endif // USE_LIBDVD
#ifdef USE_LIBBLURAY
    if (m_virtualfile->m_type == VIRTUALTYPE::BLURAY)
    {
        Logging::debug(filename(), "To avoid misdetection, forcing MPEGTS format for Blu-ray source.");
        infmt = av_find_input_format("mpegts");
    }
#endif // USE_LIBBLURAY
 
    // Open the input file to read from it.
    ret = avformat_open_input(m_in.m_format_ctx.address(), filename(), infmt, opt.address());
    if (ret < 0)
    {
        Logging::error(filename(), "Could not open input file (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    m_in.m_filetype = get_filetype_from_list(m_in.m_format_ctx->iformat->name);
 
#if HAVE_AV_FORMAT_INJECT_GLOBAL_SIDE_DATA
    av_format_inject_global_side_data(m_in.m_format_ctx);
#endif
 
    // Get information on the input file (number of streams etc.).
    ret = avformat_find_stream_info(m_in.m_format_ctx, nullptr);
    if (ret < 0)
    {
        Logging::error(filename(), "Could not find stream info (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
#ifdef USE_LIBDVD
    if (m_virtualfile->m_type == VIRTUALTYPE::DVD)
    {
        // FFmpeg API calculates a wrong duration, so use value from IFO
        m_in.m_format_ctx->duration = m_fileio->duration();
    }
#endif // USE_LIBDVD
#ifdef USE_LIBBLURAY
    if (m_virtualfile->m_type == VIRTUALTYPE::BLURAY)
    {
        // FFmpeg API calculates a wrong duration, so use value from Blu-ray directory
        m_in.m_format_ctx->duration = m_fileio->duration();
    }
#endif // USE_LIBBLURAY
 
    m_virtualfile->m_duration = m_in.m_format_ctx->duration;
 
    ret = open_bestmatch_video();
    if (ret < 0)
    {
        // Already logged
        return ret;
    }
 
#ifdef USE_LIBDVD
    if (m_virtualfile->m_type == VIRTUALTYPE::DVD && m_in.m_video.m_codec_ctx != nullptr && m_in.m_video.m_stream != nullptr)
    {
        // FFmpeg API sometimes cannot detect video size or frame rate, so use value from IFO
        if (!m_in.m_video.m_codec_ctx->width || !m_in.m_video.m_stream->codecpar->height)
        {
            m_in.m_video.m_codec_ctx->width = m_in.m_video.m_stream->codecpar->width = m_virtualfile->m_width;
            m_in.m_video.m_codec_ctx->height = m_in.m_video.m_stream->codecpar->height = m_virtualfile->m_height;
        }
        if (!m_in.m_video.m_stream->avg_frame_rate.den)
        {
            m_in.m_video.m_stream->avg_frame_rate = m_virtualfile->m_framerate;
        }
    }
#endif // USE_LIBDVD
#ifdef USE_LIBBLURAY
    if (m_virtualfile->m_type == VIRTUALTYPE::BLURAY && m_in.m_video.m_codec_ctx != nullptr && m_in.m_video.m_stream != nullptr)
    {
        // FFmpeg API sometimes cannot detect video size or frame rate, so use value from Blu-ray directory
        if (!m_in.m_video.m_codec_ctx->width || !m_in.m_video.m_stream->codecpar->height)
        {
            m_in.m_video.m_codec_ctx->width = m_in.m_video.m_stream->codecpar->width = m_virtualfile->m_width;
            m_in.m_video.m_codec_ctx->height = m_in.m_video.m_stream->codecpar->height = m_virtualfile->m_height;
        }
        if (!m_in.m_video.m_stream->avg_frame_rate.den)
        {
            m_in.m_video.m_stream->avg_frame_rate = m_virtualfile->m_framerate;
        }
    }
#endif // USE_LIBBLURAY
 
    ret = open_bestmatch_audio();
    if (ret < 0)
    {
        // Already logged
        return ret;
    }
 
    if (!stream_exists(m_in.m_audio.m_stream_idx) && !stream_exists(m_in.m_video.m_stream_idx))
    {
        Logging::error(filename(), "The file contains neither a video nor an audio stream.");
        return AVERROR(EINVAL);
    }
 
    if (!params.m_no_subtitles)
    {
        ret = open_subtitles();
        if (ret < 0)
        {
            // Already logged
            return ret;
        }
    }
 
    // Predict size of transcoded file as exact as possible
    m_virtualfile->m_predicted_size = calculate_predicted_filesize();
 
    // Calculate number or video frames in file based on duration and frame rate
    if (m_in.m_video.m_stream != nullptr && m_in.m_video.m_stream->avg_frame_rate.den)
    {
        // Number of frames: should be quite accurate
        m_virtualfile->m_video_frame_count = static_cast<uint32_t>(ffmpeg_rescale_q(m_in.m_video.m_stream->duration, m_in.m_video.m_stream->time_base, av_inv_q(m_in.m_video.m_stream->avg_frame_rate)));
    }
 
    ret = open_albumarts();
    if (ret < 0)
    {
        // Already logged
        return ret;
    }
 
    if (m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
    {
        // Position to start of cue sheet track
        ret = av_seek_frame(m_in.m_format_ctx, -1, m_virtualfile->m_cuesheet_track.m_start, 0);
        if (ret < 0)
        {
            Logging::error(filename(), "The track start was nout found (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::open_bestmatch_video()
{
    // Issue #80: Open input video codec, but only if target supports video.
    // Saves resources: no need to decode video frames if not used.
    if (m_current_format->video_codec() != AV_CODEC_ID_NONE)
    {
        int ret;
 
        // Open best match video codec
        AVCodecContext * codec_ctx = nullptr;
        ret = open_bestmatch_decoder(m_in.m_format_ctx, &codec_ctx, &m_in.m_video.m_stream_idx, AVMEDIA_TYPE_VIDEO);
        if (ret < 0 && ret != AVERROR_STREAM_NOT_FOUND)    // AVERROR_STREAM_NOT_FOUND is not an error
        {
            Logging::error(filename(), "The video codec could not be opened (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
        m_in.m_video.set_codec_ctx(codec_ctx);
 
        if (stream_exists(m_in.m_video.m_stream_idx))
        {
            // We have a video stream
            // Check to see if encoder hardware acceleration is both requested and supported by codec.
            std::string hw_encoder_codec_name;
            if (!get_hw_encoder_name(m_current_format->video_codec(), &hw_encoder_codec_name))
            {
                // API supports hardware frame buffers
                m_hwaccel_enable_enc_buffering = (params.m_hwaccel_enc_device_type != AV_HWDEVICE_TYPE_NONE);
            }
 
            if (m_hwaccel_enable_enc_buffering)
            {
                // Hardware buffers available, enabling encoder hardware accceleration.
                Logging::trace(virtname(), "Hardware encoder frame buffering %1 is enabled.", get_hwaccel_API_text(params.m_hwaccel_enc_API).c_str());
                ret = hwdevice_ctx_create(&m_hwaccel_enc_device_ctx, params.m_hwaccel_enc_device_type, params.m_hwaccel_enc_device);
                if (ret < 0)
                {
                    Logging::error(virtname(), "Failed to create a %1 device for encoding (error %2).", get_hwaccel_API_text(params.m_hwaccel_enc_API).c_str(), ffmpeg_geterror(ret).c_str());
                    return ret;
                }
                Logging::info(virtname(), "Hardware encoder acceleration and frame buffering are active using codec '%1'.", hw_encoder_codec_name.c_str());
            }
            else if (params.m_hwaccel_enc_device_type != AV_HWDEVICE_TYPE_NONE)
            {
                // No hardware acceleration, fallback to software,
                Logging::debug(virtname(), "Hardware encoder frame buffering %1 is not supported by codec '%2'. Falling back to software.", get_hwaccel_API_text(params.m_hwaccel_enc_API).c_str(), get_codec_name(m_in.m_video.m_codec_ctx->codec_id, true));
            }
            else if (!hw_encoder_codec_name.empty())
            {
                // No frame buffering (e.g. OpenMAX or MMAL), but hardware acceleration possible.
                Logging::info(virtname(), "Hardware encoder acceleration is active using codec '%1'.", hw_encoder_codec_name.c_str());
            }
 
            m_in.m_video.m_stream               = m_in.m_format_ctx->streams[m_in.m_video.m_stream_idx];
 
#ifdef USE_LIBDVD
            if (m_virtualfile->m_type == VIRTUALTYPE::DVD)
            {
                // FFmpeg API calculates a wrong duration, so use value from IFO
                m_in.m_video.m_stream->duration = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), m_in.m_video.m_stream->time_base);
            }
#endif // USE_LIBDVD
#ifdef USE_LIBBLURAY
            if (m_virtualfile->m_type == VIRTUALTYPE::BLURAY)
            {
                // FFmpeg API calculates a wrong duration, so use value from Blu-ray
                m_in.m_video.m_stream->duration = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), m_in.m_video.m_stream->time_base);
            }
#endif // USE_LIBBLURAY
 
            video_info(false, m_in.m_format_ctx, m_in.m_video.m_stream);
 
            m_is_video = is_video();
 
#if !LAVC_DEP_FLAG_TRUNCATED
#ifdef AV_CODEC_CAP_TRUNCATED
            if (m_in.m_video.m_codec_ctx->codec->capabilities & AV_CODEC_CAP_TRUNCATED)
            {
                m_in.m_video.m_codec_ctx->flags|= AV_CODEC_FLAG_TRUNCATED; // we do not send complete frames
            }
#else
#warning "Your FFMPEG distribution is missing AV_CODEC_CAP_TRUNCATED flag. Probably requires fixing!"
#endif
#endif  // !LAVC_DEP_FLAG_TRUNCATED
        }
    }
    return 0;
}
 
int FFmpeg_Transcoder::open_bestmatch_audio()
{
    int ret;
 
    // Open best match audio codec
    AVCodecContext * codec_ctx = nullptr;
    ret = open_bestmatch_decoder(m_in.m_format_ctx, &codec_ctx, &m_in.m_audio.m_stream_idx, AVMEDIA_TYPE_AUDIO);
    if (ret < 0 && ret != AVERROR_STREAM_NOT_FOUND)    // AVERROR_STREAM_NOT_FOUND is not an error
    {
        Logging::error(filename(), "The audio codec could not be opened (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
    m_in.m_audio.set_codec_ctx(codec_ctx);
 
    if (stream_exists(m_in.m_audio.m_stream_idx))
    {
        // We have an audio stream
        m_in.m_audio.m_stream = m_in.m_format_ctx->streams[m_in.m_audio.m_stream_idx];
 
#ifdef USE_LIBDVD
        if (m_virtualfile->m_type == VIRTUALTYPE::DVD)
        {
            // FFmpeg API calculates a wrong duration, so use value from IFO
            m_in.m_audio.m_stream->duration = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), m_in.m_audio.m_stream->time_base);
        }
#endif // USE_LIBDVD
#ifdef USE_LIBBLURAY
        if (m_virtualfile->m_type == VIRTUALTYPE::BLURAY)
        {
            // FFmpeg API calculates a wrong duration, so use value from Blu-ray directory
            m_in.m_audio.m_stream->duration = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), m_in.m_audio.m_stream->time_base);
        }
#endif // USE_LIBBLURAY
 
        audio_info(false, m_in.m_format_ctx, m_in.m_audio.m_stream);
    }
    return 0;
}
 
int FFmpeg_Transcoder::open_subtitles()
{
    // If target supports subtitles, check to transcode subtitles
    for (int stream_idx = 0; stream_idx < static_cast<int>(m_in.m_format_ctx->nb_streams); stream_idx++)
    {
        AVStream * stream = m_in.m_format_ctx->streams[stream_idx];
 
        if (avcodec_get_type(stream->codecpar->codec_id) != AVMEDIA_TYPE_SUBTITLE)
        {
            continue;
        }
 
        if (m_current_format->subtitle_codec(stream->codecpar->codec_id) == AV_CODEC_ID_NONE)
        {
            // No match, no support for this type of subtitle
            continue;
        }
 
        AVCodecContext * codec_ctx = nullptr;
        int ret;
 
        ret = open_decoder(m_in.m_format_ctx, &codec_ctx, stream_idx, nullptr, AVMEDIA_TYPE_SUBTITLE);
        if (ret < 0)
        {
            Logging::error(filename(), "The subtitle codec could not be opened (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
        codec_ctx->pkt_timebase = codec_ctx->time_base = stream->time_base;
 
        StreamRef input_streamref;
 
        // We have a subtitle stream
        input_streamref.set_codec_ctx(codec_ctx);
        input_streamref.m_stream      = stream;
        input_streamref.m_stream_idx  = stream_idx;
 
        m_in.m_subtitle.emplace(input_streamref.m_stream_idx, input_streamref);
 
        subtitle_info(false, m_in.m_format_ctx, input_streamref.m_stream);
    }
    return 0;
}
 
int FFmpeg_Transcoder::open_albumarts()
{
    // Open album art streams if present and supported by both source and target
    if (!params.m_noalbumarts && m_in.m_audio.m_stream != nullptr)
    {
        for (int stream_idx = 0; stream_idx < static_cast<int>(m_in.m_format_ctx->nb_streams); stream_idx++)
        {
            AVStream *input_stream = m_in.m_format_ctx->streams[stream_idx];
 
            if (is_album_art(input_stream->codecpar->codec_id, &input_stream->r_frame_rate))
            {
                StreamRef streamref;
                AVCodecContext * input_codec_ctx;
                int ret;
 
                Logging::trace(filename(), "Found album art.");
 
                ret = open_decoder(m_in.m_format_ctx, &input_codec_ctx, stream_idx, nullptr, AVMEDIA_TYPE_VIDEO);
                if (ret < 0)
                {
                    Logging::error(filename(), "The album art codec could not be opened (error '%1').", ffmpeg_geterror(ret).c_str());
                    return ret;
                }
 
                streamref.set_codec_ctx(input_codec_ctx);
                streamref.m_stream     = input_stream;
                streamref.m_stream_idx = input_stream->index;
 
                m_in.m_album_art.push_back(streamref);
            }
        }
    }
    return 0;
}
 
bool FFmpeg_Transcoder::can_copy_stream(const AVStream *stream) const
{
    if (params.m_autocopy == AUTOCOPY::OFF)
    {
        // Auto copy disabled
        return false;
    }
 
    if (stream == nullptr)
    {
        // Should normally not happen: Input stream stream unknown, no way to check - no auto copy
        return false;
    }
 
    AVMediaType codec_type = stream->codecpar->codec_type;
    AVCodecID codec_in = stream->codecpar->codec_id;
    std::string codec_type_str;
    AVCodecID codec_out;
    int64_t bitrate_out;
    if (codec_type == AVMEDIA_TYPE_VIDEO)
    {
        codec_type_str = "video";
        codec_out = m_current_format->video_codec();
        bitrate_out = params.m_videobitrate;
    }
    else if (codec_type == AVMEDIA_TYPE_AUDIO)
    {
        codec_type_str = "audio";
        codec_out = m_current_format->audio_codec();
        bitrate_out = params.m_audiobitrate;
    }
    else
    {
        // Codec is not video or audio
        return false;
    }
 
    if ((params.m_autocopy == AUTOCOPY::MATCH || params.m_autocopy == AUTOCOPY::MATCHLIMIT))
    {
        // Any codec supported by output format OK
        const AVOutputFormat* oformat = av_guess_format(nullptr, virtname(), nullptr);
        if (oformat->codec_tag == nullptr || av_codec_get_tag(oformat->codec_tag, stream->codecpar->codec_id) <= 0)
        {
            // Codec not supported - no auto copy
            return false;
        }
    }
    else if ((params.m_autocopy == AUTOCOPY::STRICT || params.m_autocopy == AUTOCOPY::STRICTLIMIT))
    {
        // Output codec must strictly match
        Logging::debug(virtname(), "Check autocopy strict: %1: %2 -> %3", codec_type_str.c_str(), avcodec_get_name(codec_in), avcodec_get_name(codec_out));
        if (codec_in != codec_out)
        {
            // Different codecs - no auto copy
            return false;
        }
    }
 
    if (params.m_autocopy == AUTOCOPY::MATCHLIMIT || params.m_autocopy == AUTOCOPY::STRICTLIMIT)
    {
        BITRATE orig_bit_rate = (stream->codecpar->bit_rate != 0) ? stream->codecpar->bit_rate : m_in.m_format_ctx->bit_rate;
        if (get_output_bit_rate(orig_bit_rate, bitrate_out))
        {
            // Bit rate changed, no auto copy
            Logging::info(virtname(), "Because the bit rate has changed, no auto copy is possible.");
            return false;
        }
    }
 
    return true;
}
 
int FFmpeg_Transcoder::open_output_file(Buffer *buffer)
{
    if (buffer == nullptr)
    {
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::open_output_file()! buffer == nullptr in open_output_file()");
        return AVERROR(EINVAL);
    }
 
    m_out.m_filetype    = m_current_format->filetype();
 
    Logging::debug(virtname(), "Opening the output file.");
 
    if (!stream_exists(m_in.m_audio.m_stream_idx) && m_current_format->video_codec() == AV_CODEC_ID_NONE)
    {
        Logging::error(virtname(), "Unable to transcode. The source contains no audio stream, but the target just supports audio.");
        m_virtualfile->m_flags |= VIRTUALFLAG_HIDDEN;   // Hide file from now on
        return AVERROR(ENOENT);                         // Report file not found
    }
 
    if (!is_frameset())
    {
        // Not a frame set, open regular buffer
        return open_output(buffer);
    }
    else
    {
        Logging::debug(virtname(), "Opening frame set type '%1'.", m_current_format->desttype().c_str());
 
        // Open frame set buffer
        return open_output_frame_set(buffer);
    }
}
 
int FFmpeg_Transcoder::open_bestmatch_decoder(AVFormatContext *format_ctx, AVCodecContext **codec_ctx, int *stream_idx, AVMediaType type)
{
#if IF_DECLARED_CONST
    const AVCodec *input_codec = nullptr;
#else // !IF_DECLARED_CONST
    AVCodec *input_codec = nullptr;
#endif // !IF_DECLARED_CONST
    int ret;
 
    *codec_ctx = nullptr;
    *stream_idx = INVALID_STREAM;
 
    ret = av_find_best_stream(format_ctx, type, INVALID_STREAM, INVALID_STREAM, &input_codec, 0);
    if (ret < 0)
    {
        if (ret != AVERROR_STREAM_NOT_FOUND)    // Not an error
        {
            Logging::error(filename(), "Could not find a %1 stream in the input file (error '%2').", get_media_type_string(type), ffmpeg_geterror(ret).c_str());
        }
        return ret;
    }
 
    *stream_idx = ret;
 
    return open_decoder(format_ctx, codec_ctx, *stream_idx, input_codec, type);
}
 
#if IF_DECLARED_CONST
AVPixelFormat FFmpeg_Transcoder::get_hw_pix_fmt(const AVCodec *codec, AVHWDeviceType dev_type, bool use_device_ctx) const
#else // !IF_DECLARED_CONST
AVPixelFormat FFmpeg_Transcoder::get_hw_pix_fmt(AVCodec *codec, AVHWDeviceType dev_type, bool use_device_ctx) const
#endif // !IF_DECLARED_CONST
{
    AVPixelFormat hw_pix_fmt = AV_PIX_FMT_NONE;
 
    if (codec != nullptr && dev_type != AV_HWDEVICE_TYPE_NONE)
    {
        int method = use_device_ctx ? AV_CODEC_HW_CONFIG_METHOD_HW_DEVICE_CTX : AV_CODEC_HW_CONFIG_METHOD_HW_FRAMES_CTX;
 
        for (int i = 0;; i++)
        {
            const AVCodecHWConfig *config = avcodec_get_hw_config(codec, i);
            if (!config)
            {
                Logging::error(av_codec_is_decoder(codec) ? filename() : virtname(), "%1 '%2' does not support device type %3.\n", av_codec_is_encoder(codec) ? "Encoder" : "Decoder", codec->name, hwdevice_get_type_name(dev_type));
                break;
            }
 
            if ((config->methods & method) && (config->device_type == dev_type))
            {
                hw_pix_fmt = config->pix_fmt;
                Logging::debug(av_codec_is_decoder(codec) ? filename() : virtname(), "%1 '%2' requests %3 for device type %4.\n", av_codec_is_encoder(codec) ? "Encoder" : "Decoder", codec->name, av_get_pix_fmt_name(hw_pix_fmt), hwdevice_get_type_name(dev_type));
                break;
            }
        }
    }
 
    return hw_pix_fmt;
}
 
#if IF_DECLARED_CONST
int FFmpeg_Transcoder::open_decoder(AVFormatContext *format_ctx, AVCodecContext **codec_ctx, int stream_idx, const AVCodec *input_codec, AVMediaType mediatype)
#else // !IF_DECLARED_CONST
int FFmpeg_Transcoder::open_decoder(AVFormatContext *format_ctx, AVCodecContext **codec_ctx, int stream_idx, AVCodec *input_codec, AVMediaType mediatype)
#endif // !IF_DECLARED_CONST
{
    while (true)
    {
        AVCodecContext *input_codec_ctx     = nullptr;
        AVStream *      input_stream        = nullptr;
        FFmpeg_Dictionary opt;
        AVCodecID       codec_id            = AV_CODEC_ID_NONE;
        int ret;
 
        input_stream = format_ctx->streams[stream_idx];
 
        // Init the decoders, with or without reference counting
        // av_dict_set_with_check(opt.address(), "refcounted_frames", refcount ? "1" : "0", 0);
 
        // allocate a new decoding context
        input_codec_ctx = avcodec_alloc_context3(nullptr);
        if (input_codec_ctx == nullptr)
        {
            Logging::error(filename(), "Decoding context could not be allocated.");
            return AVERROR(ENOMEM);
        }
 
        // initialise the stream parameters with demuxer information
        ret = avcodec_parameters_to_context(input_codec_ctx, input_stream->codecpar);
        if (ret < 0)
        {
            return ret;
        }
 
        codec_id = input_stream->codecpar->codec_id;
 
        if (params.m_hwaccel_dec_API != HWACCELAPI::NONE)
        {
            if (mediatype == AVMEDIA_TYPE_VIDEO)
            {
                if (check_hwaccel_dec_blocked(input_stream->codecpar->codec_id, input_stream->codecpar->profile))
                {
                    const char *profile = ::avcodec_profile_name(codec_id, input_stream->codecpar->profile);
                    Logging::info(filename(), "Codec '%1' profile '%2' is blocked from hardware decoding. Reverting to software decoder.", ::get_codec_name(codec_id), profile != nullptr ? profile : "unknown");
                    m_hwaccel_dec_mode              = HWACCELMODE::FALLBACK;
                }
            }
 
            if (mediatype == AVMEDIA_TYPE_VIDEO && m_hwaccel_dec_mode != HWACCELMODE::FALLBACK)
            {
                // Decide whether to use a hardware decoder
                // Check to see if decoder hardware acceleration is both requested and supported by codec.
                std::string hw_decoder_codec_name;
                if (!get_hw_decoder_name(input_codec_ctx->codec_id, &hw_decoder_codec_name))
                {
                    m_dec_hw_pix_fmt = get_hw_pix_fmt(input_codec, params.m_hwaccel_dec_device_type, true);
 
                    m_hwaccel_enable_dec_buffering = (params.m_hwaccel_dec_device_type != AV_HWDEVICE_TYPE_NONE && m_dec_hw_pix_fmt != AV_PIX_FMT_NONE);
                    //{
                    //    std::string fourcc2str;
                    //    fourcc_make_string(&fourcc2str, input_codec_ctx->codec_tag);
                    //    fprintf(stderr, "fourcc2str %s\n", fourcc2str.c_str());
                    //}
                }
 
                if (m_hwaccel_enable_dec_buffering)
                {
                    // Hardware buffers available, enabling decoder hardware acceleration.
                    Logging::trace(filename(), "Hardware decoder frame buffering %1 is enabled.", get_hwaccel_API_text(params.m_hwaccel_dec_API).c_str());
                    ret = hwdevice_ctx_create(&m_hwaccel_dec_device_ctx, params.m_hwaccel_dec_device_type, params.m_hwaccel_dec_device);
                    if (ret < 0)
                    {
                        Logging::error(filename(), "Failed to create a %1 device for decoding (error %2).", get_hwaccel_API_text(params.m_hwaccel_dec_API).c_str(), ffmpeg_geterror(ret).c_str());
                        return ret;
                    }
 
                    Logging::info(filename(), "Hardware decoder acceleration and frame buffering are active using codec '%1'.", (input_codec != nullptr) ? input_codec->name : "unknown");
 
                    m_hwaccel_dec_mode = HWACCELMODE::ENABLED; // Hardware acceleration active
                }
                else if (params.m_hwaccel_dec_device_type != AV_HWDEVICE_TYPE_NONE)
                {
                    // No hardware acceleration, fallback to software,
                    Logging::debug(filename(), "Hardware decoder frame buffering %1 not supported by codec '%2'. Falling back to software.", get_hwaccel_API_text(params.m_hwaccel_dec_API).c_str(), get_codec_name(input_codec_ctx->codec_id, true));
                }
                else if (!hw_decoder_codec_name.empty())
                {
                    // No frame buffering (e.g. OpenMAX or MMAL), but hardware acceleration possible.
                    // Open hw_decoder_codec_name codec here
                    input_codec = avcodec_find_decoder_by_name(hw_decoder_codec_name.c_str());
 
                    if (input_codec == nullptr)
                    {
                        Logging::error(filename(), "Decoder '%1' could not be found.", hw_decoder_codec_name.c_str());
                        return AVERROR(EINVAL);
                    }
 
                    Logging::info(filename(), "Hardware decoder acceleration is active using codec '%1'.", input_codec->name);
 
                    m_hwaccel_dec_mode = HWACCELMODE::ENABLED; // Hardware acceleration active
                }
 
                if (m_hwaccel_enable_dec_buffering)
                {
                    ret = hwdevice_ctx_add_ref(input_codec_ctx);
                    if (ret < 0)
                    {
                        return ret;
                    }
                }
            }
        }
 
        if (input_codec == nullptr)
        {
            // Find a decoder for the stream.
            input_codec = avcodec_find_decoder(codec_id);
 
            if (input_codec == nullptr)
            {
                Logging::error(filename(), "Failed to find %1 input codec '%2'.", get_media_type_string(mediatype), avcodec_get_name(codec_id));
                return AVERROR(EINVAL);
            }
        }
 
        input_codec_ctx->codec_id = input_codec->id;
 
        //input_codec_ctx->time_base = input_stream->time_base;
 
        ret = avcodec_open2(input_codec_ctx, input_codec, opt.address());
 
        if (ret < 0)
        {
            if (m_hwaccel_dec_mode == HWACCELMODE::ENABLED)
            {
                Logging::info(filename(), "Unable to use %1 input codec '%2' with hardware acceleration. Falling back to software.", get_media_type_string(mediatype), avcodec_get_name(codec_id));
 
                m_hwaccel_dec_mode              = HWACCELMODE::FALLBACK;
                m_hwaccel_enable_dec_buffering  = false;
                m_dec_hw_pix_fmt                = AV_PIX_FMT_NONE;
 
                // Free hardware device contexts if open
                hwdevice_ctx_free(&m_hwaccel_dec_device_ctx);
 
                m_in.m_video.reset();
 
                // Try again with a software decoder
                continue;
            }
 
            Logging::error(filename(), "Failed to open %1 input codec for stream #%1 (error '%2').", get_media_type_string(mediatype), input_stream->index, ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
        Logging::debug(filename(), "Opened input codec for stream #%1: %2", input_stream->index, get_codec_name(codec_id, true));
 
        *codec_ctx = input_codec_ctx;
 
        return 0;
    };
}
 
int FFmpeg_Transcoder::open_output_frame_set(Buffer *buffer)
{
    const AVCodec * output_codec        = nullptr;
    AVCodecContext *output_codec_ctx    = nullptr;
    FFmpeg_Dictionary opt;
    int ret = 0;
 
    m_buffer            = buffer;
    {
        std::lock_guard<std::recursive_mutex> lock_seek_to_fifo_mutex(m_seek_to_fifo_mutex);
        while (m_seek_to_fifo.size())
        {
            m_seek_to_fifo.pop();
        }
    }
    m_have_seeked       = false;
 
    output_codec = avcodec_find_encoder(m_current_format->video_codec());
    if (output_codec == nullptr)
    {
        Logging::error(virtname(), "Codec not found.");
        return AVERROR(EINVAL);
    }
 
    output_codec_ctx = avcodec_alloc_context3(output_codec);
    if (output_codec_ctx == nullptr)
    {
        Logging::error(virtname(), "The video codec context could not be allocated.");
        return AVERROR(ENOMEM);
    }
 
    output_codec_ctx->bit_rate             = 400000;   
    output_codec_ctx->width                = m_in.m_video.m_codec_ctx->width;
    output_codec_ctx->height               = m_in.m_video.m_codec_ctx->height;
    output_codec_ctx->time_base            = {1, 25};
 
    const AVPixFmtDescriptor *dst_desc = av_pix_fmt_desc_get(m_in.m_video.m_codec_ctx->pix_fmt);
    int loss = 0;
 
#if LAVC_USE_SUPPORTED_CFG
    {
        const enum AVPixelFormat *pix_list = nullptr;
        int npix = 0;
        int ret_cfg = avcodec_get_supported_config(output_codec_ctx, output_codec,
                                                   AV_CODEC_CONFIG_PIX_FORMAT,
                                                   0, (const void**)&pix_list, &npix);
        if (ret_cfg >= 0 && pix_list && npix > 0)
        {
            output_codec_ctx->pix_fmt = avcodec_find_best_pix_fmt_of_list(pix_list, m_in.m_video.m_codec_ctx->pix_fmt, (dst_desc->flags & AV_PIX_FMT_FLAG_ALPHA) ? 1 : 0, &loss);
        }
        else
        {
            output_codec_ctx->pix_fmt = m_in.m_video.m_codec_ctx->pix_fmt;
        }
    }
#else
    output_codec_ctx->pix_fmt = avcodec_find_best_pix_fmt_of_list(output_codec->pix_fmts, m_in.m_video.m_codec_ctx->pix_fmt, (dst_desc->flags & AV_PIX_FMT_FLAG_ALPHA) ? 1 : 0, &loss);
#endif
 
    if (output_codec_ctx->pix_fmt == AV_PIX_FMT_NONE)
    {
        // No best match found, use default
        switch (m_current_format->video_codec())
        {
        case AV_CODEC_ID_MJPEG:
        {
            output_codec_ctx->pix_fmt   = AV_PIX_FMT_YUVJ444P;
            break;
        }
        case AV_CODEC_ID_PNG:
        {
            output_codec_ctx->pix_fmt   = AV_PIX_FMT_RGB24;
            break;
        }
        case AV_CODEC_ID_BMP:
        {
            output_codec_ctx->pix_fmt   = AV_PIX_FMT_BGR24;
            break;
        }
        default:
        {
            break;
        }
        }
        Logging::debug(virtname(), "There was no best match output pixel format found, so we used the default: %1", get_pix_fmt_name(output_codec_ctx->pix_fmt).c_str());
    }
    else
    {
        Logging::debug(virtname(), "Output pixel format: %1", get_pix_fmt_name(output_codec_ctx->pix_fmt).c_str());
    }
 
 
    switch (m_current_format->video_codec())
    {
    case AV_CODEC_ID_MJPEG:
    {
        // set -strict -1 for JPG
        dict_set_with_check(opt.address(), "strict", "-1", 0);
 
        // Allow the use of unoffical extensions
        output_codec_ctx->strict_std_compliance = FF_COMPLIANCE_UNOFFICIAL;
        break;
    }
    case AV_CODEC_ID_PNG:
    {
        output_codec_ctx->pix_fmt   = AV_PIX_FMT_RGB24;
        break;
    }
    case AV_CODEC_ID_BMP:
    {
        output_codec_ctx->pix_fmt   = AV_PIX_FMT_BGR24;
        break;
    }
    default:
    {
        break;
    }
    }
 
    //codec_ctx->sample_aspect_ratio  = frame->sample_aspect_ratio;
    //codec_ctx->sample_aspect_ratio  = m_in.m_video.m_codec_ctx->sample_aspect_ratio;
 
    ret = avcodec_open2(output_codec_ctx, output_codec, opt.address());
    if (ret < 0)
    {
        Logging::error(virtname(), "The image codec could not be opened.");
        return ret;
    }
 
    // Initialise pixel format conversion and rescaling if necessary
    get_pix_formats(&m_in.m_pix_fmt, &m_out.m_pix_fmt, output_codec_ctx);
 
    ret = init_rescaler(m_in.m_pix_fmt, m_in.m_video.m_stream->codecpar->width, m_in.m_video.m_stream->codecpar->height, m_out.m_pix_fmt, output_codec_ctx->width, output_codec_ctx->height);
    if (ret < 0)
    {
        return ret;
    }
 
    if (params.m_deinterlace)
    {
        ret = init_deinterlace_filters(output_codec_ctx, m_in.m_pix_fmt, m_in.m_video.m_stream->avg_frame_rate, m_in.m_video.m_stream->time_base);
        if (ret < 0)
        {
            return ret;
        }
    }
 
    m_out.m_video.set_codec_ctx(output_codec_ctx);
    m_out.m_video.m_stream_idx              = INVALID_STREAM;
    m_out.m_video.m_stream                  = nullptr;
 
    // No audio
    m_out.m_audio.set_codec_ctx(nullptr);
    m_out.m_audio.m_stream_idx              = INVALID_STREAM;
    m_out.m_audio.m_stream                  = nullptr;
 
    // Open for read/write
    // Pre-allocate the predicted file size to reduce memory reallocations
    size_t buffsize = predicted_filesize() * video_frame_count();
 
    if (!buffer->open_file(0, CACHE_FLAG_RW, buffsize))
    {
        return AVERROR(EPERM);
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::open_output(Buffer *buffer)
{
    int ret = 0;
 
    m_buffer = buffer;
    m_insert_keyframe = false;
 
    if (!m_out.m_video_pts && is_hls())
    {
        const bool hls_segment_preselected = m_current_segment > 1;
 
        if (!hls_segment_preselected)
        {
            m_current_segment = 1;
 
            // The first output open is special: start_new_segment() has not run yet,
            // so a seek stacked before opening the output would otherwise not be
            // consumed until after segment 1 had already been opened and encoded.
            // Consume an initial HLS seek here and position the input before any
            // output segment is opened.
            uint32_t initial_seek_segment = 0;
            {
                std::lock_guard<std::recursive_mutex> lock_seek_to_fifo_mutex(m_seek_to_fifo_mutex);
                while (!m_seek_to_fifo.empty())
                {
                    const uint32_t segment_no = m_seek_to_fifo.front();
                    m_seek_to_fifo.pop();
 
                    if (segment_no > 1)
                    {
                        initial_seek_segment = segment_no;
                        break;
                    }
                }
            }
 
            if (initial_seek_segment)
            {
                int ret = 0;
                const int64_t pos = (initial_seek_segment - 1) * params.m_segment_duration;
 
                m_reset_pts    = FFMPEGFS_AUDIO | FFMPEGFS_VIDEO;
                m_have_seeked   = true;
 
                Logging::info(virtname(), "Performing seek request to HLS segment no. %1.", initial_seek_segment);
 
                if (stream_exists(m_in.m_video.m_stream_idx) && m_in.m_video.m_stream != nullptr)
                {
                    int64_t vstream_pts = ffmpeg_rescale_q(pos, av_get_time_base_q(), m_in.m_video.m_stream->time_base);
 
                    if (m_in.m_video.m_stream->start_time != AV_NOPTS_VALUE)
                    {
                        vstream_pts += m_in.m_video.m_stream->start_time;
                    }
 
                    ret = av_seek_frame(m_in.m_format_ctx, m_in.m_video.m_stream_idx, vstream_pts, AVSEEK_FLAG_BACKWARD);
                }
                else if (stream_exists(m_in.m_audio.m_stream_idx) && m_in.m_audio.m_stream != nullptr)
                {
                    int64_t astream_pts = ffmpeg_rescale_q(pos, av_get_time_base_q(), m_in.m_audio.m_stream->time_base);
 
                    if (m_in.m_audio.m_stream->start_time != AV_NOPTS_VALUE)
                    {
                        astream_pts += m_in.m_audio.m_stream->start_time;
                    }
 
                    ret = av_seek_frame(m_in.m_format_ctx, m_in.m_audio.m_stream_idx, astream_pts, AVSEEK_FLAG_BACKWARD);
                }
 
                if (ret < 0)
                {
                    Logging::error(virtname(), "Seek failed on input file (error '%1').", ffmpeg_geterror(ret).c_str());
                    return ret;
                }
 
                flush_buffers();
                purge_hls_fifo();
 
                m_current_segment = initial_seek_segment;
            }
        }
 
        Logging::info(virtname(), "Starting HLS segment no. %1 of %2.", m_current_segment, m_virtualfile->get_segment_count());
 
        // HLS uses one physical cache file per segment.  Select the cache file
        // for the current segment before opening the output format and before
        // avformat_write_header()/process_output() can emit any data.  This is
        // especially important for repair runs after a seek, where the first
        // segment written may be segment 2 or later rather than segment 1.
        const uint32_t segment_count = m_virtualfile != nullptr ? m_virtualfile->get_segment_count() : 0;
        if (!segment_count || !m_current_segment || m_current_segment > segment_count)
        {
            return AVERROR(EINVAL);
        }
 
        size_t segment_buffsize = m_virtualfile->m_predicted_size / segment_count;
        if (!segment_buffsize)
        {
            segment_buffsize = static_cast<size_t>(sysconf(_SC_PAGESIZE));
        }
 
        if (!buffer->set_segment(m_current_segment, segment_buffsize))
        {
            return AVERROR(errno);
        }
    }
 
    while (true)
    {
        // Open the output file for writing. If buffer == nullptr continue using existing buffer.
        ret = open_output_filestreams(buffer);
        if (ret)
        {
            if (m_hwaccel_enc_mode == HWACCELMODE::ENABLED)
            {
                Logging::info(virtname(), "Unable to use output codec '%1' with hardware acceleration. Falling back to software.", avcodec_get_name(m_current_format->video_codec()));
 
                m_hwaccel_enc_mode              = HWACCELMODE::FALLBACK;
                m_hwaccel_enable_enc_buffering  = false;
                m_enc_hw_pix_fmt                = AV_PIX_FMT_NONE;
 
                // Free hardware device contexts if open
                hwdevice_ctx_free(&m_hwaccel_enc_device_ctx);
 
                close_output_file();
 
                // Try again with a software decoder
                continue;
            }
            return ret;
        }
        break;
    }
 
    if (stream_exists(m_out.m_audio.m_stream_idx))
    {
        audio_info(true, m_out.m_format_ctx, m_out.m_audio.m_stream);
 
        if (m_out.m_audio.m_codec_ctx != nullptr)
        {
            // If not just copying the stream, initialise the audio FIFO buffer to store audio samples to be encoded.
            ret = init_audio_fifo();
            if (ret)
            {
                return ret;
            }
        }
    }
 
    if (stream_exists(m_out.m_video.m_stream_idx))
    {
        video_info(true, m_out.m_format_ctx, m_out.m_video.m_stream);
    }
 
    for (const auto & [key, value] : m_out.m_subtitle)
    {
        subtitle_info(true, m_out.m_format_ctx, value.m_stream);
    }
 
    if (!is_hls())
    {
        // Open regular output files for read/write.
        // HLS output uses one cache file per segment; the active segment was
        // already selected above with Buffer::set_segment().  Opening segment
        // 0 here would switch the active cache file back to the first segment
        // and make repair/seek runs append the following output to 000001.ts.
        size_t buffsize = predicted_filesize();
        if (!buffer->open_file(0, CACHE_FLAG_RW, buffsize))
        {
            return AVERROR(EPERM);
        }
    }
 
    ret = process_output();
    if (ret)
    {
        return ret;
    }
 
    // process_output() calls avformat_write_header which feels free to change the stream time bases sometimes.
    // This means we have to do the following calculations here to use the correct values, otherwise this can cause
    // a lot of havoc.
 
    if (m_in.m_audio.m_stream != nullptr && m_out.m_audio.m_stream != nullptr && m_in.m_audio.m_stream->start_time != AV_NOPTS_VALUE)
    {
        m_in.m_audio.m_start_time               = m_in.m_audio.m_stream->start_time;
        m_out.m_audio.m_start_time              = ffmpeg_rescale_q_rnd(m_in.m_audio.m_stream->start_time, m_in.m_audio.m_stream->time_base, m_out.m_audio.m_stream->time_base);
        m_out.m_audio.m_stream->start_time      = m_out.m_audio.m_start_time;
    }
    else
    {
        m_in.m_audio.m_start_time               = 0;
        m_out.m_audio.m_start_time              = 0;
        if (m_out.m_audio.m_stream)
        {
            m_out.m_audio.m_stream->start_time  = AV_NOPTS_VALUE;
        }
    }
 
    if (m_in.m_video.m_stream != nullptr && m_out.m_video.m_stream != nullptr && m_in.m_video.m_stream->start_time != AV_NOPTS_VALUE)
    {
        m_in.m_video.m_start_time               = m_in.m_video.m_stream->start_time;
        m_out.m_video.m_start_time              = ffmpeg_rescale_q_rnd(m_in.m_video.m_stream->start_time, m_in.m_video.m_stream->time_base, m_out.m_video.m_stream->time_base);
        m_out.m_video.m_stream->start_time      = m_out.m_video.m_start_time;
    }
    else
    {
        m_in.m_video.m_start_time               = 0;
        m_out.m_video.m_start_time              = 0;
        if (m_out.m_video.m_stream)
        {
            m_out.m_video.m_stream->start_time  = AV_NOPTS_VALUE;
        }
    }
 
    for (auto & [key, value] : m_out.m_subtitle)
    {
        StreamRef * out_streamref = get_out_subtitle_stream(map_in_to_out_stream(key));
        if (out_streamref != nullptr)
        {
            value.m_start_time                      = value.m_stream->start_time;
            out_streamref->m_start_time             = ffmpeg_rescale_q_rnd(value.m_stream->start_time, value.m_stream->time_base, out_streamref->m_stream->time_base);
            out_streamref->m_stream->start_time     = out_streamref->m_start_time;
        }
    }
 
    m_out.m_audio_pts         = m_out.m_audio.m_start_time;
    m_out.m_video_pts         = m_out.m_video.m_start_time;
    m_out.m_last_mux_dts      = AV_NOPTS_VALUE;
 
    return 0;
}
 
int FFmpeg_Transcoder::process_output()
{
    // Process metadata. The decoder will call the encoder to set appropriate
    // tag values for the output file.
    int ret = process_metadata();
    if (ret)
    {
        return ret;
    }
 
    // Write the header of the output file container.
    ret = write_output_file_header();
    if (ret)
    {
        return ret;
    }
 
    // Process album arts: copy all from source file to target.
    return process_albumarts();
}
 
bool FFmpeg_Transcoder::get_output_sample_rate(int input_sample_rate, int max_sample_rate, int *output_sample_rate /*= nullptr*/)
{
    if (input_sample_rate > max_sample_rate)
    {
        if (output_sample_rate != nullptr)
        {
            *output_sample_rate = max_sample_rate;
        }
        return true;
    }
    else
    {
        if (output_sample_rate != nullptr)
        {
            *output_sample_rate = input_sample_rate;
        }
        return false;
    }
}
 
bool FFmpeg_Transcoder::get_output_bit_rate(BITRATE input_bit_rate, BITRATE max_bit_rate, BITRATE * output_bit_rate /*= nullptr*/)
{
    if (!input_bit_rate || input_bit_rate > max_bit_rate)
    {
        if (output_bit_rate != nullptr)
        {
            *output_bit_rate = max_bit_rate;
        }
        return true;
    }
    else
    {
        if (output_bit_rate != nullptr)
        {
            *output_bit_rate = input_bit_rate;
        }
        return false;
    }
}
 
bool FFmpeg_Transcoder::get_aspect_ratio(int width, int height, const AVRational & sar, AVRational *ar) const
{
    // Try to determine display aspect ratio
    AVRational dar;
 
    ::av_reduce(&dar.num, &dar.den,
                static_cast<int64_t>(width)  * sar.num,
                static_cast<int64_t>(height) * sar.den,
                1024 * 1024);
 
    ar->num = ar->den = 0;
 
    if (dar.num && dar.den)
    {
        *ar = dar;
    }
 
    // If that fails, try sample aspect ratio instead
    if (!ar->den && sar.num != 0 && sar.den != 0)
    {
        *ar = sar;
    }
 
    // If even that fails, try to use video size
    if (!ar->den && height)
    {
        ar->num = width;
        ar->den = height;
    }
 
    if (!ar->den)
    {
        // Return false if all above failed
        return false;
    }
 
    ::av_reduce(&ar->num, &ar->den,
                ar->num,
                ar->den,
                1024 * 1024);
 
    return true;
}
 
bool FFmpeg_Transcoder::get_video_size(int *output_width, int *output_height) const
{
    if (!params.m_videowidth && !params.m_videoheight)
    {
        // No options, leave as is
        return false;
    }
 
    int input_width     = m_in.m_video.m_stream->codecpar->width;
    int input_height    = m_in.m_video.m_stream->codecpar->height;
    AVRational sar      = m_in.m_video.m_stream->codecpar->sample_aspect_ratio;
 
    if (params.m_videowidth && params.m_videoheight)
    {
        // Both width/source set. May look strange, but this is an order...
        *output_width   = params.m_videowidth;
        *output_height  = params.m_videoheight;
    }
    else if (params.m_videowidth)
    {
        // Only video width
        AVRational ar;
 
        *output_width      = params.m_videowidth;
 
        if (!get_aspect_ratio(input_width, input_height, sar, &ar))
        {
            *output_height = input_height;
        }
        else
        {
            *output_height = static_cast<int>(params.m_videowidth / av_q2d(ar));
            *output_height &= ~(static_cast<int>(0x1)); // height must be multiple of 2
        }
    }
    else //if (params.m_videoheight)
    {
        // Only video height
        AVRational ar;
 
        if (!get_aspect_ratio(input_width, input_height, sar, &ar))
        {
            *output_width  = input_width;
        }
        else
        {
            *output_width  = static_cast<int>(params.m_videoheight / av_q2d(ar));
            *output_width  &= ~(static_cast<int>(0x1)); // width must be multiple of 2
        }
        *output_height     = params.m_videoheight;
    }
 
    return (input_width > *output_width || input_height > *output_height);
}
 
int FFmpeg_Transcoder::update_codec(void *opt, const PROFILE_OPTION_VEC& profile_option_vec) const
{
    int ret = 0;
 
    for (const PROFILE_OPTION & profile_option : profile_option_vec)
    {
        if ((m_hwaccel_enable_enc_buffering && profile_option.m_options & OPT_SW_ONLY) || (!m_hwaccel_enable_enc_buffering && profile_option.m_options & OPT_HW_ONLY))
        {
            continue;
        }
 
        Logging::trace(virtname(), "Profile codec option -%1%2%3.", profile_option.m_key, *profile_option.m_value ? " " : "", profile_option.m_value);
 
        ret = opt_set_with_check(opt, profile_option.m_key, profile_option.m_value, profile_option.m_flags, virtname());
        if (ret < 0)
        {
            break;
        }
    }
    return ret;
}
 
int FFmpeg_Transcoder::prepare_codec(void *opt, FILETYPE filetype) const
{
    int ret = 0;
 
    for (const PROFILE_LIST & profile : m_profile)
    {
        if (profile.m_filetype == filetype)
        {
            ret = AVERROR_OPTION_NOT_FOUND; // Once we found the file type, we also need to find the profile. Otherwise we have an invalid command line option.
            if (profile.m_profile == params.m_profile)
            {
                ret = update_codec(opt, profile.m_option_codec);
                break;
            }
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::init_rescaler(AVPixelFormat in_pix_fmt, int in_width, int in_height, AVPixelFormat out_pix_fmt, int out_width, int out_height)
{
    if (in_pix_fmt != out_pix_fmt || in_width != out_width || in_height != out_height)
    {
        // Rescale image if required
        if (in_pix_fmt != out_pix_fmt)
        {
            Logging::trace(virtname(), "Initialising pixel format conversion from %1 to %2.", get_pix_fmt_name(in_pix_fmt).c_str(), get_pix_fmt_name(out_pix_fmt).c_str());
        }
 
        if (in_width != out_width || in_height != out_height)
        {
            Logging::debug(virtname(), "Rescaling video size from %1:%2 to %3:%4.",
                           in_width, in_height,
                           out_width, out_height);
        }
 
        m_sws_ctx.reset(sws_getContext(
                    // Source settings
                    in_width,               // width
                    in_height,              // height
                    in_pix_fmt,             // format
                    // Target settings
                    out_width,              // width
                    out_height,             // height
                    out_pix_fmt,            // format
                    SWS_FAST_BILINEAR, nullptr, nullptr, nullptr));    // Maybe SWS_LANCZOS | SWS_ACCURATE_RND
        if (m_sws_ctx == nullptr)
        {
            Logging::error(virtname(), "Could not allocate a scaling/conversion context.");
            return AVERROR(ENOMEM);
        }
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::add_stream(AVCodecID codec_id)
{
    AVCodecContext *output_codec_ctx    = nullptr;
    AVStream *      output_stream       = nullptr;
#if IF_DECLARED_CONST
    const AVCodec * output_codec        = nullptr;
#else // !IF_DECLARED_CONST
    AVCodec * output_codec              = nullptr;
#endif // !IF_DECLARED_CONST
    FFmpeg_Dictionary opt;
    int ret;
 
    std::string codec_name;
 
    if (get_hw_encoder_name(codec_id, &codec_name) || m_hwaccel_enc_mode == HWACCELMODE::FALLBACK)
    {
        // find the encoder
        output_codec = avcodec_find_encoder(codec_id);
 
        if (output_codec == nullptr)
        {
            Logging::error(virtname(), "Could not find encoder '%1'.", avcodec_get_name(codec_id));
            return AVERROR(EINVAL);
        }
    }
    else
    {
        output_codec = avcodec_find_encoder_by_name(codec_name.c_str());
 
        if (output_codec == nullptr)
        {
            Logging::error(virtname(), "Could not find encoder '%1'.", codec_name.c_str());
            return AVERROR(EINVAL);
        }
 
        //Logging::info(virtname(), "Hardware encoder acceleration active with codec '%1'.", output_codec->name);
 
        m_hwaccel_enc_mode = HWACCELMODE::ENABLED;
    }
 
    output_stream = avformat_new_stream(m_out.m_format_ctx, output_codec);
    if (output_stream == nullptr)
    {
        Logging::error(virtname(), "Could not allocate stream for encoder '%1'.",  avcodec_get_name(codec_id));
        return AVERROR(ENOMEM);
    }
    output_stream->id = static_cast<int>(m_out.m_format_ctx->nb_streams - 1);
 
    output_codec_ctx = avcodec_alloc_context3(output_codec);
    if (output_codec_ctx == nullptr)
    {
        Logging::error(virtname(), "Could not allocate an encoding context.");
        return AVERROR(ENOMEM);
    }
 
    switch (output_codec->type)
    {
    case AVMEDIA_TYPE_AUDIO:
    {
        BITRATE orig_bit_rate;
        int orig_sample_rate;
 
        // Set the basic encoder parameters
        orig_bit_rate = (m_in.m_audio.m_stream->codecpar->bit_rate != 0) ? m_in.m_audio.m_stream->codecpar->bit_rate : m_in.m_format_ctx->bit_rate;
        if (get_output_bit_rate(orig_bit_rate, params.m_audiobitrate, &output_codec_ctx->bit_rate))
        {
            // Limit bit rate
            Logging::trace(virtname(), "Limiting audio bit rate from %1 to %2.",
                           format_bitrate(orig_bit_rate).c_str(),
                           format_bitrate(output_codec_ctx->bit_rate).c_str());
        }
 
        if (params.m_audiochannels > 0 && get_channels(m_in.m_audio.m_codec_ctx.get()) > params.m_audiochannels)
        {
            Logging::trace(virtname(), "Limiting audio channels from %1 to %2.",
                           get_channels(m_in.m_audio.m_codec_ctx.get()),
                           params.m_audiochannels);
            set_channels(output_codec_ctx, params.m_audiochannels);
        }
        else
        {
            set_channels(output_codec_ctx, m_in.m_audio.m_codec_ctx.get());
        }
 
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
        av_channel_layout_default(&output_codec_ctx->ch_layout, output_codec_ctx->ch_layout.nb_channels);
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
        output_codec_ctx->channel_layout        = static_cast<uint64_t>(av_get_default_channel_layout(output_codec_ctx->channels));
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
 
        output_codec_ctx->sample_rate           = m_in.m_audio.m_codec_ctx->sample_rate;
        orig_sample_rate                        = m_in.m_audio.m_codec_ctx->sample_rate;
        if (get_output_sample_rate(m_in.m_audio.m_stream->codecpar->sample_rate, params.m_audiosamplerate, &output_codec_ctx->sample_rate))
        {
            // Limit sample rate
            Logging::trace(virtname(), "Limiting audio sample rate from %1 to %2.",
                           format_samplerate(orig_sample_rate).c_str(),
                           format_samplerate(output_codec_ctx->sample_rate).c_str());
            orig_sample_rate = output_codec_ctx->sample_rate;
        }
 
#if LAVC_USE_SUPPORTED_CFG
        {
            const int *supported_samplerates = nullptr;
            int num_samplerates = 0;
            int ret_cfg = avcodec_get_supported_config(output_codec_ctx, output_codec,
                                                       AV_CODEC_CONFIG_SAMPLE_RATE,
                                                       0, (const void**)&supported_samplerates,
                                                       &num_samplerates);
            if (ret_cfg >= 0 && supported_samplerates && num_samplerates > 0)
            {
                bool exact_match = false;
                for (int n = 0; n < num_samplerates; n++)
                {
                    if (supported_samplerates[n] == output_codec_ctx->sample_rate)
                    {
                        exact_match = true;
                        break;
                    }
                }
                if (!exact_match)
                {
                    int min_samplerate = 0, max_samplerate = INT_MAX;
                    for (int n = 0; n < num_samplerates; n++)
                    {
                        int s = supported_samplerates[n];
                        if (min_samplerate <= s && output_codec_ctx->sample_rate >= s)
                            min_samplerate = s;
                    }
 
                    for (int n = 0; n < num_samplerates; n++)
                    {
                        int s = supported_samplerates[n];
                        if (max_samplerate >= s && output_codec_ctx->sample_rate <= s)
                            max_samplerate = s;
                    }
 
                    if (min_samplerate != 0 && max_samplerate != INT_MAX)
                    {
                        if (output_codec_ctx->sample_rate - min_samplerate < max_samplerate - output_codec_ctx->sample_rate)
                            output_codec_ctx->sample_rate = min_samplerate;
                        else
                            output_codec_ctx->sample_rate = max_samplerate;
                    }
                    else if (min_samplerate != 0)
                    {
                        output_codec_ctx->sample_rate = min_samplerate;
                    }
                    else if (max_samplerate != INT_MAX)
                    {
                        output_codec_ctx->sample_rate = max_samplerate;
                    }
                    else
                    {
                        for (int n = 0; n < num_samplerates; n++)
                            if (supported_samplerates[n] == 48000)
                            {
                                output_codec_ctx->sample_rate = 48000;
                                break;
                            }
 
                        if (output_codec_ctx->sample_rate <= 0)
                            output_codec_ctx->sample_rate = supported_samplerates[0];
                    }
                }
            }
        }
#else
        if (output_codec->supported_samplerates != nullptr)
        {
            // Go through supported sample rates and adjust if necessary
            bool supported = false;
 
            for (int n = 0; output_codec->supported_samplerates[n] != 0; n++)
            {
                if (output_codec->supported_samplerates[n] == output_codec_ctx->sample_rate)
                {
                    // Is supported
                    supported = true;
                    break;
                }
            }
 
            if (!supported)
            {
                int min_samplerate = 0;
                int max_samplerate = INT_MAX;
 
                // Find next lower sample rate in probably unsorted list
                for (int n = 0; output_codec->supported_samplerates[n] != 0; n++)
                {
                    if (min_samplerate <= output_codec->supported_samplerates[n] && output_codec_ctx->sample_rate >= output_codec->supported_samplerates[n])
                    {
                        min_samplerate = output_codec->supported_samplerates[n];
                    }
                }
 
                // Find next higher sample rate in probably unsorted list
                for (int n = 0; output_codec->supported_samplerates[n] != 0; n++)
                {
                    if (max_samplerate >= output_codec->supported_samplerates[n] && output_codec_ctx->sample_rate <= output_codec->supported_samplerates[n])
                    {
                        max_samplerate = output_codec->supported_samplerates[n];
                    }
                }
 
                if (min_samplerate != 0 && max_samplerate != INT_MAX)
                {
                    // set to nearest value
                    if (output_codec_ctx->sample_rate - min_samplerate < max_samplerate - output_codec_ctx->sample_rate)
                    {
                        output_codec_ctx->sample_rate = min_samplerate;
                    }
                    else
                    {
                        output_codec_ctx->sample_rate = max_samplerate;
                    }
                }
                else if (min_samplerate != 0)
                {
                    // No higher sample rate, use next lower
                    output_codec_ctx->sample_rate = min_samplerate;
                }
                else if (max_samplerate != INT_MAX)
                {
                    // No lower sample rate, use higher lower
                    output_codec_ctx->sample_rate = max_samplerate;
                }
                else
                {
                    // Should never happen... There must at least be one.
                    Logging::error(virtname(), "The codec does not support an audio sample rate of %1.", format_samplerate(output_codec_ctx->sample_rate).c_str());
                    return AVERROR(EINVAL);
                }
 
                Logging::debug(virtname(), "Because the requested value is not supported by codec, the audio sample rate was changed from %1 to %2.",
                               format_samplerate(orig_sample_rate).c_str(),
                               format_samplerate(output_codec_ctx->sample_rate).c_str());
            }
        }
#endif
 
        // If sample format not pre-defined (not AV_SAMPLE_FMT_NONE), use input file setting.
        AVSampleFormat in_sample_format = (m_current_format->sample_format() == AV_SAMPLE_FMT_NONE) ? m_in.m_audio.m_codec_ctx->sample_fmt : m_current_format->sample_format();
#if LAVC_USE_SUPPORTED_CFG
        {
            // Query supported sample formats via the new API
            const enum AVSampleFormat *sample_fmts = nullptr;
            int num_fmts = 0;
            int ret_cfg = avcodec_get_supported_config(output_codec_ctx, output_codec,
                                                       AV_CODEC_CONFIG_SAMPLE_FORMAT,
                                                       0, (const void**)&sample_fmts,
                                                       &num_fmts);
            if (ret_cfg >= 0 && sample_fmts && num_fmts > 0)
            {
                AVSampleFormat input_fmt_planar = av_get_planar_sample_fmt(in_sample_format);
                for (int i = 0; i < num_fmts; i++)
                {
                    AVSampleFormat output_fmt_planar = av_get_planar_sample_fmt(sample_fmts[i]);
                    if (sample_fmts[i] == in_sample_format ||
                            (input_fmt_planar != AV_SAMPLE_FMT_NONE && input_fmt_planar == output_fmt_planar))
                    {
                        output_codec_ctx->sample_fmt = sample_fmts[i];
                        break;
                    }
                }
                if (output_codec_ctx->sample_fmt == AV_SAMPLE_FMT_NONE)
                {
                    // Fallback: first supported format
                    output_codec_ctx->sample_fmt = sample_fmts[0];
                }
            }
            else
            {
                // If supported sample formats are unknown simply take input format
                output_codec_ctx->sample_fmt = in_sample_format;
            }
        }
#else
        if (output_codec->sample_fmts != nullptr)
        {
            // Check if input sample format is supported and if so, use it (avoiding resampling)
            AVSampleFormat input_fmt_planar = av_get_planar_sample_fmt(in_sample_format);
 
            output_codec_ctx->sample_fmt        = AV_SAMPLE_FMT_NONE;
 
            for (const AVSampleFormat *sample_fmt = output_codec->sample_fmts; *sample_fmt != -1; sample_fmt++)
            {
                AVSampleFormat output_fmt_planar = av_get_planar_sample_fmt(*sample_fmt);
 
                if (*sample_fmt == in_sample_format ||
                        (input_fmt_planar != AV_SAMPLE_FMT_NONE &&
                         input_fmt_planar == output_fmt_planar))
                {
                    output_codec_ctx->sample_fmt    = *sample_fmt;
                    break;
                }
            }
 
            // If none of the supported formats match use the first supported
            if (output_codec_ctx->sample_fmt == AV_SAMPLE_FMT_NONE)
            {
                output_codec_ctx->sample_fmt    = output_codec->sample_fmts[0];
            }
        }
        else
        {
            // If supported sample formats are unknown simply take input format and cross our fingers it'll work...
            output_codec_ctx->sample_fmt        = in_sample_format;
        }
#endif
        // Set the sample rate for the container.
        output_stream->time_base.den            = output_codec_ctx->sample_rate;
        output_stream->time_base.num            = 1;
        output_codec_ctx->time_base             = output_stream->time_base;
 
        // set -strict -2 for aac (required for FFmpeg 2)
        dict_set_with_check(opt.address(), "strict", "-2", 0);
 
        // Allow the use of the experimental AAC encoder
        output_codec_ctx->strict_std_compliance = FF_COMPLIANCE_EXPERIMENTAL;
 
        // Set duration as hint for muxer
        if (m_in.m_audio.m_stream->duration != AV_NOPTS_VALUE)
        {
            output_stream->duration             = ffmpeg_rescale_q(m_in.m_audio.m_stream->duration, m_in.m_audio.m_stream->time_base, output_stream->time_base);
        }
        else if (m_in.m_format_ctx->duration != AV_NOPTS_VALUE)
        {
            output_stream->duration             = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), output_stream->time_base);
        }
 
        //av_dict_set_int(&output_stream->metadata, "DURATION", output_stream->duration, AV_DICT_IGNORE_SUFFIX);
 
        // Save the encoder context for easier access later.
        m_out.m_audio.set_codec_ctx(output_codec_ctx);
        // Save the stream index
        m_out.m_audio.m_stream_idx              = output_stream->index;
        // Save output audio stream for faster reference
        m_out.m_audio.m_stream                  = output_stream;
 
        // Update input to output stream map, this is rather boring because currently we only have a single audio stream
        add_stream_map(m_in.m_audio.m_stream_idx, m_out.m_audio.m_stream_idx);
        break;
    }
    case AVMEDIA_TYPE_VIDEO:
    {
        BITRATE orig_bit_rate;
 
        if (m_hwaccel_enable_enc_buffering && m_hwaccel_enc_device_ctx != nullptr)
        {
            Logging::debug(virtname(), "Hardware encoder init: Creating a new hardware frame context for the encoder.", get_hwaccel_API_text(params.m_hwaccel_enc_API).c_str());
 
            m_enc_hw_pix_fmt = get_hw_pix_fmt(output_codec, params.m_hwaccel_enc_device_type, false);
 
            ret = hwframe_ctx_set(output_codec_ctx, m_in.m_video.m_codec_ctx.get(), m_hwaccel_enc_device_ctx);
            if (ret < 0)
            {
                return ret;
            }
        }
 
        output_codec_ctx->codec_id = codec_id;
 
        // Set the basic encoder parameters
        orig_bit_rate = (m_in.m_video.m_stream->codecpar->bit_rate != 0) ? m_in.m_video.m_stream->codecpar->bit_rate : m_in.m_format_ctx->bit_rate;
        if (get_output_bit_rate(orig_bit_rate, params.m_videobitrate, &output_codec_ctx->bit_rate))
        {
            // Limit sample rate
            Logging::trace(virtname(), "Limiting video bit rate from %1 to %2.",
                           format_bitrate(orig_bit_rate).c_str(),
                           format_bitrate(output_codec_ctx->bit_rate).c_str());
        }
 
        // output_codec_ctx->rc_min_rate = output_codec_ctx->bit_rate * 75 / 100;
        // output_codec_ctx->rc_max_rate = output_codec_ctx->bit_rate * 125 / 100;
 
        // output_codec_ctx->qmin = 1;
        // output_codec_ctx->qmax = 31;
 
        int width = 0;
        int height = 0;
        if (get_video_size(&width, &height))
        {
            Logging::trace(virtname(), "Changing video size from %1/%2 to %3/%4.", output_codec_ctx->width, output_codec_ctx->height, width, height);
            output_codec_ctx->width             = width;
            output_codec_ctx->height            = height;
        }
        else
        {
            output_codec_ctx->width             = m_in.m_video.m_stream->codecpar->width;
            output_codec_ctx->height            = m_in.m_video.m_stream->codecpar->height;
        }
 
        video_stream_setup(output_codec_ctx, output_stream, m_in.m_video.m_codec_ctx.get(), m_in.m_video.m_stream->avg_frame_rate, m_enc_hw_pix_fmt);
 
        if (!m_hwaccel_enable_enc_buffering && output_codec_ctx->codec_id == AV_CODEC_ID_H264 && m_out.m_filetype == FILETYPE::HLS && output_codec_ctx->pix_fmt != AV_PIX_FMT_YUV420P)
        {
            Logging::info(virtname(), "Forcing HLS/H.264 output pixel format from %1 to yuv420p for browser-compatible 8-bit output.", get_pix_fmt_name(output_codec_ctx->pix_fmt).c_str());
            output_codec_ctx->pix_fmt = AV_PIX_FMT_YUV420P;
        }
 
        AVRational sample_aspect_ratio                      = m_in.m_video.m_stream->codecpar->sample_aspect_ratio;
 
        if (output_codec_ctx->codec_id != AV_CODEC_ID_VP9 && m_out.m_filetype != FILETYPE::MKV)
        {
            output_codec_ctx->sample_aspect_ratio           = sample_aspect_ratio;
            output_stream->codecpar->sample_aspect_ratio    = sample_aspect_ratio;
        }
 
        else
        {
            // WebM and MKV do not respect the aspect ratio and always use 1:1 so we need to rescale "manually".
            output_codec_ctx->sample_aspect_ratio           = { 1, 1 };
            output_stream->codecpar->sample_aspect_ratio    = { 1, 1 };
 
            // Make sure we do not zero width
            if (sample_aspect_ratio.num && sample_aspect_ratio.den)
            {
                output_codec_ctx->width                       = output_codec_ctx->width * sample_aspect_ratio.num / sample_aspect_ratio.den;
            }
            //output_codec_ctx->height                        *= sample_aspect_ratio.den;
        }
 
        // Set up optimisations
        switch (output_codec_ctx->codec_id)
        {
        case AV_CODEC_ID_H264:
        {
            ret = prepare_codec(output_codec_ctx->priv_data, m_out.m_filetype);
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not set profile for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                return ret;
            }
 
            if (m_hwaccel_enable_enc_buffering)
            {
                // For hardware encoding only
 
                // Defaults to 20. Set to 40 to create slightly smaller results (the bigger, the smaller the files).
                // Values seem to range between 1 and 51.
                // Must be non-zero, otherwise hardware encoding my fail with:
                // "Driver does not support any RC mode compatible with selected options (supported modes: CQP)."
                output_codec_ctx->global_quality = 40;
            }
 
            //#define EXPERIMENTAL
#ifdef EXPERIMENTAL
            if (m_hwaccel_enable_enc_buffering)
            {
                // For hardware encoding only
#if 0
                // From libavcodec/vaapi_encode.c:
                //
                // Rate control mode selection:
                // * If the user has set a mode explicitly with the rc_mode option,
                //   use it and fail if it is not available.
                // * If an explicit QP option has been set, use CQP.
                // * If the codec is CQ-only, use CQP.
                // * If the QSCALE avcodec option is set, use CQP.
                // * If bitrate and quality are both set, try QVBR.
                // * If quality is set, try ICQ, then CQP.
                // * If bitrate and maxrate are set and have the same value, try CBR.
                // * If a bitrate is set, try AVBR, then VBR, then CBR.
                // * If no bitrate is set, try ICQ, then CQP.
                ret = av_opt_set(output_codec_ctx->priv_data, "rc_mode", "CQP", AV_OPT_SEARCH_CHILDREN);
                if (ret < 0)
                {
                    Logging::error(virtname(), "Could not set 'rc_mode=CQP' for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                    return ret;
                }
 
                // The range of the CRF scale is 0–51, where 0 is lossless (for 8 bit only, for 10 bit use -qp 0),
                // 23 is the default, and 51 is worst quality possible. A lower value generally leads to higher
                // quality, and a subjectively sane range is 17–28. Consider 17 or 18 to be visually lossless or
                // nearly so; it should look the same or nearly the same as the input but it isn't technically lossless.
                // See https://trac.ffmpeg.org/wiki/Encode/H.264
                ret = av_opt_set(output_codec_ctx->priv_data, "qp", "30", AV_OPT_SEARCH_CHILDREN);
                if (ret < 0)
                {
                    Logging::error(virtname(), "Could not set 'qp' for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                    return ret;
                }
#endif
            }
            else
            {
                // Software encoding
#if 0
                // Affects hard- and software encoding
                //
                // The range of the CRF scale is 0–51, where 0 is lossless (for 8 bit only, for 10 bit use -qp 0),
                // 23 is the default, and 51 is worst quality possible. A lower value generally leads to higher
                // quality, and a subjectively sane range is 17–28. Consider 17 or 18 to be visually lossless or
                // nearly so; it should look the same or nearly the same as the input but it isn't technically lossless.
                // See https://trac.ffmpeg.org/wiki/Encode/H.264
                ret = av_opt_set(output_codec_ctx->priv_data, "qp", "30", AV_OPT_SEARCH_CHILDREN);
                if (ret < 0)
                {
                    Logging::error(virtname(), "Could not set 'qp' for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                    return ret;
                }
#endif
 
#if 0
                // Set constant rate factor to avoid getting huge result files
                // The default is 23, but values between 30..40 create properly sized results.
                // Possible values are 0 (lossless) to 51 (very small but ugly results).
                ret = av_opt_set(output_codec_ctx->priv_data, "crf", "30", AV_OPT_SEARCH_CHILDREN);
                if (ret < 0)
                {
                    Logging::error(virtname(), "Could not set 'crf' for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                    return ret;
                }
#endif
            }
#endif // EXPERIMENTAL
 
            // Avoid mismatches for H264 and profile
            uint8_t   *out_val;
            ret = av_opt_get(output_codec_ctx->priv_data, "profile", 0, &out_val);
            if (!ret)
            {
                if (!strcasecmp(reinterpret_cast<const char *>(out_val), "high"))
                {
                    switch (output_codec_ctx->pix_fmt)
                    {
                    case AV_PIX_FMT_YUV420P9BE:
                    case AV_PIX_FMT_YUV420P9LE:
                    case AV_PIX_FMT_YUV420P10BE:
                    case AV_PIX_FMT_YUV420P10LE:
                    {
                        ret = av_opt_set(output_codec_ctx->priv_data, "profile", "high10", 0);
                        if (ret < 0)
                        {
                            Logging::error(virtname(), "Could not set profile=high10 for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                            return ret;
                        }
                        break;
                    }
                    case AV_PIX_FMT_YUYV422:
                    case AV_PIX_FMT_YUV422P:
                    case AV_PIX_FMT_YUVJ422P:
                    case AV_PIX_FMT_UYVY422:
                    case AV_PIX_FMT_YUV422P16LE:
                    case AV_PIX_FMT_YUV422P16BE:
                    case AV_PIX_FMT_YUV422P10BE:
                    case AV_PIX_FMT_YUV422P10LE:
                    case AV_PIX_FMT_YUV422P9BE:
                    case AV_PIX_FMT_YUV422P9LE:
                    case AV_PIX_FMT_YUVA422P9BE:
                    case AV_PIX_FMT_YUVA422P9LE:
                    case AV_PIX_FMT_YUVA422P10BE:
                    case AV_PIX_FMT_YUVA422P10LE:
                    case AV_PIX_FMT_YUVA422P16BE:
                    case AV_PIX_FMT_YUVA422P16LE:
                    case AV_PIX_FMT_NV16:
                    case AV_PIX_FMT_NV20LE:
                    case AV_PIX_FMT_NV20BE:
                    case AV_PIX_FMT_YVYU422:
                    case AV_PIX_FMT_YUVA422P:
                    case AV_PIX_FMT_YUV422P12BE:
                    case AV_PIX_FMT_YUV422P12LE:
                    case AV_PIX_FMT_YUV422P14BE:
                    case AV_PIX_FMT_YUV422P14LE:
                    {
                        ret = av_opt_set(output_codec_ctx->priv_data, "profile", "high422", 0);
                        if (ret < 0)
                        {
                            Logging::error(virtname(), "Could not set profile=high422 for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                            return ret;
                        }
                        break;
                    }
                    case AV_PIX_FMT_YUV444P:
                    case AV_PIX_FMT_YUVJ444P:
                    case AV_PIX_FMT_YUV444P16LE:
                    case AV_PIX_FMT_YUV444P16BE:
                    case AV_PIX_FMT_RGB444LE:
                    case AV_PIX_FMT_RGB444BE:
                    case AV_PIX_FMT_BGR444LE:
                    case AV_PIX_FMT_BGR444BE:
                    case AV_PIX_FMT_YUV444P9BE:
                    case AV_PIX_FMT_YUV444P9LE:
                    case AV_PIX_FMT_YUV444P10BE:
                    case AV_PIX_FMT_YUV444P10LE:
                    case AV_PIX_FMT_GBRP:
                    case AV_PIX_FMT_GBRP9BE:
                    case AV_PIX_FMT_GBRP9LE:
                    case AV_PIX_FMT_GBRP10BE:
                    case AV_PIX_FMT_GBRP10LE:
                    case AV_PIX_FMT_GBRP16BE:
                    case AV_PIX_FMT_GBRP16LE:
                    case AV_PIX_FMT_YUVA444P9BE:
                    case AV_PIX_FMT_YUVA444P9LE:
                    case AV_PIX_FMT_YUVA444P10BE:
                    case AV_PIX_FMT_YUVA444P10LE:
                    case AV_PIX_FMT_YUVA444P16BE:
                    case AV_PIX_FMT_YUVA444P16LE:
                    case AV_PIX_FMT_XYZ12LE:
                    case AV_PIX_FMT_XYZ12BE:
                    case AV_PIX_FMT_YUVA444P:
                    case AV_PIX_FMT_GBRAP:
                    case AV_PIX_FMT_GBRAP16BE:
                    case AV_PIX_FMT_GBRAP16LE:
                    case AV_PIX_FMT_YUV444P12BE:
                    case AV_PIX_FMT_YUV444P12LE:
                    case AV_PIX_FMT_YUV444P14BE:
                    case AV_PIX_FMT_YUV444P14LE:
                    case AV_PIX_FMT_GBRP12BE:
                    case AV_PIX_FMT_GBRP12LE:
                    case AV_PIX_FMT_GBRP14BE:
                    case AV_PIX_FMT_GBRP14LE:
                    case AV_PIX_FMT_AYUV64LE:
                    case AV_PIX_FMT_AYUV64BE:
                    {
                        ret = av_opt_set(output_codec_ctx->priv_data, "profile", "high444", 0);
                        if (ret < 0)
                        {
                            Logging::error(virtname(), "Could not set profile=high444 for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                            return ret;
                        }
                        break;
                    }
                    default:
                    {
                        break;
                    }
                    }
                }
                av_free(out_val);
            }
            break;
        }
        case AV_CODEC_ID_VP9:
        {
            ret = prepare_codec(output_codec_ctx->priv_data, FILETYPE::WEBM);
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not set profile for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                return ret;
            }
            break;
        }
        case AV_CODEC_ID_PRORES:
        {
            ret = prepare_codec(output_codec_ctx->priv_data, FILETYPE::PRORES);
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not set profile for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                return ret;
            }
 
            // 0 = ‘proxy’,
            // 1 = ‘lt’,
            // 2 = ‘standard’,
            // 3 = ‘hq’
            output_codec_ctx->profile = static_cast<int>(params.m_level);
            break;
        }
        case AV_CODEC_ID_ALAC:
        {
            ret = prepare_codec(output_codec_ctx->priv_data, FILETYPE::ALAC);
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not set profile for %1 output codec %2 (error '%3').", get_media_type_string(output_codec->type), get_codec_name(codec_id), ffmpeg_geterror(ret).c_str());
                return ret;
            }
            break;
        }
        default:
        {
            break;
        }
        }
 
        // Initialise pixel format conversion and rescaling if necessary
        get_pix_formats(&m_in.m_pix_fmt, &m_out.m_pix_fmt, output_codec_ctx);
 
        ret = init_rescaler(m_in.m_pix_fmt, m_in.m_video.m_stream->codecpar->width, m_in.m_video.m_stream->codecpar->height, m_out.m_pix_fmt, output_codec_ctx->width, output_codec_ctx->height);
        if (ret < 0)
        {
            return ret;
        }
 
        // set -strict -2 for aac (required for FFmpeg 2)
        dict_set_with_check(opt.address(), "strict", "-2", 0);
 
        // Allow the use of the experimental AAC encoder
        output_codec_ctx->strict_std_compliance = FF_COMPLIANCE_EXPERIMENTAL;
 
#ifdef _DEBUG
        print_stream_info(output_stream);
#endif // _DEBUG
 
        // Set duration as hint for muxer
        if (m_in.m_video.m_stream->duration != AV_NOPTS_VALUE)
        {
            output_stream->duration             = ffmpeg_rescale_q(m_in.m_video.m_stream->duration, m_in.m_video.m_stream->time_base, output_stream->time_base);
        }
        else if (m_in.m_format_ctx->duration != AV_NOPTS_VALUE)
        {
            output_stream->duration             = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), output_stream->time_base);
        }
 
        //av_dict_set_int(&output_stream->metadata, "DURATION", output_stream->duration, AV_DICT_IGNORE_SUFFIX);
 
        // Save the encoder context for easier access later.
        m_out.m_video.set_codec_ctx(output_codec_ctx);
        // Save the stream index
        m_out.m_video.m_stream_idx              = output_stream->index;
        // Save output video stream for faster reference
        m_out.m_video.m_stream                  = output_stream;
 
        // Update input to output stream map, this is rather boring because currently we only have a single video stream
        add_stream_map(m_in.m_video.m_stream_idx, m_out.m_video.m_stream_idx);
        break;
    }
    default:
        break;
    }
 
    // Although docs state this is "Demuxing only", this is actually used by encoders like Matroska/WebM, so we need to set this here.
    m_out.m_format_ctx->duration = m_in.m_format_ctx->duration;
    if (m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
    {
        av_dict_set_int(&m_out.m_format_ctx->metadata, "DURATION", m_virtualfile->m_cuesheet_track.m_duration, AV_DICT_IGNORE_SUFFIX);
    }
    else
    {
        av_dict_set_int(&m_out.m_format_ctx->metadata, "DURATION", m_out.m_format_ctx->duration, AV_DICT_IGNORE_SUFFIX);
    }
 
    // Some formats want stream headers to be separate.
    if (m_out.m_format_ctx->oformat->flags & AVFMT_GLOBALHEADER)
    {
        output_codec_ctx->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;
    }
 
    if (!av_dict_get(opt, "threads", nullptr, 0))
    {
        Logging::trace(virtname(), "Setting threads to auto for codec %1.", get_codec_name(output_codec_ctx->codec_id));
        dict_set_with_check(opt.address(), "threads", "auto", 0, virtname());
    }
 
    // Open the encoder for the stream to use it later.
    ret = avcodec_open2(output_codec_ctx, output_codec, opt.address());
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not open %1 output codec %2 for stream #%3 (error '%4').", get_media_type_string(output_codec->type), get_codec_name(codec_id), output_stream->index, ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    Logging::debug(virtname(), "Opened %1 output codec %2 for stream #%3.", get_media_type_string(output_codec->type), get_codec_name(codec_id, true), output_stream->index);
 
    ret = avcodec_parameters_from_context(output_stream->codecpar, output_codec_ctx);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not initialise stream parameters (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return (output_stream->index);
}
 
int FFmpeg_Transcoder::add_subtitle_stream(AVCodecID codec_id, StreamRef & input_streamref, const std::optional<std::string> & language)
{
    AVCodecContext *output_codec_ctx    = nullptr;
    AVStream *      output_stream       = nullptr;
#if IF_DECLARED_CONST
    const AVCodec * output_codec        = nullptr;
#else // !IF_DECLARED_CONST
    AVCodec * output_codec              = nullptr;
#endif // !IF_DECLARED_CONST
    FFmpeg_Dictionary opt;
    int ret;
 
    // find the encoder
    output_codec = avcodec_find_encoder(codec_id);
 
    if (output_codec == nullptr)
    {
        Logging::error(virtname(), "'%1' encoder could not be found.", avcodec_get_name(codec_id));
        return AVERROR(EINVAL);
    }
 
    output_stream = avformat_new_stream(m_out.m_format_ctx, output_codec);
    if (output_stream == nullptr)
    {
        Logging::error(virtname(), "Could not allocate stream for encoder '%1'.", avcodec_get_name(codec_id));
        return AVERROR(ENOMEM);
    }
    output_stream->id = static_cast<int>(m_out.m_format_ctx->nb_streams - 1);
 
    output_codec_ctx = avcodec_alloc_context3(output_codec);
    if (output_codec_ctx == nullptr)
    {
        Logging::error(virtname(), "Could not allocate an encoding context for encoder '%1'.", avcodec_get_name(codec_id));
        return AVERROR(ENOMEM);
    }
 
    output_stream->time_base                = input_streamref.m_stream->time_base;
    output_codec_ctx->time_base             = output_stream->time_base;
 
    // set -strict -2 for aac (required for FFmpeg 2)
    dict_set_with_check(opt.address(), "strict", "-2", 0);
 
    // Allow the use of the experimental AAC encoder
    output_codec_ctx->strict_std_compliance = FF_COMPLIANCE_EXPERIMENTAL;
 
    // Set duration as hint for muxer
    if (m_in.m_video.m_stream != nullptr && m_in.m_video.m_stream->duration != AV_NOPTS_VALUE)
    {
        output_stream->duration             = ffmpeg_rescale_q(m_in.m_video.m_stream->duration, m_in.m_video.m_stream->time_base, output_stream->time_base);
    }
    if (m_in.m_audio.m_stream != nullptr && m_in.m_audio.m_stream->duration != AV_NOPTS_VALUE)
    {
        output_stream->duration             = ffmpeg_rescale_q(m_in.m_audio.m_stream->duration, m_in.m_audio.m_stream->time_base, output_stream->time_base);
    }
    else if (m_in.m_format_ctx != nullptr && m_in.m_format_ctx->duration != AV_NOPTS_VALUE)
    {
        output_stream->duration             = ffmpeg_rescale_q(m_in.m_format_ctx->duration, av_get_time_base_q(), output_stream->time_base);
    }
 
    AVCodecContext * input_codec_ctx = input_streamref.m_codec_ctx.get();
 
    if (input_codec_ctx != nullptr && input_codec_ctx->subtitle_header != nullptr)
    {
        // ASS code assumes this buffer is null terminated so add extra byte.
        output_codec_ctx->subtitle_header = static_cast<uint8_t *>(av_mallocz(static_cast<size_t>(input_codec_ctx->subtitle_header_size) + 1));
        if (output_codec_ctx->subtitle_header == nullptr)
        {
            return AVERROR(ENOMEM);
        }
        std::memcpy(output_codec_ctx->subtitle_header, input_codec_ctx->subtitle_header, static_cast<size_t>(input_codec_ctx->subtitle_header_size));
        output_codec_ctx->subtitle_header_size = input_codec_ctx->subtitle_header_size;
    }
    else if (output_codec_ctx->codec_id == AV_CODEC_ID_WEBVTT || output_codec_ctx->codec_id == AV_CODEC_ID_SUBRIP)
    {
        // If source had no header, we create a default one
        ret = get_script_info(output_codec_ctx,
                              ASS_DEFAULT_PLAYRESX, ASS_DEFAULT_PLAYRESY,
                              ASS_DEFAULT_FONT, ASS_DEFAULT_FONT_SIZE, ASS_DEFAULT_COLOUR, ASS_DEFAULT_COLOUR,
                              ASS_DEFAULT_BACK_COLOUR, ASS_DEFAULT_BACK_COLOUR,
                              ASS_DEFAULT_BOLD, ASS_DEFAULT_ITALIC, ASS_DEFAULT_UNDERLINE,
                              ASS_DEFAULT_BORDERSTYLE, ASS_DEFAULT_ALIGNMENT);
 
        if (ret)
        {
            Logging::error(virtname(), "Could not create ASS script info for encoder '%1'.", avcodec_get_name(codec_id));
            return ret;
        }
    }
 
    // Open the encoder for the stream to use it later.
    ret = avcodec_open2(output_codec_ctx, output_codec, opt.address());
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not open %1 output codec %2 for stream #%3 (error '%4').", get_media_type_string(output_codec->type), get_codec_name(codec_id), output_stream->index, ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    Logging::debug(virtname(), "Opened %1 output codec %2 for stream #%3.", get_media_type_string(output_codec->type), get_codec_name(codec_id, true), output_stream->index);
 
    ret = avcodec_parameters_from_context(output_stream->codecpar, output_codec_ctx);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not initialise stream parameters (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    if (!language)
    {
        // Copy language
        AVDictionaryEntry *tag = nullptr;
 
        tag = av_dict_get(input_streamref.m_stream->metadata, "language", nullptr, AV_DICT_IGNORE_SUFFIX);
        if (tag != nullptr)
        {
            av_dict_set(&output_stream->metadata, "language", tag->value, AV_DICT_IGNORE_SUFFIX);
        }
    }
    else
    {
        // Use predefined value
        av_dict_set(&output_stream->metadata, "language", language->c_str(), AV_DICT_IGNORE_SUFFIX);
    }
 
    // Save the encoder context for easier access later.
    StreamRef output_streamref;
 
    output_streamref.set_codec_ctx(output_codec_ctx);
    // Save the stream index
    output_streamref.m_stream_idx              = output_stream->index;
    // Save output audio stream for faster reference
    output_streamref.m_stream                  = output_stream;
 
    m_out.m_subtitle.emplace(output_streamref.m_stream_idx, output_streamref);
 
    // Update input to output stream map
    add_stream_map(input_streamref.m_stream_idx, output_streamref.m_stream_idx);
 
    return output_streamref.m_stream_idx;
}
 
int FFmpeg_Transcoder::add_stream_copy(AVCodecID codec_id, AVMediaType codec_type)
{
    AVStream *      output_stream       = nullptr;
    int ret;
 
    output_stream = avformat_new_stream(m_out.m_format_ctx, nullptr);
    if (output_stream == nullptr)
    {
        Logging::error(virtname(), "Could not allocate stream for encoder '%1'.",  avcodec_get_name(codec_id));
        return AVERROR(ENOMEM);
    }
    output_stream->id = static_cast<int>(m_out.m_format_ctx->nb_streams - 1);
 
    switch (codec_type)
    {
    case AVMEDIA_TYPE_AUDIO:
    {
        ret = avcodec_parameters_copy(output_stream->codecpar, m_in.m_audio.m_stream->codecpar);
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not allocate an encoding context (error '%2').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
        // Set the sample rate for the container.
        output_stream->time_base                = m_in.m_audio.m_stream->time_base;
 
        // Set duration as hint for muxer
        output_stream->duration                 = ffmpeg_rescale_q(m_in.m_audio.m_stream->duration, m_in.m_audio.m_stream->time_base, output_stream->time_base);
 
        // Save the encoder context for easier access later.
        m_out.m_audio.set_codec_ctx(nullptr);
        // Save the stream index
        m_out.m_audio.m_stream_idx              = output_stream->index;
        // Save output audio stream for faster reference
        m_out.m_audio.m_stream                  = output_stream;
 
        // Update input to output stream map, this is rather boring because currently we only have a single audio stream
        add_stream_map(m_in.m_audio.m_stream_idx, m_out.m_audio.m_stream_idx);
        break;
    }
    case AVMEDIA_TYPE_VIDEO:
    {
        ret = avcodec_parameters_copy(output_stream->codecpar, m_in.m_video.m_stream->codecpar);
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not allocate an encoding context (error '%2').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
        output_stream->time_base                = m_in.m_video.m_stream->time_base;
 
#ifdef _DEBUG
        print_stream_info(output_stream);
#endif // _DEBUG
 
        // Set duration as hint for muxer
        output_stream->duration                 = ffmpeg_rescale_q(m_in.m_video.m_stream->duration, m_in.m_video.m_stream->time_base, output_stream->time_base);
 
        // Save the encoder context for easier access later.
        m_out.m_video.set_codec_ctx(nullptr);
        // Save the stream index
        m_out.m_video.m_stream_idx              = output_stream->index;
        // Save output video stream for faster reference
        m_out.m_video.m_stream                  = output_stream;
 
        // Update input to output stream map, this is rather boring because currently we only have a single video stream
        add_stream_map(m_in.m_video.m_stream_idx, m_out.m_video.m_stream_idx);
        break;
    }
    default:
        break;
    }
 
    output_stream->codecpar->codec_tag = 0;
 
    return 0;
}
 
int FFmpeg_Transcoder::add_albumart_stream(const AVCodecContext * input_codec_ctx)
{
    AVCodecContext * output_codec_ctx   = nullptr;
    AVStream * output_stream            = nullptr;
    const AVCodec * input_codec         = input_codec_ctx->codec;
    const AVCodec * output_codec        = nullptr;
    FFmpeg_Dictionary opt;
    int ret;
 
    // find the encoder
    output_codec = avcodec_find_encoder(input_codec->id);
    if (output_codec == nullptr)
    {
        Logging::error(virtname(), "'%1' encoder could not be found.", avcodec_get_name(input_codec->id));
        return AVERROR(EINVAL);
    }
 
    // Must be a video codec
    if (output_codec->type != AVMEDIA_TYPE_VIDEO)
    {
        Logging::error(virtname(), "INTERNAL TROUBLE! Encoder '%1' is not a video codec.", avcodec_get_name(input_codec->id));
        return AVERROR(EINVAL);
    }
 
    output_stream = avformat_new_stream(m_out.m_format_ctx, output_codec);
    if (output_stream == nullptr)
    {
        Logging::error(virtname(), "Could not allocate stream for encoder '%1'.", avcodec_get_name(input_codec->id));
        return AVERROR(ENOMEM);
    }
    output_stream->id = static_cast<int>(m_out.m_format_ctx->nb_streams - 1);
 
    output_codec_ctx = avcodec_alloc_context3(output_codec);
    if (output_codec_ctx == nullptr)
    {
        Logging::error(virtname(), "Could not allocate an encoding context.");
        return AVERROR(ENOMEM);
    }
 
    // Ignore missing width/height when adding album arts
#if !IF_DECLARED_CONST
    m_out.m_format_ctx->oformat->flags |= AVFMT_NODIMENSIONS;
#endif // !IF_DECLARED_CONST
    // This is required for some reason (let encoder decide?)
    // If not set, write header will fail!
    //output_codec_ctx->codec_tag = 0; //av_codec_get_tag(of->codec_tag, codec->codec_id);
 
    //output_stream->codec->framerate = { 1, 0 };
 
    // mp4 album arts do not work with ipod profile. Set mp4.
    //if (m_out.m_format_ctx->oformat->mime_type != nullptr && (!strcmp(m_out.m_format_ctx->oformat->mime_type, "application/mp4") || !strcmp(m_out.m_format_ctx->oformat->mime_type, "video/mp4")))
    //{
    //    m_out.m_format_ctx->oformat->name = "mp4";
    //    m_out.m_format_ctx->oformat->mime_type = "application/mp4";
    //}
 
    // copy disposition
    // output_stream->disposition = input_stream->disposition;
    output_stream->disposition = AV_DISPOSITION_ATTACHED_PIC;
 
    // copy estimated duration as a hint to the muxer
    if (output_stream->duration <= 0 && m_in.m_audio.m_stream->duration > 0)
    {
        output_stream->duration = ffmpeg_rescale_q(m_in.m_audio.m_stream->duration, m_in.m_audio.m_stream->time_base, output_stream->time_base);
    }
 
    output_codec_ctx->time_base = { 1, 90000 };
    output_stream->time_base    = { 1, 90000 };
 
    output_codec_ctx->pix_fmt   = input_codec_ctx->pix_fmt;
    output_codec_ctx->width     = input_codec_ctx->width;
    output_codec_ctx->height    = input_codec_ctx->height;
 
    // Some formats want stream headers to be separate.
    if (m_out.m_format_ctx->oformat->flags & AVFMT_GLOBALHEADER)
    {
        output_codec_ctx->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;
    }
 
    // Open the encoder for the stream to use it later.
    ret = avcodec_open2(output_codec_ctx, output_codec, opt.address());
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not open %1 output codec %2 for stream #%3 (error '%4').", get_media_type_string(output_codec->type), get_codec_name(input_codec->id), output_stream->index, ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    Logging::debug(virtname(), "Opened album art output codec %1 for stream #%2 (dimensions %3x%4).", get_codec_name(input_codec->id, true), output_stream->index, output_codec_ctx->width, output_codec_ctx->height);
 
    ret = avcodec_parameters_from_context(output_stream->codecpar, output_codec_ctx);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not initialise stream parameters stream #%1 (error '%2').", output_stream->index, ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    StreamRef streamref;
 
    streamref.set_codec_ctx(output_codec_ctx);
    streamref.m_stream        = output_stream;
    streamref.m_stream_idx    = output_stream->index;
 
    m_out.m_album_art.push_back(streamref);
 
    return 0;
}
 
int FFmpeg_Transcoder::add_albumart_frame(AVStream *output_stream, AVPacket *pkt_in)
{
    FFmpeg_Packet tmp_pkt(pkt_in);
    int ret = tmp_pkt.res();
 
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not write album art packet (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    Logging::trace(virtname(), "Adding album art stream #%1.", output_stream->index);
 
    tmp_pkt->stream_index = output_stream->index;
    tmp_pkt->flags |= AV_PKT_FLAG_KEY;  // Contains a single frame, make sure it's a key frame
    tmp_pkt->pos = 0;
    tmp_pkt->dts = 0;
 
    return store_packet(tmp_pkt, AVMEDIA_TYPE_ATTACHMENT);
}
 
int FFmpeg_Transcoder::open_output_filestreams(Buffer *buffer)
{
    m_out.m_filetype = m_current_format->filetype();
 
    Logging::debug(virtname(), "Opening output format '%1'.", m_current_format->desttype().c_str());
 
    // Reset active streams
    m_active_stream_msk     = 0;
    m_inhibit_stream_msk    = 0;
 
    // Check if we can copy audio or video.
    m_copy_audio = can_copy_stream(m_in.m_audio.m_stream);
    m_copy_video = can_copy_stream(m_in.m_video.m_stream);
 
    // Create a new format context for the output container format.
    int ret = 0;
    if (m_current_format->format_name() != "m4a")
    {
        ret = m_out.m_format_ctx.alloc_output_context(m_current_format->format_name().c_str(), nullptr);
    }
    else
    {
        ret = m_out.m_format_ctx.alloc_output_context(nullptr, ".m4a");
    }
 
    if (ret < 0 || m_out.m_format_ctx == nullptr)
    {
        Logging::error(virtname(), "Could not allocate an output format context.");
        return (ret < 0) ? ret : AVERROR(ENOMEM);
    }
 
    if (!m_is_video)
    {
        m_in.m_video.m_stream_idx = INVALID_STREAM;
    }
 
    //video_codec = m_out.m_format_ctx->oformat->video_codec;
 
    // Open video streams
    if (stream_exists(m_in.m_video.m_stream_idx) && m_current_format->video_codec() != AV_CODEC_ID_NONE)
    {
        m_active_stream_msk     |= FFMPEGFS_VIDEO;
 
        if (!m_copy_video)
        {
            int ret;
 
            ret = add_stream(m_current_format->video_codec());
            if (ret < 0)
            {
                return ret;
            }
 
            if (params.m_deinterlace)
            {
                // Init deinterlace filters
                ret = init_deinterlace_filters(m_in.m_video.m_codec_ctx.get(), m_in.m_pix_fmt, m_in.m_video.m_stream->avg_frame_rate, m_in.m_video.m_stream->time_base);
                if (ret < 0)
                {
                    return ret;
                }
            }
        }
        else
        {
            int ret;
 
            Logging::info(virtname(), "Copying video stream.");
 
            ret = add_stream_copy(m_current_format->video_codec(), AVMEDIA_TYPE_VIDEO);
            if (ret < 0)
            {
                return ret;
            }
        }
    }
 
    // Open audio streams
    if (stream_exists(m_in.m_audio.m_stream_idx) && m_current_format->audio_codec() != AV_CODEC_ID_NONE)
    {
        m_active_stream_msk     |= FFMPEGFS_AUDIO;
 
        if (!m_copy_audio)
        {
            int ret;
 
            ret = add_stream(m_current_format->audio_codec());
            if (ret < 0)
            {
                return ret;
            }
        }
        else
        {
            int ret;
 
            Logging::info(virtname(), "Copying audio stream.");
 
            ret = add_stream_copy(m_current_format->audio_codec(), AVMEDIA_TYPE_AUDIO);
            if (ret < 0)
            {
                return ret;
            }
        }
    }
 
    if (stream_exists(m_in.m_video.m_stream_idx) && m_current_format->video_codec() != AV_CODEC_ID_NONE)
    {
        int ret;
 
        // Open subtitle streams
        if (m_in.m_subtitle.size())
        {
            // No copy option, not worth it for a few frames
            // Create as many subtitle streams as required
            ret = add_subtitle_streams();
            if (ret < 0)
            {
                return ret;
            }
        }
 
        // Open streams for external subtitle files
        ret = add_external_subtitle_streams();
        if (ret < 0)
        {
            return ret;
        }
    }
 
    if (!params.m_noalbumarts && m_current_format->albumart_supported())
    {
        for (StreamRef & album_art : m_in.m_album_art)
        {
            int ret;
 
            ret = add_albumart_stream(album_art.m_codec_ctx.get());
            if (ret < 0)
            {
                return ret;
            }
        }
    }
 
    const int buf_size = 5*1024*1024;
    unsigned char *iobuffer = static_cast<unsigned char *>(av_malloc(buf_size + FF_INPUT_BUFFER_PADDING_SIZE));
    if (iobuffer == nullptr)
    {
        Logging::error(virtname(), "Out of memory opening output file: Unable to allocate I/O buffer.");
        return AVERROR(ENOMEM);
    }
 
    // open the output file
    m_out.m_format_ctx->pb = avio_alloc_context(
                iobuffer,
                buf_size,
                1,
                static_cast<void *>(buffer),
                nullptr,        // read not required
                output_write,   // write
                (m_current_format->audio_codec() != AV_CODEC_ID_OPUS) ? seek : nullptr);          // seek
 
    if (m_out.m_format_ctx->pb == nullptr)
    {
        Logging::error(virtname(), "Out of memory opening output file: Unable to allocate format context.");
        av_freep(&iobuffer);
        return AVERROR(ENOMEM);
    }
    m_out.m_format_ctx.set_custom_io();
 
    return 0;
}
 
int FFmpeg_Transcoder::add_subtitle_streams()
{
    for (auto & [key, value] : m_in.m_subtitle)
    {
        AVCodecID codec_id = m_current_format->subtitle_codec(value.m_stream->codecpar->codec_id); // Get matching output codec
 
        if (codec_id == AV_CODEC_ID_NONE)
        {
            // No matching output codec
            continue;
        }
 
        if (map_in_to_out_stream(value.m_stream_idx) != INVALID_STREAM)
        {
            // Already existing
            continue;
        }
 
        //m_active_stream_msk     |= FFMPEGFS_SUBTITLE;
 
        int ret;
 
        ret = add_subtitle_stream(codec_id, value);
        if (ret < 0)
        {
            return ret;
        }
    }
    return 0;
}
 
int FFmpeg_Transcoder::init_resampler()
{
    // Fail save: if channel layout not known assume mono or stereo
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
    if (!m_in.m_audio.m_codec_ctx->ch_layout.nb_channels)
    {
        av_channel_layout_default(&m_in.m_audio.m_codec_ctx->ch_layout, 2);
    }
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    if (!m_in.m_audio.m_codec_ctx->channel_layout)
    {
        m_in.m_audio.m_codec_ctx->channel_layout = static_cast<uint64_t>(av_get_default_channel_layout(m_in.m_audio.m_codec_ctx->channels));
    }
    if (!m_in.m_audio.m_codec_ctx->channel_layout)
    {
        m_in.m_audio.m_codec_ctx->channel_layout = AV_CH_LAYOUT_STEREO;
    }
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
 
    // Only initialise the resampler if it is necessary, i.e.,
    // if and only if the sample formats differ.
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
    if (m_in.m_audio.m_codec_ctx->sample_fmt == m_out.m_audio.m_codec_ctx->sample_fmt &&
            m_in.m_audio.m_codec_ctx->sample_rate == m_out.m_audio.m_codec_ctx->sample_rate &&
            !av_channel_layout_compare(&m_in.m_audio.m_codec_ctx->ch_layout, &m_out.m_audio.m_codec_ctx->ch_layout))
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    if (m_in.m_audio.m_codec_ctx->sample_fmt == m_out.m_audio.m_codec_ctx->sample_fmt &&
            m_in.m_audio.m_codec_ctx->sample_rate == m_out.m_audio.m_codec_ctx->sample_rate &&
            m_in.m_audio.m_codec_ctx->channel_layout == m_out.m_audio.m_codec_ctx->channel_layout)
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    {
        // Formats are same
        close_resample();
        return 0;
    }
 
    if ((m_audio_resample_ctx == nullptr) ||
            (m_cur_sample_fmt != m_in.m_audio.m_codec_ctx->sample_fmt) ||
            (m_cur_sample_rate != m_in.m_audio.m_codec_ctx->sample_rate) ||
        #if LAVU_DEP_OLD_CHANNEL_LAYOUT
            av_channel_layout_compare(&m_cur_ch_layout, &m_in.m_audio.m_codec_ctx->ch_layout))
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
            (m_cur_channel_layout != m_in.m_audio.m_codec_ctx->channel_layout))
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    {
        int ret;
 
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
        Logging::debug(virtname(), "Creating audio resampler: %1 -> %2 / %3 -> %4 / %5 -> %6.",
                       get_sample_fmt_name(m_in.m_audio.m_codec_ctx->sample_fmt).c_str(),
                       get_sample_fmt_name(m_out.m_audio.m_codec_ctx->sample_fmt).c_str(),
                       format_samplerate(m_in.m_audio.m_codec_ctx->sample_rate).c_str(),
                       format_samplerate(m_out.m_audio.m_codec_ctx->sample_rate).c_str(),
                       get_channel_layout_name(&m_in.m_audio.m_codec_ctx->ch_layout).c_str(),
                       get_channel_layout_name(&m_out.m_audio.m_codec_ctx->ch_layout).c_str());
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
        Logging::debug(virtname(), "Creating audio resampler: %1 -> %2 / %3 -> %4 / %5 -> %6.",
                       get_sample_fmt_name(m_in.m_audio.m_codec_ctx->sample_fmt).c_str(),
                       get_sample_fmt_name(m_out.m_audio.m_codec_ctx->sample_fmt).c_str(),
                       format_samplerate(m_in.m_audio.m_codec_ctx->sample_rate).c_str(),
                       format_samplerate(m_out.m_audio.m_codec_ctx->sample_rate).c_str(),
                       get_channel_layout_name(m_in.m_audio.m_codec_ctx->channels, m_in.m_audio.m_codec_ctx->channel_layout).c_str(),
                       get_channel_layout_name(m_out.m_audio.m_codec_ctx->channels, m_out.m_audio.m_codec_ctx->channel_layout).c_str());
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
 
        close_resample();
 
        m_cur_sample_fmt        = m_in.m_audio.m_codec_ctx->sample_fmt;
        m_cur_sample_rate       = m_in.m_audio.m_codec_ctx->sample_rate;
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
        av_channel_layout_copy(&m_cur_ch_layout, &m_in.m_audio.m_codec_ctx->ch_layout);
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
        m_cur_channel_layout    = m_in.m_audio.m_codec_ctx->channel_layout;
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
 
        // Create a resampler context for the conversion.
        // Set the conversion parameters.
#if SWR_DEP_ALLOC_SET_OPTS
        ret = swr_alloc_set_opts2(m_audio_resample_ctx.address(),
                                  &m_out.m_audio.m_codec_ctx->ch_layout,
                                  m_out.m_audio.m_codec_ctx->sample_fmt,
                                  m_out.m_audio.m_codec_ctx->sample_rate,
                                  &m_in.m_audio.m_codec_ctx->ch_layout,
                                  m_in.m_audio.m_codec_ctx->sample_fmt,
                                  m_in.m_audio.m_codec_ctx->sample_rate,
                                  0, nullptr);
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not allocate resample context (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
#else
        m_audio_resample_ctx.reset(swr_alloc_set_opts(nullptr,
                                                       static_cast<int64_t>(m_out.m_audio.m_codec_ctx->channel_layout),
                                                       m_out.m_audio.m_codec_ctx->sample_fmt,
                                                       m_out.m_audio.m_codec_ctx->sample_rate,
                                                       static_cast<int64_t>(m_in.m_audio.m_codec_ctx->channel_layout),
                                                       m_in.m_audio.m_codec_ctx->sample_fmt,
                                                       m_in.m_audio.m_codec_ctx->sample_rate,
                                                       0, nullptr));
        if (m_audio_resample_ctx == nullptr)
        {
            Logging::error(virtname(), "Could not allocate a resample context.");
            return AVERROR(ENOMEM);
        }
#endif
 
        // Open the resampler with the specified parameters.
        ret = swr_init(m_audio_resample_ctx);
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not open resampler context (error '%1').", ffmpeg_geterror(ret).c_str());
            m_audio_resample_ctx.reset();
            return ret;
        }
    }
    return 0;
}
 
int FFmpeg_Transcoder::init_audio_fifo()
{
    // Create the audio FIFO buffer based on the specified output sample format.
    int ret = m_audio_fifo.alloc(m_out.m_audio.m_codec_ctx->sample_fmt, get_channels(m_out.m_audio.m_codec_ctx.get()), 1);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not allocate an audio FIFO.");
        return ret;
    }
    return 0;
}
 
int FFmpeg_Transcoder::update_format(AVDictionary** dict, const PROFILE_OPTION_VEC &option_vec) const
{
    int ret = 0;
 
    for (const PROFILE_OPTION & option : option_vec)
    {
        if ((option.m_options & OPT_AUDIO) && stream_exists(m_out.m_video.m_stream_idx))
        {
            // Option for audio only, but file contains video stream
            continue;
        }
 
        if ((option.m_options & OPT_VIDEO) && !stream_exists(m_out.m_video.m_stream_idx))
        {
            // Option for video, but file contains no video stream
            continue;
        }
 
        Logging::trace(virtname(), "Profile format option -%1%2%3.",  option.m_key, *option.m_value ? " " : "", option.m_value);
 
        ret = dict_set_with_check(dict, option.m_key, option.m_value, option.m_flags, virtname());
        if (ret < 0)
        {
            break;
        }
    }
    return ret;
}
 
int FFmpeg_Transcoder::prepare_format(AVDictionary** dict, FILETYPE filetype) const
{
    int ret = 0;
 
    for (const PROFILE_LIST & profile : m_profile)
    {
        if (profile.m_filetype == filetype)
        {
            ret = AVERROR_OPTION_NOT_FOUND; // Once we found the file type, we also need to find the profile. Otherwise we have an invalid command line option.
            if (profile.m_profile == params.m_profile)
            {
                ret = update_format(dict, profile.m_option_format);
                break;
            }
        }
    }
 
    if (filetype == FILETYPE::MP4 || filetype == FILETYPE::PRORES || filetype == FILETYPE::TS || filetype == FILETYPE::HLS)
    {
        // All
        dict_set_with_check(dict, "flags:a", "+global_header", 0, virtname());
        dict_set_with_check(dict, "flags:v", "+global_header", 0, virtname());
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::create_fake_wav_header() const
{
    // Insert fake WAV header (fill in size fields with estimated values instead of setting to -1)
    AVIOContext * output_io_context = static_cast<AVIOContext *>(m_out.m_format_ctx->pb);
    Buffer *buffer = static_cast<Buffer *>(output_io_context->opaque);
    size_t current_offset = buffer->tell();
    size_t read_offset = 0;
    WAV_HEADER wav_header;
    WAV_LIST_HEADER list_header;
    WAV_DATA_HEADER data_header;
 
    buffer->copy(reinterpret_cast<uint8_t*>(&wav_header), 0, sizeof(WAV_HEADER));
    read_offset = sizeof(WAV_HEADER);
 
    if (wav_header.m_audio_format == 0xfffe)
    {
        //WAV_HEADER_EX wav_header_ex;
        WAV_FACT wav_fact;
 
        //buffer->copy(reinterpret_cast<uint8_t*>(&wav_header_ex), read_offset, sizeof(WAV_HEADER_EX));
        read_offset += sizeof(WAV_HEADER_EX);   // Need to skip extension header
 
        // Check for presence of "fact" chunk
        buffer->copy(reinterpret_cast<uint8_t*>(&wav_fact), read_offset, sizeof(WAV_FACT));
        if (!memcmp(&wav_fact.m_chunk_id, "fact", sizeof(wav_fact.m_chunk_id)))
        {
            read_offset += sizeof(WAV_FACT);    // Also skip fact header
        }
    }
 
    // Read list header
    buffer->copy(reinterpret_cast<uint8_t*>(&list_header), read_offset, sizeof(WAV_LIST_HEADER));
    read_offset += sizeof(WAV_LIST_HEADER) + list_header.m_data_bytes - 4;
    // Read data header
    buffer->copy(reinterpret_cast<uint8_t*>(&data_header), read_offset, sizeof(WAV_DATA_HEADER));
 
    // Fill in size fields with predicted size
    wav_header.m_wav_size = static_cast<unsigned int>(predicted_filesize() - 8);
    data_header.m_data_bytes = static_cast<unsigned int>(predicted_filesize() - (read_offset + sizeof(WAV_DATA_HEADER)));
#if __BYTE_ORDER == __BIG_ENDIAN
    wav_header.m_wav_size = __builtin_bswap32(wav_header.m_wav_size);
    data_header.m_data_bytes = __builtin_bswap32(data_header.m_data_bytes);
#endif
 
    // Write updated wav header
    buffer->seek(0, SEEK_SET);
    buffer->writeio(reinterpret_cast<uint8_t*>(&wav_header), sizeof(WAV_HEADER));
 
    // Write updated data header
    buffer->seek(static_cast<long>(read_offset), SEEK_SET);
    buffer->writeio(reinterpret_cast<uint8_t*>(&data_header), sizeof(WAV_DATA_HEADER));
 
    // Restore write position
    buffer->seek(static_cast<long>(current_offset), SEEK_SET);
 
    return 0;
}
 
int FFmpeg_Transcoder::read_aiff_chunk(Buffer *buffer, size_t *buffoffset, const char *ID, uint8_t *chunk, size_t *size) const
{
    AIFF_CHUNK *p = reinterpret_cast<AIFF_CHUNK*>(chunk);
    size_t buffsize = *size;
 
    for (;;)
    {
        if (!buffer->copy(chunk, *buffoffset, buffsize))
        {
            return -1;
        }
 
        if (buffer->eof())
        {
            errno = 0;
            return -1;
        }
 
        if (!memcmp(&p->m_ckID, AIFF_FORMID, sizeof(p->m_ckID)))
        {
            // Special case: FormChunk has a fixed size
            *size = sizeof(AIFF_FORMCHUNK);
        }
        else
        {
#if __BYTE_ORDER == __BIG_ENDIAN
            *size = p->m_ckSize + 8;
#else
            *size = __builtin_bswap32(p->m_ckSize) + 8;
#endif
        }
 
        if (!memcmp(&p->m_ckID, ID, sizeof(p->m_ckID)))
        {
            // Found
            break;
        }
 
        // Advance to next potential position
        *buffoffset += *size;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::create_fake_aiff_header() const
{
    // Insert fake WAV header (fill in size fields with estimated values instead of setting to -1)
    AVIOContext * output_io_context = static_cast<AVIOContext *>(m_out.m_format_ctx->pb);
    Buffer *buffer = static_cast<Buffer *>(output_io_context->opaque);
    size_t current_offset = buffer->tell();
    size_t read_offset = 0;
    size_t size;
    AIFF_FORMCHUNK form_chunk;
    AIFF_COMMONCHUNK common_chunk;
 
    size = sizeof(form_chunk);
    if (read_aiff_chunk(buffer, &read_offset, AIFF_FORMID, reinterpret_cast<uint8_t*>(&form_chunk), &size))
    {
        return -1;
    }
 
    read_offset += size;
 
    form_chunk.m_ckSize = static_cast<uint32_t>(predicted_filesize() - 8);
#if __BYTE_ORDER != __BIG_ENDIAN
    form_chunk.m_ckSize = __builtin_bswap32(form_chunk.m_ckSize);
#endif
 
    size = sizeof(common_chunk);
    if (read_aiff_chunk(buffer, &read_offset, AIFF_COMMONID, reinterpret_cast<uint8_t*>(&common_chunk), &size))
    {
        return -1;
    }
 
    read_offset += size;
 
    AIFF_SOUNDDATACHUNK sounddata_chunk;
 
    size = sizeof(sounddata_chunk);
    if (read_aiff_chunk(buffer, &read_offset, AIFF_SOUNDATAID, reinterpret_cast<uint8_t*>(&sounddata_chunk), &size))
    {
        return -1;
    }
 
    sounddata_chunk.m_ckSize = static_cast<uint32_t>(predicted_filesize() - read_offset);
#if __BYTE_ORDER != __BIG_ENDIAN
    sounddata_chunk.m_ckSize = __builtin_bswap32(sounddata_chunk.m_ckSize);
#endif
 
    // Write updated AIFF header
    buffer->seek(0, SEEK_SET);
    buffer->writeio(reinterpret_cast<uint8_t*>(&form_chunk), sizeof(form_chunk));
 
    // Write updated data header
    buffer->seek(static_cast<long>(read_offset), SEEK_SET);
    buffer->writeio(reinterpret_cast<uint8_t*>(&sounddata_chunk), sizeof(sounddata_chunk));
 
    // Restore write position
    buffer->seek(static_cast<long>(current_offset), SEEK_SET);
 
    return 0;
}
 
int FFmpeg_Transcoder::write_output_file_header()
{
    FFmpeg_Dictionary dict;
    int ret;
 
    ret = prepare_format(dict.address(), m_out.m_filetype);
    if (ret < 0)
    {
        return ret;
    }
 
    ret = avformat_write_header(m_out.m_format_ctx, dict.address());
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not write output file header (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    switch (m_current_format->filetype())
    {
    case FILETYPE::WAV:
    {
        ret = create_fake_wav_header();
        break;
    }
    case FILETYPE::AIFF:
    {
        ret = create_fake_aiff_header();
        break;
    }
    default:
    {
        break;
    }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::alloc_picture(AVFrame *frame, AVPixelFormat pix_fmt, int width, int height) const
{
    int ret;
 
    frame->format = pix_fmt;
    frame->width  = width;
    frame->height = height;
 
    // allocate the buffers for the frame data
    ret = av_frame_get_buffer(frame, 32);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not allocate frame data (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::decode(AVCodecContext *codec_ctx, AVFrame *frame, int *got_frame, const AVPacket *pkt) const
{
    int ret;
 
    *got_frame = 0;
 
    if (pkt != nullptr)
    {
        ret = avcodec_send_packet(codec_ctx, pkt);
        if (ret < 0 && ret != AVERROR_EOF)
        {
            // In particular, we don't expect AVERROR(EAGAIN), because we read all
            // decoded frames with avcodec_receive_frame() until done, so this should be handled
            // as an error.
            if (ret == AVERROR(EAGAIN))
            {
                ret = AVERROR_EXTERNAL;
            }
 
            if (is_audio_stream(pkt->stream_index) && stream_exists(m_out.m_audio.m_stream_idx))
            {
                Logging::error(filename(), "Could not send audio packet at PTS=%1 to decoder (error '%2').", ffmpeg_rescale_q(pkt->pts, m_in.m_audio.m_stream->time_base), ffmpeg_geterror(ret).c_str());
            }
            else if (is_video_stream(pkt->stream_index) && stream_exists(m_out.m_video.m_stream_idx))
            {
                Logging::error(filename(), "Could not send video packet at PTS=%1 to decoder (error '%2').", ffmpeg_rescale_q(pkt->pts, m_in.m_video.m_stream->time_base), ffmpeg_geterror(ret).c_str());
            }
            else
            {
                // Should never come here, but what the heck...
                Logging::error(filename(), "Could not send packet at PTS=%1 to decoder (error '%2').", pkt->pts, ffmpeg_geterror(ret).c_str());
            }
            return ret;
        }
    }
 
    ret = avcodec_receive_frame(codec_ctx, frame);
    if (ret < 0 && ret != AVERROR(EAGAIN) && ret != AVERROR_EOF)
    {
        Logging::error(filename(), "Could not receive packet from decoder (error '%1').", ffmpeg_geterror(ret).c_str());
    }
 
    *got_frame = (ret >= 0) ? 1 : 0;
 
    return ret;
}
 
int FFmpeg_Transcoder::decode_audio_frame(AVPacket *pkt, int *decoded)
{
    int data_present = 0;
    int ret = 0;
 
    *decoded = 0;
 
    // Decode the audio frame stored in the temporary packet.
    // The input audio stream decoder is used to do this.
    // If we are at the end of the file, pass an empty packet to the decoder
    // to flush it.
 
    // Since FFMpeg version >= 3.2 this is deprecated
    bool again = false;
 
    data_present = 0;
 
    // read all the output frames (in general there may be any number of them)
    while (ret >= 0)
    {
        FFmpeg_Frame frame(m_out.m_audio.m_stream_idx);
 
        ret = frame.res();
        if (ret < 0)
        {
            Logging::error(filename(), "Could not decode audio frame (error '%1').", ffmpeg_geterror(ret).c_str());
            break;
        }
 
        ret = decode(m_in.m_audio.m_codec_ctx.get(), frame, &data_present, again ? nullptr : pkt);
        if (!data_present)
        {
            break;
        }
 
        if (ret < 0)
        {
            // Anything else is an error, report it!
            Logging::error(filename(), "Could not decode audio frame (error '%1').", ffmpeg_geterror(ret).c_str());
            break;
        }
 
        again = true;
 
        *decoded += pkt->size;
 
        // If there is decoded data, convert and store it
        if (frame->nb_samples)
        {
            // Temporary storage for the converted input samples.
            uint8_t **converted_input_samples = nullptr;
            try
            {
                int nb_output_samples;
 
                // Initialise the resampler to be able to convert audio sample formats.
                ret = init_resampler();
                if (ret)
                {
                    throw ret;
                }
 
                nb_output_samples = (m_audio_resample_ctx != nullptr) ? swr_get_out_samples(m_audio_resample_ctx, frame->nb_samples) : frame->nb_samples;
 
                // Store audio frame
                // Initialise the temporary storage for the converted input samples.
                ret = init_converted_samples(&converted_input_samples, nb_output_samples);
                if (ret < 0)
                {
                    throw ret;
                }
 
                // Convert the input samples to the desired output sample format.
                // This requires a temporary storage provided by converted_input_samples.
                ret = convert_samples(frame->extended_data, frame->nb_samples, converted_input_samples, &nb_output_samples);
                if (ret < 0)
                {
                    throw ret;
                }
 
                // Add the converted input samples to the audio FIFO buffer for later processing.
                ret = add_samples_to_fifo(converted_input_samples, nb_output_samples);
                if (ret < 0)
                {
                    throw ret;
                }
                ret = 0;
            }
            catch (int _ret)
            {
                ret = _ret;
            }
 
            if (converted_input_samples != nullptr)
            {
                av_freep(&converted_input_samples[0]);
                av_free(converted_input_samples);
            }
        }
    }
    return ret;
}
 
int FFmpeg_Transcoder::decode_video_frame(AVPacket *pkt, int *decoded)
{
    int data_present;
    int ret = 0;
 
    *decoded = 0;
 
    // NOTE1: some codecs are stream based (mpegvideo, mpegaudio)
    // and this is the only method to use them because you cannot
    // know the compressed data size before analysing it.
 
    // BUT some other codecs (msmpeg4, mpeg4) are inherently frame
    // based, so you must call them with all the data for one
    // frame exactly. You must also initialise 'width' and
    // 'height' before initialising them.
 
    // NOTE2: some codecs allow the raw parameters (frame size,
    // sample rate) to be changed at any frame. We handle this, so
    // you should also take care of it
 
    // Since FFMpeg version >= 3.2 this is deprecated
    bool again = false;
 
    data_present = 0;
 
    // read all the output frames (in general there may be any number of them)
    while (ret >= 0)
    {
        FFmpeg_Frame frame(m_out.m_video.m_stream_idx);
 
        ret = frame.res();
        if (ret < 0)
        {
            Logging::error(filename(), "Could not decode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
            break;
        }
 
        ret = decode(m_in.m_video.m_codec_ctx.get(), frame, &data_present, again ? nullptr : pkt);
        if (!data_present)
        {
            // No data available
            break;
        }
 
        if (ret < 0)
        {
            // Anything else is an error, report it!
            Logging::error(filename(), "Could not decode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
            break;
        }
 
        if (m_hwaccel_enable_dec_buffering && frame != nullptr)
        {
            FFmpeg_Frame sw_frame(m_out.m_video.m_stream_idx);
 
            ret = sw_frame.res();
            if (ret < 0)
            {
                Logging::error(filename(), "Could not decode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
                break;
            }
 
            // If decoding is done in hardware, the resulting frame data needs to be copied to software memory
            //ret = hwframe_copy_from_hw(m_in.m_video.m_codec_ctx.get(), &sw_frame, frame);
 
            // retrieve data from GPU to CPU
            ret = av_hwframe_transfer_data(sw_frame, frame, 0); // hwframe_copy_from_hw
            if (ret < 0)
            {
                Logging::error(filename(), "Error transferring the data to system memory (error '%1').", ffmpeg_geterror(ret).c_str());
                break;
            }
            frame = sw_frame;
        }
 
        again = true;
        *decoded += pkt->size;
 
        // Sometimes only a few packets contain valid dts/pts/pos data, so we keep it
        if (pkt->dts != AV_NOPTS_VALUE)
        {
            int64_t pkt_dts = pkt->dts;
            if (pkt_dts > m_pts)
            {
                m_pts = pkt_dts;
            }
        }
        else if (pkt->pts != AV_NOPTS_VALUE)
        {
            int64_t pkt_pts = pkt->pts;
            if (pkt_pts > m_pts)
            {
                m_pts = pkt_pts;
            }
        }
 
        if (pkt->pos > -1)
        {
            m_pos = pkt->pos;
        }
 
        if (frame != nullptr)
        {
            if (!(frame->flags & AV_FRAME_FLAG_CORRUPT || frame->flags & AV_FRAME_FLAG_DISCARD))
            {
                ret = send_filters(&frame, ret);
                if (ret)
                {
                    break;
                }
 
                if (m_sws_ctx != nullptr)
                {
                    FFmpeg_Frame tmp_frame(m_out.m_video.m_stream_idx);
 
                    ret = tmp_frame.res();
                    if (ret < 0)
                    {
                        Logging::error(filename(), "Could not decode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
                        break;
                    }
 
                    AVCodecContext *output_codec_ctx = m_out.m_video.m_codec_ctx.get();
 
                    ret = alloc_picture(tmp_frame, m_out.m_pix_fmt, output_codec_ctx->width, output_codec_ctx->height);
                    if (ret < 0)
                    {
                        break;
                    }
 
                    sws_scale(m_sws_ctx,
                              static_cast<const uint8_t * const *>(frame->data), frame->linesize,
                              0, frame->height,
                              tmp_frame->data, tmp_frame->linesize);
 
                    tmp_frame->pts                      = frame->pts;
                    tmp_frame->best_effort_timestamp    = frame->best_effort_timestamp;
 
                    frame = tmp_frame;
                }
 
                int64_t best_effort_timestamp = frame->best_effort_timestamp;
 
                if (best_effort_timestamp != AV_NOPTS_VALUE)
                {
                    frame->pts = best_effort_timestamp;
                }
 
                if (frame->pts == AV_NOPTS_VALUE)
                {
                    frame->pts = m_pts;
                }
 
                int64_t video_start_time = m_out.m_video.m_start_time;
 
                if (m_out.m_video.m_stream != nullptr && frame->pts != AV_NOPTS_VALUE)
                {
                    if (m_in.m_video.m_stream->time_base.den != m_out.m_video.m_stream->time_base.den || m_in.m_video.m_stream->time_base.num != m_out.m_video.m_stream->time_base.num)
                    {
                        frame->pts = ffmpeg_rescale_q_rnd(frame->pts, m_in.m_video.m_stream->time_base, m_out.m_video.m_stream->time_base);
                        video_start_time = ffmpeg_rescale_q_rnd(video_start_time, m_in.m_video.m_stream->time_base, m_out.m_video.m_stream->time_base);
                    }
 
                    // Fix for issue #46: bitrate too high.
                    // Solution found here https://stackoverflow.com/questions/11466184/setting-video-bit-rate-through-ffmpeg-api-is-ignored-for-libx264-codec
                    // This is permanently used in the current ffmpeg.c code (see commit: e3fb9af6f1353f30855eaa1cbd5befaf06e303b8 Date:Wed Jan 22 15:52:10 2020 +0100)
                    frame->pts = ffmpeg_rescale_q_rnd(frame->pts, m_out.m_video.m_stream->time_base, m_out.m_video.m_codec_ctx->time_base);
                    video_start_time = ffmpeg_rescale_q_rnd(video_start_time, m_out.m_video.m_stream->time_base, m_out.m_video.m_codec_ctx->time_base);
                }
 
                frame->quality      = m_out.m_video.m_codec_ctx->global_quality;
#if !LAVU_ADD_NEW_FRAME_FLAGS
                frame->key_frame    = 0;                    // Leave that decision to encoder
#endif
                frame->pict_type    = AV_PICTURE_TYPE_NONE; // other than AV_PICTURE_TYPE_NONE causes warnings
 
                if (frame->pts != AV_NOPTS_VALUE)
                {
                    int64_t tmp_pts = frame->pts - video_start_time;
                    int64_t pos = ffmpeg_rescale_q_rnd(tmp_pts, m_out.m_video.m_codec_ctx->time_base);
                    if (pos < 0)
                    {
                        pos = 0;
                    }
 
                    if (is_hls())
                    {
                        // Issue #90: Insert key frame at start of each subsequent HLS segment
                        uint32_t next_segment = get_next_segment(pos);
 
                        if (goto_next_segment(next_segment) && !m_insert_keyframe)
                        {
                            Logging::debug(virtname(), "Force key frame for next segment no. %1 at PTS=%2 (%3).", next_segment, tmp_pts, format_duration(pos).c_str());
 
#if LAVU_ADD_NEW_FRAME_FLAGS
                            frame->flags        |= AV_FRAME_FLAG_KEY;   // This is required to reset the GOP counter (insert the next key frame after gop_size frames)
#else   // !LAVU_ADD_NEW_FRAME_FLAGS
                            frame->key_frame    = 1;                    // This is required to reset the GOP counter (insert the next key frame after gop_size frames)
#endif  // !LAVU_ADD_NEW_FRAME_FLAGS
                            frame->pict_type    = AV_PICTURE_TYPE_I;
                            m_insert_keyframe   = true;
                        }
                    }
 
                    m_frame_map.emplace(pos, frame);
                }
                else
                {
                    m_frame_map.emplace(0, frame);
                }
            }
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::decode_subtitle(AVPacket *pkt, int *decoded)
{
    StreamRef_map::const_iterator it = m_in.m_subtitle.find(pkt->stream_index);
 
    *decoded = 0;
 
    if (it == m_in.m_subtitle.cend())
    {
        // Should never happen, this should never be called with anything else than subtitle packets.
        int ret = AVERROR_STREAM_NOT_FOUND;
        Logging::error(filename(), "INTERNAL ERROR: FFmpeg_Transcoder::decode_subtitle()! Subtitle stream #%1 not found (error '%2').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    // Decode the audio frame stored in the temporary packet.
    // The input audio stream decoder is used to do this.
    // If we are at the end of the file, pass an empty packet to the decoder
    // to flush it.
 
    // Temporary storage of the input samples of the frame read from the file.
 
    int out_stream_idx = map_in_to_out_stream(it->first);
 
    if (out_stream_idx == INVALID_STREAM)
    {
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::decode_subtitle()! Unable to map input subtitle stream #%1 to output stream.", it->first);
        throw AVERROR(EINVAL);
    }
 
    return decode_subtitle(it->second.m_codec_ctx.get(), pkt, decoded, out_stream_idx);
}
 
int FFmpeg_Transcoder::decode_subtitle(AVCodecContext *codec_ctx, AVPacket *pkt, int *decoded, int out_stream_idx)
{
    FFmpeg_Subtitle subtitle(out_stream_idx);
    int data_present = 0;
    int ret = 0;
 
    *decoded = 0;
 
    ret = subtitle.res();
    if (ret < 0)
    {
        Logging::error(filename(), "Could not decode subtitle (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    ret = avcodec_decode_subtitle2(codec_ctx, subtitle, &data_present, pkt);
 
    if (ret < 0 && ret != AVERROR(EINVAL))
    {
        Logging::error(filename(), "Could not decode subtitle frame (error '%1').", ffmpeg_geterror(ret).c_str());
        data_present = 0;
    }
    else
    {
        *decoded = ret;
        ret = 0;
    }
 
    if (data_present)
    {
        // If there is decoded data, store it
        // sub->pts is already in AV_TIME_BASE
        m_frame_map.emplace(subtitle->pts, subtitle);
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::store_packet(AVPacket *pkt, AVMediaType mediatype)
{
    int ret;
    if (is_hls() && pkt->pts != AV_NOPTS_VALUE)
    {
        switch (mediatype)
        {
        case AVMEDIA_TYPE_AUDIO:
        {
            int64_t pos = ffmpeg_rescale_q_rnd(pkt->pts - m_out.m_audio.m_start_time, m_out.m_audio.m_stream->time_base);
            if (pos < 0)
            {
                pos = 0;
            }
            uint32_t next_segment = get_next_segment(pos);
 
            if (goto_next_segment(next_segment))
            {
                if (!(m_inhibit_stream_msk & FFMPEGFS_AUDIO))
                {
                    m_inhibit_stream_msk |= FFMPEGFS_AUDIO;
 
                    Logging::trace(virtname(), "Buffering audio packets until the next segment no. %1 from position %2 (%3).", next_segment, pos, format_duration(pos).c_str());
                }
 
                FFmpeg_Packet fifo_pkt(pkt);
                ret = fifo_pkt.res();
                if (ret < 0)
                {
                    return ret;
                }
                m_hls_packet_fifo.push(std::move(fifo_pkt));
                return 0;
            }
            break;
        }
        case AVMEDIA_TYPE_VIDEO:
        {
            int64_t pos = ffmpeg_rescale_q_rnd(pkt->pts - m_out.m_video.m_start_time, m_out.m_video.m_stream->time_base);
            if (pos < 0)
            {
                pos = 0;
            }
            uint32_t next_segment = get_next_segment(pos);
 
            if (goto_next_segment(next_segment))
            {
                if (!(m_inhibit_stream_msk & FFMPEGFS_VIDEO))
                {
                    m_inhibit_stream_msk |= FFMPEGFS_VIDEO;
 
                    Logging::trace(virtname(), "Buffering video packets until the next segment no. %1 from position %2 (%3).", next_segment, pos, format_duration(pos).c_str());
                }
 
                FFmpeg_Packet fifo_pkt(pkt);
                ret = fifo_pkt.res();
                if (ret < 0)
                {
                    return ret;
                }
                m_hls_packet_fifo.push(std::move(fifo_pkt));
                return 0;
            }
            break;
        }
        case AVMEDIA_TYPE_SUBTITLE:
        {
            StreamRef * subtitle = get_out_subtitle_stream(pkt->stream_index);
 
            if (subtitle != nullptr && subtitle->m_stream != nullptr)
            {
                int64_t pos = ffmpeg_rescale_q_rnd(pkt->pts - subtitle->m_start_time, subtitle->m_stream->time_base);
                if (pos < 0)
                {
                    pos = 0;
                }
                uint32_t next_segment = get_next_segment(pos);
 
                if (goto_next_segment(next_segment))
                {
                    FFmpeg_Packet fifo_pkt(pkt);
                    ret = fifo_pkt.res();
                    if (ret < 0)
                    {
                        return ret;
                    }
                    m_hls_packet_fifo.push(std::move(fifo_pkt));
                    return 0;
                }
            }
            break;
        }
        default:
        {
            break;
        }
        }
    }
 
    ret = av_write_frame(m_out.m_format_ctx, pkt);
 
    if (ret < 0)
    {
        const char *type;
 
        if (mediatype != AVMEDIA_TYPE_ATTACHMENT)
        {
            type = av_get_media_type_string(mediatype);
 
            if (type == nullptr)
            {
                type = "unknown";
            }
        }
        else
        {
            type = "album art";
        }
 
        Logging::error(virtname(), "Could not write %1 frame (error '%2').", type, ffmpeg_geterror(ret).c_str());
    }
 
    return ret;
}
 
void FFmpeg_Transcoder::make_pts(AVPacket *pkt, int64_t *cur_ts) const
{
    if (pkt->pts != AV_NOPTS_VALUE)
    {
        *cur_ts = pkt->pts + pkt->duration;
    }
    else if (pkt->dts != AV_NOPTS_VALUE)
    {
        *cur_ts = pkt->dts;
    }
 
    if (pkt->duration)
    {
        if (pkt->pts == AV_NOPTS_VALUE)
        {
            pkt->pts            = *cur_ts;
        }
 
        *cur_ts += pkt->duration;
 
        if (pkt->dts == AV_NOPTS_VALUE)
        {
            pkt->dts            = *cur_ts;
        }
    }
}
 
int FFmpeg_Transcoder::decode_frame(AVPacket *pkt)
{
    int ret = 0;
 
    if (m_in.m_audio.m_stream != nullptr && is_audio_stream(pkt->stream_index) && stream_exists(m_out.m_audio.m_stream_idx))
    {
        if (m_reset_pts & FFMPEGFS_AUDIO && pkt->pts != AV_NOPTS_VALUE)
        {
            m_reset_pts &= ~FFMPEGFS_AUDIO; // Clear reset bit
 
            int64_t pkt_pts = ffmpeg_rescale_q(pkt->pts, m_in.m_audio.m_stream->time_base);
 
            m_out.m_audio_pts = ffmpeg_rescale_q(pkt_pts, av_get_time_base_q(), m_out.m_audio.m_stream->time_base);
 
            Logging::debug(virtname(), "Reset the PTS from the audio packet to %1.", format_duration(pkt_pts).c_str());
        }
 
        if (!m_copy_audio)
        {
            int decoded = 0;
            ret = decode_audio_frame(pkt, &decoded);
        }
        else
        {
            // Simply copy packet without recoding
            pkt->stream_index   = m_out.m_audio.m_stream_idx;
 
            // Rescale packet
            av_packet_rescale_ts(pkt, m_in.m_audio.m_stream->time_base, m_out.m_audio.m_stream->time_base);
 
            // Make PTS/DTS if missing
            make_pts(pkt, &m_cur_audio_ts);
 
            pkt->pos            = -1;
 
            ret = store_packet(pkt, AVMEDIA_TYPE_AUDIO);
        }
    }
    else if (m_in.m_video.m_stream != nullptr && is_video_stream(pkt->stream_index) && (stream_exists(m_out.m_video.m_stream_idx) || is_frameset()))
    {
        if (m_reset_pts & FFMPEGFS_VIDEO && pkt->pts != AV_NOPTS_VALUE)
        {
            m_reset_pts &= ~FFMPEGFS_VIDEO; // Clear reset bit
 
            int64_t pkt_pts = ffmpeg_rescale_q(pkt->pts, m_in.m_video.m_stream->time_base);
 
            m_out.m_video_pts = ffmpeg_rescale_q(pkt_pts, av_get_time_base_q(), m_out.m_video.m_stream->time_base);
 
            Logging::debug(virtname(), "Reset PTS from the video packet to %1.", format_duration(pkt_pts).c_str());
        }
 
        if (!m_copy_video)
        {
            int decoded = 0;
#ifndef USE_LIBDVD
            ret = decode_video_frame(pkt, &decoded);
#else //USE_LIBDVD
            if (m_virtualfile->m_type != VIRTUALTYPE::DVD)
            {
                ret = decode_video_frame(pkt, &decoded);
            }
            else
            {
                int lastret = 0;
 
                do
                {
                    // Decode one frame.
                    ret = decode_video_frame(pkt, &decoded);
 
                    if ((ret == AVERROR(EAGAIN) && ret == lastret) || ret == AVERROR_EOF)
                    {
                        // If EAGAIN reported twice or stream at EOF
                        // quit loop, but this is not an error
                        // (must process all streams).
                        break;
                    }
 
                    if (ret < 0 && ret != AVERROR(EAGAIN))
                    {
                        Logging::error(filename(), "Could not decode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
                        return ret;
                    }
 
                    lastret = ret;
 
                    pkt->data += decoded;
                    pkt->size -= decoded;
                }
                while (pkt->size > 0 && (ret == 0 || ret == AVERROR(EAGAIN)));
 
                ret = 0;
            }
#endif // USE_LIBDVD
        }
        else
        {
            // Simply copy packet without recoding
            pkt->stream_index   = m_out.m_video.m_stream_idx;
 
            // Rescale packet
            av_packet_rescale_ts(pkt, m_in.m_video.m_stream->time_base, m_out.m_video.m_stream->time_base);
 
            // Make PTS/DTS if missing
            make_pts(pkt, &m_cur_video_ts);
 
            pkt->pos            = -1;
 
            ret = store_packet(pkt, AVMEDIA_TYPE_VIDEO);
        }
    }
    else if (is_subtitle_stream(pkt->stream_index))
    {
        // Decode subtitle. No copy option available.
        int decoded = 0;
        ret = decode_subtitle(pkt, &decoded);
    }
    else
    {
        // Finally process album arts
        switch (m_in.m_format_ctx->streams[pkt->stream_index]->codecpar->codec_type)
        {
        case AVMEDIA_TYPE_VIDEO:
        {
            for (size_t n = 0; n < m_in.m_album_art.size() && n < m_out.m_album_art.size(); n++)
            {
                AVStream *input_stream = m_in.m_album_art.at(n).m_stream;
 
                // AV_DISPOSITION_ATTACHED_PIC streams already processed in process_albumarts()
                if (pkt->stream_index == input_stream->index && !(input_stream->disposition & AV_DISPOSITION_ATTACHED_PIC))
                {
                    AVStream *output_stream = m_out.m_album_art.at(n).m_stream;
 
                    ret = add_albumart_frame(output_stream, pkt);
                    break;
                }
            }
            break;
        }
        default:
        {
            break;
        }
        }
    }
 
    // If decoding errors should be ignored by command line, reset return code.
    // Exemptions that need to be passed on anyway:
    // * EAGAIN tells the caller to retry, this is not an error
    // * AVERROR_EXTERNAL is an unrecoverable error and should be handled
    if (!params.m_decoding_errors && ret < 0 && ret != AVERROR(EAGAIN) && ret != AVERROR_EXTERNAL)
    {
        // Ignore error, go on with transcoding
        ret = 0;
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::init_converted_samples(uint8_t ***converted_input_samples, int frame_size)
{
    int ret;
 
    // Allocate as many pointers as there are audio channels.
    // Each pointer will later point to the audio samples of the corresponding
    // channels (although it may be nullptr for interleaved formats).
 
    *converted_input_samples = static_cast<uint8_t **>(av_calloc(static_cast<size_t>(get_channels(m_out.m_audio.m_codec_ctx.get())), sizeof(**converted_input_samples)));
 
    if (*converted_input_samples == nullptr)
    {
        Logging::error(virtname(), "Could not allocate converted input sample pointers.");
        return AVERROR(ENOMEM);
    }
 
    // Allocate memory for the samples of all channels in one consecutive
    // block for convenience.
    ret = av_samples_alloc(*converted_input_samples, nullptr,
                           get_channels(m_out.m_audio.m_codec_ctx.get()),
                           frame_size,
                           m_out.m_audio.m_codec_ctx->sample_fmt, 0);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not allocate converted input samples (error '%1').", ffmpeg_geterror(ret).c_str());
        av_freep(&(*converted_input_samples)[0]);
        av_free(*converted_input_samples);
        return ret;
    }
    return 0;
}
 
int FFmpeg_Transcoder::convert_samples(uint8_t **input_data, int in_samples, uint8_t **converted_data, int *out_samples)
{
    if (m_audio_resample_ctx != nullptr)
    {
        int ret;
 
        // Convert the samples using the resampler.
        ret = swr_convert(m_audio_resample_ctx, converted_data, *out_samples, const_cast<const uint8_t **>(input_data), in_samples);
        if (ret  < 0)
        {
            Logging::error(virtname(), "Could not convert input samples (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
        *out_samples = ret;
    }
    else
    {
        *out_samples = in_samples;
 
        // No resampling, just copy samples
        if (!av_sample_fmt_is_planar(m_out.m_audio.m_codec_ctx->sample_fmt))
        {
            // Interleaved format
            int samples = in_samples * av_get_bytes_per_sample(m_out.m_audio.m_codec_ctx->sample_fmt) * get_channels(m_in.m_audio.m_codec_ctx.get());
            std::memcpy(converted_data[0], input_data[0], static_cast<size_t>(samples));
        }
        else
        {
            // Planar format
            int samples = in_samples * av_get_bytes_per_sample(m_out.m_audio.m_codec_ctx->sample_fmt);
            for (int n = 0; n < get_channels(m_out.m_audio.m_codec_ctx.get()); n++)
            {
                std::memcpy(converted_data[n], input_data[n], static_cast<size_t>(samples));
            }
        }
    }
    return 0;
}
 
int FFmpeg_Transcoder::add_samples_to_fifo(uint8_t **converted_input_samples, int frame_size)
{
    int ret;
 
    // Make the audio FIFO as large as it needs to be to hold both,
    // the old and the new samples.
 
    ret = m_audio_fifo.realloc(m_audio_fifo.size() + frame_size);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not reallocate the audio FIFO.");
        return ret;
    }
 
    // Store the new samples in the audio FIFO buffer.
    ret = m_audio_fifo.write(reinterpret_cast<void **>(converted_input_samples), frame_size);
    if (ret < frame_size)
    {
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not write data to audio FIFO (error '%1').", ffmpeg_geterror(ret).c_str());
        }
        else
        {
            Logging::error(virtname(), "Could not write data to audio FIFO.");
        }
        return AVERROR_EXIT;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::flush_frames_all(bool use_flush_packet)
{
    int ret = 0;
 
    if (m_in.m_audio.m_codec_ctx != nullptr)
    {
        int ret2 = flush_frames_single(m_in.m_audio.m_stream_idx, use_flush_packet);
        if (ret2 < 0)
        {
            ret = ret2;
        }
    }
 
    if (m_in.m_video.m_codec_ctx != nullptr)
    {
        int ret2 = flush_frames_single(m_in.m_video.m_stream_idx, use_flush_packet);
        if (ret2 < 0)
        {
            ret = ret2;
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::flush_frames_single(int stream_idx, bool use_flush_packet)
{
    int ret = 0;
 
    if (stream_exists(stream_idx))
    {
        int (FFmpeg_Transcoder::*decode_frame_ptr)(AVPacket *pkt, int *decoded) = nullptr;
 
        if (!m_copy_audio && is_audio_stream(stream_idx) && stream_exists(m_out.m_audio.m_stream_idx))
        {
            decode_frame_ptr = &FFmpeg_Transcoder::decode_audio_frame;
        }
        else if (!m_copy_video && is_video_stream(stream_idx) && (stream_exists(m_out.m_video.m_stream_idx) || is_frameset()))
        {
            decode_frame_ptr = &FFmpeg_Transcoder::decode_video_frame;
        }
 
        if (decode_frame_ptr != nullptr)
        {
            FFmpeg_Packet flush_packet(stream_idx);
            AVPacket *flush_packet_ptr = nullptr;
 
            if (flush_packet.res() < 0)
            {
                return flush_packet.res();
            }
 
            if (use_flush_packet)
            {
                flush_packet->data          = nullptr;
                flush_packet->size          = 0;
                flush_packet->stream_index  = stream_idx;
                flush_packet_ptr            = flush_packet;
            }
 
            // cppcheck-suppress knownConditionTrueFalse
            for (int decoded = 1; decoded;)
            {
                ret = (this->*decode_frame_ptr)(flush_packet_ptr, &decoded);
                if (ret < 0 && ret != AVERROR(EAGAIN))
                {
                    break;
                }
            }
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::read_decode_convert_and_store(int *finished)
{
    // Packet used for temporary storage.
    FFmpeg_Packet pkt;
    int ret = pkt.res();
 
    if (ret < 0)
    {
        return ret;
    }
 
    try
    {
        // Read one frame from the input file into a temporary packet.
        ret = av_read_frame(m_in.m_format_ctx, pkt);
        if (ret < 0)
        {
            if (ret == AVERROR_EOF)
            {
                // If we are the the end of the file, flush the decoder below.
                *finished = 1;
                Logging::trace(virtname(), "Read input file to EOF.");
            }
            else
            {
                Logging::error(virtname(), "Could not read frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
        }
 
        if (m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
        {
            // Check for end of cue sheet track
            if (is_audio_stream(pkt->stream_index))
            {
                int64_t pkt_pts = ffmpeg_rescale_q(pkt->pts, m_in.m_audio.m_stream->time_base);
                if (pkt_pts > m_virtualfile->m_cuesheet_track.m_start + m_virtualfile->m_cuesheet_track.m_duration)
                {
                    Logging::trace(virtname(), "Read to end of track.");
                    *finished = 1;
                    ret = AVERROR_EOF;
                }
            }
        }
 
        if (!*finished)
        {
            // Decode one packet, at least with the old API (!LAV_NEW_PACKET_INTERFACE)
            // it seems a packet can contain more than one frame so loop around it
            // if necessary...
            ret = decode_frame(pkt);
 
            if (ret < 0 && ret != AVERROR(EAGAIN))
            {
                throw ret;
            }
        }
        else
        {
            // Flush cached frames, ignoring any errors
            flush_frames_all(true);
        }
 
        ret = 0;    // Errors will be reported by exception
    }
    catch (int _ret)
    {
        ret = _ret;
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::init_audio_output_frame(AVFrame *frame, int frame_size) const
{
    int ret;
 
    //
    // Set the frame's parameters, especially its size and format.
    // av_frame_get_buffer needs this to allocate memory for the
    // audio samples of the frame.
    // Default channel layouts based on the number of channels
    // are assumed for simplicity.
 
    frame->nb_samples        = frame_size;
#if LAVU_DEP_OLD_CHANNEL_LAYOUT
    ret = av_channel_layout_copy(&frame->ch_layout, &m_out.m_audio.m_codec_ctx->ch_layout);
    if (ret < 0)
    {
        Logging::error(virtname(), "Unable to copy channel layout (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
#else   // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    frame->channel_layout    = m_out.m_audio.m_codec_ctx->channel_layout;
#endif  // !LAVU_DEP_OLD_CHANNEL_LAYOUT
    frame->format            = m_out.m_audio.m_codec_ctx->sample_fmt;
    frame->sample_rate       = m_out.m_audio.m_codec_ctx->sample_rate;
 
    // Allocate the samples of the created frame. This call will make
    // sure that the audio frame can hold as many samples as specified.
    // 29.05.2021: Let API decide about alignment. Should be properly set for the current CPU.
 
    ret = av_frame_get_buffer(frame, 0);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could allocate output frame samples (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return 0;
}
 
void FFmpeg_Transcoder::produce_audio_dts(AVPacket *pkt)
{
    if (pkt->pts == AV_NOPTS_VALUE && pkt->dts == AV_NOPTS_VALUE)
    {
        // Normally we have already added the PTS to the frame when it was created. Just in case
        // this failed, and there are no valid PTS/DTS values, we add it here.
        int64_t pkt_duration;
 
        // Some encoders to not produce dts/pts.
        // So we make some up.
        if (pkt->duration)
        {
            pkt_duration = pkt->duration;
 
#if !LAVC_DEP_TICKSPERFRAME
            // This has probably long since been fixed in FFmpeg, so we remove this completly
            // instead of replacing it with updated code.
            if (m_out.m_audio.m_codec_ctx->codec_id == AV_CODEC_ID_OPUS || m_current_format->filetype() == FILETYPE::TS || m_current_format->filetype() == FILETYPE::HLS)
            {
                if (pkt_duration > 0 && m_out.m_audio.m_stream->codecpar->sample_rate > 0)
                {
                    pkt->duration = pkt_duration = static_cast<int>(av_rescale(pkt_duration, static_cast<int64_t>(m_out.m_audio.m_stream->time_base.den) * m_out.m_audio.m_codec_ctx->ticks_per_frame, m_out.m_audio.m_stream->codecpar->sample_rate * static_cast<int64_t>(m_out.m_audio.m_stream->time_base.num)));
                }
            }
#endif
        }
        else
        {
            pkt_duration = 1;
        }
 
        pkt->dts = m_out.m_audio_pts - 1;
        pkt->pts = m_out.m_audio_pts;
 
        m_out.m_audio_pts += pkt_duration;
    }
}
 
int FFmpeg_Transcoder::encode_audio_frame(const AVFrame *frame, int *data_present)
{
    // Packet used for temporary storage.
    FFmpeg_Packet pkt;
    int ret = pkt.res();
 
    if (ret < 0)
    {
        return ret;
    }
 
    try
    {
        // Encode the audio frame and store it in the temporary packet.
        // The output audio stream encoder is used to do this.
 
        *data_present = 0;
 
        // send the frame for encoding
        ret = avcodec_send_frame(m_out.m_audio.m_codec_ctx.get(), frame);
        if (ret < 0 && ret != AVERROR_EOF)
        {
            Logging::error(virtname(), "Could not encode audio frame (error %1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        // read all the available output packets (in general there may be any number of them)
        while (ret >= 0)
        {
            *data_present = 0;
 
            ret = avcodec_receive_packet(m_out.m_audio.m_codec_ctx.get(), pkt);
            if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF)
            {
                throw ret;
            }
            else if (ret < 0)
            {
                Logging::error(virtname(), "Could not encode audio frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            *data_present = 1;
 
            // Write one audio frame from the temporary packet to the output buffer.
            {
                pkt->stream_index = m_out.m_audio.m_stream_idx;
 
                const bool packet_has_timestamps =
                    pkt->pts != AV_NOPTS_VALUE || pkt->dts != AV_NOPTS_VALUE;
 
                produce_audio_dts(pkt);
 
                /*
                 * AVFrame::pts passed to the encoder is in codec time base.
                 * Therefore packet timestamps returned by the encoder are in
                 * codec time base as well and must be converted to the output
                 * stream time base before muxing/storing.
                 *
                 * If produce_audio_dts() had to invent timestamps, it used the
                 * existing m_out.m_audio_pts fallback in output stream time base;
                 * do not rescale those invented values a second time.
                 */
                if (packet_has_timestamps)
                {
                    av_packet_rescale_ts(pkt,
                                         m_out.m_audio.m_codec_ctx->time_base,
                                         m_out.m_audio.m_stream->time_base);
                }
 
                ret = store_packet(pkt, AVMEDIA_TYPE_AUDIO);
                if (ret < 0)
                {
                    throw ret;
                }
            }
        }
 
        pkt.unref();
    }
    catch (int _ret)
    {
        pkt.unref();
        ret = _ret;
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::encode_image_frame(const AVFrame *frame, int *data_present)
{
    *data_present = 0;
 
    if (frame == nullptr || m_skip_next_frame)
    {
        // This called internally to flush frames. We do not have a cache to flush, so simply ignore that.
        // After seek oprations we need to skip the first frame.
        m_skip_next_frame = false;
        return 0;
    }
 
    if (m_current_format == nullptr)
    {
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::encode_image_frame()! Missing format.");
        return AVERROR(EINVAL);
    }
 
    if (m_buffer == nullptr)
    {
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::encode_image_frame()! Cache not open.");
        return AVERROR(EINVAL);
    }
 
    FFmpeg_Packet pkt;
    int ret = pkt.res();
 
    if (ret < 0)
    {
        return ret;
    }
 
    try
    {
        FFmpeg_Frame cloned_frame(frame);  // Clone frame. Does not copy data but references it, only the properties are copied. Not a big memory impact.
 
        ret = cloned_frame.res();
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not encode image frame (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        uint32_t frame_no = pts_to_frame(m_in.m_video.m_stream, frame->pts);
 
        if (m_current_format->video_codec() == AV_CODEC_ID_MJPEG)
        {
            // The MJEPG codec requires monotonically growing PTS values so we fake some to avoid them going backwards after seeks
            cloned_frame->pts = frame_to_pts(m_in.m_video.m_stream, ++m_fake_frame_no);
        }
 
        *data_present = 0;
 
        // send the frame for encoding
        ret = avcodec_send_frame(m_out.m_video.m_codec_ctx.get(), cloned_frame);
        if (ret < 0 && ret != AVERROR_EOF)
        {
            Logging::error(virtname(), "Could not encode image frame (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        // read all the available output packets (in general there may be any number of them
        while (ret >= 0)
        {
            *data_present = 0;
 
            ret = avcodec_receive_packet(m_out.m_video.m_codec_ctx.get(), pkt);
            if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF)
            {
                pkt.unref();
                break;
            }
            else if (ret < 0)
            {
                Logging::error(virtname(), "Could not encode image frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            *data_present = 1;
 
            // Write one video frame from the temporary packet to the output buffer.
            {
                // Store current video PTS
                if (pkt->pts != AV_NOPTS_VALUE)
                {
                    m_out.m_video_pts = pkt->pts;
                }
 
                m_buffer->write_frame(pkt->data, static_cast<size_t>(pkt->size), frame_no);
 
                if (m_last_seek_frame_no == frame_no)    // Skip frames until seek pos
                {
                    m_last_seek_frame_no = 0;
                }
            }
 
            pkt.unref();
        }
    }
    catch (int _ret)
    {
        pkt.unref();
        ret = _ret;
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::encode_video_frame(const AVFrame *frame, int *data_present)
{
    if (m_out.m_video.m_stream == nullptr)
    {
        return 0; // ignore, avoid crash
    }
 
    // Packet used for temporary storage.
    if (frame != nullptr)
    {
#if LAVU_ADD_NEW_FRAME_FLAGS
        if (frame->flags & AV_FRAME_FLAG_INTERLACED)
        {
            if (m_out.m_video.m_codec_ctx->codec->id == AV_CODEC_ID_MJPEG)
            {
                m_out.m_video.m_stream->codecpar->field_order = (frame->flags & AV_FRAME_FLAG_TOP_FIELD_FIRST) ? AV_FIELD_TT : AV_FIELD_BB;
            }
            else
            {
                m_out.m_video.m_stream->codecpar->field_order = (frame->flags & AV_FRAME_FLAG_TOP_FIELD_FIRST) ? AV_FIELD_TB : AV_FIELD_BT;
            }
        }
#else   // !LAVU_ADD_NEW_FRAME_FLAGS
        if (frame->interlaced_frame)
        {
            if (m_out.m_video.m_codec_ctx->codec->id == AV_CODEC_ID_MJPEG)
            {
                m_out.m_video.m_stream->codecpar->field_order = frame->top_field_first ? AV_FIELD_TT : AV_FIELD_BB;
            }
            else
            {
                m_out.m_video.m_stream->codecpar->field_order = frame->top_field_first ? AV_FIELD_TB : AV_FIELD_BT;
            }
        }
#endif  // !LAVU_ADD_NEW_FRAME_FLAGS
        else
        {
            m_out.m_video.m_stream->codecpar->field_order = AV_FIELD_PROGRESSIVE;
        }
    }
    FFmpeg_Frame *hw_frame = nullptr;
    FFmpeg_Packet pkt;
    int ret = pkt.res();
 
    if (ret < 0)
    {
        return ret;
    }
 
    try
    {
        if (m_hwaccel_enable_enc_buffering && frame != nullptr)
        {
            hw_frame = new (std::nothrow) FFmpeg_Frame(m_out.m_video.m_stream_idx);
            if (hw_frame == nullptr)
            {
                ret = AVERROR(ENOMEM);
                Logging::error(virtname(), "Could not encode video frame at PTS=%1 (error %2').", ffmpeg_rescale_q(frame->pts, m_in.m_video.m_stream->time_base), ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            ret = hw_frame->res();
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not encode video frame at PTS=%1 (error %2').", ffmpeg_rescale_q(frame->pts, m_in.m_video.m_stream->time_base), ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            // If encoding is done in hardware, the resulting frame data needs to be copied to hardware
            ret = hwframe_copy_to_hw(m_out.m_video.m_codec_ctx.get(), hw_frame, frame);
            if (ret < 0)
            {
                throw ret;
            }
            frame = *hw_frame;  // Copy, not clone!
        }
 
        // Encode the video frame and store it in the temporary packet.
        // The output video stream encoder is used to do this.
 
        *data_present = 0;
 
        // send the frame for encoding
        ret = avcodec_send_frame(m_out.m_video.m_codec_ctx.get(), frame);
        if (ret < 0 && ret != AVERROR_EOF)
        {
            Logging::error(virtname(), "Could not encode video frame (error %1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        // read all the available output packets (in general there may be any number of them
        while (ret >= 0)
        {
            *data_present = 0;
 
            ret = avcodec_receive_packet(m_out.m_video.m_codec_ctx.get(), pkt);
            if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF)
            {
                pkt.unref();
                break;
            }
            else if (ret < 0)
            {
                Logging::error(virtname(), "Could not encode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            *data_present = 1;
 
            // Write one video frame from the temporary packet to the output buffer.
            {
                // Fix for issue #46: bitrate too high.
                av_packet_rescale_ts(pkt, m_out.m_video.m_codec_ctx->time_base, m_out.m_video.m_stream->time_base);
 
                if (!(m_out.m_format_ctx->oformat->flags & AVFMT_NOTIMESTAMPS))
                {
                    if (pkt->dts != AV_NOPTS_VALUE &&
                            pkt->pts != AV_NOPTS_VALUE &&
                            pkt->dts > pkt->pts &&
                            m_out.m_last_mux_dts != AV_NOPTS_VALUE)
                    {
 
                        Logging::warning(virtname(), "Invalid DTS=%1 PTS=%2 in video output, replacing by guess.", pkt->dts, pkt->pts);
 
                        pkt->pts =
                                pkt->dts = pkt->pts + pkt->dts + m_out.m_last_mux_dts + 1
                                - FFMIN3(pkt->pts, pkt->dts, m_out.m_last_mux_dts + 1)
                                - FFMAX3(pkt->pts, pkt->dts, m_out.m_last_mux_dts + 1);
                    }
 
                    if (pkt->dts != AV_NOPTS_VALUE && m_out.m_last_mux_dts != AV_NOPTS_VALUE)
                    {
                        int64_t max = m_out.m_last_mux_dts + !(m_out.m_format_ctx->oformat->flags & AVFMT_TS_NONSTRICT);
                        // AVRational avg_frame_rate = { m_out.m_video.m_stream->avg_frame_rate.den, m_out.m_video.m_stream->avg_frame_rate.num };
                        // int64_t max = m_out.m_last_mux_dts + ffmpeg_rescale_q(1, avg_frame_rate, m_out.m_video.m_stream->time_base);
 
                        if (pkt->dts < max)
                        {
                            Logging::trace(virtname(), "Non-monotonous DTS in video output stream; previous: %1, current: %2; changing to %3. This may result in incorrect timestamps in the output.", m_out.m_last_mux_dts, pkt->dts, max);
 
                            if (pkt->pts >= pkt->dts)
                            {
                                pkt->pts = FFMAX(pkt->pts, max);
                            }
                            pkt->dts = max;
                        }
                    }
                }
 
                if (frame != nullptr && !pkt->duration)
                {
#if !LAVU_DEP_PKT_DURATION
                    pkt->duration = frame->pkt_duration;
#else
                    pkt->duration = frame->duration;
#endif
                }
 
                if (pkt->pts != AV_NOPTS_VALUE)
                {
                    m_out.m_video_pts       = pkt->pts;
                    m_out.m_last_mux_dts    = (pkt->dts != AV_NOPTS_VALUE) ? pkt->dts : (pkt->pts - pkt->duration);
                }
 
                // Write packet to buffer
                ret = store_packet(pkt, AVMEDIA_TYPE_VIDEO);
                if (ret < 0)
                {
                    throw ret;
                }
            }
 
            pkt.unref();
        }
    }
    catch (int _ret)
    {
        pkt.unref();
        ret = _ret;
    }
 
    delete hw_frame;
 
    return ret;
}
 
int FFmpeg_Transcoder::encode_subtitle(const AVSubtitle *sub, int out_stream_idx, int *data_present)
{
    StreamRef * out_streamref = get_out_subtitle_stream(out_stream_idx);
 
    *data_present = 0;
 
    if (out_streamref == nullptr)
    {
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::encode_subtitle()! Invalid stream index #%1.", out_stream_idx);
        return AVERROR(EINVAL);
    }
 
    // Packet used for temporary storage.
    FFmpeg_Packet pkt;
    int ret = pkt.res();
 
    if (ret < 0)
    {
        return ret;
    }
 
    AVSubtitle subtmp;
 
    // Make a local copy, we have to modify it
    std::memcpy(&subtmp, sub, sizeof(AVSubtitle));
 
    try
    {
        int nb;
        int64_t sub_pts;
 
        if (subtmp.pts == AV_NOPTS_VALUE)
        {
            Logging::error(virtname(), "Subtitle packets must have a PTS (stream index #%1).", out_streamref->m_stream_idx);
            throw AVERROR(EINVAL);
        }
 
        // Allocate a packet with 1KB buffer, hope that's sufficient
        ret = av_new_packet(pkt, 1024 * 1024);
        if (ret < 0)
        {
            Logging::error(virtname(), "Failed to allocate new packet (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        // Note: DVB subtitles need one packet to draw them and one other packet to clear them
        if (out_streamref->m_codec_ctx->codec_id == AV_CODEC_ID_DVB_SUBTITLE)
        {
            nb = 2;
        }
        else
        {
            nb = 1;
        }
 
        // shift timestamp
        sub_pts = subtmp.pts;
 
        //if (out_streamref->m_stream->start_time != AV_NOPTS_VALUE)
        //{
        //    pts -= ffmpeg_rescale_q(out_streamref->m_stream->start_time, out_streamref->m_stream->time_base);
        //}
 
        for (int i = 0; i < nb; i++)
        {
            unsigned save_num_rects     = subtmp.num_rects;
            subtmp.pts                  = sub_pts;
            // Some decoders may return end_display_time as UINT32_MAX, this causes strange results.
            if (subtmp.end_display_time == UINT32_MAX)
            {
                subtmp.end_display_time = 0;
            }
 
            // start_display_time is required to be 0
            subtmp.pts                  += ffmpeg_rescale_q(subtmp.start_display_time, AVRational({ 1, 1000 }));
            subtmp.end_display_time     -= subtmp.start_display_time;
            subtmp.start_display_time   = 0;
            if (i == 1)
            {
                subtmp.num_rects = 0;
            }
 
            // The avcodec_encode_subtitle seems to be not completely ready
            ret = avcodec_encode_subtitle(out_streamref->m_codec_ctx.get(), pkt->data, pkt->size, &subtmp);
            if (i == 1)
            {
                subtmp.num_rects = save_num_rects;
            }
 
            if (ret < 0)
            {
                Logging::error(virtname(), "Could not encode subtitle frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            pkt->size           = ret;
            pkt->pts            = ffmpeg_rescale_q(subtmp.pts, av_get_time_base_q(), out_streamref->m_stream->time_base);
            pkt->duration       = ffmpeg_rescale_q(subtmp.end_display_time, AVRational({ 1, 1000 }), out_streamref->m_stream->time_base);
            pkt->stream_index   = out_streamref->m_stream_idx;
 
            if (out_streamref->m_codec_ctx->codec_id == AV_CODEC_ID_DVB_SUBTITLE)
            {
                // the pts correction is handled here. Maybe handling it in the codec would be better
                if (i)
                {
                    pkt->pts += ffmpeg_rescale_q(subtmp.end_display_time, AVRational({ 1, 1000 }), out_streamref->m_stream->time_base);
                }
            }
            pkt->dts = pkt->pts;
 
            ret = store_packet(pkt, AVMEDIA_TYPE_SUBTITLE);
            if (ret < 0)
            {
                throw ret;
            }
 
            *data_present = 1;
        }
        pkt.unref();
    }
    catch (int _ret)
    {
        pkt.unref();
        ret = _ret;
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::create_audio_frame(int frame_size)
{
    // Temporary storage of the output samples of the frame written to the file.
    FFmpeg_Frame output_frame(m_out.m_audio.m_stream_idx);
    int ret = 0;
 
    ret = output_frame.res();
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not read data from the audio FIFO (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    // Use the maximum number of possible samples per frame.
    // If there is less than the maximum possible frame size in the audio FIFO
    // buffer use this number. Otherwise, use the maximum possible frame size
 
    frame_size = FFMIN(m_audio_fifo.size(), frame_size);
 
    // Initialise temporary storage for one output frame.
    ret = init_audio_output_frame(output_frame, frame_size);
    if (ret < 0)
    {
        return ret;
    }
 
    // Read as many samples from the FIFO buffer as required to fill the frame.
    // The samples are stored in the frame temporarily.
 
    ret = m_audio_fifo.read(reinterpret_cast<void **>(output_frame->data), frame_size);
    if (ret < frame_size)
    {
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not read data from the audio FIFO (error '%1').", ffmpeg_geterror(ret).c_str());
        }
        else
        {
            Logging::error(virtname(), "Could not read data from the audio FIFO.");
            ret = AVERROR_EXIT;
        }
        return ret;
    }
 
    /*
     * Build the output frame PTS.
     *
     * Keep m_out.m_audio_pts in the output stream time base because that is
     * what the cache/frame map and muxing side use. However, AVFrame::pts
     * handed to avcodec_send_frame() must use the encoder codec time base.
     *
     * This mirrors the video path: frames are passed to the encoder in codec
     * time base, and encoded packets are converted back to stream time base
     * before they are stored.
     */
    const int64_t stream_pts = m_out.m_audio_pts;
 
    if (output_frame->sample_rate)
    {
        // Not used for encoding, but keep it meaningful for diagnostics.
        output_frame->best_effort_timestamp = ffmpeg_rescale_q(stream_pts,
                                                               m_out.m_audio.m_stream->time_base,
                                                               m_in.m_audio.m_stream->time_base);
 
        output_frame->pts = ffmpeg_rescale_q(stream_pts,
                                             m_out.m_audio.m_stream->time_base,
                                             m_out.m_audio.m_codec_ctx->time_base);
 
        // duration = `a * b / c` = AV_TIME_BASE * output_frame->nb_samples / output_frame->sample_rate;
        int64_t sample_duration = av_rescale(AV_TIME_BASE, output_frame->nb_samples, output_frame->sample_rate);
 
        sample_duration = ffmpeg_rescale_q(sample_duration, av_get_time_base_q(), m_out.m_audio.m_stream->time_base);
 
        m_out.m_audio_pts += sample_duration;
    }
 
    int64_t pos = ffmpeg_rescale_q_rnd(stream_pts - m_out.m_audio.m_start_time, m_out.m_audio.m_stream->time_base);
 
    m_frame_map.emplace(pos, output_frame);
 
    return ret;
}
 
int FFmpeg_Transcoder::write_output_file_trailer()
{
    int ret;
 
    ret = av_write_trailer(m_out.m_format_ctx);
    if (ret < 0)
    {
        Logging::error(virtname(), "Could not write output file trailer (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return 0;
}
 
time_t FFmpeg_Transcoder::mtime() const
{
    return m_mtime;
}
 
template <size_t size>
const char * FFmpeg_Transcoder::tagcpy(char (&out) [ size ], const std::string & in) const  // NOLINT(modernize-avoid-c-arrays)
{
    std::memset(out, ' ', size);
    std::memcpy(out, in.c_str(), std::min(size, in.size()));
    return out;
}
 
template <class T>
const T & FFmpeg_Transcoder::tagcpy(T & out, const std::string & in) const
{
    out.fill(' ');
    std::memcpy(out.data(), in.c_str(), std::min(out.size(), in.size()));
    //    std::memset(out, ' ', size);
    //    std::memcpy(out, in.c_str(), std::min(size, in.size()));
    return out;
}
 
 
void FFmpeg_Transcoder::copy_metadata(AVDictionary **metadata_out, const AVDictionary *metadata_in, bool contentstream)
{
    AVDictionaryEntry *tag = nullptr;
 
    while ((tag = av_dict_get(metadata_in, "", tag, AV_DICT_IGNORE_SUFFIX)) != nullptr)
    {
        std::string value(tag->value);
 
        if (contentstream && m_virtualfile != nullptr && m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
        {
            // Replace tags with cue sheet values
            if (!strcasecmp(tag->key, "ARTIST"))
            {
                value = m_virtualfile->m_cuesheet_track.m_artist;
            }
            else if (!strcasecmp(tag->key, "TITLE"))
            {
                value = m_virtualfile->m_cuesheet_track.m_title;
            }
            else if (!strcasecmp(tag->key, "TRACK"))
            {
                strsprintf(&value, "%i", m_virtualfile->m_cuesheet_track.m_trackno);
            }
        }
 
        dict_set_with_check(metadata_out, tag->key, value.c_str(), 0, virtname());
 
        if (contentstream && m_out.m_filetype == FILETYPE::MP3)
        {
            // For MP3 fill in ID3v1 structure
            if (!strcasecmp(tag->key, "ARTIST"))
            {
                tagcpy(m_out.m_id3v1.m_artist, value);
            }
            else if (!strcasecmp(tag->key, "TITLE"))
            {
                tagcpy(m_out.m_id3v1.m_title, value);
            }
            else if (!strcasecmp(tag->key, "ALBUM"))
            {
                tagcpy(m_out.m_id3v1.m_album, value);
            }
            else if (!strcasecmp(tag->key, "COMMENT"))
            {
                tagcpy(m_out.m_id3v1.m_comment, value);
            }
            else if (!strcasecmp(tag->key, "YEAR") || !strcasecmp(tag->key, "DATE"))
            {
                tagcpy(m_out.m_id3v1.m_year, value);
            }
            else if (!strcasecmp(tag->key, "TRACK"))
            {
                m_out.m_id3v1.m_title_no = static_cast<char>(std::stoi(value));
            }
        }
    }
}
 
int FFmpeg_Transcoder::process_metadata()
{
    Logging::trace(virtname(), "Processing metadata.");
 
    if (m_in.m_audio.m_stream != nullptr && m_in.m_audio.m_stream->codecpar->codec_id == AV_CODEC_ID_VORBIS)
    {
        // For some formats (namely ogg) FFmpeg returns the tags, odd enough, with streams...
        copy_metadata(&m_out.m_format_ctx->metadata, m_in.m_audio.m_stream->metadata);
    }
 
    copy_metadata(&m_out.m_format_ctx->metadata, m_in.m_format_ctx->metadata);
 
    if (m_out.m_audio.m_stream != nullptr && m_in.m_audio.m_stream != nullptr)
    {
        // Copy audio stream meta data
        copy_metadata(&m_out.m_audio.m_stream->metadata, m_in.m_audio.m_stream->metadata);
    }
 
    if (m_out.m_video.m_stream != nullptr && m_in.m_video.m_stream != nullptr)
    {
        // Copy video stream meta data
        copy_metadata(&m_out.m_video.m_stream->metadata, m_in.m_video.m_stream->metadata);
    }
 
    // Also copy album art meta tags
    for (size_t n = 0; n < m_in.m_album_art.size() && n < m_out.m_album_art.size(); n++)
    {
        AVStream *input_stream = m_in.m_album_art.at(n).m_stream;
        AVStream *output_stream = m_out.m_album_art.at(n).m_stream;
 
        copy_metadata(&output_stream->metadata, input_stream->metadata, is_audio_stream(input_stream->index) || is_video_stream(input_stream->index));
    }
 
    if (m_virtualfile != nullptr && m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
    {
        dict_set_with_check(&m_out.m_format_ctx->metadata, "TRACKTOTAL", m_virtualfile->m_cuesheet_track.m_tracktotal, 0, virtname());
        dict_set_with_check(&m_out.m_format_ctx->metadata, "TRACK", m_virtualfile->m_cuesheet_track.m_trackno, 0, virtname(), true);
        dict_set_with_check(&m_out.m_format_ctx->metadata, "ARTIST", m_virtualfile->m_cuesheet_track.m_artist.c_str(), 0, virtname(), true);
        if (av_dict_get(m_out.m_format_ctx->metadata, "ALBUM_ARTIST", nullptr, 0) == nullptr)
        {
            // Issue #78: duplicate ARTIST tag to ALBUM_ARTIST, if target is empty.
            dict_set_with_check(&m_out.m_format_ctx->metadata, "ALBUM_ARTIST", m_virtualfile->m_cuesheet_track.m_artist.c_str(), 0, virtname(), true);
        }
        dict_set_with_check(&m_out.m_format_ctx->metadata, "TITLE", m_virtualfile->m_cuesheet_track.m_title.c_str(), 0, virtname(), true);
        dict_set_with_check(&m_out.m_format_ctx->metadata, "ALBUM", m_virtualfile->m_cuesheet_track.m_album.c_str(), 0, virtname(), true);
        dict_set_with_check(&m_out.m_format_ctx->metadata, "GENRE", m_virtualfile->m_cuesheet_track.m_genre.c_str(), 0, virtname(), true);
        dict_set_with_check(&m_out.m_format_ctx->metadata, "DATE", m_virtualfile->m_cuesheet_track.m_date.c_str(), 0, virtname(), true);
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::process_albumarts()
{
    int ret = 0;
 
    for (size_t n = 0; n < m_in.m_album_art.size() && n < m_out.m_album_art.size(); n++)
    {
        AVStream *input_stream = m_in.m_album_art.at(n).m_stream;
 
        if (input_stream->disposition & AV_DISPOSITION_ATTACHED_PIC)
        {
            AVStream *output_stream = m_out.m_album_art.at(n).m_stream;
 
            ret = add_albumart_frame(output_stream, &input_stream->attached_pic);
            if (ret < 0)
            {
                break;
            }
        }
    }
 
    return ret;
}
 
void FFmpeg_Transcoder::flush_buffers()
{
    if (m_in.m_audio.m_codec_ctx != nullptr)
    {
        avcodec_flush_buffers(m_in.m_audio.m_codec_ctx.get());
    }
    if (m_in.m_video.m_codec_ctx != nullptr)
    {
        avcodec_flush_buffers(m_in.m_video.m_codec_ctx.get());
    }
}
 
int FFmpeg_Transcoder::do_seek_frame(uint32_t frame_no)
{
    m_have_seeked           = true;     // Note that we have seeked, thus skipped frames. We need to start transcoding over to fill any gaps.
 
    //m_skip_next_frame = true; /**< @todo Take deinterlace into account. If deinterlace is on the frame number is decreased by one. */
 
    if (m_skip_next_frame)
    {
        --frame_no;
    }
 
    int64_t vstream_pts = frame_to_pts(m_in.m_video.m_stream, frame_no);
 
    if (m_in.m_video.m_stream->start_time != AV_NOPTS_VALUE)
    {
        vstream_pts += m_in.m_video.m_stream->start_time;
    }
 
    return av_seek_frame(m_in.m_format_ctx, m_in.m_video.m_stream_idx, vstream_pts, AVSEEK_FLAG_BACKWARD|AVSEEK_FLAG_FRAME);
}
 
int FFmpeg_Transcoder::skip_decoded_frames(uint32_t frame_no, bool forced_seek)
{
    int ret = 0;
    uint32_t next_frame_no = frame_no;
 
    // Seek next undecoded frame
    for (; m_buffer->have_frame(next_frame_no); next_frame_no++)
    {
        std::this_thread::yield();
    }
 
    if (next_frame_no > m_virtualfile->m_video_frame_count)
    {
        // Reached end of file
        // Set PTS to end of file
        m_out.m_video_pts = m_in.m_video.m_stream->duration;
        if (m_in.m_video.m_stream->start_time != AV_NOPTS_VALUE)
        {
            m_out.m_video_pts += m_in.m_video.m_stream->start_time;
        }
        // Seek to end of file to force AVERROR_EOF from next av_read_frame() call. Ignore errrors.
        av_seek_frame(m_in.m_format_ctx, m_in.m_video.m_stream_idx, m_out.m_video_pts, AVSEEK_FLAG_ANY);
        return 0;
    }
 
    uint32_t last_frame_no = pts_to_frame(m_in.m_video.m_stream, m_out.m_video_pts);
 
    // Ignore seek if target is within the next FRAME_SEEK_THRESHOLD frames
    if (next_frame_no >= last_frame_no /*+ 1*/ && next_frame_no <= last_frame_no + FRAME_SEEK_THRESHOLD)
    {
        return 0;
    }
 
    if (forced_seek || (frame_no != next_frame_no && next_frame_no > 1))
    {
        // If frame changed, skip to it
        ret = do_seek_frame(next_frame_no);
 
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not encode audio frame: Seek to frame #%1 failed (error '%2').", next_frame_no, ffmpeg_geterror(ret).c_str());
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::flush_delayed_audio()
{
    int ret = 0;
 
    if (m_out.m_audio.m_codec_ctx != nullptr)
    {
        // Flush the encoder as it may have delayed frames.
        int data_written = 0;
        do
        {
            ret = encode_audio_frame(nullptr, &data_written);
 
            if (ret == AVERROR_EOF)
            {
                // Not an error
                break;
            }
 
            if (ret < 0 && ret != AVERROR(EAGAIN))
            {
                Logging::error(virtname(), "Could not encode audio frame (error '%1').", ffmpeg_geterror(ret).c_str());
                break;
            }
        }
        while (data_written);
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::flush_delayed_video()
{
    int ret = 0;
 
    if (m_out.m_video.m_codec_ctx != nullptr)
    {
        // Flush the encoder as it may have delayed frames.
        int data_written = 0;
        do
        {
            if (!is_frameset())
            {
                // Encode regular frame
                ret = encode_video_frame(nullptr, &data_written);
            }
            else
            {
                // Encode seperate image frame
                ret = encode_image_frame(nullptr, &data_written);
            }
 
            if (ret == AVERROR_EOF)
            {
                // Not an error
                break;
            }
            if (ret < 0 && ret != AVERROR(EAGAIN))
            {
                Logging::error(virtname(), "Could not encode video frame (error '%1').", ffmpeg_geterror(ret).c_str());
                break;
            }
        }
        while (data_written);
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::flush_delayed_subtitles()    
{
    return 0;
}
 
int FFmpeg_Transcoder::copy_audio_to_frame_buffer(int *finished)
{
    int output_frame_size;
 
    if (m_out.m_audio.m_codec_ctx->codec->capabilities & AV_CODEC_CAP_VARIABLE_FRAME_SIZE)
    {
        // Encode supports variable frame size, use an arbitrary value
        output_frame_size =  10000;
    }
    else
    {
        // Use the encoder's desired frame size for processing.
        output_frame_size = m_out.m_audio.m_codec_ctx->frame_size;
    }
 
    // Make sure that there is one frame worth of samples in the audio FIFO
    // buffer so that the encoder can do its work.
    // Since the decoder's and the encoder's frame size may differ, we
    // need to FIFO buffer to store as many frames worth of input samples
    // that they make up at least one frame worth of output samples.
 
    while (m_audio_fifo.size() < output_frame_size)
    {
        int ret = 0;
 
        // Decode one frame worth of audio samples, convert it to the
        // output sample format and put it into the audio FIFO buffer.
 
        ret = read_decode_convert_and_store(finished);
        if (ret < 0)
        {
            return ret;
        }
 
        // If we are at the end of the input file, we continue
        // encoding the remaining audio samples to the output file.
 
        if (*finished)
        {
            break;
        }
    }
 
    // If we have enough samples for the encoder, we encode them.
    // At the end of the file, we pass the remaining samples to
    // the encoder.
 
    while (m_audio_fifo.size() >= output_frame_size || (*finished && m_audio_fifo.size() > 0))
    {
        int ret = 0;
 
        // Take one frame worth of audio samples from the audio FIFO buffer,
        // create a frame and store in audio frame buffer.
 
        ret = create_audio_frame(output_frame_size);
        if (ret < 0)
        {
            return ret;
        }
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::process_single_fr(DECODER_STATUS *status)
{
    int finished = 0;
 
    *status = DECODER_STATUS::DEC_SUCCESS;
 
    try
    {
        if (m_in.m_video.m_stream != nullptr && is_frameset())
        {
            int ret = 0;
 
            // Direct access handling for frame sets: seek to frame if requested.
            ret = seek_frame();
            if (ret == AVERROR_EOF)
            {
                *status = DECODER_STATUS::DEC_EOF;  // Report EOF, but return no error
                throw 0;
            }
 
            if (ret < 0)
            {
                throw ret;
            }
        }
 
        if (!m_copy_audio && stream_exists(m_out.m_audio.m_stream_idx))
        {
            int ret = 0;
 
            // Copy audio FIFO into frame buffer
            ret = copy_audio_to_frame_buffer(&finished);
            if (ret < 0)
            {
                throw ret;
            }
        }
        else
        {
            int ret = 0;
 
            // If we have no audio stream, we'll only get video data
            // or we simply copy audio and/or video frames into the packet queue
            ret = read_decode_convert_and_store(&finished);
            if (ret < 0)
            {
                throw ret;
            }
 
            if (finished)
            {
                *status = DECODER_STATUS::DEC_EOF;  // Report EOF
            }
        }
 
        do
        {
            if (!is_frameset())
            {
                int64_t delay;
 
                // The following values are arbitrarily chosen and seem to work.
                if (is_hls())
                {
                    delay = params.m_segment_duration * 75 / 100;   // 75% of the segment duration
                }
                else
                {
                    delay = 6 * AV_TIME_BASE;                       // 6 seconds
                }
 
                if (!finished && (!m_frame_map.empty() && m_frame_map.cbegin()->first + delay > m_frame_map.crbegin()->first))
                {
                    return 0;
                }
 
                while (!m_frame_map.empty())
                {
                    // Take first entry in map
                    MULTIFRAME_MAP::const_iterator it = m_frame_map.cbegin();
 
                    if (is_hls())
                    {
                        uint32_t next_segment = get_next_segment(it->first);
 
                        if (goto_next_segment(next_segment))
                        {
                            // Reached next segment, end current now, and force new.
                            m_inhibit_stream_msk = m_active_stream_msk;
                            break;
                        }
                    }
 
                    // Get multiframe from map
                    MULTIFRAME multiframe = it->second;
 
                    // Drop key from map, we've got a clone in multiframe now.
                    m_frame_map.erase(it);
 
                    if (std::holds_alternative<FFmpeg_Frame>(multiframe))
                    {
                        // Object is an audio/video frame
                        const FFmpeg_Frame & frame = std::get<FFmpeg_Frame>(multiframe);
 
                        int stream_idx = frame.m_stream_idx;
 
                        if (!stream_exists(stream_idx))
                        {
                            Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::process_single_fr()! Invalid stream index in audio/video buffer skipped.");
                            continue;
                        }
 
                        if (stream_idx == m_out.m_audio.m_stream_idx)
                        {
                            // Encode audio
                            int ret = 0;
                            int data_written;
 
                            // Encode one frame worth of audio samples.
                            ret = encode_audio_frame(frame, &data_written);
 
                            if (ret < 0 && ret != AVERROR(EAGAIN))
                            {
                                throw ret;
                            }
                        }
                        else if (stream_idx == m_out.m_video.m_stream_idx)
                        {
                            // Encode video
                            int ret = 0;
                            int data_written = 0;
                            ret = encode_video_frame(frame, &data_written);
 
                            if (ret < 0 && ret != AVERROR(EAGAIN))
                            {
                                throw ret;
                            }
                        }
                    }
                    else if (std::holds_alternative<FFmpeg_Subtitle>(multiframe))
                    {
                        // Object is a subtitle
                        const FFmpeg_Subtitle & subtitle = std::get<FFmpeg_Subtitle>(multiframe);
 
                        int stream_idx = subtitle.m_stream_idx;
 
                        if (!stream_exists(stream_idx))
                        {
                            Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::process_single_fr()! Invalid stream index in subtitle buffer skipped.");
                            continue;
                        }
 
                        // Encode subtitles
 
                        int ret = 0;
                        int data_written = 0;
 
                        ret = encode_subtitle(subtitle, stream_idx, &data_written);
 
                        if (ret < 0 && ret != AVERROR(EAGAIN))
                        {
                            throw ret;
                        }
                    }
                }
            }
            else
            {
                // Frame sets: no audio, no subtitles, no output stream (index)
                while (!m_frame_map.empty())
                {
                    // Although I abhore "auto", it seems that nodes are declared slightly different throughout
                    // several std::map implementations. To avoid #ifdef orgies, I resign: Using "auto" here
                    // is much more coherent.
                    auto nh = m_frame_map.extract(m_frame_map.cbegin());
                    const MULTIFRAME & multiframe = nh.mapped();
                    int ret = 0;
                    int data_written = 0;
 
                    // Encode video
                    ret = encode_image_frame(std::get<FFmpeg_Frame>(multiframe), &data_written);
 
                    if (ret < 0 && ret != AVERROR(EAGAIN))
                    {
                        throw ret;
                    }
                }
            }
 
            if (is_hls() && m_active_stream_msk == m_inhibit_stream_msk)
            {
                // Start new HLS segment
                int ret = 0;
 
                ret = start_new_segment();
                if (ret < 0)
                {
                    throw ret;
                }
            }
        } while (finished && !m_frame_map.empty()); // Ensure we've processed all frames in our buffer
 
        // If we are at the end of the input file and have encoded
        // all remaining samples, we can exit this loop and finish.
 
        if (finished && m_frame_map.empty())
        {
            flush_delayed_audio();
            flush_delayed_video();
            flush_delayed_subtitles();
 
            *status = DECODER_STATUS::DEC_EOF;  // Report EOF
        }
    }
    catch (int _ret)
    {
        *status = (_ret != AVERROR_EOF ? DECODER_STATUS::DEC_ERROR : DECODER_STATUS::DEC_EOF);   // If _ret == AVERROR_EOF, simply signal EOF
        return _ret;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::seek_frame()
{
    if (!m_last_seek_frame_no)
    {
        // No current seek frame, check if new seek frame was stacked.
        {
            std::lock_guard<std::recursive_mutex> lock_seek_to_fifo_mutex(m_seek_to_fifo_mutex);
 
            while (!m_seek_to_fifo.empty())
            {
                uint32_t frame_no = m_seek_to_fifo.front();
                m_seek_to_fifo.pop();
 
                if (!m_buffer->have_frame(frame_no))
                {
                    // Frame not yet decoded, so skip to it.
                    m_last_seek_frame_no = frame_no;
                    break;
                }
            }
        }
 
        if (m_last_seek_frame_no)
        {
            int ret = 0;
 
            // The first frame that FFmpeg API returns after av_seek_frame is wrong (the last frame before seek).
            // We are unable to detect that because the pts seems correct (the one that we requested).
            // So we position before the frame requested, and simply throw the first away.
 
            //#define PRESCAN_FRAMES  3
            uint32_t seek_frame_no = m_last_seek_frame_no.exchange(0);
#ifdef PRESCAN_FRAMES
            if (seek_frame_no > PRESCAN_FRAMES)
            {
                seek_frame_no -= PRESCAN_FRAMES;
                //m_skip_next_frame = true; /**< @todo Take deinterlace into account */
            }
            else
            {
                seek_frame_no = 1;
            }
 
#endif
            ret = skip_decoded_frames(seek_frame_no, true);
            if (ret < 0)
            {
                return ret;
            }
        }
    }
    return 0;
}
 
int FFmpeg_Transcoder::start_new_segment()
{
    bool opened = false;
 
    encode_finish();
 
    // Go to next requested segment...
    uint32_t next_segment = m_current_segment + 1;
 
    // ...or process any stacked seek requests.
    while (!m_seek_to_fifo.empty())
    {
        uint32_t segment_no = m_seek_to_fifo.front();
        m_seek_to_fifo.pop();
 
        // No check if m_segment_duration == 0, values <= 0 not accepted
        // Cast is OK here, the result will always be small enough for an int32.
        uint32_t min_seek_segments = static_cast<uint32_t>(params.m_min_seek_time_diff / params.m_segment_duration);
 
        if (min_seek_segments && segment_no >= next_segment && segment_no <= next_segment + min_seek_segments)
        {
            Logging::info(virtname(), "Discarding seek request to HLS segment no. %1, less than %2 seconds (%3 segments) away.", segment_no, params.m_min_seek_time_diff / AV_TIME_BASE, min_seek_segments);
            continue;
        }
 
        if (!m_buffer->segment_exists(segment_no) || !m_buffer->tell(segment_no)) // NOT EXIST or NO DATA YET
        {
            int ret = 0;
 
            m_reset_pts    = FFMPEGFS_AUDIO | FFMPEGFS_VIDEO;   // Note that we have to reset audio/video pts to the new position
            m_have_seeked   = true;                             // Note that we have seeked, thus skipped frames. We need to start transcoding over to fill any gaps.
 
            Logging::info(virtname(), "Performing seek request to HLS segment no. %1.", segment_no);
 
            int64_t pos = (segment_no - 1) * params.m_segment_duration;
 
            if (m_in.m_video.m_stream_idx && stream_exists(m_out.m_video.m_stream_idx) && m_in.m_video.m_stream != nullptr)
            {
                int64_t vstream_pts = ffmpeg_rescale_q(pos, av_get_time_base_q(), m_in.m_video.m_stream->time_base);
 
                if (m_in.m_video.m_stream->start_time != AV_NOPTS_VALUE)
                {
                    vstream_pts += m_in.m_video.m_stream->start_time;
                }
 
                ret = av_seek_frame(m_in.m_format_ctx, m_in.m_video.m_stream_idx, vstream_pts, AVSEEK_FLAG_BACKWARD);
            }
            else if (m_in.m_audio.m_stream_idx && stream_exists(m_out.m_audio.m_stream_idx) && m_in.m_audio.m_stream != nullptr)
            {
                int64_t astream_pts = ffmpeg_rescale_q(pos, av_get_time_base_q(), m_in.m_audio.m_stream->time_base);
 
                if (m_in.m_audio.m_stream->start_time != AV_NOPTS_VALUE)
                {
                    astream_pts += m_in.m_audio.m_stream->start_time;
                }
 
                ret = av_seek_frame(m_in.m_format_ctx, m_in.m_audio.m_stream_idx, astream_pts, AVSEEK_FLAG_BACKWARD);
            }
 
            if (ret < 0)
            {
                Logging::error(virtname(), "Seek failed on input file (error '%1').", ffmpeg_geterror(ret).c_str());
                return ret;
            }
 
            flush_buffers();
 
            close_output_file();
 
            purge_hls_fifo();   // We do not need the packets for the next frame, we start a new one at another position!
 
            // open_output() selects the active HLS cache file before
            // process_output()/avformat_write_header() can emit data.  Make
            // the requested seek segment visible before reopening the output,
            // otherwise a mid-stream repair can reopen the previous segment.
            m_current_segment = segment_no;
 
            ret = open_output(m_buffer);
            if (ret < 0)
            {
                return ret;
            }
 
            next_segment = segment_no;
 
            opened = true;
 
            break;
        }
 
        Logging::info(virtname(), "Discarded seek request to HLS segment no. %1.", segment_no);
    }
 
    // Set current segment
    m_current_segment       = next_segment;
    m_inhibit_stream_msk    = 0;
    m_insert_keyframe       = false;
 
    Logging::info(virtname(), "Starting HLS segment no. %1 of %2.", m_current_segment, m_virtualfile->get_segment_count());
 
    if (!m_buffer->set_segment(m_current_segment, m_virtualfile->m_predicted_size / m_virtualfile->get_segment_count()))   
    {
        return AVERROR(errno);
    }
 
    if (!opened)
    {
        int ret = 0;
 
        // Process output file, already done by open_output() if file has been newly opened.
        ret = process_output();
        if (ret)
        {
            return ret;
        }
    }
 
    // Flush delayed packets to disk, if any
    while (!m_hls_packet_fifo.empty())
    {
        int ret = 0;
        FFmpeg_Packet pkt(std::move(m_hls_packet_fifo.front()));
        m_hls_packet_fifo.pop();
 
        ret = av_write_frame(m_out.m_format_ctx, pkt);
 
        if (ret < 0)
        {
            Logging::error(virtname(), "Could not write frame (error '%1').", ffmpeg_geterror(ret).c_str());
            return ret;
        }
 
    }
    return 0;
}
 
BITRATE FFmpeg_Transcoder::get_prores_bitrate(int width, int height, const AVRational &framerate, bool interleaved, PRORESLEVEL profile)
{
    unsigned int mindist;
    size_t match = UINT_MAX;
 
    // Find best match resolution
    mindist = UINT_MAX;
    for (size_t i = 0; i < m_prores_bitrate.size(); i++)
    {
        unsigned int x = static_cast<unsigned int>(width - m_prores_bitrate[i].m_width);
        unsigned int y = static_cast<unsigned int>(height - m_prores_bitrate[i].m_height);
        unsigned int dist = (x * x) + (y * y);
 
        if (dist < mindist)
        {
            mindist = dist;
            match = i;
        }
 
        if (!dist)
        {
            // Exact match, won't find a better one.
            break;
        }
    }
 
    if (match == UINT_MAX)
    {
        return 0;
    }
 
    width   = m_prores_bitrate[match].m_width;
    height  = m_prores_bitrate[match].m_height;
 
    // Find best match framerate
    double framerateX = av_q2d(framerate);
    mindist = UINT_MAX;
    for (size_t i = match; width == m_prores_bitrate[i].m_width && height == m_prores_bitrate[i].m_height; i++)
    {
        unsigned int dist = UINT_MAX;
        for (size_t j = 0; j < MAX_PRORES_FRAMERATE && m_prores_bitrate[i].m_framerate[j].m_framerate; j++)
        {
            unsigned int x = static_cast<unsigned int>(framerateX - m_prores_bitrate[i].m_framerate[j].m_framerate);
            unsigned int y = static_cast<unsigned int>(interleaved - m_prores_bitrate[i].m_framerate[j].m_interleaved);
 
            dist = (x * x) + (y * y);
 
            if (dist < mindist)
            {
                mindist = dist;
                match = i;
            }
 
            if (!dist)
            {
                // Exact match, won't find a better one.
                break;
            }
        }
 
        if (!dist)
        {
            // Exact match, won't find a better one.
            break;
        }
    }
 
    if (match == UINT_MAX)
    {
        return 0;
    }
 
    return m_prores_bitrate[match].m_bitrate[static_cast<size_t>(profile)] * (1000 * 1000);
}
 
bool FFmpeg_Transcoder::audio_size(size_t *filesize, AVCodecID codec_id, BITRATE bit_rate, int64_t duration, int channels, int sample_rate, AVSampleFormat sample_format)
{
    BITRATE output_audio_bit_rate;
    int output_sample_rate;
    bool success = true;
 
    get_output_bit_rate(bit_rate, params.m_audiobitrate, &output_audio_bit_rate);
    get_output_sample_rate(sample_rate, params.m_audiosamplerate, &output_sample_rate);
 
    switch (codec_id)
    {
    case AV_CODEC_ID_AAC:
    {
        // Try to predict the size of the AAC stream (this is fairly accurate, sometimes a bit larger, sometimes a bit too small
        *filesize += static_cast<size_t>(duration * output_audio_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1025 * (*filesize) / 1000); // add overhead (empirically determined value)
        break;
    }
    case AV_CODEC_ID_MP3:
    {
        // Kbps = bits per second / 8 = Bytes per second x 60 seconds = Bytes per minute x 60 minutes = Bytes per hour
        // This is the sum of the size of
        // ID3v2, ID3v1, and raw MP3 data. This is theoretically only approximate
        // but in practice gives excellent answers, usually exactly correct.
        // Cast to 64-bit int to avoid overflow.
 
        *filesize += static_cast<size_t>(duration * output_audio_bit_rate / (8LL * AV_TIME_BASE)) + ID3V1_TAG_LENGTH;
        break;
    }
    case AV_CODEC_ID_PCM_U8:
    case AV_CODEC_ID_PCM_S8:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_U8); // Unsigned/signed 8 have the same width
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_S8_PLANAR:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_U8P);
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_U16LE:
    case AV_CODEC_ID_PCM_U16BE:
    case AV_CODEC_ID_PCM_S16LE:
    case AV_CODEC_ID_PCM_S16BE:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S16); // Unsigned/signed 16 have the same width
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_S16LE_PLANAR:
    case AV_CODEC_ID_PCM_S16BE_PLANAR:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S16P); // Unsigned/signed 16 have the same width
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_U24LE: // U/S24 uses U/S32 storage
    case AV_CODEC_ID_PCM_U24BE:
    case AV_CODEC_ID_PCM_S24LE:
    case AV_CODEC_ID_PCM_S24BE:
    case AV_CODEC_ID_PCM_U32LE:
    case AV_CODEC_ID_PCM_U32BE:
    case AV_CODEC_ID_PCM_S32LE:
    case AV_CODEC_ID_PCM_S32BE:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S32); // Unsigned/signed 32 have the same width
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_S24LE_PLANAR:   // S24 uses S32 storage
    case AV_CODEC_ID_PCM_S32LE_PLANAR:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S32P);
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_S64LE:
    case AV_CODEC_ID_PCM_S64BE:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S64);
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_PCM_F16LE:
    case AV_CODEC_ID_PCM_F24LE:
    case AV_CODEC_ID_PCM_F32BE:
    case AV_CODEC_ID_PCM_F32LE:
    case AV_CODEC_ID_PCM_F64BE:
    case AV_CODEC_ID_PCM_F64LE:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_FLT);
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // + WAV_HEADER + DATA_HEADER + (with FFMpeg always) LIST_HEADER
        // The real size of the list header is unkown as we don't know the contents (meta tags)
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        break;
    }
    case AV_CODEC_ID_VORBIS:
    {
        // Kbps = bits per second / 8 = Bytes per second x 60 seconds = Bytes per minute x 60 minutes = Bytes per hour
        *filesize += static_cast<size_t>(duration * output_audio_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(900 * (*filesize) / 1000); // OGG files seem to be rather smaller than expected (empirically determined value)
        break;
    }
    case AV_CODEC_ID_OPUS:
    {
        // Kbps = bits per second / 8 = Bytes per second x 60 seconds = Bytes per minute x 60 minutes = Bytes per hour
        *filesize += static_cast<size_t>(duration * output_audio_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1020 * (*filesize) / 1000); // add overhead (empirically determined value)
        break;
    }
    case AV_CODEC_ID_ALAC:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(AV_SAMPLE_FMT_S16);
 
        // File size:
        // Apple Lossless Audio Coding promises a compression rate of 60-70%. The actual result ranges
        // between 30 and over 50%, heavily depending on the input.
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        *filesize = static_cast<size_t>(620 * (*filesize) / 1000); // Estimate 38% compression rate (empirically determined value)
        break;
    }
    case AV_CODEC_ID_AC3:
    {
        // Kbps = bits per second / 8 = Bytes per second x 60 seconds = Bytes per minute x 60 minutes = Bytes per hour
        *filesize += static_cast<size_t>(duration * output_audio_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1025 * (*filesize) / 1000); // add overhead (empirically determined value)
        break;
    }
    case AV_CODEC_ID_FLAC:
    {
        int bytes_per_sample    = av_get_bytes_per_sample(sample_format != AV_SAMPLE_FMT_NONE ? sample_format : AV_SAMPLE_FMT_S16);
 
        // File size:
        // file duration * sample rate (HZ) * channels * bytes per sample
        // We do not add the overhead for headers, as this is an estimation and not exact anyways.
        *filesize += static_cast<size_t>(duration * sample_rate * (channels >= 2 ? 2 : 1) * bytes_per_sample / AV_TIME_BASE);
        *filesize = static_cast<size_t>(600 * (*filesize) / 1000); // Estimate 40% compression rate (empirically determined value)
        break;
    }
    case AV_CODEC_ID_NONE:
    {
        break;
    }
    default:
    {
        success = false;
        break;
    }
    }
    return success;
}
 
bool FFmpeg_Transcoder::video_size(size_t *filesize, AVCodecID codec_id, BITRATE bit_rate, int64_t duration, int width, int height, bool interleaved, const AVRational &framerate)
{
    BITRATE out_video_bit_rate;
    bool success = true;
 
    get_output_bit_rate(bit_rate, params.m_videobitrate, &out_video_bit_rate);
 
    switch (codec_id)
    {
    case AV_CODEC_ID_MPEG1VIDEO:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1020 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_MPEG2VIDEO:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1020 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_H264:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1050 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_H265:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1250 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_THEORA:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1025 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_VP8:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1020 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_VP9:
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        *filesize = static_cast<size_t>(1450 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_AV1:           
    {
        *filesize += static_cast<size_t>(duration * out_video_bit_rate / (8LL * AV_TIME_BASE));
        //*filesize = static_cast<size_t>(1150 * (*filesize) / 1000); // add overhead
        break;
    }
    case AV_CODEC_ID_PRORES:
    {
        *filesize += static_cast<size_t>(duration * get_prores_bitrate(width, height, framerate, interleaved, params.m_level) / (8LL * AV_TIME_BASE));
        break;
    }
    case AV_CODEC_ID_PNG:
    case AV_CODEC_ID_BMP:
    case AV_CODEC_ID_MJPEG:
    {
        // Max. file size = (pixel dimensions x bit depth) / 8 for an uncompressed BMP,
        // more than sufficient for JPG/PNG as they should never get this large.
        *filesize += static_cast<size_t>(width * height * 24 / 8);   // Get the max. size
        break;
    }
    case AV_CODEC_ID_NONE:
    {
        break;
    }
    default:
    {
        success = false;
        break;
    }
    }
    return success;
}
 
bool FFmpeg_Transcoder::total_overhead(size_t *filesize, FILETYPE filetype)
{
    bool success = true;
 
    switch (filetype)
    {
    //
    //  Audio only
    //
    case FILETYPE::MP3:
    {
        // The FFmpeg API always adds an IDv2 header, size of which is unknown and
        // really hard to determine. So we simply add something reasonable (empirically determined value).
        *filesize += 250000;
        break;
    }
    case FILETYPE::WAV:
    {
        // This could actually precise, but yet the FFmpeg API always adds an IDv2 header,
        // size of which is unknown and really hard to determine. The header is small, ~30 bytes,
        // so we ignore that deliberatly.
        *filesize += sizeof(WAV_HEADER) + sizeof(WAV_LIST_HEADER) + sizeof(WAV_DATA_HEADER);
        break;
    }
    case FILETYPE::AIFF:
    {
        // These two "chunks" will always be there, others may be there, may be not. Their
        // size is hard to precalculate and small (~100 bytes), so we disregard the rest.
        *filesize += sizeof(AIFF_FORMCHUNK) + sizeof(AIFF_COMMONCHUNK);
        break;
    }
    case FILETYPE::OPUS:
    case FILETYPE::ALAC:
    case FILETYPE::FLAC:
    {
        break;
    }
        //
        // Video
        //
    case FILETYPE::TS:
    case FILETYPE::HLS:
    {
        *filesize += 1600000;   // empirically determined value
        break;
    }
    case FILETYPE::MP4:
    case FILETYPE::OGG:
    case FILETYPE::WEBM:
    case FILETYPE::MOV:
    case FILETYPE::PRORES:
    case FILETYPE::MKV:
    {
        break;
    }
        //
        // Stills
        //
    case FILETYPE::PNG:
    case FILETYPE::JPG:
    case FILETYPE::BMP:
    {
        break;
    }
        //
        // Invalid
        //
    case FILETYPE::UNKNOWN:
    {
        success = false;
        break;
    }
    }
 
    return success;
}
 
size_t FFmpeg_Transcoder::calculate_predicted_filesize() const
{
    if (m_in.m_format_ctx == nullptr)
    {
        return 0;
    }
 
    if (m_current_format == nullptr)
    {
        // Should ever happen, but better check this to avoid crashes.
        return 0;
    }
 
    size_t filesize = 0;
 
    int64_t file_duration = m_in.m_format_ctx->duration != AV_NOPTS_VALUE ? m_in.m_format_ctx->duration : 0;
    BITRATE input_audio_bit_rate = 0;
    int input_sample_rate = 0;
    BITRATE input_video_bit_rate = 0;
 
    if (m_fileio->duration() != AV_NOPTS_VALUE)
    {
        file_duration = m_fileio->duration();
    }
 
    if (stream_exists(m_in.m_audio.m_stream_idx))
    {
        input_sample_rate = m_in.m_audio.m_stream->codecpar->sample_rate;
        input_audio_bit_rate = (m_in.m_audio.m_stream->codecpar->bit_rate != 0) ? m_in.m_audio.m_stream->codecpar->bit_rate : m_in.m_format_ctx->bit_rate;
    }
 
    if (stream_exists(m_in.m_video.m_stream_idx))
    {
        input_video_bit_rate = (m_in.m_video.m_stream->codecpar->bit_rate != 0) ? m_in.m_video.m_stream->codecpar->bit_rate : m_in.m_format_ctx->bit_rate;
    }
 
    if (input_audio_bit_rate)
    {
        int channels = get_channels(m_in.m_audio.m_codec_ctx.get());
 
        if (!audio_size(&filesize, m_current_format->audio_codec(), input_audio_bit_rate, file_duration, channels, input_sample_rate, m_cur_sample_fmt))
        {
            Logging::warning(filename(), "Unsupported audio codec '%1' for format %2.", get_codec_name(m_current_format->audio_codec()), m_current_format->desttype().c_str());
        }
    }
 
    if (input_video_bit_rate)
    {
        if (m_is_video)
        {
            int width = m_in.m_video.m_stream->codecpar->width;
            int height = m_in.m_video.m_stream->codecpar->height;
            bool interleaved = params.m_deinterlace ? false : (m_in.m_video.m_stream->codecpar->field_order != AV_FIELD_PROGRESSIVE);    // Deinterlace only if source is interlaced
            AVRational framerate = m_in.m_video.m_stream->avg_frame_rate;
 
            if (!video_size(&filesize, m_current_format->video_codec(), input_video_bit_rate, file_duration, width, height, interleaved, framerate))
            {
                Logging::warning(filename(), "Unsupported video codec '%1' for format %2.", get_codec_name(m_current_format->video_codec()), m_current_format->desttype().c_str());
            }
        }
        // else      /** @todo Feature #2260: Add picture size */
        // {
        // }
    }
 
    // Support #2654: Test Code
    // add total overhead
    total_overhead(&filesize, m_current_format->filetype());
 
    return filesize;
}
 
int64_t FFmpeg_Transcoder::duration() const
{
    return SAFE_VALUE(m_virtualfile, m_duration, 0);
}
 
size_t FFmpeg_Transcoder::predicted_filesize() const
{
    return SAFE_VALUE(m_virtualfile, m_predicted_size, 0);
}
 
uint32_t FFmpeg_Transcoder::video_frame_count() const
{
    return SAFE_VALUE(m_virtualfile, m_video_frame_count, 0);
}
 
uint32_t FFmpeg_Transcoder::segment_count() const
{
    return SAFE_VALUE(m_virtualfile, get_segment_count(), 0);
}
 
int FFmpeg_Transcoder::encode_finish()
{
    int ret = 0;
 
    if (!is_frameset())
    {
        // If not a frame set, write trailer
 
        // Write the trailer of the output file container.
        ret = write_output_file_trailer();
    }
 
    if (is_hls())
    {
        m_buffer->finished_segment();
 
        // Get segment VIRTUALFILE object
        std::string seg_filename(m_buffer->virtualfile()->m_destfile + "/" + make_filename(m_current_segment, params.current_format(m_buffer->virtualfile())->fileext()));
        LPVIRTUALFILE virtualfile = find_file(seg_filename);
 
        if (virtualfile != nullptr)
        {
            virtualfile->m_predicted_size   = m_buffer->buffer_watermark(m_current_segment);
 
            stat_set_size(&virtualfile->m_st, virtualfile->m_predicted_size);
        }
    }
    else //if (m_virtualfile->m_flags & VIRTUALFLAG_CUESHEET)
    {
        // Save actual result size of the file
        stat_set_size(&m_virtualfile->m_st, m_buffer->buffer_watermark());
    }
 
    return ret;
}
 
const ID3v1 * FFmpeg_Transcoder::id3v1tag() const
{
    return &m_out.m_id3v1;
}
 
int FFmpeg_Transcoder::input_read(void * opaque, unsigned char * data, int size)
{
    FileIO * io = static_cast<FileIO *>(opaque);
 
    if (io == nullptr)
    {
        Logging::error(nullptr, "input_read(): Internal error: FileIO is NULL!");
        return AVERROR(EINVAL);
    }
 
    if (io->eof())
    {
        // At EOF
        return AVERROR_EOF;
    }
 
    int read = static_cast<int>(io->readio(reinterpret_cast<char *>(data), static_cast<size_t>(size)));
 
    if (read != size && io->error())
    {
        // Read failed
        return AVERROR(io->error());
    }
 
    return read;
}
 
#if LAVF_WRITEPACKET_CONST
int FFmpeg_Transcoder::output_write(void * opaque, const uint8_t * data, int size)
#else
int FFmpeg_Transcoder::output_write(void * opaque, unsigned char * data, int size)
#endif
{
    Buffer * buffer = static_cast<Buffer *>(opaque);
 
    if (buffer == nullptr)
    {
        Logging::error(nullptr, "input_write(): Internal error: FileIO is NULL!");
        return AVERROR(EINVAL);
    }
 
#if LAVF_WRITEPACKET_CONST
    int written = static_cast<int>(buffer->writeio(data, static_cast<size_t>(size)));
#else
    int written = static_cast<int>(buffer->writeio(static_cast<const uint8_t*>(data), static_cast<size_t>(size)));
#endif
    if (written != size)
    {
        // Write error
        return (AVERROR(errno));
    }
    return written;
}
 
int64_t FFmpeg_Transcoder::seek(void * opaque, int64_t offset, int whence)
{
    FileIO * io = static_cast<FileIO *>(opaque);
    int64_t res_offset = 0;
 
    if (io == nullptr)
    {
        Logging::error(nullptr, "seek(): Internal error: FileIO is NULL!");
        return AVERROR(EINVAL);
    }
 
    if (whence & AVSEEK_SIZE)
    {
        // Return file size
        res_offset = static_cast<int64_t>(io->size());
    }
    else
    {
        whence &= ~(AVSEEK_SIZE | AVSEEK_FORCE);
 
        if (!io->seek(offset, whence))
        {
            // OK: Return position
            res_offset = offset;
        }
        else
        {
            // Error
            res_offset = AVERROR(errno);
        }
    }
 
    return res_offset;
}
 
bool FFmpeg_Transcoder::close_resample()
{
    return m_audio_resample_ctx.reset();
}
 
int FFmpeg_Transcoder::purge_audio_fifo()
{
    int audio_samples_left = 0;
 
    if (!m_audio_fifo.empty())
    {
        audio_samples_left = m_audio_fifo.size();
        m_audio_fifo.reset();
    }
 
    return audio_samples_left;
}
 
size_t FFmpeg_Transcoder::purge_multiframe_map()
{
    size_t frames_left = m_frame_map.size();
 
    m_frame_map.clear();
 
    return frames_left;
}
 
size_t FFmpeg_Transcoder::purge_hls_fifo()
{
    size_t hls_packets_left = m_hls_packet_fifo.size();
 
    while (!m_hls_packet_fifo.empty())
    {
        m_hls_packet_fifo.pop();
    }
 
    return hls_packets_left;
}
 
void FFmpeg_Transcoder::purge()
{
    std::string outfile;
    int audio_samples_left      = purge_audio_fifo();
    size_t frames_left          = purge_multiframe_map();
    size_t hls_packets_left     = purge_hls_fifo();
 
    if (m_out.m_format_ctx != nullptr && m_out.m_format_ctx->url != nullptr)
    {
        outfile = m_out.m_format_ctx->url;
    }
    else if (m_virtualfile != nullptr)
    {
        outfile = m_virtualfile->m_virtfile;
    }
 
    const char *p = outfile.empty() ? nullptr : outfile.c_str();
    if (audio_samples_left)
    {
        Logging::warning(p, "%1 audio samples left in buffer and not written to target file!", audio_samples_left);
    }
 
    if (frames_left)
    {
        Logging::warning(p, "%1 frames left in buffer and not written to target file!", frames_left);
    }
 
    if (hls_packets_left)
    {
        Logging::warning(p, "%1 HLS packets left in buffer and not written to target file!", hls_packets_left);
    }
}
 
bool FFmpeg_Transcoder::close_output_file()
{
    bool closed = false;
 
    purge();
 
    close_resample();
 
    // The deinterlace filter graph belongs to the current output/transcoding
    // pipeline. HLS seeks and output reopens can rebuild that pipeline without
    // closing the input file, so do not leave an old AVFilterGraph attached
    // until close_input_file().
    free_filters();
 
    m_sws_ctx.reset();
 
    // Close output file
    m_out.m_audio.reset();
    m_out.m_video.reset();
 
    m_out.m_album_art.clear();
    m_out.m_subtitle.clear();
 
    closed = m_out.m_format_ctx.reset();
 
    return closed;
}
 
bool FFmpeg_Transcoder::close_input_file()
{
    bool closed = false;
 
    m_in.m_audio.reset();
    m_in.m_video.reset();
 
    m_in.m_album_art.clear();
    m_in.m_subtitle.clear();
 
    if (m_in.m_format_ctx != nullptr)
    {
        if (m_fileio.use_count() <= 1 && m_fileio != nullptr)
        {
            m_fileio->closeio();
        }
        m_fileio.reset();
 
        closed = m_in.m_format_ctx.reset();
    }
 
    free_filters();
 
    return closed;
}
 
void FFmpeg_Transcoder::closeio()
{
    bool closed = false;
 
    // Close input file
    closed |= close_input_file();
 
    // Close output file
    closed |= close_output_file();
 
    // Free hardware device contexts if open
    hwdevice_ctx_free(&m_hwaccel_dec_device_ctx);
    hwdevice_ctx_free(&m_hwaccel_enc_device_ctx);
 
    // Closed anything (anything had been open to be closed in the first place)...
    if (closed)
    {
        Logging::trace(nullptr, "FFmpeg transcoder closed.");
    }
}
 
const char *FFmpeg_Transcoder::filename() const
{
    return (m_virtualfile != nullptr ? m_virtualfile->m_origfile.c_str() : "");
}
 
const char *FFmpeg_Transcoder::destname() const
{
    return (m_virtualfile != nullptr ? m_virtualfile->m_destfile.c_str() : "");
}
 
const char *FFmpeg_Transcoder::virtname() const
{
    return (m_virtualfile != nullptr ? m_virtualfile->m_virtfile.c_str() : "");
}
 
// create
int FFmpeg_Transcoder::init_deinterlace_filters(AVCodecContext *codec_ctx, AVPixelFormat pix_fmt, const AVRational & avg_frame_rate, const AVRational & time_base)
{
    // Defensive cleanup: this function may be called again when the output
    // pipeline is rebuilt, for example after an HLS seek.  Do not overwrite the
    // old filter pointers with nullptr before the old AVFilterGraph has been
    // freed, otherwise the graph and its internal buffers become unreachable.
    free_filters();
 
    const AVFilter * buffer_src  = avfilter_get_by_name("buffer");
    const AVFilter * buffer_sink = avfilter_get_by_name("buffersink");
    AVFilterInOut * outputs      = avfilter_inout_alloc();
    AVFilterInOut * inputs       = avfilter_inout_alloc();
    int ret = 0;
 
    try
    {
        if (!avg_frame_rate.den && !avg_frame_rate.num)
        {
            // No framerate, so this video "stream" has only one picture
            throw static_cast<int>(AVERROR(EINVAL)); // Einzelbild-"Stream"
        }
 
        m_filter_graph = avfilter_graph_alloc();
 
        if (outputs == nullptr || inputs == nullptr || m_filter_graph == nullptr)
        {
            throw static_cast<int>(AVERROR(ENOMEM));
        }
 
        // --- buffersrc (Quelle) direkt mit Args erstellen ---
        std::string args;
        strsprintf(&args,
                   "video_size=%dx%d:pix_fmt=%d:time_base=%d/%d:pixel_aspect=%d/%d",
                   codec_ctx->width, codec_ctx->height, pix_fmt,
                   time_base.num, time_base.den,
                   codec_ctx->sample_aspect_ratio.num,
                   FFMAX(codec_ctx->sample_aspect_ratio.den, 1));
 
        ret = avfilter_graph_create_filter(&m_buffer_source_context, buffer_src, "in", args.c_str(), nullptr, m_filter_graph);
        if (ret < 0)
        {
            Logging::error(virtname(), "Cannot create buffer source (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        // --- buffersink (Senke) mit Pre-Init-Optionen ---
#if LIBAVFILTER_VERSION_INT >= AV_VERSION_INT(10, 6, 100) && LIBAVUTIL_VERSION_INT >= AV_VERSION_INT(59, 36, 100)
        // Neuer Weg: Array-Optionen (pixel_formats) + av_opt_set_array()
        m_buffer_sink_context = avfilter_graph_alloc_filter(m_filter_graph, buffer_sink, "out");
        if (!m_buffer_sink_context)
        {
            throw static_cast<int>(AVERROR(ENOMEM));
        }
 
        // Nicht-Runtime-Optionen vor dem Init setzen
        {
            const enum AVPixelFormat pf = pix_fmt;
            // Wir ersetzen (ab Index 0) 1 Element in "pixel_formats"
            ret = av_opt_set_array(m_buffer_sink_context,
                                   "pixel_formats",
                                   AV_OPT_SEARCH_CHILDREN | AV_OPT_ARRAY_REPLACE,
                                   0, /* start_elem */
                                   1, /* nb_elems */
                                   AV_OPT_TYPE_PIXEL_FMT,
                                   &pf);
            if (ret < 0)
            {
                Logging::error(virtname(), "Cannot set buffersink pixel_formats (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
        }
 
        ret = avfilter_init_str(m_buffer_sink_context, nullptr);
        if (ret < 0)
        {
            Logging::error(virtname(), "Cannot init buffer sink (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
#else
        // Alter Weg: int-list-Option (pix_fmts) vor Init setzen
        m_buffer_sink_context = avfilter_graph_alloc_filter(m_filter_graph, buffer_sink, "out");
        if (!m_buffer_sink_context)
        {
            throw static_cast<int>(AVERROR(ENOMEM));
        }
 
        // Liste inkl. Terminator, wie in älteren Beispielen
        enum AVPixelFormat pixel_fmts[] = { pix_fmt, AV_PIX_FMT_NONE };
 
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wconversion"
#pragma GCC diagnostic ignored "-Wsign-conversion"
        ret = av_opt_set_int_list(m_buffer_sink_context, "pix_fmts", pixel_fmts, AV_PIX_FMT_NONE, AV_OPT_SEARCH_CHILDREN);
#pragma GCC diagnostic pop
 
        if (ret < 0)
        {
            Logging::error(virtname(), "Cannot set output pixel format (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        ret = avfilter_init_str(m_buffer_sink_context, nullptr);
        if (ret < 0)
        {
            Logging::error(virtname(), "Cannot init buffer sink (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
#endif
 
        // Endpunkte für Graph
        outputs->name       = av_strdup("in");
        outputs->filter_ctx = m_buffer_source_context;
        outputs->pad_idx    = 0;
        outputs->next       = nullptr;
 
        inputs->name        = av_strdup("out");
        inputs->filter_ctx  = m_buffer_sink_context;
        inputs->pad_idx     = 0;
        inputs->next        = nullptr;
 
        // args "null"      passthrough (dummy) filter for video
        // args "null"      passthrough (dummy) filter for audio
 
        // --- Deinterlace-Filterkette
        const char * filters;
        //filters = "yadif=mode=send_frame:parity=auto:deint=interlaced";
        filters = "yadif=mode=send_frame:parity=auto:deint=all";
        //filters = "yadif=0:-1:0";
        //filters = "bwdif=mode=send_frame:parity=auto:deint=all";
        //filters = "kerndeint=thresh=10:map=0:order=0:sharp=1:twoway=1";
        //filters = "zoompan=z='min(max(zoom,pzoom)+0.0015,1.5)':d=1:x='iw/2-(iw/zoom/2)':y='ih/2-(ih/zoom/2)'";
 
        // vaapi_deinterlace=rate=field
        // format=nv12,hwupload,deinterlace_vaapi,hwdownload,format=nv12
        // deinterlace_vaapi,scale_vaapi=w=1280:h=720,hwdownload,format=nv12
 
        ret = avfilter_graph_parse_ptr(m_filter_graph, filters, &inputs, &outputs, nullptr);
        if (ret < 0)
        {
            Logging::error(virtname(), "avfilter_graph_parse_ptr failed (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        ret = avfilter_graph_config(m_filter_graph, nullptr);
        if (ret < 0)
        {
            Logging::error(virtname(), "avfilter_graph_config failed (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        Logging::debug(virtname(), "Deinterlacing initialised with filters '%1'.", filters);
    }
    catch (int _ret)
    {
        ret = _ret;
 
        // If graph creation/configuration failed halfway through, release the
        // partial graph immediately.  Otherwise the next retry/seek would start
        // with stale filter pointers and retained filter buffers.
        free_filters();
    }
 
    if (inputs != nullptr)
    {
        avfilter_inout_free(&inputs);
    }
    if (outputs != nullptr)
    {
        avfilter_inout_free(&outputs);
    }
 
    return ret;
}
 
 
//    Aug 26 21:41:22 plattenlurch ffmpegfs[1999231]: WARNING: FILTER  [out @ 0x7f99a4193bc0] The "pix_fmts" option is deprecated: set the supported pixel formats
//    Aug 26 21:41:22 plattenlurch ffmpegfs[1999231]: WARNING: FILTER  [in @ 0x7f99a40f8700] Changing video frame properties on the fly is not supported by all filters.
//    Aug 26 21:41:22 plattenlurch ffmpegfs[1999231]: WARNING: FILTER  [in @ 0x7f99a40f8700] filter context - w: 720 h: 480 fmt: 0 csp: unknown range: unknown, incoming frame - w: 720 h: 480 fmt: 0 csp: unknown range: tv pts_time: 1117.2298
//    Aug 26 21:41:22 plattenlurch ffmpegfs[1999231]: WARNING: ENCODER [libx264 @ 0x7f99a40c9080] non-strictly-monotonic PTS
 
 
int FFmpeg_Transcoder::send_filters(FFmpeg_Frame *srcframe, int & ret)
{
    ret = 0;
 
    if (m_buffer_source_context != nullptr)
    {
        try
        {
            FFmpeg_Frame filterframe(srcframe->m_stream_idx);
 
            ret = filterframe.res();
            if (ret < 0)
            {
                Logging::error(virtname(), "Unable to allocate filter frame (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            // push the decoded frame into the filtergraph
            ret = av_buffersrc_add_frame_flags(m_buffer_source_context, *srcframe, AV_BUFFERSRC_FLAG_KEEP_REF);
            if (ret < 0)
            {
                Logging::warning(virtname(), "Error while feeding the frame to filtergraph (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
 
            // pull filtered frames from the filtergraph
            ret = av_buffersink_get_frame(m_buffer_sink_context, filterframe);
            if (ret == AVERROR(EAGAIN) || ret == AVERROR_EOF)
            {
                // Not an error, go on
                ret = 0;
            }
            else if (ret < 0)
            {
                Logging::error(virtname(), "Error while getting frame from filtergraph (error '%1').", ffmpeg_geterror(ret).c_str());
                throw ret;
            }
            else
            {
                // All OK; copy filtered frame and unref original
                filterframe->pts                   = (*srcframe)->pts;
                filterframe->best_effort_timestamp = (*srcframe)->best_effort_timestamp;
 
                *srcframe = filterframe;
            }
        }
        catch (int _ret)
        {
            ret = _ret;
        }
    }
 
    return ret;
}
 
// free
 
void FFmpeg_Transcoder::free_filters()
{
    // Filter contexts are owned by the graph once they have been attached to it.
    // Freeing the AVFilterGraph releases the source/sink contexts and all
    // buffers owned by the filter pipeline in one place.  The member pointers
    // must be reset afterwards because they become dangling pointers.
    if (m_filter_graph != nullptr)
    {
        avfilter_graph_free(&m_filter_graph);
    }
 
    m_buffer_source_context = nullptr;
    m_buffer_sink_context   = nullptr;
    m_filter_graph          = nullptr;
}
 
int FFmpeg_Transcoder::stack_seek_frame(uint32_t frame_no)
{
    if (frame_no > 0 && frame_no <= video_frame_count())
    {
        std::lock_guard<std::recursive_mutex> lock_seek_to_fifo_mutex(m_seek_to_fifo_mutex);
        m_seek_to_fifo.push(frame_no);  // Seek to this frame next decoding operation
        return 0;
    }
    else
    {
        errno = EINVAL;
        Logging::error(virtname(), "stack_seek_frame() failed: Frame %1 was requested, but is out of range (1...%2)", frame_no, video_frame_count() + 1);
        return AVERROR(EINVAL);
    }
}
 
int FFmpeg_Transcoder::stack_seek_segment(uint32_t segment_no)
{
    if (segment_no > 0 && segment_no <= segment_count())
    {
        std::lock_guard<std::recursive_mutex> lock_seek_to_fifo_mutex(m_seek_to_fifo_mutex);
        m_seek_to_fifo.push(segment_no);  // Seek to this segment next decoding operation
        return 0;
    }
    else
    {
        errno = EINVAL;
        Logging::error(virtname(), "stack_seek() failed: Segment no. %1 was requested, but is out of range (1...%2)", segment_no, video_frame_count() + 1);
        return AVERROR(EINVAL);
    }
}
 
bool FFmpeg_Transcoder::is_multiformat() const
{
    if (m_current_format == nullptr)
    {
        return false;
    }
    else
    {
        return m_current_format->is_multiformat();
    }
}
 
 
bool FFmpeg_Transcoder::is_frameset() const
{
    if (m_current_format == nullptr)
    {
        return false;
    }
    else
    {
        return m_current_format->is_frameset();
    }
}
 
bool FFmpeg_Transcoder::is_hls() const
{
    if (m_current_format == nullptr)
    {
        return false;
    }
    else
    {
        return m_current_format->is_hls();
    }
}
 
bool FFmpeg_Transcoder::have_seeked() const
{
    return m_have_seeked;
}
 
enum AVPixelFormat FFmpeg_Transcoder::get_format_static(AVCodecContext *input_codec_ctx, const enum AVPixelFormat *pix_fmts)
{
    FFmpeg_Transcoder * pThis = static_cast<FFmpeg_Transcoder *>(input_codec_ctx->opaque);
    return pThis->get_format(input_codec_ctx, pix_fmts);
}
 
enum AVPixelFormat FFmpeg_Transcoder::get_format(__attribute__((unused)) AVCodecContext *input_codec_ctx, const enum AVPixelFormat *pix_fmts) const
{
    if (params.m_hwaccel_dec_device_type == AV_HWDEVICE_TYPE_NONE)
    {
        // We should never happen to end up here...
        Logging::error(filename(), "Unable to decode this file using hardware acceleration: Internal error! No hardware device type set.");
        return AV_PIX_FMT_NONE;
    }
 
    AVPixelFormat pix_fmt_expected = m_dec_hw_pix_fmt;
 
    for (const AVPixelFormat *p = pix_fmts; *p != AV_PIX_FMT_NONE; p++)
    {
        if (*p == pix_fmt_expected)
        {
            return pix_fmt_expected;
        }
    }
 
    Logging::error(filename(), "Unable to decode this file using hardware acceleration. Expected format '%1' not supported.", get_pix_fmt_name(pix_fmt_expected).c_str());
 
    return AV_PIX_FMT_NONE;
}
 
int FFmpeg_Transcoder::hwdevice_ctx_create(AVBufferRef ** hwaccel_enc_device_ctx, AVHWDeviceType dev_type, const std::string & device) const
{
    std::string active_device(device);
    int ret;
 
    if (active_device == "AUTO" && dev_type == AV_HWDEVICE_TYPE_VAAPI)
    {
        active_device = "/dev/dri/renderD128";  //** @todo HWACCEL - Try to autodetect rendering device
    }
 
    ret = av_hwdevice_ctx_create(hwaccel_enc_device_ctx, dev_type, !active_device.empty() ? active_device.c_str() : nullptr, nullptr, 0);
    if (ret < 0)
    {
        Logging::error(virtname(), "Failed to create a %1 device (error '%2').", hwdevice_get_type_name(dev_type), ffmpeg_geterror(ret).c_str());
        return ret;
    }
    return 0;
}
 
int FFmpeg_Transcoder::hwdevice_ctx_add_ref(AVCodecContext *input_codec_ctx)
{
    if (m_hwaccel_dec_device_ctx == nullptr)
    {
        int ret = AVERROR(EINVAL);
        Logging::error(virtname(), "INTERNAL ERROR: FFmpeg_Transcoder::hwdevice_ctx_add_ref()! HW decoder device context is NULL (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    input_codec_ctx->hw_device_ctx = av_buffer_ref(m_hwaccel_dec_device_ctx);
    if (input_codec_ctx->hw_device_ctx == nullptr)
    {
        int ret = AVERROR(ENOMEM);
        Logging::error(virtname(), "A hardware device reference create failed (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    input_codec_ctx->opaque     = static_cast<void*>(this);
    input_codec_ctx->get_format = &FFmpeg_Transcoder::get_format_static;
 
    return 0;
}
 
void FFmpeg_Transcoder::hwdevice_ctx_free(AVBufferRef **hwaccel_device_ctx)
{
    if (*hwaccel_device_ctx != nullptr)
    {
        av_buffer_unref(hwaccel_device_ctx);
        *hwaccel_device_ctx = nullptr;
    }
}
 
int FFmpeg_Transcoder::hwframe_ctx_set(AVCodecContext *output_codec_ctx, AVCodecContext *input_codec_ctx, AVBufferRef *hw_device_ctx) const
{
    AVBufferRef *hw_new_frames_ref;
    AVHWFramesContext *frames_ctx = nullptr;
    int ret = 0;
 
    hw_new_frames_ref = av_hwframe_ctx_alloc(hw_device_ctx);
    if (hw_new_frames_ref == nullptr)
    {
        ret = AVERROR(ENOMEM);
        Logging::error(virtname(), "hwframe_ctx_set(): Failed to create hwframe context (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    frames_ctx = reinterpret_cast<AVHWFramesContext *>(hw_new_frames_ref->data);
    frames_ctx->format    = m_enc_hw_pix_fmt;
    frames_ctx->sw_format = /*input_codec_ctx->sw_pix_fmt; */find_sw_fmt_by_hw_type(params.m_hwaccel_enc_device_type);
    frames_ctx->width     = input_codec_ctx->width;
    frames_ctx->height    = input_codec_ctx->height;
 
    frames_ctx->initial_pool_size = 20; // Driver default seems to be 17
 
    ret = av_hwframe_ctx_init(hw_new_frames_ref);
    if (ret < 0)
    {
        Logging::error(virtname(), "hwframe_ctx_set(): Failed to initialise hwframe context (error '%1').", ffmpeg_geterror(ret).c_str());
        av_buffer_unref(&hw_new_frames_ref);
        return ret;
    }
 
    output_codec_ctx->hw_frames_ctx = av_buffer_ref(hw_new_frames_ref);
    if (output_codec_ctx->hw_frames_ctx == nullptr)
    {
        ret = AVERROR(ENOMEM);
        Logging::error(virtname(), "hwframe_ctx_set(): A hardware frame reference create failed (error '%1').", ffmpeg_geterror(ret).c_str());
    }
 
    av_buffer_unref(&hw_new_frames_ref);
 
    return ret;
}
 
//int FFmpeg_Transcoder::hwframe_ctx_set(AVCodecContext *output_codec_ctx, AVCodecContext *input_codec_ctx, AVBufferRef *hw_device_ctx)
//{
//    // If the decoder runs in hardware, we should use the decoder's frames context. This will save us from
//    // having to transfer frames from hardware to software and vice versa.
//    // If the decoder runs in software, create a new frames context.
//    if (input_codec_ctx->hw_frames_ctx != nullptr)
//    {
//        Logging::debug(virtname(), "Hardware encoder init: Hardware decoder active, using decoder hw_frames_ctx for encoder.");
 
//        /* we need to ref hw_frames_ctx of decoder to initialize encoder's codec.
//       Only after we get a decoded frame, can we obtain its hw_frames_ctx */
//        output_codec_ctx->hw_frames_ctx = av_buffer_ref(input_codec_ctx->hw_frames_ctx);
//        if (!output_codec_ctx->hw_frames_ctx)
//        {
//            int ret = AVERROR(ENOMEM);
//            Logging::error(virtname(), "A hardware frame reference create failed (error '%1').", ffmpeg_geterror(ret).c_str());
//            return ret;
//        }
 
//        m_hwaccel_dec = true;   /* Doing decoding in hardware */
//    }
//    else {
//        Logging::debug(virtname(), "Hardware encoder init: Software decoder active, creating new hw_frames_ctx for encoder.");
 
//        AVBufferRef *hw_new_frames_ref;
//        AVHWFramesContext *frames_ctx = nullptr;
//        int ret = 0;
 
//        if (!(hw_new_frames_ref = av_hwframe_ctx_alloc(hw_device_ctx)))
//        {
//            ret = AVERROR(ENOMEM);
//            Logging::error(virtname(), "Failed to create hwframe context (error '%1').", ffmpeg_geterror(ret).c_str());
//            return ret;
//        }
//        frames_ctx = (AVHWFramesContext *)(hw_new_frames_ref->data);
//        frames_ctx->format    = m_hw_pix_fmt;
//        frames_ctx->sw_format = find_sw_fmt_by_hw_type(params.m_hwaccel_enc_device_type);
//        frames_ctx->width     = input_codec_ctx->width;
//        frames_ctx->height    = input_codec_ctx->height;
 
//        frames_ctx->initial_pool_size = 20;   // Driver default: 17
//        if ((ret = av_hwframe_ctx_init(hw_new_frames_ref)) < 0)
//        {
//            Logging::error(virtname(), "Failed to initialise hwframe context (error '%1').", ffmpeg_geterror(ret).c_str());
//            av_buffer_unref(&hw_new_frames_ref);
//            return ret;
//        }
 
//        output_codec_ctx->hw_frames_ctx = av_buffer_ref(hw_new_frames_ref);
//        if (!output_codec_ctx->hw_frames_ctx)
//        {
//            Logging::error(virtname(), "A hardware frame reference create failed (error '%1').", ffmpeg_geterror(AVERROR(ENOMEM)));
//            ret = AVERROR(ENOMEM);
//        }
 
//        av_buffer_unref(&hw_new_frames_ref);
 
//        m_hwaccel_dec = false;   /* Doing decoding in software */
//    }
 
//    return 0;
//}
 
int FFmpeg_Transcoder::hwframe_copy_from_hw(AVCodecContext * /*ctx*/, FFmpeg_Frame *sw_frame, const AVFrame * hw_frame) const
{
    int ret;
 
    ret = av_frame_copy_props(*sw_frame, hw_frame);
    if (ret < 0)
    {
        Logging::error(filename(), "Failed to copy frame properties (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    ret = av_hwframe_transfer_data(*sw_frame, hw_frame, 0);
    if (ret < 0)
    {
        Logging::error(filename(), "Error while transferring frame data from surface (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::hwframe_copy_to_hw(AVCodecContext *output_codec_ctx, FFmpeg_Frame *hw_frame, const AVFrame * sw_frame) const
{
    int ret;
 
    ret = av_frame_copy_props(*hw_frame, sw_frame);
    if (ret < 0)
    {
        Logging::error(virtname(), "Failed to copy frame properties (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    ret = av_hwframe_get_buffer(output_codec_ctx->hw_frames_ctx, *hw_frame, 0);
    if (ret < 0)
    {
        Logging::error(virtname(), "Failed to copy frame buffers to hardware memory (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    if ((*hw_frame)->hw_frames_ctx == nullptr)
    {
        ret = AVERROR(ENOMEM);
        Logging::error(virtname(), "Failed to copy frame buffers to hardware memory (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    ret = av_hwframe_transfer_data(*hw_frame, sw_frame, 0);
    if (ret < 0)
    {
        Logging::error(virtname(), "Error while transferring frame data to surface (error '%1').", ffmpeg_geterror(ret).c_str());
        return ret;
    }
 
    return 0;
}
 
int FFmpeg_Transcoder::get_hw_decoder_name(AVCodecID codec_id, std::string *codec_name) const
{
    std::string codec_name_buf;
    int ret = 0;
 
    switch (params.m_hwaccel_dec_API)
    {
    case HWACCELAPI::VAAPI:
    {
        ret = get_hw_vaapi_codec_name(codec_id, &codec_name_buf);
        break;
    }
    case HWACCELAPI::MMAL:
    {
        ret = get_hw_mmal_decoder_name(codec_id, &codec_name_buf);
        break;
    }
        //case HWACCELAPI::V4L2M2M:
        //{
        //    ret = get_hw_v4l2m2m_decoder_name(codec_id, &codec_name_buf);
        //    break;
        //}
    case HWACCELAPI::NONE:
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    if (codec_name != nullptr)
    {
        if (!ret)
        {
            *codec_name = codec_name_buf;
        }
        else
        {
            codec_name->clear();
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::get_hw_encoder_name(AVCodecID codec_id, std::string *codec_name) const
{
    std::string codec_name_buf;
    int ret = 0;
 
    switch (params.m_hwaccel_enc_API)
    {
    case HWACCELAPI::VAAPI:
    {
        ret = get_hw_vaapi_codec_name(codec_id, &codec_name_buf);
        break;
    }
    case HWACCELAPI::OMX:
    {
        ret = get_hw_omx_encoder_name(codec_id, &codec_name_buf);
        break;
    }
        //case HWACCELAPI::V4L2M2M:
        //{
        //    ret = get_hw_v4l2m2m_encoder_name(codec_id, &codec_name_buf);
        //    break;
        //}
    case HWACCELAPI::NONE:
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    if (codec_name != nullptr)
    {
        if (!ret)
        {
            *codec_name = codec_name_buf;
        }
        else
        {
            codec_name->clear();
        }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::get_hw_vaapi_codec_name(AVCodecID codec_id, std::string *codec_name) const
{
    int ret = 0;
    switch (codec_id)
    {
    case AV_CODEC_ID_H264:
    {
        *codec_name = "h264_vaapi";
        break;
    }
        //case AV_CODEC_ID_MJPEG:
        //{
        //    *codec_name = "mjpeg_vaapi";
        //    break;
        //}
    case AV_CODEC_ID_MPEG2VIDEO:
    {
        *codec_name = "mpeg2_vaapi";
        break;
    }
    case AV_CODEC_ID_HEVC:
    {
        *codec_name = "hevc_vaapi";
        break;
    }
    case AV_CODEC_ID_VC1:
    {
        *codec_name = "vc1_vaapi";
        break;
    }
    case AV_CODEC_ID_VP8:
    {
        *codec_name = "vp9_vaapi";
        break;
    }
    case AV_CODEC_ID_VP9:
    {
        *codec_name = "vp9_vaapi";
        break;
    }
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::get_hw_mmal_decoder_name(AVCodecID codec_id, std::string *codec_name) const
{
    int ret = 0;
    switch (codec_id)
    {
    case AV_CODEC_ID_H264:
    {
        *codec_name = "h264_mmal";
        break;
    }
    case AV_CODEC_ID_MPEG2VIDEO:
    {
        *codec_name = "mpeg2_mmal";
        break;
    }
    case AV_CODEC_ID_MPEG4:
    {
        *codec_name = "mpeg4_mmal";
        break;
    }
    case AV_CODEC_ID_VC1:
    {
        *codec_name = "vc1_mmal";
        break;
    }
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    return ret;
}
 
//int FFmpeg_Transcoder::get_hw_v4l2m2m_decoder_name(AVCodecID codec_id, std::string *codec_name) const
//{
//    int ret = 0;
//    /**
//     * *** v4l2m2m (Video2linux) decoder ***
//     *
//     * h263_v4l2m2m         V4L2 mem2mem H.263 decoder wrapper (codec h263)
//     * h264_v4l2m2m         V4L2 mem2mem H.264 decoder wrapper (codec h264)
//     * hevc_v4l2m2m         V4L2 mem2mem HEVC decoder wrapper (codec hevc)
//     * mpeg1_v4l2m2m        V4L2 mem2mem MPEG1 decoder wrapper (codec mpeg1video)
//     * mpeg2_v4l2m2m        V4L2 mem2mem MPEG2 decoder wrapper (codec mpeg2video)
//     * mpeg4_v4l2m2m        V4L2 mem2mem MPEG4 decoder wrapper (codec mpeg4)
//     * vc1_v4l2m2m          V4L2 mem2mem VC1 decoder wrapper (codec vc1)
//     * vp8_v4l2m2m          V4L2 mem2mem VP8 decoder wrapper (codec vp8)
//     * vp9_v4l2m2m          V4L2 mem2mem VP9 decoder wrapper (codec vp9)
//     */
//    switch (codec_id)
//    {
//    case AV_CODEC_ID_H263:
//    {
//        *codec_name = "h263_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_H264:
//    {
//        *codec_name = "h264_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_H265:
//    {
//        *codec_name = "hevc_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_MPEG1VIDEO:
//    {
//        *codec_name = "mpeg1_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_MPEG2VIDEO:
//    {
//        *codec_name = "mpeg2_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_MPEG4:
//    {
//        *codec_name = "mpeg4_v4l2m2m";
//        break;
//    }
//    //case AV_CODEC_ID_VC1:     /** @todo WMV is currently not supported */
//    //{
//    //    *codec_name = "vc1_v4l2m2m";
//    //    break;
//    //}
//    case AV_CODEC_ID_VP8:
//    {
//        *codec_name = "vp8_v4l2m2m";
//        break;
//    }
//    case AV_CODEC_ID_VP9:
//    {
//        *codec_name = "vp9_v4l2m2m";
//        break;
//    }
//    default:
//    {
//        ret = AVERROR_DECODER_NOT_FOUND;
//        break;
//    }
//    }
 
//    return ret;
//}
 
int FFmpeg_Transcoder::get_hw_omx_encoder_name(AVCodecID codec_id, std::string *codec_name) const
{
    int ret = 0;
    switch (codec_id)
    {
    case AV_CODEC_ID_H264:
    {
        *codec_name = "h264_omx";
        break;
    }
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::get_hw_v4l2m2m_encoder_name(AVCodecID codec_id, std::string *codec_name) const
{
    int ret = 0;
    switch (codec_id)
    {
    case AV_CODEC_ID_H263:
    {
        *codec_name = "h263_v4l2m2m";
        break;
    }
    case AV_CODEC_ID_H264:
    {
        *codec_name = "h264_v4l2m2m";
        break;
    }
    case AV_CODEC_ID_H265:
    {
        *codec_name = "hevc_v4l2m2m";
        break;
    }
    case AV_CODEC_ID_MPEG4:
    {
        *codec_name = "mpeg4_v4l2m2m";
        break;
    }
    case AV_CODEC_ID_VP8:
    {
        *codec_name = "vp8_v4l2m2m";
        break;
    }
    default:
    {
        ret = AVERROR_DECODER_NOT_FOUND;
        break;
    }
    }
 
    return ret;
}
 
AVPixelFormat FFmpeg_Transcoder::find_sw_fmt_by_hw_type(AVHWDeviceType type)
{
    DEVICETYPE_MAP::const_iterator it = m_devicetype_map.find(type);
 
    if (it == m_devicetype_map.cend())
    {
        return AV_PIX_FMT_NONE;
    }
 
    return it->second;
}
 
void FFmpeg_Transcoder::get_pix_formats(AVPixelFormat *in_pix_fmt, AVPixelFormat *out_pix_fmt, AVCodecContext* output_codec_ctx) const
{
    *in_pix_fmt = static_cast<AVPixelFormat>(m_in.m_video.m_stream->codecpar->format);
 
    if (m_hwaccel_enable_dec_buffering)
    {
        *in_pix_fmt = find_sw_fmt_by_hw_type(params.m_hwaccel_dec_device_type);
    }
 
    if (output_codec_ctx == nullptr)
    {
        output_codec_ctx = m_out.m_video.m_codec_ctx.get();
    }
 
    // Fail safe: If output_codec_ctx is NULL, set to something common (AV_PIX_FMT_YUV420P is widely used)
    *out_pix_fmt = (output_codec_ctx != nullptr) ? output_codec_ctx->pix_fmt : AV_PIX_FMT_YUV420P;
 
    if (*in_pix_fmt == AV_PIX_FMT_NONE)
    {
        // If input's stream pixel format is unknown, use same as output (may not work but at least will not crash FFmpeg)
        *in_pix_fmt = *out_pix_fmt;
    }
 
    // If hardware acceleration is enabled, e.g., output_codec_ctx->pix_fmt is AV_PIX_FMT_VAAPI
    // but the format actually is AV_PIX_FMT_NV12 so we use the correct value from sw_format in
    // the hardware frames context.
    if (m_hwaccel_enable_enc_buffering &&
            output_codec_ctx != nullptr &&
            output_codec_ctx->hw_frames_ctx != nullptr &&
            output_codec_ctx->hw_frames_ctx->data != nullptr)
    {
        *out_pix_fmt = reinterpret_cast<AVHWFramesContext*>(output_codec_ctx->hw_frames_ctx->data)->sw_format;
    }
}
 
uint32_t FFmpeg_Transcoder::get_next_segment(int64_t pos) const
{
    return (static_cast<uint32_t>(pos / params.m_segment_duration + 1));
}
 
bool FFmpeg_Transcoder::goto_next_segment(uint32_t next_segment) const
{
    return (next_segment == m_current_segment + 1 && next_segment <= m_virtualfile->get_segment_count());
}
 
bool FFmpeg_Transcoder::is_audio_stream(int stream_idx) const
{
    return (stream_exists(stream_idx) && stream_idx == m_in.m_audio.m_stream_idx);
}
 
bool FFmpeg_Transcoder::is_video_stream(int stream_idx) const
{
    return (stream_exists(stream_idx) && stream_idx == m_in.m_video.m_stream_idx);
}
 
bool FFmpeg_Transcoder::is_subtitle_stream(int stream_idx) const
{
    StreamRef_map::const_iterator it = m_in.m_subtitle.find(stream_idx);
 
    return (it != m_in.m_subtitle.cend());
}
 
FFmpeg_Transcoder::StreamRef * FFmpeg_Transcoder::get_out_subtitle_stream(int stream_idx)
{
    StreamRef_map::iterator it = m_out.m_subtitle.find(stream_idx);
 
    if (it == m_out.m_subtitle.end())
    {
        return nullptr;
    }
 
    return &it->second;
}
 
bool FFmpeg_Transcoder::stream_exists(int stream_idx) const
{
    return (stream_idx != INVALID_STREAM);
}
 
void FFmpeg_Transcoder::add_stream_map(int in_stream_idx, int out_stream_idx)
{
    if (in_stream_idx != INVALID_STREAM)
    {
        m_stream_map.emplace(in_stream_idx, out_stream_idx);
    }
}
 
int FFmpeg_Transcoder::map_in_to_out_stream(int in_stream_idx) const
{
    STREAM_MAP::const_iterator it = m_stream_map.find(in_stream_idx);
 
    if (it == m_stream_map.cend())
    {
        return INVALID_STREAM;
    }
 
    return (it->second);
}
 
inline int FFmpeg_Transcoder::foreach_subtitle_file(const std::string& search_path, const std::regex& regex, int depth, const std::function<int (const std::string &, const std::optional<std::string> &)> &f)
{
    int ret = 0;
 
    try
    {
        const std::filesystem::directory_iterator end;
        for (std::filesystem::directory_iterator iter{ search_path }; iter != end && ret == 0; iter++)
        {
            const std::string subtitle_filename(iter->path().filename().string());
            if (std::filesystem::is_regular_file(*iter))
            {
                if (std::regex_match(subtitle_filename, regex))
                {
                    std::smatch res;
                    if (std::regex_search(subtitle_filename.cbegin(), subtitle_filename.cend(), res, regex))
                    {
                        if (res[2].length())
                        {
                            ret = f(iter->path().string(), res[2]);
                        }
                        else
                        {
                            ret = f(iter->path().string(), std::nullopt);
                        }
                    }
                }
            }
            else if (std::filesystem::is_directory(*iter) && depth > 0)
            {
                ret = foreach_subtitle_file(iter->path().string(), regex, depth - 1, f);
            }
        }
    }
    catch (std::filesystem::filesystem_error& e)
    {
        ret = AVERROR(e.code().value());
        Logging::error(filename(), "Could not open directory '%1' (error '%2').", search_path.c_str(), ffmpeg_geterror(ret).c_str());
    }
    catch (std::bad_alloc & e)
    {
        ret = AVERROR(ENOMEM);
        Logging::error(filename(), "Could not open directory '%1' (error '%2').", search_path.c_str(), ffmpeg_geterror(ret).c_str());
    }
 
    return ret;
}
 
int FFmpeg_Transcoder::read_packet(void *opaque, uint8_t *buf, int buf_size)
{
    BUFFER_DATA *bd = static_cast<BUFFER_DATA *>(opaque);
    buf_size = FFMIN(buf_size, static_cast<int>(bd->size));
 
    if (!buf_size)
    {
        return AVERROR_EOF;
    }
 
    /* copy internal buffer data to buf */
    std::memcpy(buf, bd->ptr, static_cast<size_t>(buf_size));
    bd->ptr  += buf_size;
    bd->size -= static_cast<size_t>(buf_size);
 
    return buf_size;
}
 
int FFmpeg_Transcoder::add_external_subtitle_stream(const std::string & subtitle_file, const std::optional<std::string> & language)
{
    AVFormatContext *format_ctx = nullptr;
    AVIOContext *avio_ctx = nullptr;
    uint8_t *buffer = nullptr;
    size_t buffer_size;
    int ret = 0;
 
    if (language)
    {
        Logging::debug(filename(), "Adding external subtitle stream: %1 [%2]", subtitle_file.c_str(), language->c_str());
    }
    else
    {
        Logging::debug(filename(), "Adding external subtitle stream: %1", subtitle_file.c_str());
    }
 
    try
    {
        uint8_t *avio_ctx_buffer = nullptr;
        int avio_ctx_buffer_size = 4096;
        BUFFER_DATA bd = { nullptr, 0 };
 
        // slurp file content into buffer
        ret = av_file_map(subtitle_file.c_str(), &buffer, &buffer_size, 0, nullptr);
        if (ret < 0)
        {
            throw ret;
        }
 
        // fill opaque structure used by the AVIOContext read callback
        bd.ptr  = buffer;
        bd.size = buffer_size;
 
        format_ctx = avformat_alloc_context();
        if (format_ctx == nullptr)
        {
            throw AVERROR(ENOMEM);
        }
 
        avio_ctx_buffer = reinterpret_cast<uint8_t *>(av_malloc(static_cast<size_t>(avio_ctx_buffer_size)));
        if (avio_ctx_buffer == nullptr)
        {
            throw AVERROR(ENOMEM);
        }
 
        avio_ctx = avio_alloc_context(avio_ctx_buffer, avio_ctx_buffer_size, 0, &bd, &read_packet, nullptr, nullptr);
        if (avio_ctx == nullptr)
        {
            throw AVERROR(ENOMEM);
        }
        format_ctx->pb = avio_ctx;
 
        ret = avformat_open_input(&format_ctx, nullptr, nullptr, nullptr);
        if (ret < 0)
        {
            Logging::error(filename(), "Could not open input file (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        ret = avformat_find_stream_info(format_ctx, nullptr);
        if (ret < 0)
        {
            Logging::error(filename(), "Could not find stream info (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        //av_dump_format(format_ctx, 0, subtitle_file.c_str(), 0);
 
        AVCodecContext * codec_ctx = nullptr;
        int stream_idx = INVALID_STREAM;
 
        ret = open_bestmatch_decoder(format_ctx, &codec_ctx, &stream_idx, AVMEDIA_TYPE_SUBTITLE);
        if (ret < 0 && ret != AVERROR_STREAM_NOT_FOUND)    // AVERROR_STREAM_NOT_FOUND is not an error
        {
            Logging::error(filename(), "Failed to open video codec (error '%1').", ffmpeg_geterror(ret).c_str());
            throw ret;
        }
 
        if (ret != AVERROR_STREAM_NOT_FOUND)
        {
            AVCodecID codec_id = m_current_format->subtitle_codec(codec_ctx->codec_id); // Get matching output codec
 
            if (codec_id != AV_CODEC_ID_NONE)
            {
                StreamRef input_streamref;
 
                codec_ctx->pkt_timebase = codec_ctx->time_base = format_ctx->streams[0]->time_base;
 
                // We have a subtitle stream
                input_streamref.set_codec_ctx(codec_ctx);
                input_streamref.m_stream      = format_ctx->streams[0];
                input_streamref.m_stream_idx  = INVALID_STREAM;
 
                //m_active_stream_msk     |= FFMPEGFS_SUBTITLE;
 
                ret = add_subtitle_stream(codec_id, input_streamref, language);
                if (ret < 0)
                {
                    throw ret;
                }
 
                int output_stream_index = ret;
                FFmpeg_Packet pkt;
                ret = pkt.res();
                if (ret < 0)
                {
                    throw ret;
                }
 
                // Read one frame from the input file into a temporary packet.
                while ((ret = av_read_frame(format_ctx, pkt)) == 0)
                {
                    int decoded;
                    ret = decode_subtitle(codec_ctx, pkt, &decoded, output_stream_index);
                    if (ret < 0)
                    {
                        throw ret;
                    }
                }
            }
        }
 
        if (ret == AVERROR_EOF)
        {
            ret = 0;
        }
    }
    catch (int _ret)
    {
        ret = _ret;
    }
 
    avformat_close_input(&format_ctx);
 
    // note: the internal buffer could have changed, and be != avio_ctx_buffer
    if (avio_ctx != nullptr)
    {
        av_freep(&avio_ctx->buffer);
    }
 
    avio_context_free(&avio_ctx);
 
    av_file_unmap(buffer, buffer_size);
 
    return ret;
}
 
int FFmpeg_Transcoder::add_external_subtitle_streams()
{
    int ret;
 
    try
    {
        std::filesystem::path file(filename());
        std::string stem(file.stem().string());
 
        // Escape characters that are meaningful to regexp.
        regex_escape(&stem);
 
        std::string regex_string("^(" + stem + "[.])(.*)([.]srt|[.]vtt)|^(" + stem + ")([.]srt|[.]vtt)");   // filename.srt/vtt or filename.lang.srt/vtt
        std::regex regex(regex_string, std::regex::ECMAScript);
 
        //ret = foreach_subtitle_file(
        //            file.parent_path(),
        //            regex,
        //            0,
        //            std::bind(&FFmpeg_Transcoder::add_external_subtitle_stream, this, std::placeholders::_1, std::placeholders::_2));
 
        // clang-tidy now recommends a lambda
        ret = foreach_subtitle_file(
                    file.parent_path().string(),
                    regex,
                    0,
                    [this](const std::string & subtitle_file, const std::optional<std::string> & language)
        {
            add_external_subtitle_stream(std::forward<decltype(subtitle_file)>(subtitle_file), std::forward<decltype(language)>(language));
            return 0;
        });
 
        // Ugly, but a lambda would also be possible
        //ret = foreach_subtitle_file(
        //            file.parent_path(),
        //            regex,
        //            0,
        //            [this](const std::string & subtitle_file, const std::optional<std::string> & language)
        //{
        //    if (language)
        //    {
        //        Logging::error(filename(), "[%1] %2", language->c_str(), subtitle_file.c_str());
        //    }
        //    else
        //    {
        //        Logging::error(filename(), "%1", subtitle_file.c_str());
        //    }
        //    return 0;
        //});
    }
    catch (std::regex_error & e)
    {
        ret = 0;    // Ignore error
        Logging::error(filename(), "INTERNAL ERROR: FFmpeg_Transcoder::add_external_subtitle_streams()! Unable to create reg exp: %1", e.what());
    }
 
    return ret;
}
 
int64_t FFmpeg_Transcoder::pts() const
{
    MULTIFRAME_MAP::const_reverse_iterator it = m_frame_map.crbegin();
 
    if (it != m_frame_map.crend())
    {
        return it->first;
    }
    else
    {
        return 0;
    }
}
 
uint32_t FFmpeg_Transcoder::last_seek_frame_no() const
{
    return m_last_seek_frame_no;
}