#include <XrdSendQ.hh>
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) | |
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 |
XrdSendQ::XrdSendQ | ( | XrdLink & | lP, | |
XrdSysMutex & | mP | |||
) |
virtual XrdSendQ::~XrdSendQ | ( | ) | [inline, private, virtual] |
unsigned int XrdSendQ::Backlog | ( | ) | [inline] |
References inQ.
virtual void XrdSendQ::DoIt | ( | ) | [virtual] |
Implements XrdJob.
static void XrdSendQ::Init | ( | XrdSysError * | eP, | |
XrdScheduler * | sP | |||
) | [inline, static] |
bool XrdSendQ::QMsg | ( | mBuff * | theMsg | ) | [private] |
void XrdSendQ::RelMsgs | ( | mBuff * | mP | ) | [private] |
void XrdSendQ::Scuttle | ( | ) | [private] |
int XrdSendQ::Send | ( | const struct iovec * | iov, | |
int | iovcnt, | |||
int | iotot | |||
) |
int XrdSendQ::Send | ( | const char * | buff, | |
int | blen | |||
) |
int XrdSendQ::SendNB | ( | const struct iovec * | iov, | |
int | iocnt, | |||
int | bytes, | |||
int & | iovX | |||
) | [private] |
int XrdSendQ::SendNB | ( | const char * | Buff, | |
int | Blen | |||
) | [private] |
static void XrdSendQ::SetAQ | ( | bool | onoff | ) | [inline, static] |
References qPerm.
static void XrdSendQ::SetQM | ( | unsigned int | qmVal | ) | [inline, static] |
References qMax.
static void XrdSendQ::SetQW | ( | unsigned int | qwVal | ) | [inline, static] |
References qWarn.
void XrdSendQ::Terminate | ( | XrdLink * | lP = 0 |
) |
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 [static, private] |
Referenced by SetQM().
bool XrdSendQ::qPerm [static, private] |
Referenced by SetAQ().
unsigned int XrdSendQ::qWarn [static, private] |
Referenced by SetQW().
unsigned int XrdSendQ::qWmsg [private] |
XrdSysError* XrdSendQ::Say [static, private] |
Referenced by Init().
XrdScheduler* XrdSendQ::Sched [static, private] |
Referenced by Init().
bool XrdSendQ::terminate [private] |
int XrdSendQ::theFD [private] |
XrdSysMutex& XrdSendQ::wMutex [private] |