nvmpi_shared.cpp

// FFMPEG Video Encoder Integration for OBS Studio
// Copyright (c) 2019 Michael Fabian Dirks <info@xaymar.com>
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.

//PST: replaced nvenc by nvmpi
//PST: important: several occurrences of name string "h264_nvenc"; this are real dependencies to the encoder

#include "nvmpi_shared.hpp"
#include "encoders/encoder-ffmpeg.hpp"
#include "ffmpeg/tools.hpp"

extern "C" {
#pragma warning(push)
#pragma warning(disable : 4244)
#include <libavutil/opt.h>
#pragma warning(pop)
}

#define ST_PRESET "FFmpegEncoder.NVMPI.Preset"
#define ST_PRESET_(x) ST_PRESET "." D_VSTR(x)
#define ST_RATECONTROL "FFmpegEncoder.NVMPI.RateControl"
#define ST_RATECONTROL_MODE ST_RATECONTROL ".Mode"
#define ST_RATECONTROL_MODE_(x) ST_RATECONTROL_MODE "." D_VSTR(x)
#define ST_RATECONTROL_TWOPASS ST_RATECONTROL ".TwoPass"
#define ST_RATECONTROL_LOOKAHEAD ST_RATECONTROL ".LookAhead"
#define ST_RATECONTROL_ADAPTIVEI ST_RATECONTROL ".AdaptiveI"
#define ST_RATECONTROL_ADAPTIVEB ST_RATECONTROL ".AdaptiveB"
#define ST_RATECONTROL_LIMITS ST_RATECONTROL ".Limits"
#define ST_RATECONTROL_LIMITS_BUFFERSIZE ST_RATECONTROL_LIMITS ".BufferSize"
#define ST_RATECONTROL_LIMITS_QUALITY ST_RATECONTROL_LIMITS ".Quality"
#define ST_RATECONTROL_LIMITS_BITRATE ST_RATECONTROL_LIMITS ".Bitrate"
#define ST_RATECONTROL_LIMITS_BITRATE_TARGET ST_RATECONTROL_LIMITS_BITRATE ".Target"
#define ST_RATECONTROL_LIMITS_BITRATE_MAXIMUM ST_RATECONTROL_LIMITS_BITRATE ".Maximum"
#define ST_RATECONTROL_QP ST_RATECONTROL ".QP"
#define ST_RATECONTROL_QP_MINIMUM ST_RATECONTROL_QP ".Minimum"
#define ST_RATECONTROL_QP_MAXIMUM ST_RATECONTROL_QP ".Maximum"
#define ST_RATECONTROL_QP_I ST_RATECONTROL_QP ".I"
#define ST_RATECONTROL_QP_P ST_RATECONTROL_QP ".P"
#define ST_RATECONTROL_QP_B ST_RATECONTROL_QP ".B"
#define ST_AQ "FFmpegEncoder.NVMPI.AQ"
#define ST_AQ_SPATIAL ST_AQ ".Spatial"
#define ST_AQ_TEMPORAL ST_AQ ".Temporal"
#define ST_AQ_STRENGTH ST_AQ ".Strength"
#define ST_OTHER "FFmpegEncoder.NVMPI.Other"
#define ST_OTHER_BFRAMES ST_OTHER ".BFrames"
#define ST_OTHER_BFRAMEREFERENCEMODE ST_OTHER ".BFrameReferenceMode"
#define ST_OTHER_ZEROLATENCY ST_OTHER ".ZeroLatency"
#define ST_OTHER_WEIGHTEDPREDICTION ST_OTHER ".WeightedPrediction"
#define ST_OTHER_NONREFERENCEPFRAMES ST_OTHER ".NonReferencePFrames"
#define ST_OTHER_ACCESSUNITDELIMITER ST_OTHER ".AccessUnitDelimiter"
#define ST_OTHER_DECODEDPICTUREBUFFERSIZE ST_OTHER ".DecodedPictureBufferSize"

#define KEY_PRESET "Preset"
#define KEY_RATECONTROL_MODE "RateControl.Mode"
#define KEY_RATECONTROL_TWOPASS "RateControl.TwoPass"
#define KEY_RATECONTROL_LOOKAHEAD "RateControl.LookAhead"
#define KEY_RATECONTROL_ADAPTIVEI "RateControl.AdaptiveI"
#define KEY_RATECONTROL_ADAPTIVEB "RateControl.AdaptiveB"
#define KEY_RATECONTROL_LIMITS_BUFFERSIZE "RateControl.Limits.BufferSize"
#define KEY_RATECONTROL_LIMITS_QUALITY "RateControl.Limits.Quality"
#define KEY_RATECONTROL_LIMITS_BITRATE_TARGET "RateControl.Limits.Bitrate.Target"
#define KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM "RateControl.Limits.Bitrate.Maximum"
#define KEY_RATECONTROL_QP_MINIMUM "RateControl.Quality.Minimum"
#define KEY_RATECONTROL_QP_MAXIMUM "RateControl.Quality.Maximum"
#define KEY_RATECONTROL_QP_I "RateControl.QP.I"
#define KEY_RATECONTROL_QP_P "RateControl.QP.P"
#define KEY_RATECONTROL_QP_B "RateControl.QP.B"
#define KEY_AQ_SPATIAL "AQ.Spatial"
#define KEY_AQ_TEMPORAL "AQ.Temporal"
#define KEY_AQ_STRENGTH "AQ.Strength"
#define KEY_OTHER_BFRAMES "Other.BFrames"
#define KEY_OTHER_BFRAMEREFERENCEMODE "Other.BFrameReferenceMode"
#define KEY_OTHER_ZEROLATENCY "Other.ZeroLatency"
#define KEY_OTHER_WEIGHTEDPREDICTION "Other.WeightedPrediction"
#define KEY_OTHER_NONREFERENCEPFRAMES "Other.NonReferencePFrames"
#define KEY_OTHER_ACCESSUNITDELIMITER "Other.AccessUnitDelimiter"
#define KEY_OTHER_DECODEDPICTUREBUFFERSIZE "Other.DecodedPictureBufferSize"

