/*############################################################################
  # Copyright (C) Intel Corporation
  #
  # SPDX-License-Identifier: MIT
  ############################################################################*/

#include <algorithm>

#include "src/mfx_dispatcher_vpl.h"

#if defined(_WIN32) || defined(_WIN64)
    #include "src/mfx_dispatcher_vpl_win.h"
#endif

// leave table formatting alone
// clang-format off

// new functions for API >= 2.0
static const VPLFunctionDesc FunctionDesc2[NumVPLFunctions] = {
    { "MFXQueryImplsDescription",               { {  0, 2 } } },
    { "MFXReleaseImplDescription",              { {  0, 2 } } },
    { "MFXMemory_GetSurfaceForVPP",             { {  0, 2 } } },
    { "MFXMemory_GetSurfaceForEncode",          { {  0, 2 } } },
    { "MFXMemory_GetSurfaceForDecode",          { {  0, 2 } } },
    { "MFXInitialize",                          { {  0, 2 } } },

    { "MFXMemory_GetSurfaceForVPPOut",          { {  1, 2 } } },
    { "MFXVideoDECODE_VPP_Init",                { {  1, 2 } } },
    { "MFXVideoDECODE_VPP_DecodeFrameAsync",    { {  1, 2 } } },
    { "MFXVideoDECODE_VPP_Reset",               { {  1, 2 } } },
    { "MFXVideoDECODE_VPP_GetChannelParam",     { {  1, 2 } } },
    { "MFXVideoDECODE_VPP_Close",               { {  1, 2 } } },
    { "MFXVideoVPP_ProcessFrameAsync",          { {  1, 2 } } },
};

static const VPLFunctionDesc FunctionDescOptional[NumVPLOptionalFunctions] = {
    { "MFXQueryImplsProperties",                { { 15, 2 } } },
};

static const VPLFunctionDesc MSDKCompatFunctions[NumMSDKFunctions] = {
    { "MFXInitEx",                              { { 14, 1 } } },
    { "MFXClose" ,                              { {  0, 1 } } },
};

// end table formatting
// clang-format on

// implementation of loader context (mfxLoader)
// each loader instance will build a list of valid runtimes and allow
// application to create sessions with them
LoaderCtxVPL::LoaderCtxVPL()
        : m_libInfoList(),
          m_implInfoList(),
          m_configCtxList(),
          m_gpuAdapterInfo(),
#ifdef ONEVPL_EXPERIMENTAL
          m_queryProps(),
#endif
          m_specialConfig(),
          m_implIdxNext(0),
          m_bKeepCapsUntilUnload(true),
          m_envVar(),
          m_dispLog() {
    // allow loader to distinguish between property value of 0
    //   and property not set
    m_specialConfig.bIsSet_deviceHandleType = false;
    m_specialConfig.bIsSet_deviceHandle     = false;
    m_specialConfig.bIsSet_accelerationMode = false;
    m_specialConfig.bIsSet_ApiVersion       = false;
    m_specialConfig.bIsSet_dxgiAdapterIdx   = false;
    m_specialConfig.bIsSet_NumThread        = false;
    m_specialConfig.bIsSet_DeviceCopy       = false;
    m_specialConfig.bIsSet_ExtBuffer        = false;

    // initial state
    m_bLowLatency           = false;
    m_bNeedUpdateValidImpls = true;
    m_bNeedFullQuery        = true;
    m_bNeedLowLatencyQuery  = true;
    m_bPriorityPathEnabled  = false;

#ifdef ONEVPL_EXPERIMENTAL
    m_bEnablePropsQuery = false;
#endif

    return;
}

LoaderCtxVPL::~LoaderCtxVPL() {
    return;
}

mfxStatus LoaderCtxVPL::FullLoadAndQuery() {
    // disable low latency mode
    m_bLowLatency = false;

    // search directories for candidate implementations based on search order in
    // spec
    mfxStatus sts = BuildListOfCandidateLibs();
    if (MFX_ERR_NONE != sts)
        return sts;

    // prune libraries which are not actually implementations, filling function
    // ptr table for each library which is
    mfxU32 numLibs = CheckValidLibraries();
    if (numLibs == 0)
        return MFX_ERR_UNSUPPORTED;

    // query capabilities of each implementation
    // may be more than one implementation per library
    sts = QueryLibraryCaps();
    if (MFX_ERR_NONE != sts)
        return MFX_ERR_NOT_FOUND;

    m_bNeedFullQuery        = false;
    m_bNeedUpdateValidImpls = true;

    return MFX_ERR_NONE;
}

// creates ordered list of user-specified directories to search
mfxU32 LoaderCtxVPL::ParseEnvSearchPaths(const CHAR_TYPE *envVarName,
                                         std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

#if defined(_WIN32) || defined(_WIN64)
    DWORD err;
    m_envVar[0] = 0;

    err = GetEnvironmentVariableW(envVarName, m_envVar, MAX_ENV_VAR_LEN);
    if (err == 0 || err >= MAX_ENV_VAR_LEN)
        return 0; // environment variable not defined or string too long

    // parse env variable into individual directories
    std::wstringstream envPath((CHAR_TYPE *)m_envVar);
    STRING_TYPE s;
    while (std::getline(envPath, s, L';')) {
        searchDirs.push_back(s);
    }
#else
    CHAR_TYPE *envVar = getenv(envVarName);
    if (!envVar)
        return 0; // environment variable not defined

    // parse env variable into individual directories
    std::stringstream envPath((CHAR_TYPE *)envVar);
    STRING_TYPE s;
    while (std::getline(envPath, s, ':')) {
        searchDirs.push_back(s);
    }
#endif

    return (mfxU32)searchDirs.size();
}

#define NUM_LIB_PREFIXES 3

mfxStatus LoaderCtxVPL::SearchDirForLibs(STRING_TYPE searchDir,
                                         std::list<LibInfo *> &libInfoList,
                                         mfxU32 priority,
                                         bool bLoadVPLOnly) {
    // okay to call with empty searchDir
    if (searchDir.empty())
        return MFX_ERR_NONE;

#if defined(_WIN32) || defined(_WIN64)
    HANDLE hTestFile = nullptr;
    WIN32_FIND_DATAW testFileData;
    DWORD ret;
    STRING_TYPE testFileName[NUM_LIB_PREFIXES] = {
        searchDir + MAKE_STRING("/libvpl*.dll"),
    #if defined _M_IX86
        // 32-bit GPU RT names
        searchDir + MAKE_STRING("/libmfx32-gen.dll"),
        searchDir + MAKE_STRING("/libmfxhw32.dll")
    #else
        // 64-bit GPU RT names
        searchDir + MAKE_STRING("/libmfx64-gen.dll"),
        searchDir + MAKE_STRING("/libmfxhw64.dll")
    #endif
    };

    // skip search for MSDK runtime (last entry) if bLoadVPLOnly is set
    mfxU32 numLibPrefixes = NUM_LIB_PREFIXES;
    if (bLoadVPLOnly)
        numLibPrefixes--;

    // iterate over all candidate files in directory
    for (mfxU32 i = 0; i < numLibPrefixes; i++) {
        hTestFile = FindFirstFileW(testFileName[i].c_str(), &testFileData);
        if (hTestFile != INVALID_HANDLE_VALUE) {
            do {
                wchar_t libNameFull[MAX_VPL_SEARCH_PATH];
                wchar_t *libNameBase;

                // special case: do not include dispatcher itself (libmfx.dll, libvpl.dll)
                if (wcsstr(testFileData.cFileName, L"libmfx.dll") ||
                    wcsstr(testFileData.cFileName, L"libvpl.dll") ||
                    wcsstr(testFileData.cFileName, L"libvpld.dll"))
                    continue;

                STRING_TYPE testFileFull = searchDir;
                testFileFull += MAKE_STRING("/");
                testFileFull += testFileData.cFileName;

                ret = GetFullPathNameW(testFileFull.c_str(),
                                       MAX_VPL_SEARCH_PATH,
                                       libNameFull,
                                       &libNameBase);
                // unknown error - skip it and move on to next file
                if (!ret || ret > MAX_VPL_SEARCH_PATH)
                    continue;

                // skip duplicates
                auto libFound =
                    std::find_if(libInfoList.begin(), libInfoList.end(), [&](LibInfo *li) {
                        return (li->libNameFull == libNameFull);
                    });
                if (libFound != libInfoList.end())
                    continue;

                LibInfo *libInfo = new (std::nothrow) LibInfo;
                if (!libInfo) {
                    FindClose(hTestFile);
                    return MFX_ERR_MEMORY_ALLOC;
                }

                libInfo->libNameFull = libNameFull;
                libInfo->libPriority = priority;

                // add to list
                libInfoList.push_back(libInfo);
            } while (FindNextFileW(hTestFile, &testFileData));

            FindClose(hTestFile);
        }
    }
#else
    DIR *pSearchDir;
    struct dirent *currFile;

    pSearchDir = opendir(searchDir.c_str());
    if (pSearchDir) {
        while (1) {
            currFile = readdir(pSearchDir);
            if (!currFile)
                break;

            // save files with ".so" (including .so.1, etc.)
            if (strstr(currFile->d_name, ".so")) {
                // library names must begin with "libvpl*" or "libmfx*"
                if ((strstr(currFile->d_name, "libvpl") != currFile->d_name) &&
                    (strcmp(currFile->d_name, "libmfx-gen.so.1.2") != 0) &&
                    (strcmp(currFile->d_name, "libmfxhw64.so.1") != 0))
                    continue;

                // special case: do not include dispatcher itself (libmfx.so*, libvpl.so*) or tracer library
                if (strstr(currFile->d_name, "libmfx.so") ||
                    strstr(currFile->d_name, "libvpl.so") ||
                    strstr(currFile->d_name, "libmfx-tracer"))
                    continue;

                char filePathC[MAX_VPL_SEARCH_PATH];

                // get full path to found library
                snprintf(filePathC,
                         MAX_VPL_SEARCH_PATH,
                         "%s/%s",
                         searchDir.c_str(),
                         currFile->d_name);
                char *fullPath = realpath(filePathC, NULL);

                // unknown error - skip it and move on to next file
                if (!fullPath)
                    continue;

                // skip duplicates
                auto libFound =
                    std::find_if(libInfoList.begin(), libInfoList.end(), [&](LibInfo *li) {
                        return (li->libNameFull == fullPath);
                    });
                if (libFound != libInfoList.end()) {
                    free(fullPath);
                    continue;
                }

                LibInfo *libInfo = new (std::nothrow) LibInfo;
                if (!libInfo) {
                    closedir(pSearchDir);
                    return MFX_ERR_MEMORY_ALLOC;
                }

                libInfo->libNameFull = fullPath;
                libInfo->libPriority = priority;
                free(fullPath);

                // add to list
                libInfoList.push_back(libInfo);
            }
        }
        closedir(pSearchDir);
    }
#endif

    return MFX_ERR_NONE;
}

