HttpThread.cpp File Reference

#include "HttpThread.h"
#include "GenericPlatform/HttpRequestCommon.h"
#include "HAL/PlatformTime.h"
#include "HAL/PlatformProcess.h"
#include "HAL/RunnableThread.h"
#include "HAL/IConsoleManager.h"
#include "HttpManager.h"
#include "Misc/App.h"
#include "Misc/ConfigCacheIni.h"
#include "Misc/CommandLine.h"
#include "Misc/Fork.h"
#include "Misc/Parse.h"
#include "HttpModule.h"
#include "Http.h"
#include "PlatformHttp.h"
#include "Stats/Stats.h"
#include "Templates/UnrealTemplate.h"

Classes
class	FHttpTaskTimerHandleFTSTicker

Functions
	DECLARE_STATS_GROUP (TEXT("HTTP Thread"), STATGROUP_HTTPThread, STATCAT_Advanced)
	DECLARE_CYCLE_STAT (TEXT("Process"), STAT_HTTPThread_Process, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("TickThreadedRequest"), STAT_HTTPThread_TickThreadedRequest, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("StartThreadedRequest"), STAT_HTTPThread_StartThreadedRequest, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("HttpThreadTick"), STAT_HTTPThread_HttpThreadTick, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("IsThreadedRequestComplete"), STAT_HTTPThread_IsThreadedRequestComplete, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("CompleteThreadedRequest"), STAT_HTTPThread_CompleteThreadedRequest, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("ActiveSleep"), STAT_HTTPThread_ActiveSleep, STATGROUP_HTTPThread)
	DECLARE_CYCLE_STAT (TEXT("IdleSleep"), STAT_HTTPThread_IdleSleep, STATGROUP_HTTPThread)

Variables
TAutoConsoleVariable< int32 >	CVarHttpMaxConcurrentRequests (TEXT("http.MaxConcurrentRequests"), UE_HTTP_DEFAULT_MAX_CONCURRENT_REQUESTS, TEXT("The max number of http requests to run in parallel"), ECVF_SaveForNextBoot)
TAutoConsoleVariable< int32 >	CVarHttpDurationInQueueToWarnInSeconds (TEXT("http.DurationInQueueToWarnInSeconds"), 10,)
TAutoConsoleVariable< bool >	CVarHttpRequestPriorityEnabled (TEXT("http.RequestPriorityEnabled"), true, TEXT("Whether to enable http request priority in the queue when max requests limit reached."), ECVF_SaveForNextBoot)
TAutoConsoleVariable< bool >	CVarHttpRemoveRequestUsingHttpThreadPolicyOnHttpThread
const int32	GHttpThreadPriorities []
const TCHAR *	GHttpThreadPriortyNames []
FAutoConsoleVariableRef	CVarHttpThreadPriority (TEXT("http.ThreadPriority"), GHttpThreadPriorityIndex, TEXT("Note that this is switchable at runtime"), ECVF_Default)

Function Documentation

DECLARE_CYCLE_STAT() [1/8]

DECLARE_CYCLE_STAT	(	TEXT("ActiveSleep")	,
		STAT_HTTPThread_ActiveSleep	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [2/8]

DECLARE_CYCLE_STAT	(	TEXT("CompleteThreadedRequest")	,
		STAT_HTTPThread_CompleteThreadedRequest	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [3/8]

DECLARE_CYCLE_STAT	(	TEXT("HttpThreadTick")	,
		STAT_HTTPThread_HttpThreadTick	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [4/8]

DECLARE_CYCLE_STAT	(	TEXT("IdleSleep")	,
		STAT_HTTPThread_IdleSleep	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [5/8]

DECLARE_CYCLE_STAT	(	TEXT("IsThreadedRequestComplete")	,
		STAT_HTTPThread_IsThreadedRequestComplete	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [6/8]

DECLARE_CYCLE_STAT	(	TEXT("Process")	,
		STAT_HTTPThread_Process	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [7/8]

DECLARE_CYCLE_STAT	(	TEXT("StartThreadedRequest")	,
		STAT_HTTPThread_StartThreadedRequest	,
		STATGROUP_HTTPThread
	)

DECLARE_CYCLE_STAT() [8/8]

DECLARE_CYCLE_STAT	(	TEXT("TickThreadedRequest")	,
		STAT_HTTPThread_TickThreadedRequest	,
		STATGROUP_HTTPThread
	)

DECLARE_STATS_GROUP()

DECLARE_STATS_GROUP	(	TEXT("HTTP Thread")	,
		STATGROUP_HTTPThread	,
		STATCAT_Advanced
	)

Variable Documentation

CVarHttpDurationInQueueToWarnInSeconds

TAutoConsoleVariable< int32 > CVarHttpDurationInQueueToWarnInSeconds(TEXT("http.DurationInQueueToWarnInSeconds"), 10,)	(	TEXT("http.DurationInQueueToWarnInSeconds")	,
		10
	)

CVarHttpMaxConcurrentRequests

TAutoConsoleVariable< int32 > CVarHttpMaxConcurrentRequests(TEXT("http.MaxConcurrentRequests"), UE_HTTP_DEFAULT_MAX_CONCURRENT_REQUESTS, TEXT("The max number of http requests to run in parallel"), ECVF_SaveForNextBoot)	(	TEXT("http.MaxConcurrentRequests")	,
		UE_HTTP_DEFAULT_MAX_CONCURRENT_REQUESTS	,
		TEXT("The max number of http requests to run in parallel")	,
		ECVF_SaveForNextBoot
	)

CVarHttpRemoveRequestUsingHttpThreadPolicyOnHttpThread

TAutoConsoleVariable<bool> CVarHttpRemoveRequestUsingHttpThreadPolicyOnHttpThread

extern

CVarHttpRequestPriorityEnabled

TAutoConsoleVariable< bool > CVarHttpRequestPriorityEnabled(TEXT("http.RequestPriorityEnabled"), true, TEXT("Whether to enable http request priority in the queue when max requests limit reached."), ECVF_SaveForNextBoot)	(	TEXT("http.RequestPriorityEnabled")	,
		true	,
		TEXT("Whether to enable http request priority in the queue when max requests limit reached.")	,
		ECVF_SaveForNextBoot
	)

CVarHttpThreadPriority

FAutoConsoleVariableRef CVarHttpThreadPriority(TEXT("http.ThreadPriority"), GHttpThreadPriorityIndex, TEXT("Note that this is switchable at runtime"), ECVF_Default)	(	TEXT("http.ThreadPriority")	,
		GHttpThreadPriorityIndex	,
		TEXT("Note that this is switchable at runtime")	,
		ECVF_Default
	)

GHttpThreadPriorities

const int32 GHttpThreadPriorities[]

Initial value:

=
{
    EThreadPriority::TPri_Lowest,
    EThreadPriority::TPri_BelowNormal,
    EThreadPriority::TPri_SlightlyBelowNormal,
    EThreadPriority::TPri_Normal,
    EThreadPriority::TPri_AboveNormal
}

GHttpThreadPriortyNames

const TCHAR* GHttpThreadPriortyNames[]

Initial value:

=
{
    TEXT("TPri_Lowest"),
    TEXT("TPri_BelowNormal"),
    TEXT("TPri_SlightlyBelowNormal"),
    TEXT("TPri_Normal"),
 
}