using namespace streamfx::encoder::ffmpeg::handler;

std::map<nvmpi::preset, std::string> nvmpi::presets{
	{nvmpi::preset::DEFAULT, ST_PRESET_(Default)},
	{nvmpi::preset::SLOW, ST_PRESET_(Slow)},
	{nvmpi::preset::MEDIUM, ST_PRESET_(Medium)},
	{nvmpi::preset::FAST, ST_PRESET_(Fast)},
	{nvmpi::preset::HIGH_PERFORMANCE, ST_PRESET_(HighPerformance)},
#if 0 //PST not supported
	{nvmpi::preset::HIGH_QUALITY, ST_PRESET_(HighQuality)},
	{nvmpi::preset::BLURAYDISC, ST_PRESET_(BluRayDisc)},
	{nvmpi::preset::LOW_LATENCY, ST_PRESET_(LowLatency)},
	{nvmpi::preset::LOW_LATENCY_HIGH_PERFORMANCE, ST_PRESET_(LowLatencyHighPerformance)},
	{nvmpi::preset::LOW_LATENCY_HIGH_QUALITY, ST_PRESET_(LowLatencyHighQuality)},
	{nvmpi::preset::LOSSLESS, ST_PRESET_(Lossless)},
	{nvmpi::preset::LOSSLESS_HIGH_PERFORMANCE, ST_PRESET_(LosslessHighPerformance)},
#endif
};

std::map<nvmpi::preset, std::string> nvmpi::preset_to_opt{
	{nvmpi::preset::DEFAULT, "default"},
	{nvmpi::preset::SLOW, "slow"},
	{nvmpi::preset::MEDIUM, "medium"},
	{nvmpi::preset::FAST, "fast"},
	{nvmpi::preset::HIGH_PERFORMANCE, "ultrafast"}, //PST 'hp' not supported, but preset 'ultrafast'
#if 0 //PST not supported
	{nvmpi::preset::HIGH_PERFORMANCE, "hp"},
	{nvmpi::preset::HIGH_QUALITY, "hq"},
	{nvmpi::preset::BLURAYDISC, "bd"},
	{nvmpi::preset::LOW_LATENCY, "ll"},
	{nvmpi::preset::LOW_LATENCY_HIGH_PERFORMANCE, "llhp"},
	{nvmpi::preset::LOW_LATENCY_HIGH_QUALITY, "llhq"},
	{nvmpi::preset::LOSSLESS, "lossless"},
	{nvmpi::preset::LOSSLESS_HIGH_PERFORMANCE, "losslesshp"},
#endif
};

std::map<nvmpi::ratecontrolmode, std::string> nvmpi::ratecontrolmodes{
	{nvmpi::ratecontrolmode::CQP, ST_RATECONTROL_MODE_(CQP)},
	{nvmpi::ratecontrolmode::VBR, ST_RATECONTROL_MODE_(VBR)},
#if 0 //PST not supported
	{nvmpi::ratecontrolmode::VBR_HQ, ST_RATECONTROL_MODE_(VBR_HQ)},
	{nvmpi::ratecontrolmode::CBR, ST_RATECONTROL_MODE_(CBR)},
	{nvmpi::ratecontrolmode::CBR_HQ, ST_RATECONTROL_MODE_(CBR_HQ)},
	{nvmpi::ratecontrolmode::CBR_LD_HQ, ST_RATECONTROL_MODE_(CBR_LD_HQ)},
#endif
};

std::map<nvmpi::ratecontrolmode, std::string> nvmpi::ratecontrolmode_to_opt{
//	{nvmpi::ratecontrolmode::CQP, "constqp"}, //PST
    {nvmpi::ratecontrolmode::VBR, "vbr"},
//	{nvmpi::ratecontrolmode::VBR_HQ, "vbr_hq"}, //PST
	{nvmpi::ratecontrolmode::CBR, "cbr"},
//	{nvmpi::ratecontrolmode::CBR_HQ, "cbr_hq"}, {nvmpi::ratecontrolmode::CBR_LD_HQ, "cbr_ld_hq"}, //PST
};

std::map<nvmpi::b_ref_mode, std::string> nvmpi::b_ref_modes{
	{nvmpi::b_ref_mode::INVALID, S_STATE_DEFAULT},
	{nvmpi::b_ref_mode::DISABLED, S_STATE_DISABLED},
	{nvmpi::b_ref_mode::EACH, ST_OTHER_BFRAMEREFERENCEMODE ".Each"},
	{nvmpi::b_ref_mode::MIDDLE, ST_OTHER_BFRAMEREFERENCEMODE ".Middle"},
};

std::map<nvmpi::b_ref_mode, std::string> nvmpi::b_ref_mode_to_opt{
	{nvmpi::b_ref_mode::DISABLED, "disabled"},
	{nvmpi::b_ref_mode::EACH, "each"},
	{nvmpi::b_ref_mode::MIDDLE, "middle"},
};