// fill in m_gpuAdapterInfo before calling
mfxU32 LoaderCtxVPL::GetSearchPathsDriverStore(std::list<STRING_TYPE> &searchDirs,
                                               LibType libType) {
    searchDirs.clear();

#if defined(_WIN32) || defined(_WIN64)
    mfxStatus sts = MFX_ERR_UNSUPPORTED;
    STRING_TYPE vplPath;

    int storageID = MFX::MFX_DRIVER_STORE_ONEVPL;
    if (libType == LibTypeMSDK)
        storageID = MFX::MFX_DRIVER_STORE;

    // get path to Windows driver store (if any) for each adapter
    for (mfxU32 adapterID = 0; adapterID < (mfxU32)m_gpuAdapterInfo.size(); adapterID++) {
        vplPath.clear();
        sts = MFX::MFXLibraryIterator::GetDriverStoreDir(vplPath,
                                                         MAX_VPL_SEARCH_PATH,
                                                         m_gpuAdapterInfo[adapterID].deviceID,
                                                         storageID);
        if (sts == MFX_ERR_NONE)
            searchDirs.push_back(vplPath);
    }
#endif

    return (mfxU32)searchDirs.size();
}

mfxU32 LoaderCtxVPL::GetSearchPathsCurrentExe(std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

#if defined(_WIN32) || defined(_WIN64)
    // get path to location of current executable
    wchar_t implPath[MFX::msdk_disp_path_len];
    bool ret            = MFX::GetImplPath(MFX::MFX_APP_FOLDER, implPath);
    STRING_TYPE exePath = implPath;

    // failed to get executable path
    if (!ret)
        return 0;

    // strip trailing backslash
    size_t exePathLen = exePath.find_last_of(L"\\");

    if (exePathLen == std::wstring::npos)
        return 0;

    if (exePathLen > 0)
        exePath.erase(exePathLen);

    if (!exePath.empty())
        searchDirs.push_back(exePath);

#endif

    return (mfxU32)searchDirs.size();
}

mfxU32 LoaderCtxVPL::GetSearchPathsCurrentDir(std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

#if defined(_WIN32) || defined(_WIN64)
    CHAR_TYPE currDir[MAX_VPL_SEARCH_PATH] = L"";
    if (GetCurrentDirectoryW(MAX_VPL_SEARCH_PATH, currDir)) {
        searchDirs.push_back(currDir);
    }
#else
    CHAR_TYPE currDir[MAX_VPL_SEARCH_PATH] = "";
    if (getcwd(currDir, MAX_VPL_SEARCH_PATH)) {
        searchDirs.push_back(currDir);
    }
#endif

    return (mfxU32)searchDirs.size();
}

// get legacy MSDK dispatcher search paths
// documentation found in Intel® Video Processing Library (Intel® VPL) spec
// in the "Intel® VPL Session" section
mfxU32 LoaderCtxVPL::GetSearchPathsLegacy(std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

#if defined(_WIN32) || defined(_WIN64)
    mfxStatus sts = MFX_ERR_UNSUPPORTED;
    STRING_TYPE msdkPath;

    // get path via dispatcher regkey - HKCU
    msdkPath.clear();
    sts = MFX::MFXLibraryIterator::GetRegkeyDir(msdkPath,
                                                MAX_VPL_SEARCH_PATH,
                                                MFX::MFX_CURRENT_USER_KEY);
    if (sts == MFX_ERR_NONE)
        searchDirs.push_back(msdkPath);

    // get path via dispatcher regkey - HKLM
    msdkPath.clear();
    sts = MFX::MFXLibraryIterator::GetRegkeyDir(msdkPath,
                                                MAX_VPL_SEARCH_PATH,
                                                MFX::MFX_LOCAL_MACHINE_KEY);
    if (sts == MFX_ERR_NONE)
        searchDirs.push_back(msdkPath);

    // get path to %windir%\system32 and %windir%\syswow64
    std::list<STRING_TYPE> winSysDir;
    ParseEnvSearchPaths(L"windir", winSysDir);

    // should resolve to a single directory, otherwise something went wrong
    if (winSysDir.size() == 1) {
        msdkPath = winSysDir.front() + L"\\system32";
        searchDirs.push_back(msdkPath);

        msdkPath = winSysDir.front() + L"\\syswow64";
        searchDirs.push_back(msdkPath);
    }

#else
    // MSDK open-source installation directories
    searchDirs.push_back("/opt/intel/mediasdk/lib");
    searchDirs.push_back("/opt/intel/mediasdk/lib64");
#endif

    return (mfxU32)searchDirs.size();
}

mfxU32 LoaderCtxVPL::GetSearchPathsSystemDefault(std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

#ifdef __linux__
    // Add the standard path for libmfx1 install in Ubuntu
    searchDirs.push_back("/usr/lib/x86_64-linux-gnu");

    // Add other default paths
    searchDirs.push_back("/lib");
    searchDirs.push_back("/usr/lib");
    searchDirs.push_back("/lib64");
    searchDirs.push_back("/usr/lib64");
#endif

    return (mfxU32)searchDirs.size();
}

#if defined INSTALL_LIBDIR_SEARCH
mfxU32 LoaderCtxVPL::GetSearchPathsInstallDir(std::list<STRING_TYPE> &searchDirs) {
    searchDirs.clear();

    #ifdef __linux__
    STRING_TYPE install_dir = INSTALL_LIBDIR_SEARCH;
    searchDirs.push_back(install_dir);
    #endif

    return (mfxU32)searchDirs.size();
}
#endif

// search for implementations of Intel® Video Processing Library (Intel® VPL)
//   according to the rules in the spec
mfxStatus LoaderCtxVPL::BuildListOfCandidateLibs() {
    DISP_LOG_FUNCTION(&m_dispLog);

    mfxStatus sts = MFX_ERR_NONE;

    STRING_TYPE emptyPath; // default construction = empty
    std::list<STRING_TYPE> searchDirList;
    std::list<STRING_TYPE>::iterator it;

    // special case: ONEVPL_PRIORITY_PATH may be used to specify user-defined path
    //   and bypass priority sorting (API >= 2.6)
    searchDirList.clear();
    ParseEnvSearchPaths(ONEVPL_PRIORITY_PATH_VAR, searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_SPECIAL);
        it++;
    }

    if (searchDirList.size() > 0)
        m_bPriorityPathEnabled = true;

