// Copyright 2019 Fuzhou Rockchip Electronics Co., Ltd. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "encoder.h"

namespace easymedia
{

#define VIDEO_ENC_CHANGE_MAX 50

    DEFINE_REFLECTOR(Encoder)

    // request should equal codec_name
    DEFINE_FACTORY_COMMON_PARSE(Encoder)

    bool Encoder::InitConfig(const MediaConfig& cfg)
    {
        Codec::SetConfig(cfg);
        return true;
    }

    void VideoEncoder::RequestChange(uint32_t change, std::shared_ptr<ParameterBuffer> value)
    {
        change_mtx.lock();
        if (change_list.size() > VIDEO_ENC_CHANGE_MAX) {
            LOG("WARN: Video Encoder: change list reached max cnt:%d. Drop front!\n", VIDEO_ENC_CHANGE_MAX);
            change_list.pop_front();
        }
        change_list.emplace_back(change, std::move(value));
        change_mtx.unlock();
    }

    void VideoEncoder::QueryChange(uint32_t change, void* value, int32_t size)
    {
        LOG("WARN: Video Encoder: %s should be reloaded first!\n", __func__);
        UNUSED(change);
        UNUSED(value);
        UNUSED(size);
    }

    std::pair<uint32_t, std::shared_ptr<ParameterBuffer>> VideoEncoder::PeekChange()
    {
        std::lock_guard<std::mutex> _lg(change_mtx);
        if (change_list.empty()) {
            static auto empty = std::pair<uint32_t, std::shared_ptr<ParameterBuffer>>(0, nullptr);
            return empty;
        }
        std::pair<uint32_t, std::shared_ptr<ParameterBuffer>> p = change_list.front();
        change_list.pop_front();
        return p;
    }

    DEFINE_PART_FINAL_EXPOSE_PRODUCT(VideoEncoder, Encoder)
    DEFINE_PART_FINAL_EXPOSE_PRODUCT(AudioEncoder, Encoder)

} // namespace easymedia