bool streamfx::encoder::ffmpeg::handler::nvmpi::is_available()
{
#if defined(D_PLATFORM_WINDOWS)
PST: correct identification for Windows platform tbd
#if defined(D_PLATFORM_64BIT)
	std::filesystem::path lib_name = "nvEncodeAPI64.dll";
#else
	std::filesystem::path lib_name = "nvEncodeAPI.dll";
#endif
#else
	//PST: using the library libnvmpi.so as it is built by https://github.com/jocover/jetson-ffmpeg
	//and is loaded anyhow by libavcodec.so for nvmpi support, so this does not create overhead
	//Calls to the library libnvencode.so have form NvEncodeAPI*  
	//(see https://docs.nvidia.com/video-technologies/video-codec-sdk/nvenc-video-encoder-api-prog-guide/  )
	//I'm also not seeing its include beeing included.
	std::filesystem::path lib_name = "libnvmpi.so";
#endif
	try {
		util::library::load(lib_name);
		return true;
	} catch (...) {
		DLOG_INFO("PST - nvmpi_shared.cpp:174 load of %s failed, nvmpi seems unsupported", lib_name.c_str());
		return false;
	}
}

void nvmpi::override_update(ffmpeg_instance* instance, obs_data_t*)
{   CHK(0);//PST
	AVCodecContext* context = const_cast<AVCodecContext*>(instance->get_avcodeccontext());

	int64_t rclookahead = 0;
	int64_t surfaces    = 0;
	int64_t async_depth = 0;

	CHK(av_opt_get_int(context, "rc-lookahead", AV_OPT_SEARCH_CHILDREN, &rclookahead));
	CHK(av_opt_get_int(context, "surfaces", AV_OPT_SEARCH_CHILDREN, &surfaces));
	CHK(av_opt_get_int(context, "async_depth", AV_OPT_SEARCH_CHILDREN, &async_depth));

	// Calculate and set the number of surfaces to allocate (if not user overridden).
	if (surfaces == 0) {
		surfaces = std::max<int64_t>(4ll, (context->max_b_frames + 1ll) * 4ll);
		if (rclookahead > 0) {
			surfaces = std::max<int64_t>(1ll, std::max<int64_t>(surfaces, rclookahead + (context->max_b_frames + 5ll)));
		} else if (context->max_b_frames > 0) {
			surfaces = std::max<int64_t>(4ll, (context->max_b_frames + 1ll) * 4ll);
		} else {
			surfaces = 4;
		}

		CHK(av_opt_set_int(context, "surfaces", surfaces, AV_OPT_SEARCH_CHILDREN));
	}

	// Set delay
	context->delay = std::min<int>(std::max<int64_t>(async_depth, 3ll), surfaces - 1);
}

void nvmpi::get_defaults(obs_data_t* settings, const AVCodec*, AVCodecContext*)
{
	CHK(0); //PST
	obs_data_set_default_int(settings, KEY_PRESET, static_cast<int64_t>(nvmpi::preset::DEFAULT));

	//obs_data_set_default_int(settings, KEY_RATECONTROL_MODE, static_cast<int64_t>(ratecontrolmode::CBR_HQ)); //PST
	obs_data_set_default_int(settings, KEY_RATECONTROL_MODE, static_cast<int64_t>(ratecontrolmode::VBR)); //PST
	obs_data_set_default_int(settings, KEY_RATECONTROL_TWOPASS, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_LOOKAHEAD, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_ADAPTIVEI, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_ADAPTIVEB, -1);

	obs_data_set_default_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_TARGET, 6000);
	obs_data_set_default_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM, 0);
	obs_data_set_default_int(settings, KEY_RATECONTROL_LIMITS_BUFFERSIZE, 12000);
	obs_data_set_default_double(settings, KEY_RATECONTROL_LIMITS_QUALITY, 0);

	obs_data_set_default_int(settings, KEY_RATECONTROL_QP_MINIMUM, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_QP_MAXIMUM, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_QP_I, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_QP_P, -1);
	obs_data_set_default_int(settings, KEY_RATECONTROL_QP_B, -1);

	obs_data_set_default_int(settings, KEY_AQ_SPATIAL, -1);
	obs_data_set_default_int(settings, KEY_AQ_STRENGTH, -1);
	obs_data_set_default_int(settings, KEY_AQ_TEMPORAL, -1);

	obs_data_set_default_int(settings, KEY_OTHER_BFRAMES, -1);
	obs_data_set_default_int(settings, KEY_OTHER_BFRAMEREFERENCEMODE, static_cast<int64_t>(b_ref_mode::INVALID));
	obs_data_set_default_int(settings, KEY_OTHER_ZEROLATENCY, -1);
	obs_data_set_default_int(settings, KEY_OTHER_WEIGHTEDPREDICTION, -1);
	obs_data_set_default_int(settings, KEY_OTHER_NONREFERENCEPFRAMES, -1);
	obs_data_set_default_int(settings, KEY_OTHER_ACCESSUNITDELIMITER, -1);
	obs_data_set_default_int(settings, KEY_OTHER_DECODEDPICTUREBUFFERSIZE, -1);

	// Replay Buffer
	obs_data_set_default_int(settings, "bitrate", 0);
}