#if defined(_WIN32) || defined(_WIN64)
    // retrieve list of DX11 graphics adapters (lightweight)
    // used for both Intel® VPL and legacy driver store search
    m_gpuAdapterInfo.clear();
    bool bEnumSuccess = MFX::DXGI1Device::GetAdapterList(m_gpuAdapterInfo);

    // unknown error or no adapters found - clear list
    if (!bEnumSuccess)
        m_gpuAdapterInfo.clear();

    // first priority: Windows driver store
    searchDirList.clear();
    GetSearchPathsDriverStore(searchDirList, LibTypeVPL);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_01, true);
        it++;
    }

    // second priority: path to current executable
    searchDirList.clear();
    GetSearchPathsCurrentExe(searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_02);
        it++;
    }

    // third priority: PATH environment variable
    searchDirList.clear();
    ParseEnvSearchPaths(L"PATH", searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_04);
        it++;
    }

    // fourth priority: ONEVPL_SEARCH_PATH environment variable
    searchDirList.clear();
    ParseEnvSearchPaths(L"ONEVPL_SEARCH_PATH", searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_05);
        it++;
    }

    // legacy MSDK installation: DriverStore has priority
    searchDirList.clear();
    GetSearchPathsDriverStore(searchDirList, LibTypeMSDK);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_LEGACY_DRIVERSTORE);
        it++;
    }

    // lowest priority: other legacy search paths
    searchDirList.clear();
    GetSearchPathsLegacy(searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_LEGACY);
        it++;
    }
#else
    // first priority: LD_LIBRARY_PATH environment variable
    searchDirList.clear();
    ParseEnvSearchPaths("LD_LIBRARY_PATH", searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_01);
        it++;
    }

    // second priority: Linux default paths
    searchDirList.clear();
    GetSearchPathsSystemDefault(searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_03);
        it++;
    }

    // third priority: ONEVPL_SEARCH_PATH environment variable
    searchDirList.clear();
    ParseEnvSearchPaths("ONEVPL_SEARCH_PATH", searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_05);
        it++;
    }

    // lowest priority: legacy MSDK installation
    searchDirList.clear();
    GetSearchPathsLegacy(searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_LEGACY);
        it++;
    }

    #if defined INSTALL_LIBDIR_SEARCH
    // optional: add installation lib directory to runtime search path
    // only enabled if ENABLE_LIBDIR_IN_RUNTIME_SEARCH=ON during cmake config
    searchDirList.clear();
    GetSearchPathsInstallDir(searchDirList);
    it = searchDirList.begin();
    while (it != searchDirList.end()) {
        STRING_TYPE nextDir = (*it);
        sts                 = SearchDirForLibs(nextDir, m_libInfoList, LIB_PRIORITY_9999);
        it++;
    }
    #endif

#endif

    return sts;
}

// return number of valid libraries found
mfxU32 LoaderCtxVPL::CheckValidLibraries() {
    DISP_LOG_FUNCTION(&m_dispLog);

    LibInfo *msdkLibBest   = nullptr;
    LibInfo *msdkLibBestDS = nullptr;

    // load all libraries
    std::list<LibInfo *>::iterator it = m_libInfoList.begin();
    while (it != m_libInfoList.end()) {
        LibInfo *libInfo = (*it);
        mfxStatus sts    = MFX_ERR_NONE;

        // load DLL
        sts = LoadSingleLibrary(libInfo);

        // load video functions: pointers to exposed functions
        // not all function pointers may be filled in (depends on API version)
        if (sts == MFX_ERR_NONE && libInfo->hModuleVPL)
            LoadAPIExports(libInfo, LibTypeVPL);

        // all runtime libraries with API >= 2.0 must export MFXInitialize()
        // validation of additional functions vs. API version takes place
        //   during UpdateValidImplList() since the minimum API version requested
        //   by application is not known yet (use SetConfigFilterProperty)
        if (libInfo->vplFuncTable[IdxMFXInitialize] &&
            libInfo->libPriority < LIB_PRIORITY_LEGACY_DRIVERSTORE) {
            libInfo->libType = LibTypeVPL;
            it++;
            continue;
        }

        // not a valid 2.x runtime - check for 1.x API (legacy caps query)
        mfxU32 numFunctions = 0;
        if (sts == MFX_ERR_NONE && libInfo->hModuleVPL) {
            if (libInfo->libNameFull.find(MSDK_LIB_NAME) != std::string::npos) {
                // legacy runtime must be named libmfxhw64 (or 32)
                // MSDK must export all of the required functions
                numFunctions = LoadAPIExports(libInfo, LibTypeMSDK);
            }
        }

        // check if all of the required MSDK functions were found
        //   and this is valid library (can create session, query version)
        if (numFunctions == NumMSDKFunctions) {
            sts = LoaderCtxMSDK::QueryAPIVersion(libInfo->libNameFull, &(libInfo->msdkVersion));

            if (sts == MFX_ERR_NONE) {
                libInfo->libType = LibTypeMSDK;
                if (msdkLibBest == nullptr ||
                    (libInfo->msdkVersion.Version > msdkLibBest->msdkVersion.Version)) {
                    msdkLibBest = libInfo;
                }

                if (libInfo->libPriority == LIB_PRIORITY_LEGACY_DRIVERSTORE) {
                    if (msdkLibBestDS == nullptr ||
                        (libInfo->msdkVersion.Version > msdkLibBestDS->msdkVersion.Version)) {
                        msdkLibBestDS = libInfo;
                    }
                }

#if defined(_WIN32) || defined(_WIN64)
                // workaround for double-init issue in old versions of MSDK runtime
                //   (allow DLL to be fully unloaded after each call to MFXClose)
                // apply to MSDK with API version <= 1.27
                if (libInfo->hModuleVPL && (libInfo->msdkVersion.Major == 1) &&
                    (libInfo->msdkVersion.Minor <= 27)) {
                    MFX::mfx_dll_free(libInfo->hModuleVPL);
                    libInfo->hModuleVPL = nullptr;
                }
#endif

                it++;
                continue;
            }
        }

        // required functions missing from DLL, or DLL failed to load
        // remove this library from the list of options
        UnloadSingleLibrary(libInfo);
        it = m_libInfoList.erase(it);
    }

    if (msdkLibBestDS)
        msdkLibBest = msdkLibBestDS;

    // prune duplicate MSDK libraries (only keep one with highest API version)
    it = m_libInfoList.begin();
    while (it != m_libInfoList.end()) {
        LibInfo *libInfo = (*it);

        if (libInfo->libType == LibTypeMSDK && libInfo != msdkLibBest) {
            UnloadSingleLibrary(libInfo);
            it = m_libInfoList.erase(it);
        }
        else {
            it++;
        }
    }

    // number of valid Intel® VPL libs
    return (mfxU32)m_libInfoList.size();
}

VPLFunctionPtr LoaderCtxVPL::GetFunctionAddr(void *hModuleVPL, const char *pName) {
    VPLFunctionPtr pProc = nullptr;

    if (hModuleVPL) {
#if defined(_WIN32) || defined(_WIN64)
        pProc = (VPLFunctionPtr)MFX::mfx_dll_get_addr(hModuleVPL, pName);
#else
        pProc = (VPLFunctionPtr)dlsym(hModuleVPL, pName);
#endif
    }

    return pProc;
}

// load single runtime
mfxStatus LoaderCtxVPL::LoadSingleLibrary(LibInfo *libInfo) {
    if (!libInfo)
        return MFX_ERR_NULL_PTR;

#if defined(_WIN32) || defined(_WIN64)
    libInfo->hModuleVPL = MFX::mfx_dll_load(libInfo->libNameFull.c_str());
#else
    libInfo->hModuleVPL = dlopen(libInfo->libNameFull.c_str(), RTLD_LOCAL | RTLD_NOW);
#endif

    if (!libInfo->hModuleVPL)
        return MFX_ERR_NOT_FOUND;

    return MFX_ERR_NONE;
}

// unload single runtime
mfxStatus LoaderCtxVPL::UnloadSingleLibrary(LibInfo *libInfo) {
    if (libInfo) {
        if (libInfo->hModuleVPL) {
#if defined(_WIN32) || defined(_WIN64)
            MFX::mfx_dll_free(libInfo->hModuleVPL);
#else
            dlclose(libInfo->hModuleVPL);
#endif
        }
        delete libInfo;
        return MFX_ERR_NONE;
    }
    else {
        return MFX_ERR_INVALID_HANDLE;
    }
}

