/*############################################################################ # Copyright (C) 2012-2020 Intel Corporation # # SPDX-License-Identifier: MIT ############################################################################*/ #include #include #include #include #include "windows/mfx_critical_section.h" #include "windows/mfx_dispatcher.h" #include "windows/mfx_dispatcher_log.h" #include "windows/mfx_library_iterator.h" #include "windows/mfx_load_dll.h" #include "windows/mfx_vector.h" #if defined(MEDIASDK_UWP_DISPATCHER) #include "windows/mfx_driver_store_loader.h" #endif #include /* for memset on Linux */ #include /* for qsort on Linux */ // module-local definitions namespace { const struct { // instance implementation type eMfxImplType implType; // real implementation mfxIMPL impl; // adapter numbers mfxU32 adapterID; } implTypes[] = { // MFX_IMPL_AUTO case { MFX_LIB_HARDWARE, MFX_IMPL_HARDWARE, 0 }, { MFX_LIB_SOFTWARE, MFX_IMPL_SOFTWARE, 0 }, // MFX_IMPL_ANY case { MFX_LIB_HARDWARE, MFX_IMPL_HARDWARE, 0 }, { MFX_LIB_HARDWARE, MFX_IMPL_HARDWARE2, 1 }, { MFX_LIB_HARDWARE, MFX_IMPL_HARDWARE3, 2 }, { MFX_LIB_HARDWARE, MFX_IMPL_HARDWARE4, 3 }, { MFX_LIB_SOFTWARE, MFX_IMPL_SOFTWARE, 0 }, { MFX_LIB_SOFTWARE, MFX_IMPL_SOFTWARE, 0 }, // unused - was MFX_IMPL_AUDIO }; const struct { // start index in implTypes table for specified implementation mfxU32 minIndex; // last index in implTypes table for specified implementation mfxU32 maxIndex; } implTypesRange[] = { { 0, 1 }, // MFX_IMPL_AUTO { 1, 1 }, // MFX_IMPL_SOFTWARE { 0, 0 }, // MFX_IMPL_HARDWARE { 2, 6 }, // MFX_IMPL_AUTO_ANY { 2, 5 }, // MFX_IMPL_HARDWARE_ANY { 3, 3 }, // MFX_IMPL_HARDWARE2 { 4, 4 }, // MFX_IMPL_HARDWARE3 { 5, 5 }, // MFX_IMPL_HARDWARE4 { 2, 6 }, // MFX_IMPL_RUNTIME, same as MFX_IMPL_HARDWARE_ANY }; MFX::mfxCriticalSection dispGuard = 0; } // namespace using namespace MFX; #if !defined(MEDIASDK_UWP_DISPATCHER) // // Implement DLL exposed functions. MFXInit and MFXClose have to do // slightly more than other. They require to be implemented explicitly. // All other functions are implemented implicitly. // typedef MFXVector HandleVector; typedef MFXVector StatusVector; struct VectorHandleGuard { explicit VectorHandleGuard(HandleVector &aVector) : m_vector(aVector) {} ~VectorHandleGuard() { HandleVector::iterator it = m_vector.begin(), et = m_vector.end(); for (; it != et; ++it) { delete *it; } } HandleVector &m_vector; private: void operator=(const VectorHandleGuard &); }; static int HandleSort(const void *plhs, const void *prhs) { const MFX_DISP_HANDLE_EX *lhs = *(const MFX_DISP_HANDLE_EX **)plhs; const MFX_DISP_HANDLE_EX *rhs = *(const MFX_DISP_HANDLE_EX **)prhs; const mfxVersion vplInitVersion = { 255, 1 }; // prefer oneVPL runtime (API = 1.255) if ((lhs->actualApiVersion.Version == vplInitVersion.Version) && (rhs->actualApiVersion < lhs->actualApiVersion)) { return -1; } if ((rhs->actualApiVersion.Version == vplInitVersion.Version) && (lhs->actualApiVersion < rhs->actualApiVersion)) { return 1; } // prefer HW implementation if (lhs->implType != MFX_LIB_HARDWARE && rhs->implType == MFX_LIB_HARDWARE) { return 1; } if (lhs->implType == MFX_LIB_HARDWARE && rhs->implType != MFX_LIB_HARDWARE) { return -1; } // prefer integrated GPU if (lhs->mediaAdapterType != MFX_MEDIA_INTEGRATED && rhs->mediaAdapterType == MFX_MEDIA_INTEGRATED) { return 1; } if (lhs->mediaAdapterType == MFX_MEDIA_INTEGRATED && rhs->mediaAdapterType != MFX_MEDIA_INTEGRATED) { return -1; } // prefer dll with lower API version if (lhs->actualApiVersion < rhs->actualApiVersion) { return -1; } if (rhs->actualApiVersion < lhs->actualApiVersion) { return 1; } // if versions are equal prefer library with HW if (lhs->loadStatus == MFX_WRN_PARTIAL_ACCELERATION && rhs->loadStatus == MFX_ERR_NONE) { return 1; } if (lhs->loadStatus == MFX_ERR_NONE && rhs->loadStatus == MFX_WRN_PARTIAL_ACCELERATION) { return -1; } return 0; } mfxStatus MFXInitEx(mfxInitParam par, mfxSession *session) { MFX::MFXAutomaticCriticalSection guard(&dispGuard); DISPATCHER_LOG_BLOCK(("MFXInitEx (impl=%s, pVer=%d.%d, ExternalThreads=%d session=0x%p\n", DispatcherLog_GetMFXImplString(par.Implementation).c_str(), par.Version.Major, par.Version.Minor, par.ExternalThreads, session)); mfxStatus mfxRes = MFX_ERR_UNSUPPORTED; HandleVector allocatedHandle; VectorHandleGuard handleGuard(allocatedHandle); MFX_DISP_HANDLE_EX *pHandle; wchar_t dllName[MFX_MAX_DLL_PATH] = { 0 }; MFX::MFXLibraryIterator libIterator; // there iterators are used only if the caller specified implicit type like AUTO mfxU32 curImplIdx, maxImplIdx; // implementation method masked from the input parameter // special case for audio library const mfxIMPL implMethod = par.Implementation & (MFX_IMPL_VIA_ANY - 1); // implementation interface masked from the input parameter mfxIMPL implInterface = par.Implementation & -MFX_IMPL_VIA_ANY; mfxIMPL implInterfaceOrig = implInterface; mfxVersion requiredVersion = { { MFX_VERSION_MINOR, MFX_VERSION_MAJOR } }; mfxInitializationParam vplParam = {}; if (implMethod == MFX_IMPL_SOFTWARE) { vplParam.AccelerationMode = MFX_ACCEL_MODE_NA; } else { // hardware - D3D11 by default if (implInterface == MFX_IMPL_VIA_D3D9) vplParam.AccelerationMode = MFX_ACCEL_MODE_VIA_D3D9; else vplParam.AccelerationMode = MFX_ACCEL_MODE_VIA_D3D11; } // check error(s) if (NULL == session) { return MFX_ERR_NULL_PTR; } if (((MFX_IMPL_AUTO > implMethod) || (MFX_IMPL_RUNTIME < implMethod))) { return MFX_ERR_UNSUPPORTED; } // set the minimal required version requiredVersion = par.Version; try { // reset the session value *session = 0; // allocate the dispatching handle and call-table pHandle = new MFX_DISP_HANDLE_EX(requiredVersion); } catch (...) { return MFX_ERR_MEMORY_ALLOC; } DISPATCHER_LOG_INFO( (("Required API version is %u.%u\n"), requiredVersion.Major, requiredVersion.Minor)); // particular implementation value mfxIMPL curImpl; // Load HW library or RT from system location curImplIdx = implTypesRange[implMethod].minIndex; maxImplIdx = implTypesRange[implMethod].maxIndex; do { int currentStorage = MFX::MFX_STORAGE_ID_FIRST; implInterface = implInterfaceOrig; do { // this storage will be checked below if (currentStorage == MFX::MFX_APP_FOLDER) { currentStorage += 1; continue; } // initialize the library iterator mfxRes = libIterator.Init(implTypes[curImplIdx].implType, implInterface, implTypes[curImplIdx].adapterID, currentStorage); // look through the list of installed SDK version, // looking for a suitable library with higher merit value. if (MFX_ERR_NONE == mfxRes) { if (MFX_LIB_HARDWARE == implTypes[curImplIdx].implType && (!implInterface || MFX_IMPL_VIA_ANY == implInterface)) { implInterface = libIterator.GetImplementationType(); } do { eMfxImplType implType = implTypes[curImplIdx].implType; // select a desired DLL mfxRes = libIterator.SelectDLLVersion(dllName, sizeof(dllName) / sizeof(dllName[0]), &implType, pHandle->apiVersion); if (MFX_ERR_NONE != mfxRes) { break; } DISPATCHER_LOG_INFO((("loading library %S\n"), dllName)); // try to load the selected DLL curImpl = implTypes[curImplIdx].impl; mfxRes = pHandle->LoadSelectedDLL(dllName, implType, curImpl, implInterface, par, vplParam); // unload the failed DLL if (MFX_ERR_NONE != mfxRes) { pHandle->Close(); continue; } mfxPlatform platform = { MFX_PLATFORM_UNKNOWN, 0, MFX_MEDIA_UNKNOWN }; if (pHandle->callTable[eMFXVideoCORE_QueryPlatform]) { mfxRes = MFXVideoCORE_QueryPlatform((mfxSession)pHandle, &platform); if (MFX_ERR_NONE != mfxRes) { DISPATCHER_LOG_WRN( ("MFXVideoCORE_QueryPlatform failed, rejecting loaded library\n")); pHandle->Close(); continue; } } pHandle->mediaAdapterType = platform.MediaAdapterType; DISPATCHER_LOG_INFO( (("media adapter type is %d\n"), pHandle->mediaAdapterType)); libIterator.GetSubKeyName( pHandle->subkeyName, sizeof(pHandle->subkeyName) / sizeof(pHandle->subkeyName[0])); pHandle->storageID = libIterator.GetStorageID(); allocatedHandle.push_back(pHandle); pHandle = new MFX_DISP_HANDLE_EX(requiredVersion); } while (MFX_ERR_NONE != mfxRes); } // select another place for loading engine currentStorage += 1; } while ((MFX_ERR_NONE != mfxRes) && (MFX::MFX_STORAGE_ID_LAST >= currentStorage)); } while ((MFX_ERR_NONE != mfxRes) && (++curImplIdx <= maxImplIdx)); curImplIdx = implTypesRange[implMethod].minIndex; maxImplIdx = implTypesRange[implMethod].maxIndex; // Load RT from app folder (libmfxsw64 with API >= 1.10) do { implInterface = implInterfaceOrig; // initialize the library iterator mfxRes = libIterator.Init(implTypes[curImplIdx].implType, implInterface, implTypes[curImplIdx].adapterID, MFX::MFX_APP_FOLDER); if (MFX_ERR_NONE == mfxRes) { if (MFX_LIB_HARDWARE == implTypes[curImplIdx].implType && (!implInterface || MFX_IMPL_VIA_ANY == implInterface)) { implInterface = libIterator.GetImplementationType(); } do { eMfxImplType implType; // select a desired DLL mfxRes = libIterator.SelectDLLVersion(dllName, sizeof(dllName) / sizeof(dllName[0]), &implType, pHandle->apiVersion); if (MFX_ERR_NONE != mfxRes) { break; } DISPATCHER_LOG_INFO((("loading library %S\n"), dllName)); // try to load the selected DLL curImpl = implTypes[curImplIdx].impl; mfxRes = pHandle->LoadSelectedDLL(dllName, implType, curImpl, implInterface, par, vplParam); // unload the failed DLL if (MFX_ERR_NONE != mfxRes) { pHandle->Close(); } else { if (pHandle->actualApiVersion.Major == 1 && pHandle->actualApiVersion.Minor <= 9) { // this is not RT, skip it mfxRes = MFX_ERR_ABORTED; break; } pHandle->storageID = MFX::MFX_UNKNOWN_KEY; allocatedHandle.push_back(pHandle); pHandle = new MFX_DISP_HANDLE_EX(requiredVersion); } } while (MFX_ERR_NONE != mfxRes); } } while ((MFX_ERR_NONE != mfxRes) && (++curImplIdx <= maxImplIdx)); // Load HW and SW libraries using legacy default DLL search mechanism // set current library index again curImplIdx = implTypesRange[implMethod].minIndex; do { implInterface = implInterfaceOrig; mfxRes = MFX::mfx_get_default_dll_name(dllName, sizeof(dllName) / sizeof(dllName[0]), implTypes[curImplIdx].implType); if (MFX_ERR_NONE == mfxRes) { DISPATCHER_LOG_INFO((("loading default library %S\n"), dllName)) // try to load the selected DLL using default DLL search mechanism if (MFX_LIB_HARDWARE == implTypes[curImplIdx].implType) { if (!implInterface) { implInterface = MFX_IMPL_VIA_ANY; } mfxU32 curVendorID = 0, curDeviceID = 0; mfxRes = MFX::SelectImplementationType(implTypes[curImplIdx].adapterID, &implInterface, &curVendorID, &curDeviceID); if (curVendorID != INTEL_VENDOR_ID) mfxRes = MFX_ERR_UNKNOWN; } if (MFX_ERR_NONE == mfxRes) { // try to load the selected DLL using default DLL search mechanism mfxRes = pHandle->LoadSelectedDLL(dllName, implTypes[curImplIdx].implType, implTypes[curImplIdx].impl, implInterface, par, vplParam); } // unload the failed DLL if ((MFX_ERR_NONE != mfxRes) && (MFX_WRN_PARTIAL_ACCELERATION != mfxRes)) { pHandle->Close(); } else { pHandle->storageID = MFX::MFX_UNKNOWN_KEY; allocatedHandle.push_back(pHandle); pHandle = new MFX_DISP_HANDLE_EX(requiredVersion); } } } while ((MFX_ERR_NONE > mfxRes) && (++curImplIdx <= maxImplIdx)); delete pHandle; if (allocatedHandle.size() == 0) return MFX_ERR_UNSUPPORTED; { // sort candidate list bool NeedSort = false; HandleVector::iterator first = allocatedHandle.begin(), it = allocatedHandle.begin(), et = allocatedHandle.end(); for (it++; it != et; ++it) if (HandleSort(&(*first), &(*it)) != 0) NeedSort = true; // sort allocatedHandle so that the most preferred dll is at the beginning if (NeedSort) qsort(&(*allocatedHandle.begin()), allocatedHandle.size(), sizeof(MFX_DISP_HANDLE_EX *), &HandleSort); } HandleVector::iterator candidate = allocatedHandle.begin(); // check the final result of loading try { pHandle = *candidate; //pulling up current mediasdk version, that required to match plugin version //block for now to avoid KW scanning failure (UNUSED) //mfxVersion apiVerActual = { { 0, 0 } }; //mfxStatus stsQueryVersion = // MFXQueryVersion((mfxSession)pHandle, &apiVerActual); } catch (...) { DISPATCHER_LOG_ERROR((("unknown exception while loading plugins\n"))) } // everything is OK. Save pointers to the output variable *candidate = 0; // keep this one safe from guard destructor //=================================== // MFXVideoCORE_QueryPlatform call creates d3d device handle, so we have handle right after MFXInit and can't accept external handle // This is a workaround which calls close-init to remove that handle mfxFunctionPointer *actualTable = pHandle->callTable; mfxFunctionPointer pFunc; pFunc = actualTable[eMFXClose]; mfxRes = (*(mfxStatus(MFX_CDECL *)(mfxSession))pFunc)(pHandle->session); if (mfxRes != MFX_ERR_NONE) return mfxRes; pHandle->session = 0; bool callOldInit = !actualTable[eMFXInitEx]; pFunc = actualTable[(callOldInit) ? eMFXInit : eMFXInitEx]; mfxVersion version(pHandle->apiVersion); if (callOldInit) { pHandle->loadStatus = (*(mfxStatus(MFX_CDECL *)(mfxIMPL, mfxVersion *, mfxSession *))pFunc)( pHandle->impl | pHandle->implInterface, &version, &pHandle->session); } else { mfxInitParam initPar = par; initPar.Implementation = pHandle->impl | pHandle->implInterface; initPar.Version = version; pHandle->loadStatus = (*(mfxStatus(MFX_CDECL *)(mfxInitParam, mfxSession *))pFunc)(initPar, &pHandle->session); } //=================================== *((MFX_DISP_HANDLE_EX **)session) = pHandle; return pHandle->loadStatus; } // mfxStatus MFXInitEx(mfxIMPL impl, mfxVersion *ver, mfxSession *session) // internal function - load a specific DLL, return unsupported if it fails // vplParam is required for API >= 2.0 (load via MFXInitialize) mfxStatus MFXInitEx2(mfxVersion version, mfxInitializationParam vplParam, mfxIMPL hwImpl, mfxSession *session, mfxU16 *deviceID, wchar_t *dllName) { MFX::MFXAutomaticCriticalSection guard(&dispGuard); mfxStatus mfxRes = MFX_ERR_NONE; HandleVector allocatedHandle; VectorHandleGuard handleGuard(allocatedHandle); MFX_DISP_HANDLE *pHandle; *deviceID = 0; // fill minimal 1.x parameters for LoadSelectedDLL to choose correct initialization path mfxInitParam par = {}; par.Version = version; // select first adapter if not specified // only relevant for MSDK-via-MFXLoad path if (!hwImpl) hwImpl = MFX_IMPL_HARDWARE; switch (vplParam.AccelerationMode) { case MFX_ACCEL_MODE_NA: par.Implementation = MFX_IMPL_SOFTWARE; break; case MFX_ACCEL_MODE_VIA_D3D9: par.Implementation = hwImpl | MFX_IMPL_VIA_D3D9; break; case MFX_ACCEL_MODE_VIA_D3D11: par.Implementation = hwImpl | MFX_IMPL_VIA_D3D11; break; case MFX_ACCEL_MODE_VIA_VAAPI: par.Implementation = hwImpl | MFX_IMPL_VIA_VAAPI; break; default: par.Implementation = hwImpl; break; } // also pass extBuf array (if any) to MFXInitEx for 1.x API par.NumExtParam = vplParam.NumExtParam; par.ExtParam = (vplParam.NumExtParam ? vplParam.ExtParam : nullptr); eMfxImplType implType = (par.Implementation == MFX_IMPL_SOFTWARE ? MFX_LIB_SOFTWARE : MFX_LIB_HARDWARE); mfxIMPL implInterface = par.Implementation & -MFX_IMPL_VIA_ANY; const mfxIMPL implMethod = par.Implementation & (MFX_IMPL_VIA_ANY - 1); // check error(s) if (NULL == session || NULL == dllName) { return MFX_ERR_NULL_PTR; } try { // reset the session value *session = 0; // allocate the dispatching handle and call-table pHandle = new MFX_DISP_HANDLE(par.Version); } catch (...) { return MFX_ERR_MEMORY_ALLOC; } if (MFX_ERR_NONE == mfxRes) { DISPATCHER_LOG_INFO((("loading default library %S\n"), dllName)) if (MFX_ERR_NONE == mfxRes) { // try to load the selected DLL using given DLL name mfxRes = pHandle->LoadSelectedDLL(dllName, implType, implMethod, implInterface, par, vplParam); } // unload the failed DLL if (MFX_ERR_NONE != mfxRes) { pHandle->Close(); delete pHandle; return MFX_ERR_UNSUPPORTED; } else { pHandle->storageID = MFX::MFX_UNKNOWN_KEY; } } // everything is OK. Save pointers to the output variable *((MFX_DISP_HANDLE **)session) = pHandle; return pHandle->loadStatus; } mfxStatus MFXClose(mfxSession session) { MFX::MFXAutomaticCriticalSection guard(&dispGuard); mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; MFX_DISP_HANDLE *pHandle = (MFX_DISP_HANDLE *)session; // check error(s) if (pHandle) { try { // unload the DLL library mfxRes = pHandle->Close(); // it is possible, that there is an active child session. // can't unload library in that case. if (MFX_ERR_UNDEFINED_BEHAVIOR != mfxRes) { // release the handle delete pHandle; } } catch (...) { mfxRes = MFX_ERR_INVALID_HANDLE; } } return mfxRes; } // mfxStatus MFXClose(mfxSession session) #else // relates to !defined (MEDIASDK_UWP_DISPATCHER), i.e. #else part as if MEDIASDK_UWP_DISPATCHER defined static mfxModuleHandle hModule; // for the UWP_DISPATCHER purposes implementation of MFXinitEx is calling // InitialiseMediaSession() implemented in intel_gfx_api.dll mfxStatus MFXInitEx(mfxInitParam par, mfxSession *session) { #if defined(MEDIASDK_ARM_LOADER) return MFX_ERR_UNSUPPORTED; #else wchar_t IntelGFXAPIdllName[MFX_MAX_DLL_PATH] = { 0 }; mfxI32 adapterNum = -1; switch (par.Implementation & 0xf) { case MFX_IMPL_SOFTWARE: #if (MFX_VERSION >= MFX_VERSION_NEXT) case MFX_IMPL_SINGLE_THREAD: #endif return MFX_ERR_UNSUPPORTED; case MFX_IMPL_AUTO: case MFX_IMPL_HARDWARE: adapterNum = 0; break; case MFX_IMPL_HARDWARE2: adapterNum = 1; break; case MFX_IMPL_HARDWARE3: adapterNum = 2; break; case MFX_IMPL_HARDWARE4: adapterNum = 3; break; default: return GfxApiInitPriorityIntegrated(par, session, hModule); } return GfxApiInitByAdapterNum(par, adapterNum, session, hModule); #endif } // for the UWP_DISPATCHER purposes implementation of MFXClose is calling // DisposeMediaSession() implemented in intel_gfx_api.dll mfxStatus MFXClose(mfxSession session) { if (NULL == session) { return MFX_ERR_INVALID_HANDLE; } mfxStatus sts = MFX_ERR_NONE; #if defined(MEDIASDK_ARM_LOADER) sts = MFX_ERR_UNSUPPORTED; #else sts = GfxApiClose(session, hModule); #endif session = (mfxSession)NULL; return sts; } #undef FUNCTION #define FUNCTION(return_value, func_name, formal_param_list, actual_param_list) \ return_value func_name formal_param_list { \ mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; \ \ _mfxSession *pHandle = (_mfxSession *)session; \ \ /* get the function's address and make a call */ \ if (pHandle) { \ mfxFunctionPointer pFunc = pHandle->callPlugInsTable[e##func_name]; \ if (pFunc) { \ /* pass down the call */ \ mfxRes = (*(mfxStatus(MFX_CDECL *) formal_param_list)pFunc)actual_param_list; \ } \ } \ return mfxRes; \ } FUNCTION(mfxStatus, MFXVideoUSER_Load, (mfxSession session, const mfxPluginUID *uid, mfxU32 version), (session, uid, version)) FUNCTION( mfxStatus, MFXVideoUSER_LoadByPath, (mfxSession session, const mfxPluginUID *uid, mfxU32 version, const mfxChar *path, mfxU32 len), (session, uid, version, path, len)) FUNCTION(mfxStatus, MFXVideoUSER_UnLoad, (mfxSession session, const mfxPluginUID *uid), (session, uid)) FUNCTION(mfxStatus, MFXAudioUSER_Load, (mfxSession session, const mfxPluginUID *uid, mfxU32 version), (session, uid, version)) FUNCTION(mfxStatus, MFXAudioUSER_UnLoad, (mfxSession session, const mfxPluginUID *uid), (session, uid)) #endif //!defined(MEDIASDK_UWP_DISPATCHER) mfxStatus MFXJoinSession(mfxSession session, mfxSession child_session) { mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; MFX_DISP_HANDLE *pHandle = (MFX_DISP_HANDLE *)session; MFX_DISP_HANDLE *pChildHandle = (MFX_DISP_HANDLE *)child_session; // get the function's address and make a call if ((pHandle) && (pChildHandle) && (pHandle->actualApiVersion == pChildHandle->actualApiVersion)) { /* check whether it is audio session or video */ int tableIndex = eMFXJoinSession; mfxFunctionPointer pFunc; pFunc = pHandle->callTable[tableIndex]; if (pFunc) { // pass down the call mfxRes = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxSession))pFunc)(pHandle->session, pChildHandle->session); } } return mfxRes; } // mfxStatus MFXJoinSession(mfxSession session, mfxSession child_session) static mfxStatus AllocateCloneHandle(MFX_DISP_HANDLE *parentHandle, MFX_DISP_HANDLE **cloneHandle) { MFX_DISP_HANDLE *ph = parentHandle; MFX_DISP_HANDLE *ch = nullptr; if (!ph || !ph->hModule) return MFX_ERR_NULL_PTR; // get full path to the DLL of the parent session wchar_t dllName[MFX::msdk_disp_path_len]; DWORD nSize = GetModuleFileNameW((HMODULE)(ph->hModule), dllName, msdk_disp_path_len); if (nSize == 0 || nSize == msdk_disp_path_len) return MFX_ERR_UNSUPPORTED; try { // requested version matches original session ch = new MFX_DISP_HANDLE(ph->apiVersion); } catch (...) { return MFX_ERR_MEMORY_ALLOC; } // initialization param structs are not used when bCloneSession == true mfxInitParam par = {}; mfxInitializationParam vplParam = {}; // initialization extBufs are not saved at this level // the RT should save these when the parent session is created and may use // them when creating the cloned session par.NumExtParam = 0; // load the selected DLL, fill out function pointer tables and other state mfxStatus sts = ch->LoadSelectedDLL(dllName, ph->implType, ph->impl, ph->implInterface, par, vplParam, true); // unload the failed DLL if (sts) { ch->Close(); delete ch; return MFX_ERR_UNSUPPORTED; } else { ch->storageID = MFX::MFX_UNKNOWN_KEY; } *cloneHandle = ch; return MFX_ERR_NONE; } mfxStatus MFXCloneSession(mfxSession session, mfxSession *clone) { mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; MFX_DISP_HANDLE *pHandle = (MFX_DISP_HANDLE *)session; mfxVersion apiVersion; mfxIMPL impl; if (!clone) return MFX_ERR_NULL_PTR; *clone = NULL; // check error(s) if (pHandle) { // initialize the clone session // for runtimes with 1.x API, call MFXInit followed by MFXJoinSession // for runtimes with 2.x API, use RT implementation of MFXCloneSession (passthrough) apiVersion = pHandle->actualApiVersion; if (apiVersion.Major == 1) { impl = pHandle->impl | pHandle->implInterface; mfxRes = MFXInit(impl, &apiVersion, clone); if (MFX_ERR_NONE != mfxRes) { return mfxRes; } // join the sessions mfxRes = MFXJoinSession(session, *clone); if (MFX_ERR_NONE != mfxRes) { MFXClose(*clone); *clone = NULL; return mfxRes; } } else if (apiVersion.Major == 2) { int tableIndex = eMFXCloneSession; mfxFunctionPointer pFunc; pFunc = pHandle->callTable[tableIndex]; if (!pFunc) return MFX_ERR_UNSUPPORTED; // allocate new dispatcher-level session object and initialize state // (function pointer tables, impl type, etc.) MFX_DISP_HANDLE *cloneHandle; mfxRes = AllocateCloneHandle(pHandle, &cloneHandle); if (mfxRes != MFX_ERR_NONE) return mfxRes; // call RT implementation of MFXCloneSession mfxSession cloneRT; mfxRes = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxSession *))pFunc)(pHandle->session, &cloneRT); if (mfxRes != MFX_ERR_NONE || cloneRT == NULL) { // RT call failed, delete cloned session delete cloneHandle; return MFX_ERR_UNSUPPORTED; } cloneHandle->session = cloneRT; // get version of cloned session mfxVersion cloneVersion = {}; mfxRes = MFXQueryVersion((mfxSession)cloneHandle, &cloneVersion); if (mfxRes != MFX_ERR_NONE) { MFXClose(cloneHandle); return MFX_ERR_UNSUPPORTED; } cloneHandle->actualApiVersion = cloneVersion; *clone = (mfxSession)cloneHandle; } else { return MFX_ERR_UNSUPPORTED; } } return mfxRes; } // mfxStatus MFXCloneSession(mfxSession session, mfxSession *clone) mfxStatus MFXInit(mfxIMPL impl, mfxVersion *pVer, mfxSession *session) { mfxInitParam par = {}; par.Implementation = impl; if (pVer) { par.Version = *pVer; } else { par.Version.Major = DEFAULT_API_VERSION_MAJOR; par.Version.Minor = DEFAULT_API_VERSION_MINOR; } par.ExternalThreads = 0; return MFXInitEx(par, session); } // passthrough functions to implementation mfxStatus MFXMemory_GetSurfaceForVPP(mfxSession session, mfxFrameSurface1 **surface) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXMemory_GetSurfaceForVPP]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxFrameSurface1 **))pFunc)(session, surface); } return sts; } mfxStatus MFXMemory_GetSurfaceForVPPOut(mfxSession session, mfxFrameSurface1 **surface) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXMemory_GetSurfaceForVPPOut]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxFrameSurface1 **))pFunc)(session, surface); } return sts; } mfxStatus MFXMemory_GetSurfaceForEncode(mfxSession session, mfxFrameSurface1 **surface) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXMemory_GetSurfaceForEncode]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxFrameSurface1 **))pFunc)(session, surface); } return sts; } mfxStatus MFXMemory_GetSurfaceForDecode(mfxSession session, mfxFrameSurface1 **surface) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXMemory_GetSurfaceForDecode]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxFrameSurface1 **))pFunc)(session, surface); } return sts; } mfxStatus MFXVideoDECODE_VPP_Init(mfxSession session, mfxVideoParam *decode_par, mfxVideoChannelParam **vpp_par_array, mfxU32 num_vpp_par) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoDECODE_VPP_Init]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxVideoParam *, mfxVideoChannelParam **, mfxU32)) pFunc)(session, decode_par, vpp_par_array, num_vpp_par); } return sts; } mfxStatus MFXVideoDECODE_VPP_DecodeFrameAsync(mfxSession session, mfxBitstream *bs, mfxU32 *skip_channels, mfxU32 num_skip_channels, mfxSurfaceArray **surf_array_out) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoDECODE_VPP_DecodeFrameAsync]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus( MFX_CDECL *)(mfxSession, mfxBitstream *, mfxU32 *, mfxU32, mfxSurfaceArray **)) pFunc)(session, bs, skip_channels, num_skip_channels, surf_array_out); } return sts; } mfxStatus MFXVideoDECODE_VPP_Reset(mfxSession session, mfxVideoParam *decode_par, mfxVideoChannelParam **vpp_par_array, mfxU32 num_vpp_par) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoDECODE_VPP_Reset]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxVideoParam *, mfxVideoChannelParam **, mfxU32)) pFunc)(session, decode_par, vpp_par_array, num_vpp_par); } return sts; } mfxStatus MFXVideoDECODE_VPP_GetChannelParam(mfxSession session, mfxVideoChannelParam *par, mfxU32 channel_id) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoDECODE_VPP_GetChannelParam]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxVideoChannelParam *, mfxU32))pFunc)( session, par, channel_id); } return sts; } mfxStatus MFXVideoDECODE_VPP_Close(mfxSession session) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoDECODE_VPP_Close]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession))pFunc)(session); } return sts; } mfxStatus MFXVideoVPP_ProcessFrameAsync(mfxSession session, mfxFrameSurface1 *in, mfxFrameSurface1 **out) { mfxStatus sts = MFX_ERR_INVALID_HANDLE; if (!session) return MFX_ERR_INVALID_HANDLE; struct _mfxSession *pHandle = (struct _mfxSession *)session; mfxFunctionPointer pFunc; pFunc = pHandle->callVideoTable2[eMFXVideoVPP_ProcessFrameAsync]; if (pFunc) { session = pHandle->session; sts = (*(mfxStatus(MFX_CDECL *)(mfxSession, mfxFrameSurface1 *, mfxFrameSurface1 **))pFunc)( session, in, out); } return sts; } // // // implement all other calling functions. // They just call a procedure of DLL library from the table. // // define for common functions (from mfxsession.h) #undef FUNCTION #define FUNCTION(return_value, func_name, formal_param_list, actual_param_list) \ return_value func_name formal_param_list { \ mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; \ _mfxSession *pHandle = (_mfxSession *)session; \ /* get the function's address and make a call */ \ if (pHandle) { \ /* check whether it is audio session or video */ \ int tableIndex = e##func_name; \ mfxFunctionPointer pFunc; \ pFunc = pHandle->callTable[tableIndex]; \ if (pFunc) { \ /* get the real session pointer */ \ session = pHandle->session; \ /* pass down the call */ \ mfxRes = (*(mfxStatus(MFX_CDECL *) formal_param_list)pFunc)actual_param_list; \ } \ } \ return mfxRes; \ } FUNCTION(mfxStatus, MFXQueryIMPL, (mfxSession session, mfxIMPL *impl), (session, impl)) FUNCTION(mfxStatus, MFXQueryVersion, (mfxSession session, mfxVersion *version), (session, version)) // these functions are not necessary in LOADER part of dispatcher and // need to be included only in in SOLID dispatcher or PROCTABLE part of dispatcher FUNCTION(mfxStatus, MFXDisjoinSession, (mfxSession session), (session)) FUNCTION(mfxStatus, MFXSetPriority, (mfxSession session, mfxPriority priority), (session, priority)) FUNCTION(mfxStatus, MFXGetPriority, (mfxSession session, mfxPriority *priority), (session, priority)) #undef FUNCTION #define FUNCTION(return_value, func_name, formal_param_list, actual_param_list) \ return_value func_name formal_param_list { \ mfxStatus mfxRes = MFX_ERR_INVALID_HANDLE; \ _mfxSession *pHandle = (_mfxSession *)session; \ /* get the function's address and make a call */ \ if (pHandle) { \ mfxFunctionPointer pFunc = pHandle->callTable[e##func_name]; \ if (pFunc) { \ /* get the real session pointer */ \ session = pHandle->session; \ /* pass down the call */ \ mfxRes = (*(mfxStatus(MFX_CDECL *) formal_param_list)pFunc)actual_param_list; \ } \ } \ return mfxRes; \ } #include "windows/mfx_exposed_functions_list.h"