file
function     void FAndroidPlatformBackgroundHttpManager::ActivatePendingRequests

				WorkParams.AddDataToWorkerParameters(FAndroidNativeDownloadWorkerParameterKeys::DOWNLOAD_DESCRIPTION_LIST_KEY, FileNameForDownloadDescList);
					
				//Set our MaxActiveDownloads in the underlying java layer to match our expectation
				WorkParams.AddDataToWorkerParameters(FAndroidNativeDownloadWorkerParameterKeys::DOWNLOAD_MAX_CONCURRENT_REQUESTS_KEY, MaxActiveDownloads);

				WorkParams.AddDataToWorkerParameters(FAndroidNativeDownloadWorkerParameterKeys::CELLULAR_HANDLE_KEY, CVarEnableCellularHandling.GetValueOnGameThread());

				//Make sure we pass in localized notification text bits for the important worker keys
				WorkParams.AddDataToWorkerParameters(FAndroidNativeDownloadWorkerParameterKeys::NOTIFICATION_CONTENT_TITLE_KEY, AndroidBackgroundHTTPManagerDefaultLocalizedText.DefaultNotificationText_Title.GetText());
				WorkParams.AddDataToWorkerParameters(FAndroidNativeDownloadWorkerParameterKeys::NOTIFICATION_CONTENT_COMPLETE_TEXT_KEY, AndroidBackgroundHTTPManagerDefaultLocalizedText.DefaultNotificationText_Complete.GetText());

file
function     FBackgroundHttpManagerImpl::FBackgroundHttpManagerImpl

	, ActiveRequestLock()
	, NumCurrentlyActiveRequests(0)
	, MaxActiveDownloads(4)
	, FileHashHelper(MakeShared<FBackgroundHttpFileHashHelper, ESPMode::ThreadSafe>())
{
}

FBackgroundHttpManagerImpl::~FBackgroundHttpManagerImpl()
{

file
function     void FBackgroundHttpManagerImpl::Initialize

	// Can't read into an atomic int directly
	int MaxActiveDownloadsConfig = 4;
	ensureAlwaysMsgf(GConfig->GetInt(TEXT("BackgroundHttp"), TEXT("MaxActiveDownloads"), MaxActiveDownloadsConfig, GEngineIni), TEXT("No value found for MaxActiveDownloads! Defaulting to 4!"));
	MaxActiveDownloads = MaxActiveDownloadsConfig;
}

