xrootd
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::XrdSendQ ( XrdLink &  lP,
XrdSysMutex &  mP 
)

◆ ~XrdSendQ()

virtual XrdSendQ::~XrdSendQ ( )
inlineprivatevirtual

Member Function Documentation

◆ Backlog()

unsigned int XrdSendQ::Backlog ( )
inline

References inQ.

◆ DoIt()

virtual void XrdSendQ::DoIt ( )
virtual

Implements XrdJob.

◆ Init()

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

References Say, and Sched.

◆ QMsg()

bool XrdSendQ::QMsg ( mBuff *  theMsg)
private

◆ RelMsgs()

void XrdSendQ::RelMsgs ( mBuff *  mP)
private

◆ Scuttle()

void XrdSendQ::Scuttle ( )
private

◆ Send() [1/2]

int XrdSendQ::Send ( const char *  buff,
int  blen 
)

◆ Send() [2/2]

int XrdSendQ::Send ( const struct iovec *  iov,
int  iovcnt,
int  iotot 
)

◆ SendNB() [1/2]

int XrdSendQ::SendNB ( const char *  Buff,
int  Blen 
)
private

◆ SendNB() [2/2]

int XrdSendQ::SendNB ( const struct iovec *  iov,
int  iocnt,
int  bytes,
int &  iovX 
)
private

◆ SetAQ()

static void XrdSendQ::SetAQ ( bool  onoff)
inlinestatic

References qPerm.

◆ SetQM()

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

References qMax.

◆ SetQW()

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

References qWarn.

◆ Terminate()

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

Member Data Documentation

◆ active

bool XrdSendQ::active
private

◆ delQ

mBuff* XrdSendQ::delQ
private

◆ discards

unsigned short XrdSendQ::discards
private

◆ fMsg

mBuff* XrdSendQ::fMsg
private

◆ inQ

unsigned int XrdSendQ::inQ
private

Referenced by Backlog().

◆ lMsg

mBuff* XrdSendQ::lMsg
private

◆ mLink

XrdLink& XrdSendQ::mLink
private

◆ qMax

unsigned int XrdSendQ::qMax
staticprivate

Referenced by SetQM().

◆ qPerm

bool XrdSendQ::qPerm
staticprivate

Referenced by SetAQ().

◆ qWarn

unsigned int XrdSendQ::qWarn
staticprivate

Referenced by SetQW().

◆ qWmsg

unsigned int XrdSendQ::qWmsg
private

◆ Say

XrdSysError* XrdSendQ::Say
staticprivate

Referenced by Init().

◆ Sched

XrdScheduler* XrdSendQ::Sched
staticprivate

Referenced by Init().

◆ terminate

bool XrdSendQ::terminate
private

◆ theFD

int XrdSendQ::theFD
private

◆ wMutex

XrdSysMutex& XrdSendQ::wMutex
private

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