// iterate over all implementation runtimes
// unload DLL's and free memory
mfxStatus LoaderCtxVPL::UnloadAllLibraries() {
    DISP_LOG_FUNCTION(&m_dispLog);

    std::list<ImplInfo *>::iterator it2 = m_implInfoList.begin();
    while (it2 != m_implInfoList.end()) {
        ImplInfo *implInfo = (*it2);

        if (implInfo) {
            UnloadSingleImplementation(implInfo);
        }
        it2++;
    }

    // lastly, unload and destroy LibInfo for each library
    std::list<LibInfo *>::iterator it = m_libInfoList.begin();
    while (it != m_libInfoList.end()) {
        LibInfo *libInfo = (*it);

        if (libInfo) {
            UnloadSingleLibrary(libInfo);
        }
        it++;
    }

    m_implInfoList.clear();
    m_libInfoList.clear();
    m_implIdxNext = 0;

    return MFX_ERR_NONE;
}

// unload single implementation
// each runtime library may contain 1 or more implementations
mfxStatus LoaderCtxVPL::UnloadSingleImplementation(ImplInfo *implInfo) {
    if (implInfo && implInfo->libInfo) {
        LibInfo *libInfo     = implInfo->libInfo;
        VPLFunctionPtr pFunc = libInfo->vplFuncTable[IdxMFXReleaseImplDescription];

        // call MFXReleaseImplDescription() for this implementation if it
        //   was never called by the application
        // this is a valid scenario, e.g. app did not call MFXEnumImplementations()
        //   and just used the first available implementation provided by dispatcher
        if (libInfo->libType == LibTypeVPL) {
            if (implInfo->implDesc) {
                // MFX_IMPLCAPS_IMPLDESCSTRUCTURE;
                (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implDesc);
                implInfo->implDesc = nullptr;
            }

            if (implInfo->implFuncs) {
                // MFX_IMPLCAPS_IMPLEMENTEDFUNCTIONS;
                (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implFuncs);
                implInfo->implFuncs = nullptr;
            }

            if (implInfo->implExtDeviceID) {
                // MFX_IMPLCAPS_DEVICE_ID_EXTENDED;
                (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implExtDeviceID);
                implInfo->implExtDeviceID = nullptr;
            }

#ifdef ONEVPL_EXPERIMENTAL
            if (implInfo->implSurfTypes) {
                // MFX_IMPLCAPS_SURFACE_TYPES;
                (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implSurfTypes);
                implInfo->implSurfTypes = nullptr;
            }
#endif

            // nothing to do if (capsFormat == MFX_IMPLCAPS_IMPLPATH) since no new memory was allocated
        }
        delete implInfo;
        return MFX_ERR_NONE;
    }
    else {
        return MFX_ERR_INVALID_HANDLE;
    }
}

// return number of functions loaded
mfxU32 LoaderCtxVPL::LoadAPIExports(LibInfo *libInfo, LibType libType) {
    mfxU32 i, numFunctions = 0;

    if (libType == LibTypeVPL) {
        for (i = 0; i < NumVPLFunctions; i += 1) {
            VPLFunctionPtr pProc =
                (VPLFunctionPtr)GetFunctionAddr(libInfo->hModuleVPL, FunctionDesc2[i].pName);
            if (pProc) {
                libInfo->vplFuncTable[i] = pProc;
                numFunctions++;
            }
        }

#ifdef ONEVPL_EXPERIMENTAL
        // load optional functions - if RT does not export these, dispatcher must not attempt to call them
        for (i = 0; i < NumVPLOptionalFunctions; i += 1) {
            VPLFunctionPtr pProc =
                (VPLFunctionPtr)GetFunctionAddr(libInfo->hModuleVPL, FunctionDescOptional[i].pName);
            // pProc might be null - that's okay
            libInfo->vplOptionalFuncTable[i] = pProc;
        }
#endif
    }
    else if (libType == LibTypeMSDK) {
        // don't actually need to save the function pointers for MSDK, just check if they are defined
        for (i = 0; i < NumMSDKFunctions; i += 1) {
            VPLFunctionPtr pProc =
                (VPLFunctionPtr)GetFunctionAddr(libInfo->hModuleVPL, MSDKCompatFunctions[i].pName);
            if (pProc) {
                numFunctions++;
            }
        }
    }

    return numFunctions;
}

// check that all functions for this API version are available in library
mfxStatus LoaderCtxVPL::ValidateAPIExports(VPLFunctionPtr *vplFuncTable,
                                           mfxVersion reportedVersion) {
    for (mfxU32 i = 0; i < NumVPLFunctions; i += 1) {
        if (!vplFuncTable[i] && (FunctionDesc2[i].apiVersion.Version <= reportedVersion.Version))
            return MFX_ERR_UNSUPPORTED;
    }

    return MFX_ERR_NONE;
}

// convert full path into char* for MFX_IMPLCAPS_IMPLPATH query
mfxStatus LoaderCtxVPL::UpdateImplPath(LibInfo *libInfo) {
#if defined(_WIN32) || defined(_WIN64)
    // Windows - strings are 16-bit
    size_t nCvt = 0;
    if (wcstombs_s(&nCvt,
                   libInfo->implCapsPath,
                   sizeof(libInfo->implCapsPath),
                   libInfo->libNameFull.c_str(),
                   _TRUNCATE)) {
        // unknown error - set to empty string
        libInfo->implCapsPath[0] = 0;
        return MFX_ERR_UNSUPPORTED;
    }
#else
    // Linux - strings are 8-bit
    strncpy(libInfo->implCapsPath, libInfo->libNameFull.c_str(), sizeof(libInfo->implCapsPath) - 1);
#endif

    return MFX_ERR_NONE;
}

bool LoaderCtxVPL::IsValidX86GPU(ImplInfo *implInfo, mfxU32 &deviceID, mfxU32 &adapterIdx) {
    mfxImplDescription *implDesc = (mfxImplDescription *)(implInfo->implDesc);

    // may be null in low-latency mode, ID unknown
    if (!implDesc)
        return false;

    if (implInfo->validImplIdx >= 0 && implDesc->VendorID == 0x8086 &&
        implDesc->Impl == MFX_IMPL_TYPE_HARDWARE) {
        // verify that DeviceID is a valid format for x86 GPU
        // either "DeviceID" (hex) or "DeviceID/AdapterIdx" (hex/dec)
        bool is_valid = false;
        try {
            is_valid = ConfigCtxVPL::ParseDeviceIDx86(implDesc->Dev.DeviceID, deviceID, adapterIdx);
        }
        catch (...) {
            return false;
        }

        return is_valid;
    }

    return false;
}