void FBackgroundHttpManagerImpl::Shutdown()
{
	//Pending Requests Clear
	{

file
function     int FBackgroundHttpManagerImpl::GetMaxActiveDownloads

int FBackgroundHttpManagerImpl::GetMaxActiveDownloads() const
{
	return MaxActiveDownloads;
}

void FBackgroundHttpManagerImpl::SetMaxActiveDownloads(int InMaxActiveDownloads)
{
	MaxActiveDownloads = InMaxActiveDownloads;
}

void FBackgroundHttpManagerImpl::AddRequest(const FBackgroundHttpRequestPtr Request)
{
	UE_LOG(LogBackgroundHttpManager, VeryVerbose, TEXT("AddRequest Called - RequestID:%s"), *Request->GetRequestID());

file
function     bool FBackgroundHttpManagerImpl::Tick

	ensureAlwaysMsgf(IsInGameThread(), TEXT("Called from un-expected thread! Potential error in an implementation of background downloads!"));
	CSV_CUSTOM_STAT(BackgroundDownload, MaxActiveDownloads, MaxActiveDownloads, ECsvCustomStatOp::Set);
	CSV_CUSTOM_STAT(BackgroundDownload, PendingStartRequests, PendingStartRequests.Num(), ECsvCustomStatOp::Set);
	CSV_CUSTOM_STAT(BackgroundDownload, NumCurrentlyActiveRequests, NumCurrentlyActiveRequests, ECsvCustomStatOp::Set);
	ActivatePendingRequests();
	
	//for now we are saving data every tick, could change this to be on an interval later if required
	GetFileHashHelper()->SaveData();

file
function     void FBackgroundHttpManagerImpl::ActivatePendingRequests

		FRWScopeLock ActiveScopeLock(ActiveRequestLock, SLT_ReadOnly);
		FRWScopeLock PendingScopeLock(PendingRequestLock, SLT_ReadOnly);
		const int NumRequestsWeCanProcess = (MaxActiveDownloads - NumCurrentlyActiveRequests);
		if (NumRequestsWeCanProcess > 0)
		{
			if (PendingStartRequests.Num() > 0)
			{
				UE_LOG(LogBackgroundHttpManager, Verbose, TEXT("Populating Requests to Start from PendingStartRequests - MaxActiveDownloads:%d | NumCurrentlyActiveRequests:%d | NumPendingStartRequests:%d"), MaxActiveDownloads.Load(), NumCurrentlyActiveRequests, PendingStartRequests.Num());

				HighestPriorityRequestToStart = PendingStartRequests[0];
				HighestRequestPriority = HighestPriorityRequestToStart.IsValid() ? HighestPriorityRequestToStart->GetRequestPriority() : EBackgroundHTTPPriority::Num;

				//See how many more requests we can process and only do anything if we can still process more
				{

file
function     FApplePlatformBackgroundHttpManager::FApplePlatformBackgroundHttpManager

    , RequestsPendingRemove()
    , NumCurrentlyActiveTasks(0)
	, MaxNumActualTasks(MaxActiveDownloads)
{
}

void FApplePlatformBackgroundHttpManager::Initialize()
{
	//Initialize UnAssociatedTasks

file
function     void FApplePlatformBackgroundHttpManager::PopulateUnAssociatedTasks

	FBackgroundHttpManagerImpl::SetMaxActiveDownloads(InMaxActiveDownloads);

	// It's possible we have more than the new maximum active right now, so we gracefully reduce MaxNumActualTasks down to MaxActiveDownloads as the extra tasks finish.
	MaxNumActualTasks = FMath::Max(MaxActiveDownloads.Load(), FPlatformAtomics::AtomicRead(&NumCurrentlyActiveTasks));
}

bool FApplePlatformBackgroundHttpManager::AssociateWithAnyExistingUnAssociatedTasks(const FBackgroundHttpRequestPtr Request)
{
    bool bDidAssociateWithUnAssociatedTask = false;
    

file
function     void FApplePlatformBackgroundHttpManager::FinishRequest

                    int NumActualTasks = FPlatformAtomics::InterlockedDecrement(&NumCurrentlyActiveTasks);

					// Handle the case that SetMaxActiveDownloads reduced the MaxActiveDownloads while we had more than the new maximum in progress.
					MaxNumActualTasks = FMath::Max(MaxNumActualTasks - 1, MaxActiveDownloads.Load());

                    //Sanity check that our data is valid. Shouldn't ever trip if everything is working as intended.
                    const bool bNumActualTasksIsValid = ((NumActualTasks >= 0) && (NumActualTasks <= MaxNumActualTasks));
                    
                    UE_LOG(LogBackgroundHttpManager,Display, TEXT("Finishing Request lowering Task Count: %d"), NumActualTasks);
                    

file
function     void FApplePlatformBackgroundHttpManager::TickRequests

		//Check to make sure we have room for more tasks to be active first
		int CurrentCount = FPlatformAtomics::AtomicRead(&NumCurrentlyActiveTasks);
		bool bNeedsMoreTasks = (CurrentCount < MaxActiveDownloads);
		FAppleBackgroundHttpRequestPtr FoundRequestToStart = nullptr;
		
        FRWScopeLock ScopeLock(ActiveRequestLock, SLT_ReadOnly);
        for (FBackgroundHttpRequestPtr& Request : ActiveRequests)
        {
            FAppleBackgroundHttpRequestPtr AppleRequest = StaticCastSharedPtr<FApplePlatformBackgroundHttpRequest>(Request);

file
function     void FApplePlatformBackgroundHttpManager::TickRequests

			const int32 OldTotal = FPlatformAtomics::InterlockedIncrement(&NumCurrentlyActiveTasks);
			
			if (OldTotal <= MaxActiveDownloads)
			{
				UE_LOG(LogBackgroundHttpManager, Display, TEXT("Starting Task for Request -- RequestDebugID:%s | CurrentlyActiveRequests:%d"), *(FoundRequestToStart->GetRequestDebugID()), OldTotal);
				FoundRequestToStart->ActivateUnderlyingTask();
			}
			else
			{

file
class        class FBackgroundHttpManagerImpl : public IBackgroundHttpManager , public FTSTickerObjectBase

	
	BACKGROUNDHTTP_API virtual int GetMaxActiveDownloads() const override;
	BACKGROUNDHTTP_API virtual void SetMaxActiveDownloads(int MaxActiveDownloads) override;

	
	BACKGROUNDHTTP_API virtual FString GetTempFileLocationForURL(const FString& URL) override;
	
	BACKGROUNDHTTP_API virtual void CleanUpDataAfterCompletingRequest(const FBackgroundHttpRequestPtr Request) override;
	BACKGROUNDHTTP_API virtual void SetCellularPreference(int32 Value) override;

file
class        class FBackgroundHttpManagerImpl : public IBackgroundHttpManager , public FTSTickerObjectBase

	/** Count of how many requests we have active **/
	volatile int NumCurrentlyActiveRequests;
	TAtomic<int> MaxActiveDownloads;
	
private:
	BackgroundHttpFileHashHelperRef FileHashHelper;
};

file
class        class FApplePlatformBackgroundHttpManager : public FBackgroundHttpManagerImpl

	virtual void RemoveRequest(const FBackgroundHttpRequestPtr Request) override;
	virtual bool IsGenericImplementation() const override { return false;  }
	virtual void SetMaxActiveDownloads(int MaxActiveDownloads) override;

	/**
	* Constructor
	*/
	FApplePlatformBackgroundHttpManager();

file
class        class IBackgroundHttpManager : public TSharedFromThis<IBackgroundHttpManager>

	* Function that sets how many active BackgroundHttpRequests we should have actively downloading at once.
	*
	* @param MaxActiveDownloads the maximum number of downloads that should be active at once
	*/
	virtual void SetMaxActiveDownloads(int MaxActiveDownloads) = 0;

	/**
	 * Function that returns an FString fullpath where we would expect the given URL's temp file to be located
	 *
	 */
	virtual FString GetTempFileLocationForURL(const FString& URL) = 0;
	
	/**