xrootd
|
#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) | |
![]() | |
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 | |
![]() | |
XrdJob * | NextJob |
const char * | Comment |
XrdSendQ::XrdSendQ | ( | XrdLink & | lP, |
XrdSysMutex & | mP | ||
) |
|
inlineprivatevirtual |
|
inline |
References inQ.
|
virtual |
Implements XrdJob.
|
inlinestatic |
|
private |
|
private |
|
private |
int XrdSendQ::Send | ( | const char * | buff, |
int | blen | ||
) |
int XrdSendQ::Send | ( | const struct iovec * | iov, |
int | iovcnt, | ||
int | iotot | ||
) |
|
private |
|
private |
|
inlinestatic |
References qPerm.
|
inlinestatic |
References qMax.
|
inlinestatic |
References qWarn.
void XrdSendQ::Terminate | ( | XrdLink * | lP = 0 | ) |
|
private |
|
private |
|
private |
|
private |
|
private |
Referenced by Backlog().
|
private |
|
private |
|
staticprivate |
Referenced by SetQM().
|
staticprivate |
Referenced by SetAQ().
|
staticprivate |
Referenced by SetQW().
|
private |
|
staticprivate |
Referenced by Init().
|
staticprivate |
Referenced by Init().
|
private |
|
private |
|
private |