// query capabilities of all valid libraries
//   and add to list for future calls to EnumImplementations()
//   as well as filtering by functionality
// assume MFX_IMPLCAPS_IMPLDESCSTRUCTURE is the only format supported
mfxStatus LoaderCtxVPL::QueryLibraryCaps() {
    DISP_LOG_FUNCTION(&m_dispLog);

    mfxStatus sts = MFX_ERR_NONE;

    std::list<LibInfo *>::iterator it = m_libInfoList.begin();
    while (it != m_libInfoList.end()) {
        LibInfo *libInfo = (*it);

        if (libInfo->libType == LibTypeVPL) {
            VPLFunctionPtr pFunc = libInfo->vplFuncTable[IdxMFXQueryImplsDescription];

#ifdef ONEVPL_EXPERIMENTAL
            VPLFunctionPtr pFuncProps = libInfo->vplOptionalFuncTable[IdxMFXQueryImplsProperties];
#endif

            // handle to implDesc structure, null in low-latency mode (no query)
            mfxHDL *hImpl   = nullptr;
            mfxU32 numImpls = 0;

            mfxHDL *hImplExtDeviceID   = nullptr;
            mfxU32 numImplsExtDeviceID = 0;

#ifdef ONEVPL_EXPERIMENTAL
            mfxHDL *hImplSurfTypes   = nullptr;
            mfxU32 numImplsSurfTypes = 0;
#endif

            if (m_bLowLatency == false) {
#ifdef ONEVPL_EXPERIMENTAL
                // attempt property-based query if requested by application and RT supports the function
                // otherwise just do full query
                if (m_bEnablePropsQuery == true && pFuncProps != nullptr) {
                    // create temporary array of pointers to each mfxQueryProperty for C RT API
                    std::vector<mfxQueryProperty *> queryProps;
                    for (mfxU32 i = 0; i < m_queryProps.size(); i++)
                        queryProps.push_back(&m_queryProps[i]);

                    hImpl =
                        (*(mfxHDL * (MFX_CDECL *)(mfxQueryProperty **, mfxU32, mfxU32 *))
                             pFuncProps)(queryProps.data(), (mfxU32)queryProps.size(), &numImpls);
                }
                else {
#endif
                    // call MFXQueryImplsDescription() for this implementation
                    // return handle to description in requested format
                    hImpl = (*(mfxHDL * (MFX_CDECL *)(mfxImplCapsDeliveryFormat, mfxU32 *))
                                 pFunc)(MFX_IMPLCAPS_IMPLDESCSTRUCTURE, &numImpls);
#ifdef ONEVPL_EXPERIMENTAL
                }
#endif
                // validate description pointer for each implementation
                bool b_isValidDesc = true;
                if (!hImpl) {
                    b_isValidDesc = false;
                }
                else {
                    for (mfxU32 i = 0; i < numImpls; i++) {
                        if (!hImpl[i]) {
                            b_isValidDesc = false;
                            break;
                        }
                    }
                }

                if (!b_isValidDesc) {
                    // the required function is implemented incorrectly
                    // remove this library from the list of valid libraries
                    UnloadSingleLibrary(libInfo);
                    it = m_libInfoList.erase(it);
                    continue;
                }

                hImplExtDeviceID =
                    (*(mfxHDL * (MFX_CDECL *)(mfxImplCapsDeliveryFormat, mfxU32 *))
                         pFunc)(MFX_IMPLCAPS_DEVICE_ID_EXTENDED, &numImplsExtDeviceID);

#ifdef ONEVPL_EXPERIMENTAL
                hImplSurfTypes = (*(mfxHDL * (MFX_CDECL *)(mfxImplCapsDeliveryFormat, mfxU32 *))
                                      pFunc)(MFX_IMPLCAPS_SURFACE_TYPES, &numImplsSurfTypes);
#endif
            }

            // query for list of implemented functions
            // prior to API 2.2, this will return null since the format was not defined yet
            //   so we need to check whether the returned handle is valid before attempting to use it
            mfxHDL *hImplFuncs   = nullptr;
            mfxU32 numImplsFuncs = 0;
            hImplFuncs           = (*(mfxHDL * (MFX_CDECL *)(mfxImplCapsDeliveryFormat, mfxU32 *))
                              pFunc)(MFX_IMPLCAPS_IMPLEMENTEDFUNCTIONS, &numImplsFuncs);

            // only report single impl, but application may still attempt to create session using
            //    any of VendorImplID via the DXGIAdapterIndex filter property
            if (m_bLowLatency == true)
                numImpls = 1;

            // save user-friendly path for MFX_IMPLCAPS_IMPLPATH query (API >= 2.4)
            UpdateImplPath(libInfo);

            for (mfxU32 i = 0; i < numImpls; i++) {
                ImplInfo *implInfo = new (std::nothrow) ImplInfo;
                if (!implInfo)
                    return MFX_ERR_MEMORY_ALLOC;

                // library which contains this implementation
                implInfo->libInfo = libInfo;

                if (hImplExtDeviceID && i < numImplsExtDeviceID)
                    implInfo->implExtDeviceID = hImplExtDeviceID[i];

#ifdef ONEVPL_EXPERIMENTAL
                if (hImplSurfTypes && i < numImplsSurfTypes)
                    implInfo->implSurfTypes = hImplSurfTypes[i];
#endif

                // implemented function description, if available
                if (hImplFuncs && i < numImplsFuncs)
                    implInfo->implFuncs = hImplFuncs[i];

                // fill out mfxInitializationParam for use in CreateSession (MFXInitialize path)
                memset(&(implInfo->vplParam), 0, sizeof(mfxInitializationParam));

                if (m_bLowLatency == false) {
                    // implementation descriptor returned from runtime
                    implInfo->implDesc = hImpl[i];

                    // fill out mfxInitParam struct for when we call MFXInitEx
                    //   in CreateSession()
                    mfxImplDescription *implDesc = reinterpret_cast<mfxImplDescription *>(hImpl[i]);

                    // default mode for this impl
                    // this may be changed later by MFXSetConfigFilterProperty(AccelerationMode)
                    implInfo->vplParam.AccelerationMode = implDesc->AccelerationMode;

                    implInfo->version = implDesc->ApiVersion;
                }
                else {
                    implInfo->implDesc = nullptr;

                    // application must set requested mode using MFXSetConfigFilterProperty()
                    // will be updated during CreateSession
                    implInfo->vplParam.AccelerationMode = MFX_ACCEL_MODE_NA;

                    mfxVersion queryVersion = {};

                    // create test session to get API version
                    sts = QuerySessionLowLatency(libInfo, i, &queryVersion);
                    if (sts != MFX_ERR_NONE) {
                        UnloadSingleImplementation(implInfo);
                        continue;
                    }
                    implInfo->version.Version = queryVersion.Version;
                }

                // save local index for this library
                implInfo->libImplIdx = i;

                // validate that library exports all required functions for the reported API version
                if (ValidateAPIExports(libInfo->vplFuncTable, implInfo->version)) {
                    UnloadSingleImplementation(implInfo);
                    continue;
                }

                // initially all libraries have a valid, sequential value (>= 0)
                // list of valid libraries is updated with every call to MFXSetConfigFilterProperty()
                //   (see UpdateValidImplList)
                // libraries that do not support all the required props get a value of -1, and
                //   indexing of the valid libs is recalculated from 0,1,...
                implInfo->validImplIdx = m_implIdxNext++;

                // add implementation to overall list
                m_implInfoList.push_back(implInfo);
            }
        }
        else if (libInfo->libType == LibTypeMSDK) {
            // save user-friendly path for MFX_IMPLCAPS_IMPLPATH query (API >= 2.4)
            UpdateImplPath(libInfo);

            mfxU32 maxImplMSDK = MAX_NUM_IMPL_MSDK;

            // call once on adapter 0 to get MSDK API version (same for any adapter)
            mfxVersion queryVersion = {};
            if (m_bLowLatency) {
                sts = LoaderCtxMSDK::QueryAPIVersion(libInfo->libNameFull, &queryVersion);
                if (sts != MFX_ERR_NONE)
                    queryVersion.Version = 0;

                // only report single impl, but application may still attempt to create session using
                //    any of MFX_IMPL_HARDWAREx via the DXGIAdapterIndex filter property
                maxImplMSDK = 1;
            }

            mfxU32 numImplMSDK = 0;
            for (mfxU32 i = 0; i < maxImplMSDK; i++) {
                mfxImplDescription *implDesc         = nullptr;
                mfxImplementedFunctions *implFuncs   = nullptr;
                mfxExtendedDeviceId *implExtDeviceID = nullptr;

                LoaderCtxMSDK *msdkCtx = &(libInfo->msdkCtx[i]);
                if (m_bLowLatency == false) {
                    // perf. optimization: if app requested bIsSet_accelerationMode other than D3D9, don't test whether MSDK supports D3D9
                    bool bSkipD3D9Check = false;
                    if (m_specialConfig.bIsSet_accelerationMode &&
                        m_specialConfig.accelerationMode != MFX_ACCEL_MODE_VIA_D3D9) {
                        bSkipD3D9Check = true;
                    }

                    sts = msdkCtx->QueryMSDKCaps(libInfo->libNameFull,
                                                 &implDesc,
                                                 &implFuncs,
                                                 i,
                                                 bSkipD3D9Check);

                    if (sts || !implDesc || !implFuncs) {
                        // this adapter (i) is not supported
                        continue;
                    }

                    sts = LoaderCtxMSDK::QueryExtDeviceID(&(msdkCtx->m_extDeviceID),
                                                          i,
                                                          msdkCtx->m_deviceID,
                                                          msdkCtx->m_luid);
                    if (sts == MFX_ERR_NONE)
                        implExtDeviceID = &(msdkCtx->m_extDeviceID);
                }
                else {
                    // unknown API - unable to create session on any adapter
                    if (queryVersion.Version == 0)
                        continue;

                    // these are the only values filled in for msdkCtx in low latency mode
                    // used during CreateSession
                    msdkCtx->m_msdkAdapter     = msdkImplTab[i];
                    msdkCtx->m_msdkAdapterD3D9 = msdkImplTab[i];
                }

                ImplInfo *implInfo = new (std::nothrow) ImplInfo;
                if (!implInfo)
                    return MFX_ERR_MEMORY_ALLOC;

                // library which contains this implementation
                implInfo->libInfo = libInfo;

                // implemented function description, if available
                implInfo->implFuncs = implFuncs;

                // extended device ID description, if available
                implInfo->implExtDeviceID = implExtDeviceID;

#ifdef ONEVPL_EXPERIMENTAL
                // not supported
                implInfo->implSurfTypes = nullptr;
#endif

                // fill out mfxInitializationParam for use in CreateSession (MFXInitialize path)
                memset(&(implInfo->vplParam), 0, sizeof(mfxInitializationParam));

                if (m_bLowLatency == false) {
                    // implementation descriptor returned from runtime
                    implInfo->implDesc = implDesc;

                    // default mode for this impl
                    // this may be changed later by MFXSetConfigFilterProperty(AccelerationMode)
                    implInfo->vplParam.AccelerationMode = implDesc->AccelerationMode;

                    implInfo->version = implDesc->ApiVersion;
                }
                else {
                    implInfo->implDesc = nullptr;

                    // application must set requested mode using MFXSetConfigFilterProperty()
                    // will be updated during CreateSession
                    implInfo->vplParam.AccelerationMode = MFX_ACCEL_MODE_NA;

                    // save API version from creating test MSDK session above
                    implInfo->version.Version = queryVersion.Version;
                }

                // adapter number
                implInfo->msdkImplIdx = i;

                // save local index for this library
                implInfo->libImplIdx = 0;

                // initially all libraries have a valid, sequential value (>= 0)
                // list of valid libraries is updated with every call to MFXSetConfigFilterProperty()
                //   (see UpdateValidImplList)
                // libraries that do not support all the required props get a value of -1, and
                //   indexing of the valid libs is recalculated from 0,1,...
                implInfo->validImplIdx = m_implIdxNext++;

                // add implementation to overall list
                m_implInfoList.push_back(implInfo);

                // update number of valid MSDK adapters
                numImplMSDK++;
            }

            if (numImplMSDK == 0) {
                // error loading MSDK library in compatibility mode - remove from list
                UnloadSingleLibrary(libInfo);
                it = m_libInfoList.erase(it);
                continue;
            }
        }
        it++;
    }

    if (m_bLowLatency == false && !m_implInfoList.empty()) {
        bool bD3D9Requested = (m_specialConfig.bIsSet_accelerationMode &&
                               m_specialConfig.accelerationMode == MFX_ACCEL_MODE_VIA_D3D9);

        std::list<ImplInfo *>::iterator it2 = m_implInfoList.begin();
        while (it2 != m_implInfoList.end()) {
            ImplInfo *implInfo = (*it2);

            mfxU32 deviceID   = 0;
            mfxU32 adapterIdx = 0;
            if (IsValidX86GPU(implInfo, deviceID, adapterIdx)) {
                // save the adapterIdx for any x86 GPU devices (may be used later for filtering)
                implInfo->adapterIdx = adapterIdx;
            }

            // per spec: if both Intel® VPL (HW) and MSDK are installed for the same accelerator, only load
            //   the Intel® VPL implementation (mark MSDK as invalid)
            // exception: if application requests D3D9, load MSDK if available
            if (implInfo->libInfo->libType == LibTypeMSDK) {
                mfxImplDescription *msdkImplDesc = (mfxImplDescription *)(implInfo->implDesc);
                std::string msdkDeviceID         = (msdkImplDesc ? msdkImplDesc->Dev.DeviceID : "");

                // check if Intel® VPL impl also exists for this deviceID
                auto vplIdx = std::find_if(
                    m_implInfoList.begin(),
                    m_implInfoList.end(),

                    [&](const ImplInfo *t) {
                        mfxImplDescription *implDesc = (mfxImplDescription *)(t->implDesc);

                        bool bMatchingDeviceID = false;
                        if (implDesc) {
                            std::string vplDeviceID = implDesc->Dev.DeviceID;
                            if (vplDeviceID == msdkDeviceID)
                                bMatchingDeviceID = true;
                        }

                        return (t->libInfo->libType == LibTypeVPL && implDesc != nullptr &&
                                implDesc->Impl == MFX_IMPL_TYPE_HARDWARE && bMatchingDeviceID);
                    });

                if (vplIdx != m_implInfoList.end() && bD3D9Requested == false)
                    implInfo->validImplIdx = -1;

                // avoid loading Intel® VPL RT via compatibility entrypoint
                if (msdkImplDesc && msdkImplDesc->ApiVersion.Major == 1 &&
                    msdkImplDesc->ApiVersion.Minor == 255)
                    implInfo->validImplIdx = -1;
            }

            if (implInfo->libInfo->libType == LibTypeVPL && !implInfo->implDesc) {
                //library was loaded in low-delay mode, need to query caps for it
                mfxU32 numImpls      = 0;
                VPLFunctionPtr pFunc = implInfo->libInfo->vplFuncTable[IdxMFXQueryImplsDescription];
                mfxHDL *hImpl = (*(mfxHDL * (MFX_CDECL *)(mfxImplCapsDeliveryFormat, mfxU32 *))
                                     pFunc)(MFX_IMPLCAPS_IMPLDESCSTRUCTURE, &numImpls);

                //only single impl was reported
                implInfo->implDesc = reinterpret_cast<mfxImplDescription *>(hImpl[0]);
            }
            else if (implInfo->libInfo->libType == LibTypeMSDK && !implInfo->implDesc) {
                mfxImplDescription *implDesc       = nullptr;
                mfxImplementedFunctions *implFuncs = nullptr;

                LoaderCtxMSDK *msdkCtx = &(implInfo->libInfo->msdkCtx[0]);

                // perf. optimization: if app requested bIsSet_accelerationMode other than D3D9, don't test whether MSDK supports D3D9
                bool bSkipD3D9Check = false;
                if (m_specialConfig.bIsSet_accelerationMode &&
                    m_specialConfig.accelerationMode != MFX_ACCEL_MODE_VIA_D3D9) {
                    bSkipD3D9Check = true;
                }

                sts = msdkCtx->QueryMSDKCaps(implInfo->libInfo->libNameFull,
                                             &implDesc,
                                             &implFuncs,
                                             0,
                                             bSkipD3D9Check);

                if (sts || !implDesc || !implFuncs) {
                    // this adapter (i) is not supported
                    continue;
                }
                implInfo->implDesc  = implDesc;
                implInfo->implFuncs = implFuncs;
            }

            it2++;
        }

        // sort valid implementations according to priority rules in spec
        PrioritizeImplList();
    }

    return m_implInfoList.empty() ? MFX_ERR_UNSUPPORTED : MFX_ERR_NONE;
}