static bool modified_ratecontrol(obs_properties_t* props, obs_property_t*, obs_data_t* settings) noexcept
{
	bool have_bitrate       = false;
	bool have_bitrate_range = false;
	bool have_quality       = false;
	bool have_qp            = false;
	CHK(0); //PST

	nvmpi::ratecontrolmode rc = static_cast<nvmpi::ratecontrolmode>(obs_data_get_int(settings, KEY_RATECONTROL_MODE));
	switch (rc) {
//	case nvmpi::ratecontrolmode::CQP: //PST
//		have_qp = true;
//		break;
	case nvmpi::ratecontrolmode::INVALID:
	case nvmpi::ratecontrolmode::CBR:
//	case nvmpi::ratecontrolmode::CBR_HQ: //PST
//	case nvmpi::ratecontrolmode::CBR_LD_HQ: //PST
		have_bitrate = true;
		break;
	case nvmpi::ratecontrolmode::VBR:
//	case nvmpi::ratecontrolmode::VBR_HQ: //PST
		have_bitrate       = true;
		have_bitrate_range = true;
		have_quality       = true;
		have_qp            = true;
		break;
	}

	obs_property_set_visible(obs_properties_get(props, ST_RATECONTROL_LIMITS), have_bitrate || have_quality);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BUFFERSIZE), have_bitrate);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_LIMITS_QUALITY), have_quality);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BITRATE_TARGET), have_bitrate);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM), have_bitrate_range);

	obs_property_set_visible(obs_properties_get(props, ST_RATECONTROL_QP), have_qp || have_bitrate_range);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_QP_MINIMUM), have_bitrate_range);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_QP_MAXIMUM), have_bitrate_range);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_QP_I), have_qp);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_QP_P), have_qp);
	obs_property_set_visible(obs_properties_get(props, KEY_RATECONTROL_QP_B), have_qp);

	return true;
}

static bool modified_aq(obs_properties_t* props, obs_property_t*, obs_data_t* settings) noexcept
{   CHK(0);//PST
	bool spatial_aq = streamfx::util::is_tristate_enabled(obs_data_get_int(settings, KEY_AQ_SPATIAL));
	obs_property_set_visible(obs_properties_get(props, KEY_AQ_STRENGTH), spatial_aq);
	return true;
}

