xrootd
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Classes | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
XrdSendQ Class Reference

#include <XrdSendQ.hh>

Inheritance diagram for XrdSendQ:
Inheritance graph
[legend]
Collaboration diagram for XrdSendQ:
Collaboration graph
[legend]

Classes

struct  mBuff
 

Public Member Functions

unsigned int Backlog ()
 
virtual void DoIt ()
 
int Send (const char *buff, int blen)
 
int Send (const struct iovec *iov, int iovcnt, int iotot)
 
void Terminate (XrdLink *lP=0)
 
 XrdSendQ (XrdLink &lP, XrdSysMutex &mP)
 
- Public Member Functions inherited from XrdJob
 XrdJob (const char *desc="")
 
virtual ~XrdJob ()
 

Static Public Member Functions

static void Init (XrdSysError *eP, XrdScheduler *sP)
 
static void SetAQ (bool onoff)
 
static void SetQM (unsigned int qmVal)
 
static void SetQW (unsigned int qwVal)
 

Private Member Functions

virtual ~XrdSendQ ()
 
int SendNB (const char *Buff, int Blen)
 
int SendNB (const struct iovec *iov, int iocnt, int bytes, int &iovX)
 
bool QMsg (mBuff *theMsg)
 
void RelMsgs (mBuff *mP)
 
void Scuttle ()
 

Private Attributes

XrdLink & mLink
 
XrdSysMutex & wMutex
 
mBuff * fMsg
 
mBuff * lMsg
 
mBuff * delQ
 
int theFD
 
unsigned int inQ
 
unsigned int qWmsg
 
unsigned short discards
 
bool active
 
bool terminate
 

Static Private Attributes

static XrdScheduler * Sched
 
static XrdSysError * Say
 
static unsigned int qWarn
 
static unsigned int qMax
 
static bool qPerm
 

Additional Inherited Members

- Public Attributes inherited from XrdJob
XrdJob * NextJob
 
const char * Comment
 

Constructor & Destructor Documentation

XrdSendQ::XrdSendQ ( XrdLink &  lP,
XrdSysMutex &  mP 
)
virtual XrdSendQ::~XrdSendQ ( )
inlineprivatevirtual

Member Function Documentation

unsigned int XrdSendQ::Backlog ( )
inline

References inQ.

virtual void XrdSendQ::DoIt ( )
virtual

Implements XrdJob.

static void XrdSendQ::Init ( XrdSysError *  eP,
XrdScheduler *  sP 
)
inlinestatic

References Say, and Sched.

bool XrdSendQ::QMsg ( mBuff *  theMsg)
private
void XrdSendQ::RelMsgs ( mBuff *  mP)
private
void XrdSendQ::Scuttle ( )
private
int XrdSendQ::Send ( const char *  buff,
int  blen 
)
int XrdSendQ::Send ( const struct iovec *  iov,
int  iovcnt,
int  iotot 
)
int XrdSendQ::SendNB ( const char *  Buff,
int  Blen 
)
private
int XrdSendQ::SendNB ( const struct iovec *  iov,
int  iocnt,
int  bytes,
int &  iovX 
)
private
static void XrdSendQ::SetAQ ( bool  onoff)
inlinestatic

References qPerm.

static void XrdSendQ::SetQM ( unsigned int  qmVal)
inlinestatic

References qMax.

static void XrdSendQ::SetQW ( unsigned int  qwVal)
inlinestatic

References qWarn.

void XrdSendQ::Terminate ( XrdLink *  lP = 0)

Member Data Documentation

bool XrdSendQ::active
private
mBuff* XrdSendQ::delQ
private
unsigned short XrdSendQ::discards
private
mBuff* XrdSendQ::fMsg
private
unsigned int XrdSendQ::inQ
private

Referenced by Backlog().

mBuff* XrdSendQ::lMsg
private
XrdLink& XrdSendQ::mLink
private
unsigned int XrdSendQ::qMax
staticprivate

Referenced by SetQM().

bool XrdSendQ::qPerm
staticprivate

Referenced by SetAQ().

unsigned int XrdSendQ::qWarn
staticprivate

Referenced by SetQW().

unsigned int XrdSendQ::qWmsg
private
XrdSysError* XrdSendQ::Say
staticprivate

Referenced by Init().

XrdScheduler* XrdSendQ::Sched
staticprivate

Referenced by Init().

bool XrdSendQ::terminate
private
int XrdSendQ::theFD
private
XrdSysMutex& XrdSendQ::wMutex
private

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