// query implementation i
mfxStatus LoaderCtxVPL::QueryImpl(mfxU32 idx, mfxImplCapsDeliveryFormat format, mfxHDL *idesc) {
    DISP_LOG_FUNCTION(&m_dispLog);

    *idesc = nullptr;

    std::list<ImplInfo *>::iterator it = m_implInfoList.begin();
    while (it != m_implInfoList.end()) {
        ImplInfo *implInfo = (*it);
        if (implInfo->validImplIdx == (mfxI32)idx) {
            if (format == MFX_IMPLCAPS_IMPLDESCSTRUCTURE) {
                *idesc = implInfo->implDesc;
            }
            else if (format == MFX_IMPLCAPS_IMPLEMENTEDFUNCTIONS) {
                *idesc = implInfo->implFuncs;
            }
            else if (format == MFX_IMPLCAPS_IMPLPATH) {
                *idesc = implInfo->libInfo->implCapsPath;
            }
            else if (format == MFX_IMPLCAPS_DEVICE_ID_EXTENDED) {
                *idesc = implInfo->implExtDeviceID;
            }
#ifdef ONEVPL_EXPERIMENTAL
            else if (format == MFX_IMPLCAPS_SURFACE_TYPES) {
                *idesc = implInfo->implSurfTypes;
            }
#endif

            // implementation found, but requested query format is not supported
            if (*idesc == nullptr)
                return MFX_ERR_UNSUPPORTED;

            return MFX_ERR_NONE;
        }
        it++;
    }

    // invalid idx
    return MFX_ERR_NOT_FOUND;
}