void nvmpi::get_properties_pre(obs_properties_t* props, const AVCodec*)
{   CHK(0);//PST
	auto p =
		obs_properties_add_list(props, KEY_PRESET, D_TRANSLATE(ST_PRESET), OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
	obs_property_set_long_description(p, D_TRANSLATE(ST_PRESET));
	for (auto kv : presets) {
		obs_property_list_add_int(p, D_TRANSLATE(kv.second.c_str()), static_cast<int64_t>(kv.first));
	}
}

void nvmpi::get_properties_post(obs_properties_t* props, const AVCodec* codec)
{   CHK(0);//PST
	{ // Rate Control
		obs_properties_t* grp = props;
		if (!util::are_property_groups_broken()) {
			grp = obs_properties_create();
			obs_properties_add_group(props, ST_RATECONTROL, D_TRANSLATE(ST_RATECONTROL), OBS_GROUP_NORMAL, grp);
		}

		{
			auto p = obs_properties_add_list(grp, KEY_RATECONTROL_MODE, D_TRANSLATE(ST_RATECONTROL_MODE),
											 OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_MODE));
			obs_property_set_modified_callback(p, modified_ratecontrol);
			for (auto kv : ratecontrolmodes) {
				obs_property_list_add_int(p, D_TRANSLATE(kv.second.c_str()), static_cast<int64_t>(kv.first));
			}
		}

		{
			auto p =
				util::obs_properties_add_tristate(grp, KEY_RATECONTROL_TWOPASS, D_TRANSLATE(ST_RATECONTROL_TWOPASS));
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_TWOPASS));
		}

		{
			auto p = obs_properties_add_int_slider(grp, KEY_RATECONTROL_LOOKAHEAD,
												   D_TRANSLATE(ST_RATECONTROL_LOOKAHEAD), -1, 32, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_LOOKAHEAD));
			obs_property_int_set_suffix(p, " frames");
			//obs_property_set_modified_callback(p, modified_lookahead);
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_RATECONTROL_ADAPTIVEI,
													   D_TRANSLATE(ST_RATECONTROL_ADAPTIVEI));
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_ADAPTIVEI));
		}

		if (strcmp(codec->name, "h264_nvmpi") == 0) {
			auto p = util::obs_properties_add_tristate(grp, KEY_RATECONTROL_ADAPTIVEB,
													   D_TRANSLATE(ST_RATECONTROL_ADAPTIVEB));
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_ADAPTIVEB));
		}
	}

	{
		obs_properties_t* grp = props;
		if (!util::are_property_groups_broken()) {
			grp = obs_properties_create();
			obs_properties_add_group(props, ST_RATECONTROL_LIMITS, D_TRANSLATE(ST_RATECONTROL_LIMITS), OBS_GROUP_NORMAL,
									 grp);
		}

		{
			auto p = obs_properties_add_float_slider(grp, KEY_RATECONTROL_LIMITS_QUALITY,
													 D_TRANSLATE(ST_RATECONTROL_LIMITS_QUALITY), 0, 100, 0.01);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_LIMITS_QUALITY));
		}

		{
			auto p = obs_properties_add_int(grp, KEY_RATECONTROL_LIMITS_BITRATE_TARGET,
											D_TRANSLATE(ST_RATECONTROL_LIMITS_BITRATE_TARGET), -1,
											std::numeric_limits<int32_t>::max(), 1);
			obs_property_int_set_suffix(p, " kbit/s");
		}

		{
			auto p = obs_properties_add_int(grp, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM,
											D_TRANSLATE(ST_RATECONTROL_LIMITS_BITRATE_MAXIMUM), -1,
											std::numeric_limits<int32_t>::max(), 1);
			obs_property_int_set_suffix(p, " kbit/s");
		}

		{
			auto p = obs_properties_add_int(grp, KEY_RATECONTROL_LIMITS_BUFFERSIZE,
											D_TRANSLATE(ST_RATECONTROL_LIMITS_BUFFERSIZE), 0,
											std::numeric_limits<int32_t>::max(), 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_LIMITS_BUFFERSIZE));
			obs_property_int_set_suffix(p, " kbit");
		}
	}

	{
		obs_properties_t* grp = props;
		if (!util::are_property_groups_broken()) {
			grp = obs_properties_create();
			obs_properties_add_group(props, ST_RATECONTROL_QP, D_TRANSLATE(ST_RATECONTROL_QP), OBS_GROUP_NORMAL, grp);
		}

		{
			auto p = obs_properties_add_int_slider(grp, KEY_RATECONTROL_QP_MINIMUM,
												   D_TRANSLATE(ST_RATECONTROL_QP_MINIMUM), -1, 51, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_QP_MINIMUM));
		}
		{
			auto p = obs_properties_add_int_slider(grp, KEY_RATECONTROL_QP_MAXIMUM,
												   D_TRANSLATE(ST_RATECONTROL_QP_MAXIMUM), -1, 51, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_QP_MAXIMUM));
		}

		{
			auto p =
				obs_properties_add_int_slider(grp, KEY_RATECONTROL_QP_I, D_TRANSLATE(ST_RATECONTROL_QP_I), -1, 51, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_QP_I));
		}
		{
			auto p =
				obs_properties_add_int_slider(grp, KEY_RATECONTROL_QP_P, D_TRANSLATE(ST_RATECONTROL_QP_P), -1, 51, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_QP_P));
		}
		{
			auto p =
				obs_properties_add_int_slider(grp, KEY_RATECONTROL_QP_B, D_TRANSLATE(ST_RATECONTROL_QP_B), -1, 51, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_RATECONTROL_QP_B));
		}
	}

	{
		obs_properties_t* grp = props;
		if (!util::are_property_groups_broken()) {
			grp = obs_properties_create();
			obs_properties_add_group(props, ST_AQ, D_TRANSLATE(ST_AQ), OBS_GROUP_NORMAL, grp);
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_AQ_SPATIAL, D_TRANSLATE(ST_AQ_SPATIAL));
			obs_property_set_long_description(p, D_TRANSLATE(ST_AQ_SPATIAL));
			obs_property_set_modified_callback(p, modified_aq);
		}
		{
			auto p = obs_properties_add_int_slider(grp, KEY_AQ_STRENGTH, D_TRANSLATE(ST_AQ_STRENGTH), -1, 15, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_AQ_STRENGTH));
		}
		{
			auto p = util::obs_properties_add_tristate(grp, KEY_AQ_TEMPORAL, D_TRANSLATE(ST_AQ_TEMPORAL));
			obs_property_set_long_description(p, D_TRANSLATE(ST_AQ_TEMPORAL));
		}
	}

	{
		obs_properties_t* grp = props;
		if (!util::are_property_groups_broken()) {
			grp = obs_properties_create();
			obs_properties_add_group(props, ST_OTHER, D_TRANSLATE(ST_OTHER), OBS_GROUP_NORMAL, grp);
		}

		{
			auto p = obs_properties_add_int_slider(grp, KEY_OTHER_BFRAMES, D_TRANSLATE(ST_OTHER_BFRAMES), -1, 4, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_BFRAMES));
			obs_property_int_set_suffix(p, " frames");
		}

		{
			auto p =
				obs_properties_add_list(grp, KEY_OTHER_BFRAMEREFERENCEMODE, D_TRANSLATE(ST_OTHER_BFRAMEREFERENCEMODE),
										OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
			for (auto kv : b_ref_modes) {
				if (kv.first == nvmpi::b_ref_mode::EACH && (std::string_view("h264_nvmpi") == codec->name)) {
					// H.264 does not support using all B-Frames as reference.
					continue;
				}
				obs_property_list_add_int(p, D_TRANSLATE(kv.second.c_str()), static_cast<int64_t>(kv.first));
			}
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_OTHER_ZEROLATENCY, D_TRANSLATE(ST_OTHER_ZEROLATENCY));
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_ZEROLATENCY));
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_OTHER_WEIGHTEDPREDICTION,
													   D_TRANSLATE(ST_OTHER_WEIGHTEDPREDICTION));
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_WEIGHTEDPREDICTION));
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_OTHER_NONREFERENCEPFRAMES,
													   D_TRANSLATE(ST_OTHER_NONREFERENCEPFRAMES));
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_NONREFERENCEPFRAMES));
		}

		{
			auto p = util::obs_properties_add_tristate(grp, KEY_OTHER_ACCESSUNITDELIMITER,
													   D_TRANSLATE(ST_OTHER_ACCESSUNITDELIMITER));
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_ACCESSUNITDELIMITER));
		}

		{
			auto p = obs_properties_add_int_slider(grp, KEY_OTHER_DECODEDPICTUREBUFFERSIZE,
												   D_TRANSLATE(ST_OTHER_DECODEDPICTUREBUFFERSIZE), -1, 16, 1);
			obs_property_set_long_description(p, D_TRANSLATE(ST_OTHER_DECODEDPICTUREBUFFERSIZE));
			obs_property_int_set_suffix(p, " frames");
		}
	}
}

