Public Member Functions | Public Attributes | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends

XrdOlbManager Class Reference

#include <XrdOlbManager.hh>

Collaboration diagram for XrdOlbManager:
Collaboration graph
[legend]

List of all members.

Public Member Functions

void Broadcast (SMask_t smask, char *buff, int blen)
void Broadcast (SMask_t smask, const struct iovec *, int iovcnt)
SMask_t getMask (unsigned int IPv4adr)
int haveManagers ()
void Inform (const char *cmd, int clen=0, char *arg=0, int alen=0)
void Inform (SMask_t mmask, const char *cmd, int clen=0)
XrdOlbSInfoListServers (SMask_t mask=(SMask_t)-1, int opts=0)
void * Login (XrdNetLink *lnkp)
void * MonPerf (void)
void * MonPing (void)
void * MonRefs (void)
void * Pander (char *manager, int port)
void Remove_Server (const char *reason, int sent, int sinst, int immed=0)
void Reset (void)
void ResetRef (SMask_t smask)
void Resume ()
int SelServer (int pt, char *path, SMask_t pmsk, SMask_t amsk, char *hb, const struct iovec *iodata=0, int iovcnt=0)
int SelServer (int opts, SMask_t pmask, char *hbuff)
void setNet (XrdNetWork *net)
void setPort (int port)
void Snooze (int slpsec)
void Space (int none, int doinform=1)
void Stage (int ison, int doinform=1)
int Stats (char *bfr, int bln)
void Suspend (int doinform=1)
 XrdOlbManager ()
 ~XrdOlbManager ()

Public Attributes

int ServCnt
char hasData

Static Public Attributes

static const int MTMax = 16
static const int STMax = 64

Private Member Functions

SMask_t AddPath (XrdOlbServer *sp)
int Add_Manager (XrdOlbServer *sp)
XrdOlbServerAddServer (XrdNetLink *lp, int port, int Status, int sport, char *sid)
XrdOlbServercalcDelay (int nump, int numd, int numf, int numo, int nums, int &delay, const char **reason)
int Drop_Server (int sent, int sinst, XrdOlbDrop *djp=0)
void * Login_Failed (const char *reason, XrdNetLink *lp, XrdOlbServer *sp=0)
void Record (char *path, const char *reason)
void Remove_Manager (const char *reason, XrdOlbServer *sp)
XrdOlbServerSelbyCost (SMask_t mask, int &nump, int &delay, const char **reason, int needspace)
XrdOlbServerSelbyLoad (SMask_t mask, int &nump, int &delay, const char **reason, int needspace)
XrdOlbServerSelbyRef (SMask_t mask, int &nump, int &delay, const char **reason, int needspace)
void sendAList (XrdNetLink *lp)
void setAltMan (int snum, unsigned int ipaddr, int port)

Private Attributes

XrdSysMutex XXMutex
XrdSysMutex STMutex
XrdOlbServerServTab [STMax]
XrdOlbServerServBat [STMax]
XrdSysMutex MTMutex
XrdOlbServerMastTab [MTMax]
XrdNetWorkNetTCPs
char AltMans [STMax *AltSize]
char * AltMend
int AltMent
int MTHi
int STHi
int XWait
int XnoStage
int Port
int SelAcnt
int SelRcnt
int doReset
SMask_t resetMask
SMask_t peerHost
SMask_t peerMask

Static Private Attributes

static const int AltSize = 24

Friends

class XrdOlbDrop

Constructor & Destructor Documentation

XrdOlbManager::XrdOlbManager (  ) 
XrdOlbManager::~XrdOlbManager (  )  [inline]

Member Function Documentation

int XrdOlbManager::Add_Manager ( XrdOlbServer sp  )  [private]
SMask_t XrdOlbManager::AddPath ( XrdOlbServer sp  )  [private]
XrdOlbServer * XrdOlbManager::AddServer ( XrdNetLink lp,
int  port,
int  Status,
int  sport,
char *  sid 
) [private]
void XrdOlbManager::Broadcast ( SMask_t  smask,
const struct iovec iod,
int  iovcnt 
)
void XrdOlbManager::Broadcast ( SMask_t  smask,
char *  buff,
int  blen 
)
XrdOlbServer * XrdOlbManager::calcDelay ( int  nump,
int  numd,
int  numf,
int  numo,
int  nums,
int &  delay,
const char **  reason 
) [private]
int XrdOlbManager::Drop_Server ( int  sent,
int  sinst,
XrdOlbDrop djp = 0 
) [private]
SMask_t XrdOlbManager::getMask ( unsigned int  IPv4adr  ) 
int XrdOlbManager::haveManagers (  )  [inline]