mfxStatus LoaderCtxVPL::ReleaseImpl(mfxHDL idesc) {
    DISP_LOG_FUNCTION(&m_dispLog);

    mfxStatus sts = MFX_ERR_NONE;

    if (idesc == nullptr)
        return MFX_ERR_NULL_PTR;

    // all we get from the application is a handle to the descriptor,
    //   not the implementation associated with it, so we search
    //   through the full list until we find a match
    std::list<ImplInfo *>::iterator it = m_implInfoList.begin();
    while (it != m_implInfoList.end()) {
        ImplInfo *implInfo                   = (*it);
        mfxImplCapsDeliveryFormat capsFormat = (mfxImplCapsDeliveryFormat)0; // unknown format

        // determine type of descriptor so we know which handle to
        //   invalidate in the Loader context
        if (implInfo->implDesc == idesc) {
            capsFormat = MFX_IMPLCAPS_IMPLDESCSTRUCTURE;
        }
        else if (implInfo->implFuncs == idesc) {
            capsFormat = MFX_IMPLCAPS_IMPLEMENTEDFUNCTIONS;
        }
        else if (implInfo->libInfo->implCapsPath == idesc) {
            capsFormat = MFX_IMPLCAPS_IMPLPATH;
        }
        else if (implInfo->implExtDeviceID == idesc) {
            capsFormat = MFX_IMPLCAPS_DEVICE_ID_EXTENDED;
        }
#ifdef ONEVPL_EXPERIMENTAL
        else if (implInfo->implSurfTypes == idesc) {
            capsFormat = MFX_IMPLCAPS_SURFACE_TYPES;
        }
#endif
        else {
            // no match - try next implementation
            it++;
            continue;
        }

        // if true, do not actually call ReleaseImplDescription() until
        //   MFXUnload() --> UnloadAllLibraries()
        // this permits the application to call Enum/CreateSession/DispRelease multiple
        //   times on the same implementation
        if (m_bKeepCapsUntilUnload)
            return MFX_ERR_NONE;

        // LibTypeMSDK does not require calling a release function
        if (implInfo->libInfo->libType == LibTypeVPL) {
            // call MFXReleaseImplDescription() for this implementation
            VPLFunctionPtr pFunc = implInfo->libInfo->vplFuncTable[IdxMFXReleaseImplDescription];

            if (capsFormat == MFX_IMPLCAPS_IMPLDESCSTRUCTURE) {
                sts                = (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implDesc);
                implInfo->implDesc = nullptr;
            }
            else if (capsFormat == MFX_IMPLCAPS_IMPLEMENTEDFUNCTIONS) {
                sts                 = (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implFuncs);
                implInfo->implFuncs = nullptr;
            }
            else if (capsFormat == MFX_IMPLCAPS_DEVICE_ID_EXTENDED) {
                sts = (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implExtDeviceID);
                implInfo->implExtDeviceID = nullptr;
            }
#ifdef ONEVPL_EXPERIMENTAL
            else if (capsFormat == MFX_IMPLCAPS_SURFACE_TYPES) {
                sts = (*(mfxStatus(MFX_CDECL *)(mfxHDL))pFunc)(implInfo->implSurfTypes);
                implInfo->implSurfTypes = nullptr;
            }
#endif

            // nothing to do if (capsFormat == MFX_IMPLCAPS_IMPLPATH) since no new memory was allocated
        }

        return sts;
    }

    // did not find a matching handle - should not happen
    return MFX_ERR_INVALID_HANDLE;
}

mfxStatus LoaderCtxVPL::UpdateLowLatency() {
    m_bLowLatency = false;

    m_bLowLatency = ConfigCtxVPL::CheckLowLatencyConfig(m_configCtxList, &m_specialConfig);

    return MFX_ERR_NONE;
}

#ifdef ONEVPL_EXPERIMENTAL
mfxStatus LoaderCtxVPL::UpdatePropsQuery() {
    // property-based query disabled by default
    m_bEnablePropsQuery = false;
    m_queryProps.clear();

    m_bEnablePropsQuery = ConfigCtxVPL::UpdatePropsQueryConfig(m_configCtxList, m_queryProps);

    return MFX_ERR_NONE;
}
#endif

mfxStatus LoaderCtxVPL::UpdateValidImplList(void) {
    DISP_LOG_FUNCTION(&m_dispLog);

    mfxStatus sts = MFX_ERR_NONE;

    mfxI32 validImplIdx = 0;

    // iterate over all libraries and update list of those that
    //   meet current current set of config props
    std::list<ImplInfo *>::iterator it = m_implInfoList.begin();
    while (it != m_implInfoList.end()) {
        ImplInfo *implInfo = (*it);

        // already invalidated by previous filter
        if (implInfo->validImplIdx == -1) {
            it++;
            continue;
        }

        // compare caps from this library vs. config filters
        sts = ConfigCtxVPL::ValidateConfig((mfxImplDescription *)implInfo->implDesc,
                                           (mfxImplementedFunctions *)implInfo->implFuncs,
                                           (mfxExtendedDeviceId *)implInfo->implExtDeviceID,
#ifdef ONEVPL_EXPERIMENTAL
                                           (mfxSurfaceTypesSupported *)implInfo->implSurfTypes,
#endif
                                           m_configCtxList,
                                           implInfo->libInfo->libType,
                                           &m_specialConfig);

        // check special filter properties which are not part of mfxImplDescription
        if (m_specialConfig.bIsSet_dxgiAdapterIdx &&
            (m_specialConfig.dxgiAdapterIdx != implInfo->adapterIdx)) {
            sts = MFX_ERR_UNSUPPORTED;
        }

        if (sts == MFX_ERR_NONE) {
            // library supports all required properties
            implInfo->validImplIdx = validImplIdx++;
        }
        else {
            // library does not support required props, do not include in list for
            //   MFXEnumImplementations() or MFXCreateSession()
            implInfo->validImplIdx = -1;
        }

        it++;
    }

    // re-sort valid implementations according to priority rules in spec
    PrioritizeImplList();

    m_bNeedUpdateValidImpls = false;

    return MFX_ERR_NONE;
}

// From specification section "Intel® VPL Session":
//
// When the dispatcher searches for the implementation, it uses the following priority rules
//  1) Hardware implementation has priority over software implementation.
//  2) General hardware implementation has priority over VSI hardware implementation.
//  3) Highest API version has higher priority over lower API version.
//  4) Search path priority: lower values = higher priority
mfxStatus LoaderCtxVPL::PrioritizeImplList(void) {
    DISP_LOG_FUNCTION(&m_dispLog);

    // API 2.6 introduced special search location ONEVPL_PRIORITY_PATH
    // Libs here always have highest priority = LIB_PRIORITY_SPECIAL
    //   and are not sorted by the other priority rules,
    //   so we move them to a temporary list before priority sorting and
    //   then add back to the full implementation list at the end.
    std::list<ImplInfo *> implInfoListPriority;
    if (m_bPriorityPathEnabled) {
        auto it = m_implInfoList.begin();
        while (it != m_implInfoList.end()) {
            ImplInfo *implInfo = (*it);

            auto it2 = std::next(it, 1);
            if (implInfo->libInfo->libPriority == LIB_PRIORITY_SPECIAL)
                implInfoListPriority.splice(implInfoListPriority.end(), m_implInfoList, it);

            it = it2;
        }
    }

    // stable sort - work from lowest to highest priority conditions

    // 4 - sort by search path priority
    m_implInfoList.sort([](const ImplInfo *impl1, const ImplInfo *impl2) {
        // prioritize lowest value for libPriority (1 = highest priority)
        return (impl1->libInfo->libPriority < impl2->libInfo->libPriority);
    });

    // 3 - sort by API version
    m_implInfoList.sort([](const ImplInfo *impl1, const ImplInfo *impl2) {
        mfxImplDescription *implDesc1 = (mfxImplDescription *)(impl1->implDesc);
        mfxImplDescription *implDesc2 = (mfxImplDescription *)(impl2->implDesc);

        // prioritize greatest API version
        return (implDesc1->ApiVersion.Version > implDesc2->ApiVersion.Version);
    });

    // 2 - sort by general HW vs. VSI
    m_implInfoList.sort([](const ImplInfo *impl1, const ImplInfo *impl2) {
        mfxImplDescription *implDesc1 = (mfxImplDescription *)(impl1->implDesc);
        mfxImplDescription *implDesc2 = (mfxImplDescription *)(impl2->implDesc);

        // prioritize general HW accelerator over VSI (if none, i.e. SW, will be sorted in final step)
        return (implDesc1->AccelerationMode != MFX_ACCEL_MODE_VIA_HDDLUNITE &&
                implDesc2->AccelerationMode == MFX_ACCEL_MODE_VIA_HDDLUNITE);
    });

    // 1 - sort by implementation type (HW > SW)
    m_implInfoList.sort([](const ImplInfo *impl1, const ImplInfo *impl2) {
        mfxImplDescription *implDesc1 = (mfxImplDescription *)(impl1->implDesc);
        mfxImplDescription *implDesc2 = (mfxImplDescription *)(impl2->implDesc);

        // prioritize greatest Impl value (HW = 2, SW = 1)
        return (implDesc1->Impl > implDesc2->Impl);
    });

    if (m_bPriorityPathEnabled) {
        // add back unsorted ONEVPL_PRIORITY_PATH libs to beginning of list
        m_implInfoList.splice(m_implInfoList.begin(), implInfoListPriority);
    }

    // final pass - update index to match new priority order
    // validImplIdx will be the index associated with MFXEnumImplememntations()
    mfxI32 validImplIdx                = 0;
    std::list<ImplInfo *>::iterator it = m_implInfoList.begin();
    while (it != m_implInfoList.end()) {
        ImplInfo *implInfo = (*it);

        if (implInfo->validImplIdx >= 0) {
            implInfo->validImplIdx = validImplIdx++;
        }
        it++;
    }

    return MFX_ERR_NONE;
}