void nvmpi::get_runtime_properties(obs_properties_t* props, const AVCodec*, AVCodecContext*)
{   CHK(0);//PST
	obs_property_set_enabled(obs_properties_get(props, KEY_PRESET), false);
	obs_property_set_enabled(obs_properties_get(props, ST_RATECONTROL), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_MODE), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_TWOPASS), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_LOOKAHEAD), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_ADAPTIVEI), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_ADAPTIVEB), false);
	obs_property_set_enabled(obs_properties_get(props, ST_RATECONTROL_LIMITS), true);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BUFFERSIZE), true);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BITRATE_TARGET), true);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM), true);
	obs_property_set_enabled(obs_properties_get(props, ST_RATECONTROL_LIMITS_QUALITY), false);
	obs_property_set_enabled(obs_properties_get(props, ST_RATECONTROL_QP), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_QP_MINIMUM), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_QP_MAXIMUM), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_QP_I), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_QP_P), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_RATECONTROL_QP_B), false);
	obs_property_set_enabled(obs_properties_get(props, ST_AQ), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_AQ_SPATIAL), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_AQ_STRENGTH), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_AQ_TEMPORAL), false);
	obs_property_set_enabled(obs_properties_get(props, ST_OTHER), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_BFRAMES), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_BFRAMEREFERENCEMODE), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_ZEROLATENCY), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_WEIGHTEDPREDICTION), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_NONREFERENCEPFRAMES), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_ACCESSUNITDELIMITER), false);
	obs_property_set_enabled(obs_properties_get(props, KEY_OTHER_DECODEDPICTUREBUFFERSIZE), false);
}

