XrdThrottleManager Class Reference

#include <XrdThrottleManager.hh>

Collaboration diagram for XrdThrottleManager:

Public Member Functions
void	Init ()
void	Apply (int reqsize, int reqops, int uid)
bool	IsThrottling ()
void	SetThrottles (float reqbyterate, float reqoprate, int concurrency, float interval_length)
void	SetLoadShed (std::string &hostname, unsigned port, unsigned frequency)
XrdThrottleTimer	StartIOTimer ()
void	PrepLoadShed (const char *opaque, std::string &lsOpaque)
bool	CheckLoadShed (const std::string &opaque)
void	PerformLoadShed (const std::string &opaque, std::string &host, unsigned &port)
	XrdThrottleManager (XrdSysError *lP, XrdOucTrace *tP)
	~XrdThrottleManager ()

Static Public Member Functions
static int	GetUid (const char *username)

Protected Member Functions
void	StopIOTimer (struct timespec)

Private Member Functions
void	Recompute ()
void	RecomputeInternal ()
int	WaitForShares ()
void	GetShares (int &shares, int &request)
void	StealShares (int uid, int &reqsize, int &reqops)

Static Private Member Functions
static void *	RecomputeBootstrap (void *pp)

Private Attributes
XrdOucTrace *	m_trace
XrdSysError *	m_log
XrdSysCondVar	m_compute_var
float	m_interval_length_seconds
float	m_bytes_per_second
float	m_ops_per_second
int	m_concurrency_limit
std::vector< int >	m_primary_bytes_shares
std::vector< int >	m_secondary_bytes_shares
std::vector< int >	m_primary_ops_shares
std::vector< int >	m_secondary_ops_shares
int	m_last_round_allocation
int	m_io_counter
struct timespec	m_io_wait
int	m_stable_io_counter
struct timespec	m_stable_io_wait
std::string	m_loadshed_host
unsigned	m_loadshed_port
unsigned	m_loadshed_frequency
int	m_loadshed_limit_hit

Static Private Attributes
static const int	m_max_users
static const char *	TraceID

Friends
class	XrdThrottleTimer

Constructor & Destructor Documentation

XrdThrottleManager()

XrdThrottleManager::XrdThrottleManager	(	XrdSysError *	lP,
		XrdOucTrace *	tP
	)

~XrdThrottleManager()

XrdThrottleManager::~XrdThrottleManager ( )

inline

Member Function Documentation

Apply()

void XrdThrottleManager::Apply	(	int	reqsize,
		int	reqops,
		int	uid
	)

CheckLoadShed()

bool XrdThrottleManager::CheckLoadShed

(

const std::string &

opaque

)

GetShares()

void XrdThrottleManager::GetShares ( int &  shares, int &  request  )

private

GetUid()

static int XrdThrottleManager::GetUid ( const char *  username )

static

Init()

void XrdThrottleManager::Init

(

)

IsThrottling()

bool XrdThrottleManager::IsThrottling ( )

inline

References m_bytes_per_second, and m_ops_per_second.

PerformLoadShed()

void XrdThrottleManager::PerformLoadShed	(	const std::string &	opaque,
		std::string &	host,
		unsigned &	port
	)

PrepLoadShed()

void XrdThrottleManager::PrepLoadShed	(	const char *	opaque,
		std::string &	lsOpaque
	)

Recompute()

void XrdThrottleManager::Recompute ( )

private

RecomputeBootstrap()

static void* XrdThrottleManager::RecomputeBootstrap ( void *  pp )

staticprivate

RecomputeInternal()

void XrdThrottleManager::RecomputeInternal ( )

private

SetLoadShed()

void XrdThrottleManager::SetLoadShed ( std::string &  hostname, unsigned  port, unsigned  frequency  )

inline

References m_loadshed_frequency, m_loadshed_host, and m_loadshed_port.

SetThrottles()

void XrdThrottleManager::SetThrottles ( float  reqbyterate, float  reqoprate, int  concurrency, float  interval_length  )

inline

References m_bytes_per_second, m_concurrency_limit, m_interval_length_seconds, and m_ops_per_second.

StartIOTimer()

XrdThrottleTimer XrdThrottleManager::StartIOTimer

(

)

StealShares()

void XrdThrottleManager::StealShares ( int  uid, int &  reqsize, int &  reqops  )

private

StopIOTimer()

void XrdThrottleManager::StopIOTimer ( struct timespec  )

protected

Referenced by XrdThrottleTimer::StopTimer().

WaitForShares()

int XrdThrottleManager::WaitForShares ( )

private

Friends And Related Function Documentation

XrdThrottleTimer

friend class XrdThrottleTimer

friend

Member Data Documentation

m_bytes_per_second

float XrdThrottleManager::m_bytes_per_second

private

Referenced by IsThrottling(), and SetThrottles().

m_compute_var

XrdSysCondVar XrdThrottleManager::m_compute_var

private

m_concurrency_limit

int XrdThrottleManager::m_concurrency_limit

private

Referenced by SetThrottles().

m_interval_length_seconds

float XrdThrottleManager::m_interval_length_seconds

private

Referenced by SetThrottles().

m_io_counter

int XrdThrottleManager::m_io_counter

private

m_io_wait

struct timespec XrdThrottleManager::m_io_wait

private

m_last_round_allocation

int XrdThrottleManager::m_last_round_allocation

private

m_loadshed_frequency

unsigned XrdThrottleManager::m_loadshed_frequency

private

Referenced by SetLoadShed().

m_loadshed_host

std::string XrdThrottleManager::m_loadshed_host

private

Referenced by SetLoadShed().

m_loadshed_limit_hit

int XrdThrottleManager::m_loadshed_limit_hit

private

m_loadshed_port

unsigned XrdThrottleManager::m_loadshed_port

private

Referenced by SetLoadShed().

m_log

XrdSysError* XrdThrottleManager::m_log

private

m_max_users

const int XrdThrottleManager::m_max_users

staticprivate

m_ops_per_second

float XrdThrottleManager::m_ops_per_second

private

Referenced by IsThrottling(), and SetThrottles().

m_primary_bytes_shares

std::vector<int> XrdThrottleManager::m_primary_bytes_shares

private

m_primary_ops_shares

std::vector<int> XrdThrottleManager::m_primary_ops_shares

private

m_secondary_bytes_shares

std::vector<int> XrdThrottleManager::m_secondary_bytes_shares

private

m_secondary_ops_shares

std::vector<int> XrdThrottleManager::m_secondary_ops_shares

private

m_stable_io_counter

int XrdThrottleManager::m_stable_io_counter

private

m_stable_io_wait

struct timespec XrdThrottleManager::m_stable_io_wait

private

m_trace

XrdOucTrace* XrdThrottleManager::m_trace

private

TraceID

const char* XrdThrottleManager::TraceID

staticprivate

---

The documentation for this class was generated from the following file:

• XrdThrottleManager.hh