mfxStatus LoaderCtxVPL::CreateSession(mfxU32 idx, mfxSession *session) {
    DISP_LOG_FUNCTION(&m_dispLog);

    mfxStatus sts = MFX_ERR_NONE;

    // find library with given implementation index
    // list of valid implementations (and associated indices) is updated
    //   every time a filter property is added/modified
    std::list<ImplInfo *>::iterator it = m_implInfoList.begin();
    while (it != m_implInfoList.end()) {
        ImplInfo *implInfo = (*it);

        if (implInfo->validImplIdx == (mfxI32)idx) {
            LibInfo *libInfo = implInfo->libInfo;
            mfxU16 deviceID  = 0;

            // pass VendorImplID for this implementation (disambiguate if one
            //   library contains multiple implementations)
            // NOTE: implDesc may be null in low latency mode (RT query not called)
            //   so this value will not be available
            mfxImplDescription *implDesc = (mfxImplDescription *)(implInfo->implDesc);
            if (implDesc) {
                implInfo->vplParam.VendorImplID = implDesc->VendorImplID;
            }

            // set any special parameters passed in via SetConfigProperty
            // if application did not specify accelerationMode, use default
            if (m_specialConfig.bIsSet_accelerationMode)
                implInfo->vplParam.AccelerationMode = m_specialConfig.accelerationMode;

#ifdef ONEVPL_EXPERIMENTAL
            if (m_specialConfig.bIsSet_DeviceCopy)
                implInfo->vplParam.DeviceCopy = m_specialConfig.DeviceCopy;
#endif

            // in low latency mode there was no implementation filtering, so check here
            //   for minimum API version
            if (m_bLowLatency && m_specialConfig.bIsSet_ApiVersion) {
                if (implInfo->version.Version < m_specialConfig.ApiVersion.Version)
                    return MFX_ERR_NOT_FOUND;
            }

            mfxIMPL msdkImpl = 0;
            if (libInfo->libType == LibTypeMSDK) {
                if (implInfo->vplParam.AccelerationMode == MFX_ACCEL_MODE_VIA_D3D9)
                    msdkImpl = libInfo->msdkCtx[implInfo->msdkImplIdx].m_msdkAdapterD3D9;
                else
                    msdkImpl = libInfo->msdkCtx[implInfo->msdkImplIdx].m_msdkAdapter;
            }

            // in low latency mode implDesc is not available, but application may set adapter number via DXGIAdapterIndex filter
            if (m_bLowLatency) {
                if (m_specialConfig.bIsSet_dxgiAdapterIdx && libInfo->libType == LibTypeVPL) {
                    implInfo->vplParam.VendorImplID = m_specialConfig.dxgiAdapterIdx;
                }
                else if (m_specialConfig.bIsSet_dxgiAdapterIdx && libInfo->libType == LibTypeMSDK) {
                    if (m_specialConfig.dxgiAdapterIdx >= MAX_NUM_IMPL_MSDK)
                        return MFX_ERR_NOT_FOUND; // MSDK adapter index out of range
                    msdkImpl = msdkImplTab[m_specialConfig.dxgiAdapterIdx];
                }
            }

            // add any extension buffers set via special filter properties
            std::vector<mfxExtBuffer *> extBufs;

            // pass NumThread via mfxExtThreadsParam
            mfxExtThreadsParam extThreadsParam = {};
            if (m_specialConfig.bIsSet_NumThread) {
                DISP_LOG_MESSAGE(&m_dispLog,
                                 "message:  extBuf enabled -- NumThread (%d)",
                                 m_specialConfig.NumThread);

                extThreadsParam.Header.BufferId = MFX_EXTBUFF_THREADS_PARAM;
                extThreadsParam.Header.BufferSz = sizeof(mfxExtThreadsParam);
                extThreadsParam.NumThread       = m_specialConfig.NumThread;

                extBufs.push_back((mfxExtBuffer *)&extThreadsParam);
            }

            // add extBufs provided via mfxConfig filter property "ExtBuffer"
            if (m_specialConfig.bIsSet_ExtBuffer) {
                for (auto extBuf : m_specialConfig.ExtBuffers) {
                    extBufs.push_back((mfxExtBuffer *)extBuf);
                }
            }

            // attach vector of extBufs to mfxInitializationParam
            implInfo->vplParam.NumExtParam = static_cast<mfxU16>(extBufs.size());
            implInfo->vplParam.ExtParam =
                (implInfo->vplParam.NumExtParam ? extBufs.data() : nullptr);

            // initialize this library via MFXInitialize or else fail
            //   (specify full path to library)
            sts = MFXInitEx2(implInfo->version,
                             implInfo->vplParam,
                             msdkImpl,
                             session,
                             &deviceID,
                             (CHAR_TYPE *)libInfo->libNameFull.c_str());

            // optionally call MFXSetHandle() if present via SetConfigProperty
            if (sts == MFX_ERR_NONE && m_specialConfig.bIsSet_deviceHandleType &&
                m_specialConfig.bIsSet_deviceHandle && m_specialConfig.deviceHandleType &&
                m_specialConfig.deviceHandle) {
                sts = MFXVideoCORE_SetHandle(*session,
                                             m_specialConfig.deviceHandleType,
                                             m_specialConfig.deviceHandle);
            }

            return sts;
        }
        it++;
    }

    // invalid idx
    return MFX_ERR_NOT_FOUND;
}

ConfigCtxVPL *LoaderCtxVPL::AddConfigFilter() {
    DISP_LOG_FUNCTION(&m_dispLog);

    // create new config filter context and add
    //   to list associated with this loader
    std::unique_ptr<ConfigCtxVPL> configCtx;
    try {
        configCtx.reset(new ConfigCtxVPL{});
    }
    catch (...) {
        return nullptr;
    }

    ConfigCtxVPL *config   = (ConfigCtxVPL *)(configCtx.release());
    config->m_parentLoader = this;

    m_configCtxList.push_back(config);

    return config;
}

mfxStatus LoaderCtxVPL::FreeConfigFilters() {
    DISP_LOG_FUNCTION(&m_dispLog);

    std::list<ConfigCtxVPL *>::iterator it = m_configCtxList.begin();

    while (it != m_configCtxList.end()) {
        ConfigCtxVPL *config = (*it);
        if (config)
            delete config;
        it++;
    }

    return MFX_ERR_NONE;
}

mfxStatus LoaderCtxVPL::InitDispatcherLog() {
    std::string strLogEnabled, strLogFile;

#if defined(_WIN32) || defined(_WIN64)
    DWORD err;

    char logEnabled[MAX_VPL_SEARCH_PATH] = "";
    err = GetEnvironmentVariableA("ONEVPL_DISPATCHER_LOG", logEnabled, MAX_VPL_SEARCH_PATH);
    if (err == 0 || err >= MAX_VPL_SEARCH_PATH)
        return MFX_ERR_UNSUPPORTED; // environment variable not defined or string too long

    strLogEnabled = logEnabled;

    char logFile[MAX_VPL_SEARCH_PATH] = "";
    err = GetEnvironmentVariableA("ONEVPL_DISPATCHER_LOG_FILE", logFile, MAX_VPL_SEARCH_PATH);
    if (err == 0 || err >= MAX_VPL_SEARCH_PATH) {
        // nothing to do - strLogFile is an empty string
    }
    else {
        strLogFile = logFile;
    }

#else
    const char *logEnabled = std::getenv("ONEVPL_DISPATCHER_LOG");
    if (!logEnabled)
        return MFX_ERR_UNSUPPORTED;

    strLogEnabled = logEnabled;

    const char *logFile = std::getenv("ONEVPL_DISPATCHER_LOG_FILE");
    if (logFile)
        strLogFile = logFile;
#endif

    if (strLogEnabled != "ON")
        return MFX_ERR_UNSUPPORTED;

    // currently logLevel is either 0 or non-zero
    // additional levels will be added with future API updates
    return m_dispLog.Init(1, strLogFile);
}

// public function to return logger object
// allows logging from C API functions outside of loaderCtx
DispatcherLogVPL *LoaderCtxVPL::GetLogger() {
    return &m_dispLog;
}