void nvmpi::update(obs_data_t* settings, const AVCodec* codec, AVCodecContext* context)
{   CHK(0);//PST
	{
		preset c_preset = static_cast<preset>(obs_data_get_int(settings, KEY_PRESET));
		auto   found    = preset_to_opt.find(c_preset);
		if (found != preset_to_opt.end()) {
			CHK(av_opt_set(context->priv_data, "preset", found->second.c_str(), 0));
		} else {
			CHK(av_opt_set(context->priv_data, "preset", nullptr, 0));
		}
	}

	{ // Rate Control
		bool have_bitrate       = false;
		bool have_bitrate_range = false;
		bool have_quality       = false;
		bool have_qp            = false;

		ratecontrolmode rc    = static_cast<ratecontrolmode>(obs_data_get_int(settings, KEY_RATECONTROL_MODE));
		auto            rcopt = ratecontrolmode_to_opt.find(rc);
		if (rcopt != ratecontrolmode_to_opt.end()) {
			CHK(av_opt_set(context->priv_data, "rc", rcopt->second.c_str(), AV_OPT_SEARCH_CHILDREN));
		} else {
			have_bitrate       = true;
			have_bitrate_range = true;
			have_quality       = true;
			have_qp            = true;
		}

		CHK(av_opt_set_int(context->priv_data, "cbr", 0, AV_OPT_SEARCH_CHILDREN));
		switch (rc) {
//		case ratecontrolmode::CQP: //PST
//			have_qp = true;
//			break;
		case ratecontrolmode::INVALID:
		case ratecontrolmode::CBR:
//		case ratecontrolmode::CBR_HQ: PST
//		case ratecontrolmode::CBR_LD_HQ: PST
			have_bitrate = true;
			CHK(av_opt_set_int(context->priv_data, "cbr", 1, AV_OPT_SEARCH_CHILDREN));
			break;
		case ratecontrolmode::VBR:
//		case ratecontrolmode::VBR_HQ: PST
			have_bitrate_range = true;
			have_bitrate       = true;
			have_quality       = true;
			have_qp            = true;
			break;
		}

		// Two Pass
		if (int tp = static_cast<int>(obs_data_get_int(settings, KEY_RATECONTROL_TWOPASS)); tp > -1) {
			CHK(av_opt_set_int(context->priv_data, "2pass", tp ? 1 : 0, AV_OPT_SEARCH_CHILDREN));
		}

		// Look Ahead # of Frames
		int la = static_cast<int>(obs_data_get_int(settings, KEY_RATECONTROL_LOOKAHEAD));
		if (!util::is_tristate_default(la)) {
			CHK(av_opt_set_int(context->priv_data, "rc-lookahead", la, AV_OPT_SEARCH_CHILDREN));
		}

		// Adaptive I-Frames
		if (int64_t adapt_i = obs_data_get_int(settings, KEY_RATECONTROL_ADAPTIVEI);
			!util::is_tristate_default(adapt_i) && (la != 0)) {
			// no-scenecut is inverted compared to our UI.
			CHK(av_opt_set_int(context->priv_data, "no-scenecut", 1 - adapt_i, AV_OPT_SEARCH_CHILDREN));
		}

		// Adaptive B-Frames
		constexpr std::string_view h264_encoder_name = "h264_nvmpi";
		if (h264_encoder_name == codec->name) {
			if (int64_t adapt_b = obs_data_get_int(settings, KEY_RATECONTROL_ADAPTIVEB);
				!util::is_tristate_default(adapt_b) && (la != 0)) {
				CHK(av_opt_set_int(context->priv_data, "b_adapt", adapt_b, AV_OPT_SEARCH_CHILDREN));
			}
		}

		if (have_bitrate) {
			int64_t v = obs_data_get_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_TARGET);
			if (v > -1)
				context->bit_rate = static_cast<int>(v * 1000);

			// Support for Replay Buffer
			obs_data_set_int(settings, "bitrate", v);
		} else {
			context->bit_rate = 0;
		}
		if (have_bitrate_range) {
			if (int64_t max = obs_data_get_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM); max > -1)
				context->rc_max_rate = static_cast<int>(max * 1000);
		} else {
			//context->rc_min_rate = 0;
			context->rc_max_rate = 0;
		}

		// Buffer Size
		if (have_bitrate || have_bitrate_range) {
			if (int64_t v = obs_data_get_int(settings, KEY_RATECONTROL_LIMITS_BUFFERSIZE); v > -1)
				context->rc_buffer_size = static_cast<int>(v * 1000);
		} else {
			context->rc_buffer_size = 0;
		}

		// Quality Limits
		if (have_quality) {
			if (int qmin = static_cast<int>(obs_data_get_int(settings, KEY_RATECONTROL_QP_MINIMUM)); qmin > -1)
				context->qmin = qmin;
			if (int qmax = static_cast<int>(obs_data_get_int(settings, KEY_RATECONTROL_QP_MAXIMUM)); qmax > -1)
				context->qmax = qmax;
		} else {
			context->qmin = -1;
			context->qmax = -1;
		}

		// Quality Target
		if (double_t v = obs_data_get_double(settings, KEY_RATECONTROL_LIMITS_QUALITY) / 100.0 * 51.0; v > 0) {
			CHK(av_opt_set_double(context->priv_data, "cq", v, AV_OPT_SEARCH_CHILDREN));
		}

		// QP Settings
		if (have_qp) {
			if (int64_t qp = obs_data_get_int(settings, KEY_RATECONTROL_QP_I); qp > -1)
				CHK(av_opt_set_int(context->priv_data, "init_qpI", static_cast<int>(qp), AV_OPT_SEARCH_CHILDREN));
			if (int64_t qp = obs_data_get_int(settings, KEY_RATECONTROL_QP_P); qp > -1)
				CHK(av_opt_set_int(context->priv_data, "init_qpP", static_cast<int>(qp), AV_OPT_SEARCH_CHILDREN));
			if (int64_t qp = obs_data_get_int(settings, KEY_RATECONTROL_QP_B); qp > -1)
				CHK(av_opt_set_int(context->priv_data, "init_qpB", static_cast<int>(qp), AV_OPT_SEARCH_CHILDREN));
		}
	}

	{ // AQ
		int64_t saq = obs_data_get_int(settings, KEY_AQ_SPATIAL);
		int64_t taq = obs_data_get_int(settings, KEY_AQ_TEMPORAL);

		if (strcmp(codec->name, "h264_nvmpi") == 0) {
			if (!util::is_tristate_default(saq))
				CHK(av_opt_set_int(context->priv_data, "spatial-aq", saq, AV_OPT_SEARCH_CHILDREN));
			if (!util::is_tristate_default(taq))
				CHK(av_opt_set_int(context->priv_data, "temporal-aq", taq, AV_OPT_SEARCH_CHILDREN));
		} else {
			if (!util::is_tristate_default(saq))
				CHK(av_opt_set_int(context->priv_data, "spatial_aq", saq, AV_OPT_SEARCH_CHILDREN));
			if (!util::is_tristate_default(taq))
				CHK(av_opt_set_int(context->priv_data, "temporal_aq", taq, AV_OPT_SEARCH_CHILDREN));
		}
		if (util::is_tristate_enabled(saq))
			if (int64_t aqs = obs_data_get_int(settings, KEY_AQ_STRENGTH); aqs > -1)
				CHK(av_opt_set_int(context->priv_data, "aq-strength", static_cast<int>(aqs), AV_OPT_SEARCH_CHILDREN));
	}

	{ // Other
		if (int64_t bf = obs_data_get_int(settings, KEY_OTHER_BFRAMES); bf > -1)
			context->max_b_frames = static_cast<int>(bf);

		if (int64_t zl = obs_data_get_int(settings, KEY_OTHER_ZEROLATENCY); !util::is_tristate_default(zl))
			CHK(av_opt_set_int(context->priv_data, "zerolatency", zl, AV_OPT_SEARCH_CHILDREN));
		if (int64_t nrp = obs_data_get_int(settings, KEY_OTHER_NONREFERENCEPFRAMES); !util::is_tristate_default(nrp))
			CHK(av_opt_set_int(context->priv_data, "nonref_p", nrp, AV_OPT_SEARCH_CHILDREN));
		if (int64_t v = obs_data_get_int(settings, KEY_OTHER_ACCESSUNITDELIMITER); !util::is_tristate_default(v))
			CHK(av_opt_set_int(context->priv_data, "aud", v, AV_OPT_SEARCH_CHILDREN));
		if (int64_t v = obs_data_get_int(settings, KEY_OTHER_DECODEDPICTUREBUFFERSIZE); v > -1)
			CHK(av_opt_set_int(context->priv_data, "dpb_size", v, AV_OPT_SEARCH_CHILDREN));

		int64_t wp = obs_data_get_int(settings, KEY_OTHER_WEIGHTEDPREDICTION);
		if ((context->max_b_frames > 0) && util::is_tristate_enabled(wp)) {
			DLOG_WARNING("[%s] Weighted Prediction disabled because of B-Frames being used.", codec->name);
			CHK(av_opt_set_int(context->priv_data, "weighted_pred", 0, AV_OPT_SEARCH_CHILDREN));
		} else if (!util::is_tristate_default(wp)) {
			CHK(av_opt_set_int(context->priv_data, "weighted_pred", wp, AV_OPT_SEARCH_CHILDREN));
		}

		{
			auto found = b_ref_mode_to_opt.find(
				static_cast<b_ref_mode>(obs_data_get_int(settings, KEY_OTHER_BFRAMEREFERENCEMODE)));
			if (found != b_ref_mode_to_opt.end()) {
				CHK(av_opt_set(context->priv_data, "b_ref_mode", found->second.c_str(), AV_OPT_SEARCH_CHILDREN));
			}
		}
	}
}