References MTHi.

void XrdOlbManager::Inform ( const char *  cmd,
int  clen = 0,
char *  arg = 0,
int  alen = 0 
)
void XrdOlbManager::Inform ( SMask_t  mmask,
const char *  cmd,
int  clen = 0 
)
XrdOlbSInfo * XrdOlbManager::ListServers ( SMask_t  mask = (SMask_t)-1,
int  opts = 0 
)
void * XrdOlbManager::Login ( XrdNetLink lnkp  ) 
void * XrdOlbManager::Login_Failed ( const char *  reason,
XrdNetLink lp,
XrdOlbServer sp = 0 
) [private]
void * XrdOlbManager::MonPerf ( void   ) 
void * XrdOlbManager::MonPing ( void   ) 
void * XrdOlbManager::MonRefs ( void   ) 
void * XrdOlbManager::Pander ( char *  manager,
int  port 
)
void XrdOlbManager::Record ( char *  path,
const char *  reason 
) [private]
void XrdOlbManager::Remove_Manager ( const char *  reason,
XrdOlbServer sp 
) [private]
void XrdOlbManager::Remove_Server ( const char *  reason,
int  sent,
int  sinst,
int  immed = 0 
)
void XrdOlbManager::Reset ( void   ) 
void XrdOlbManager::ResetRef ( SMask_t  smask  ) 
void XrdOlbManager::Resume (  ) 

References XrdCms::Config, Inform(), Say, and XWait.

XrdOlbServer * XrdOlbManager::SelbyCost ( SMask_t  mask,
int &  nump,
int &  delay,
const char **  reason,
int  needspace 
) [private]
XrdOlbServer * XrdOlbManager::SelbyLoad ( SMask_t  mask,
int &  nump,
int &  delay,
const char **  reason,
int  needspace 
) [private]
XrdOlbServer * XrdOlbManager::SelbyRef ( SMask_t  mask,
int &  nump,
int &  delay,
const char **  reason,
int  needspace 
) [private]
int XrdOlbManager::SelServer ( int  opts,
SMask_t  pmask,
char *  hbuff 
)
int XrdOlbManager::SelServer ( int  pt,
char *  path,
SMask_t  pmsk,
SMask_t  amsk,
char *  hb,
const struct iovec iodata = 0,
int  iovcnt = 0 
)
void XrdOlbManager::sendAList ( XrdNetLink lp  )  [private]
void XrdOlbManager::setAltMan ( int  snum,
unsigned int  ipaddr,
int  port 
) [private]

References AltMans, AltMend, AltMent, AltSize, XrdNetDNS::IP2String(), and Port.

Referenced by AddServer().

void XrdOlbManager::setNet ( XrdNetWork net  )  [inline]

References NetTCPs.

void XrdOlbManager::setPort ( int  port  )  [inline]

References Port.

void XrdOlbManager::Snooze ( int  slpsec  ) 

References Say.

Referenced by MonPerf(), MonPing(), MonRefs(), and Pander().

void XrdOlbManager::Space ( int  none,
int  doinform = 1 
)
void XrdOlbManager::Stage ( int  ison,
int  doinform = 1 
)
int XrdOlbManager::Stats ( char *  bfr,
int  bln 
)
void XrdOlbManager::Suspend ( int  doinform = 1  ) 

References Inform(), and XWait.


Friends And Related Function Documentation

friend class XrdOlbDrop [friend]

Referenced by Remove_Server().


Member Data Documentation

char* XrdOlbManager::AltMend [private]
int XrdOlbManager::AltMent [private]
const int XrdOlbManager::AltSize = 24 [static, private]

Referenced by Drop_Server(), sendAList(), and setAltMan().

int XrdOlbManager::doReset [private]

Referenced by MonRefs(), ResetRef(), and XrdOlbManager().

Referenced by XrdOlbManager().

int XrdOlbManager::MTHi [private]
const int XrdOlbManager::MTMax = 16 [static]

Referenced by Pander(), and setNet().

int XrdOlbManager::Port [private]

Referenced by Pander(), setAltMan(), and setPort().

Referenced by MonRefs(), ResetRef(), and XrdOlbManager().

int XrdOlbManager::SelAcnt [private]
int XrdOlbManager::SelRcnt [private]
int XrdOlbManager::STHi [private]
const int XrdOlbManager::STMax = 64 [static]
int XrdOlbManager::XnoStage [private]

Referenced by Pander(), Space(), Stage(), and XrdOlbManager().

int XrdOlbManager::XWait [private]

Referenced by Pander(), Resume(), Suspend(), and XrdOlbManager().

Referenced by Space(), and Stage().


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