OnDemandHttpIoDispacher.cpp File Reference

#include "OnDemandHttpIoDispatcher.h"
#include "Async/Mutex.h"
#include "Async/UniqueLock.h"
#include "AtomicFlags.h"
#include "Containers/AnsiString.h"
#include "CVarUtilities.h"
#include "Experimental/ConcurrentLinearAllocator.h"
#include "HAL/Platform.h"
#include "HAL/Runnable.h"
#include "HAL/RunnableThread.h"
#include "IO/HttpIoDispatcher.h"
#include "IO/IoContainers.h"
#include "IO/IoStoreOnDemand.h"
#include "IasCache.h"
#include "IasHostGroup.h"
#include "Logging/LogVerbosity.h"
#include "Logging/StructuredLog.h"
#include "Misc/CommandLine.h"
#include "Misc/EnumClassFlags.h"
#include "Misc/Fork.h"
#include "Misc/SingleThreadRunnable.h"
#include "OnDemandHttpClient.h"
#include "OnDemandHttpThread.h"
#include "Statistics.h"
#include <atomic>

Classes
class	UE::IoStore::HttpIoDispatcher::FCancelationToken
struct	UE::IoStore::HttpIoDispatcher::FHttpRequestBlockAllocationTag
struct	UE::IoStore::HttpIoDispatcher::FHttpRequest
class	UE::IoStore::HttpIoDispatcher::FHttpQueue
class	UE::IoStore::HttpIoDispatcher::FHttpDispatcher

Namespaces
namespace	UE
namespace	UE::IoStore
	NO_LOGGING.
namespace	UE::IoStore::HttpIoDispatcher

Macros
#define	UE_ALLOW_INVALID_URL_DEBUGGING   !UE_BUILD_SHIPPING
#define	UE_ALLOW_CACHE_POISONING   !UE_BUILD_SHIPPING

Typedefs
using	UE::IoStore::HttpIoDispatcher::FHttpRequestList = TIntrusiveList< FHttpRequest >

Enumerations
enum class	UE::IoStore::HttpIoDispatcher::EHttpRequestFlags : uint32 {   UE::IoStore::HttpIoDispatcher::None = 0 , UE::IoStore::HttpIoDispatcher::Issued = (1 << 0) , UE::IoStore::HttpIoDispatcher::CacheInflight = (1 << 1) , UE::IoStore::HttpIoDispatcher::HttpQueued = (1 << 2) ,   UE::IoStore::HttpIoDispatcher::HttpInflight = (1 << 3) , UE::IoStore::HttpIoDispatcher::CancelRequested = (1 << 4) , UE::IoStore::HttpIoDispatcher::Completing = (1 << 5) , UE::IoStore::HttpIoDispatcher::Completed = (1 << 6) }

Functions
const TCHAR *	LexToString (EThreadPriority Priority)
	UE::IoStore::DECLARE_MULTICAST_DELEGATE (FOnRecreateHttpClient)
	UE::IoStore::HttpIoDispatcher::ENUM_CLASS_FLAGS (EHttpRequestFlags)
FIoHttpRange	UE::IoStore::HttpIoDispatcher::GetTotalRange (FHttpRequest *Request)
void	UE::IoStore::HttpIoDispatcher::DebugPrintRange (FHttpRequest *Requests, const UE::FIoHttpRange &TotalRange)
TSharedPtr< IOnDemandHttpIoDispatcher >	UE::IoStore::MakeOnDemanHttpIoDispatcher (TUniquePtr< class IIasCache > &&Cache)

Variables
FOnRecreateHttpClient	UE::IoStore::OnRecreateHttpClient
int32	UE::IoStore::GIasHttpTimeOutMs = 10 * 1000
int32	UE::IoStore::GOnDemandBackendThreadPriorityIndex = 4
bool	UE::IoStore::GIaxHttpEnableInflightCancellation = true
float	UE::IoStore::GIaxInvalidUrlChance = 0.0
bool	UE::IoStore::GIasPoisonCache = false
bool	UE::IoStore::GHttpCacheEnabled = true

Macro Definition Documentation

UE_ALLOW_CACHE_POISONING

#define UE_ALLOW_CACHE_POISONING   !UE_BUILD_SHIPPING

UE_ALLOW_INVALID_URL_DEBUGGING

#define UE_ALLOW_INVALID_URL_DEBUGGING   !UE_BUILD_SHIPPING

Function Documentation

LexToString()

const TCHAR * LexToString ( EThreadPriority  Priority )

extern