void nvmpi::log_options(obs_data_t*, const AVCodec* codec, AVCodecContext* context)
{
	using namespace ::streamfx::ffmpeg;

	DLOG_INFO("[%s]   Nvidia NVMPI:", codec->name);
	tools::print_av_option_string2(context, "preset", "    Preset",
								   [](int64_t v, std::string_view o) { return std::string(o); });
	tools::print_av_option_string2(context, "rc", "    Rate Control",
								   [](int64_t v, std::string_view o) { return std::string(o); });
	tools::print_av_option_bool(context, "2pass", "      Two Pass");
	tools::print_av_option_int(context, "rc-lookahead", "      Look-Ahead", "Frames");
	tools::print_av_option_bool(context, "no-scenecut", "      Adaptive I-Frames", true);
	if (strcmp(codec->name, "h264_nvmpi") == 0)
		tools::print_av_option_bool(context, "b_adapt", "      Adaptive B-Frames");

	DLOG_INFO("[%s]       Bitrate:", codec->name);
	tools::print_av_option_int(context, "b", "        Target", "bits/sec");
	tools::print_av_option_int(context, "minrate", "        Minimum", "bits/sec");
	tools::print_av_option_int(context, "maxrate", "        Maximum", "bits/sec");
	tools::print_av_option_int(context, "bufsize", "        Buffer", "bits");
	DLOG_INFO("[%s]       Quality:", codec->name);
	tools::print_av_option_int(context, "cq", "        Target", "");
	tools::print_av_option_int(context, "qmin", "        Minimum", "");
	tools::print_av_option_int(context, "qmax", "        Maximum", "");
	DLOG_INFO("[%s]       Quantization Parameters:", codec->name);
	tools::print_av_option_int(context, "init_qpI", "        I-Frame", "");
	tools::print_av_option_int(context, "init_qpP", "        P-Frame", "");
	tools::print_av_option_int(context, "init_qpB", "        B-Frame", "");

	tools::print_av_option_int(context, "bf", "    B-Frames", "Frames");
	tools::print_av_option_string2(context, "b_ref_mode", "      Reference Mode",
								   [](int64_t v, std::string_view o) { return std::string(o); });

	DLOG_INFO("[%s]     Adaptive Quantization:", codec->name);
	if (strcmp(codec->name, "h264_nvmpi") == 0) {
		tools::print_av_option_bool(context, "spatial-aq", "      Spatial AQ");
		tools::print_av_option_int(context, "aq-strength", "        Strength", "");
		tools::print_av_option_bool(context, "temporal-aq", "      Temporal AQ");
	} else {
		tools::print_av_option_bool(context, "spatial_aq", "      Spatial AQ");
		tools::print_av_option_int(context, "aq-strength", "        Strength", "");
		tools::print_av_option_bool(context, "temporal_aq", "      Temporal AQ");
	}

	DLOG_INFO("[%s]     Other:", codec->name);
	tools::print_av_option_bool(context, "zerolatency", "      Zero Latency");
	tools::print_av_option_bool(context, "weighted_pred", "      Weighted Prediction");
	tools::print_av_option_bool(context, "nonref_p", "      Non-reference P-Frames");
	tools::print_av_option_bool(context, "strict_gop", "      Strict GOP");
	tools::print_av_option_bool(context, "aud", "      Access Unit Delimiters");
	tools::print_av_option_bool(context, "bluray-compat", "      Bluray Compatibility");
	if (strcmp(codec->name, "h264_nvmpi") == 0)
		tools::print_av_option_bool(context, "a53cc", "      A53 Closed Captions");
	tools::print_av_option_int(context, "dpb_size", "      DPB Size", "Frames");
}

void streamfx::encoder::ffmpeg::handler::nvmpi::migrate(obs_data_t* settings, uint64_t version, const AVCodec* codec,
														AVCodecContext* context)
{   CHK(0);//PST
	switch (static_cast<uint64_t>(obs_data_get_int(settings, S_VERSION)) & STREAMFX_MASK_UPDATE) {
	default:
	case STREAMFX_MAKE_VERSION(0, 8, 0, 0):

		obs_data_set_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_TARGET,
						 obs_data_get_int(settings, "RateControl.Bitrate.Target"));
		obs_data_set_int(settings, KEY_RATECONTROL_LIMITS_BITRATE_MAXIMUM,
						 obs_data_get_int(settings, "RateControl.Bitrate.Maximum"));
		obs_data_set_int(settings, KEY_RATECONTROL_LIMITS_BUFFERSIZE,
						 obs_data_get_int(settings, "RateControl.BufferSize"));
		obs_data_set_double(settings, KEY_RATECONTROL_LIMITS_QUALITY,
							obs_data_get_double(settings, "RateControl.Quality.Target"));
		obs_data_set_int(settings, KEY_RATECONTROL_QP_MINIMUM,
						 obs_data_get_int(settings, "RateControl.Quality.Minimum"));
		obs_data_set_int(settings, KEY_RATECONTROL_QP_MAXIMUM,
						 obs_data_get_int(settings, "RateControl.Quality.Maximum"));

		break;
	}
}