Method start

framework/cacheModule/CacheModule.cpp:103–175

}

CacheRet CacheModule::start()
{
    {
        unique_lock<mutex> lock(mStatusMutex);

        if (mStatus == Status::Stopped) {
            AF_LOGE("---> start()  , mStatus == Status::Stopped return ");
            return CACHE_ERROR_STATUS;
        }
    }
    AF_LOGD("---> start()");
    const CacheRet &canCheck = checkCanCache();

    if (canCheck.mCode != CACHE_SUCCESS.mCode) {
        AF_LOGE("---> start()  , checkCanCache fail.. return ");
        return canCheck;
    }

    {
        std::unique_lock<mutex> remuxerLock(mReumxerMutex);

        if (mCacheFileRemuxer != nullptr) {
            mCacheFileRemuxer->interrupt();
            mCacheFileRemuxer->stop();
            delete mCacheFileRemuxer;
            mCacheFileRemuxer = nullptr;
        }

        string cacheTmpPath = mCachePath.getCachePath() + TMP_SUFFIX;
        mCacheFileRemuxer = new CacheFileRemuxer(cacheTmpPath, mDescription);
        mCacheFileRemuxer->setStreamMeta(&mStreamMetas);
        mCacheFileRemuxer->setErrorCallback([this](int code, string msg) -> void {
            if (mErrorCallback != nullptr) {
                mErrorCallback(code, msg);
            }
        });
        mCacheFileRemuxer->setResultCallback([this](bool success) -> void {
            const string &cachePath = mCachePath.getCachePath();
            string cacheTmpFilePath = cachePath + TMP_SUFFIX;
            if (success) {
                bool ret = FileUtils::Rename(cacheTmpFilePath.c_str(), cachePath.c_str());

                if (ret) {
                    mCacheRet = CacheStatus::success;
                } else {
                    FileUtils::rmrf(cacheTmpFilePath.c_str());
                    mCacheRet = CacheStatus::fail;
                }
            } else {
                // not completion ,  need delete cached file
                FileUtils::rmrf(cacheTmpFilePath.c_str());
                mCacheRet = CacheStatus::fail;
            }

            if (mResultCallback != nullptr) {
                mResultCallback(success);
            }
        });