#include <XrdThrottleManager.hh>
|
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 int | GetUid (const char *username) |
|
XrdThrottleManager::~XrdThrottleManager |
( |
| ) |
|
|
inline |
void XrdThrottleManager::Apply |
( |
int |
reqsize, |
|
|
int |
reqops, |
|
|
int |
uid |
|
) |
| |
bool XrdThrottleManager::CheckLoadShed |
( |
const std::string & |
opaque | ) |
|
void XrdThrottleManager::GetShares |
( |
int & |
shares, |
|
|
int & |
request |
|
) |
| |
|
private |
static int XrdThrottleManager::GetUid |
( |
const char * |
username | ) |
|
|
static |
void XrdThrottleManager::Init |
( |
| ) |
|
bool XrdThrottleManager::IsThrottling |
( |
| ) |
|
|
inline |
void XrdThrottleManager::PerformLoadShed |
( |
const std::string & |
opaque, |
|
|
std::string & |
host, |
|
|
unsigned & |
port |
|
) |
| |
void XrdThrottleManager::PrepLoadShed |
( |
const char * |
opaque, |
|
|
std::string & |
lsOpaque |
|
) |
| |
void XrdThrottleManager::Recompute |
( |
| ) |
|
|
private |
static void* XrdThrottleManager::RecomputeBootstrap |
( |
void * |
pp | ) |
|
|
staticprivate |
void XrdThrottleManager::RecomputeInternal |
( |
| ) |
|
|
private |
void XrdThrottleManager::SetLoadShed |
( |
std::string & |
hostname, |
|
|
unsigned |
port, |
|
|
unsigned |
frequency |
|
) |
| |
|
inline |
void XrdThrottleManager::SetThrottles |
( |
float |
reqbyterate, |
|
|
float |
reqoprate, |
|
|
int |
concurrency, |
|
|
float |
interval_length |
|
) |
| |
|
inline |
void XrdThrottleManager::StealShares |
( |
int |
uid, |
|
|
int & |
reqsize, |
|
|
int & |
reqops |
|
) |
| |
|
private |
void XrdThrottleManager::StopIOTimer |
( |
struct timespec |
| ) |
|
|
protected |
int XrdThrottleManager::WaitForShares |
( |
| ) |
|
|
private |
float XrdThrottleManager::m_bytes_per_second |
|
private |
int XrdThrottleManager::m_concurrency_limit |
|
private |
float XrdThrottleManager::m_interval_length_seconds |
|
private |
int XrdThrottleManager::m_io_counter |
|
private |
struct timespec XrdThrottleManager::m_io_wait |
|
private |
int XrdThrottleManager::m_last_round_allocation |
|
private |
unsigned XrdThrottleManager::m_loadshed_frequency |
|
private |
std::string XrdThrottleManager::m_loadshed_host |
|
private |
int XrdThrottleManager::m_loadshed_limit_hit |
|
private |
unsigned XrdThrottleManager::m_loadshed_port |
|
private |
const int XrdThrottleManager::m_max_users |
|
staticprivate |
float XrdThrottleManager::m_ops_per_second |
|
private |
std::vector<int> XrdThrottleManager::m_primary_bytes_shares |
|
private |
std::vector<int> XrdThrottleManager::m_primary_ops_shares |
|
private |
std::vector<int> XrdThrottleManager::m_secondary_bytes_shares |
|
private |
std::vector<int> XrdThrottleManager::m_secondary_ops_shares |
|
private |
int XrdThrottleManager::m_stable_io_counter |
|
private |
struct timespec XrdThrottleManager::m_stable_io_wait |
|
private |
const char* XrdThrottleManager::TraceID |
|
staticprivate |
The documentation for this class was generated from the following file: