xrootd
Loading...
Searching...
No Matches
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 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

XrdLinkmLink
 
XrdSysMutexwMutex
 
mBufffMsg
 
mBufflMsg
 
mBuffdelQ
 
int theFD
 
unsigned int inQ
 
unsigned int qWmsg
 
unsigned short discards
 
bool active
 
bool terminate
 

Static Private Attributes

static unsigned int qWarn
 
static unsigned int qMax
 
static bool qPerm
 

Additional Inherited Members

- Public Attributes inherited from XrdJob
XrdJobNextJob
 
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.

◆ 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

◆ 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: