RuntimeAssetCacheAsyncWorker.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "Containers/UnrealString.h"
#include "UObject/NameTypes.h"
#include "Stats/Stats.h"
#include "Async/AsyncWork.h"
#include "RuntimeAssetCacheInterface.h"
#include "RuntimeAssetCachePrivate.h"
 
class FRuntimeAssetCacheBucket;
class IRuntimeAssetCacheBuilder;
class UClass;
 
DECLARE_DWORD_ACCUMULATOR_STAT_EXTERN(TEXT("RAC Num Build"), STAT_RAC_NumBuilds, STATGROUP_RAC, );
DECLARE_DWORD_ACCUMULATOR_STAT_EXTERN(TEXT("RAC Num Cache Hits"), STAT_RAC_NumCacheHits, STATGROUP_RAC, );
DECLARE_DWORD_ACCUMULATOR_STAT_EXTERN(TEXT("RAC Num Retrieve fails"), STAT_RAC_NumFails, STATGROUP_RAC, );
DECLARE_DWORD_ACCUMULATOR_STAT_EXTERN(TEXT("RAC Num Gets"), STAT_RAC_NumGets, STATGROUP_RAC, );
DECLARE_DWORD_ACCUMULATOR_STAT_EXTERN(TEXT("RAC Num Puts"), STAT_RAC_NumPuts, STATGROUP_RAC, );
 
class IRuntimeAssetCacheBuilder;
class FRuntimeAssetCacheBucket;
 
class FRuntimeAssetCacheAsyncWorker : public FNonAbandonableTask
{
public:
    FRuntimeAssetCacheAsyncWorker(IRuntimeAssetCacheBuilder* InCacheBuilder, TMap<FName, FRuntimeAssetCacheBucket*>* InBuckets, int32 InHandle, const FOnRuntimeAssetCacheAsyncComplete& InCompletionCallback);
 
    void DoWork();
    TStatId GetStatId() const;
    void* GetData()
    {
        return Data;
    }
 
    int64 GetDataSize()
    {
        return DataSize;
    }
 
    FVoidPtrParam GetDataAndSize()
    {
        return FVoidPtrParam(Data, DataSize);
    }
 
    void FireCompletionDelegate();
 
private:
    bool FiredCompletionDelegate() const
    {
        return bFiredCompletionDelegate;
    }
 
    static FString SanitizeCacheKey(const TCHAR* CacheKey);
 
    static FString BuildCacheKey(const TCHAR* VersionString, const TCHAR* PluginSpecificCacheKeySuffix);
 
    static FString BuildCacheKey(IRuntimeAssetCacheBuilder* CacheBuilder);
 
    void FreeCacheSpace(FName Bucket, int32 SizeOfSpaceToFreeInBytes);
 
    IRuntimeAssetCacheBuilder* CacheBuilder;
    
    void* Data;
 
    int64 DataSize;
 
    TMap<FName, FRuntimeAssetCacheBucket*>* Buckets;
 
    bool bEntryRetrieved;
 
    FOnRuntimeAssetCacheAsyncComplete CompletionCallback;
 
    int32 Handle;
 
    bool bFiredCompletionDelegate;
 
    UClass* Class;
};