xrootd
Classes | Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | Protected Member Functions | Static Protected Member Functions | Protected Attributes | Static Protected Attributes | Private Attributes | Static Private Attributes | List of all members
XrdPoll Class Referenceabstract

#include <XrdPoll.hh>

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

Classes

struct  PipeData
 

Public Member Functions

virtual void Disable (XrdLink *lp, const char *etxt=0)=0
 
virtual int Enable (XrdLink *lp)=0
 
virtual void Start (XrdSysSemaphore *syncp, int &rc)=0
 
 XrdPoll ()
 
virtual ~XrdPoll ()
 

Static Public Member Functions

static int Attach (XrdLink *lp)
 
static void Detach (XrdLink *lp)
 
static int Finish (XrdLink *lp, const char *etxt=0)
 
static void Init (XrdSysError *eP, XrdOucTrace *tP, XrdScheduler *sP)
 
static char * Poll2Text (short events)
 
static int Setup (int numfd)
 
static int Stats (char *buff, int blen, int do_sync=0)
 

Public Attributes

int PID
 
pthread_t TID
 

Static Public Attributes

static XrdPoll * Pollers [XRD_NUMPOLLERS] = {0, 0, 0}
 

Protected Member Functions

int getRequest ()
 
virtual void Exclude (XrdLink *lp)=0
 
virtual int Include (XrdLink *lp)=0
 

Static Protected Member Functions

static XrdPoll * newPoller (int pollid, int numfd)
 

Protected Attributes

XrdSysMutex PollPipe
 
struct pollfd PipePoll
 
int CmdFD
 
int ReqFD
 
PipeData ReqBuff
 
char * PipeBuff
 
int PipeBlen
 
int numEnabled
 
int numEvents
 
int numInterrupts
 

Static Protected Attributes

static const char * TraceID = "Poll"
 
static XrdOucTrace * XrdTrace = 0
 
static XrdSysError * XrdLog = 0
 
static XrdScheduler * XrdSched = 0
 

Private Attributes

int numAttached
 

Static Private Attributes

static XrdSysMutex doingAttach
 

Constructor & Destructor Documentation

XrdPoll::XrdPoll ( )

References CmdFD, XrdSysError::Emsg(), fcntl(), numAttached, numEnabled, numEvents, numInterrupts, PipeBlen, PipeBuff, PipePoll, ReqFD, TID, and XrdLog.

virtual XrdPoll::~XrdPoll ( )
inlinevirtual

Member Function Documentation

int XrdPoll::Attach ( XrdLink *  lp)
static

References doingAttach, XrdLink::FD, Include(), XrdSysMutex::Lock(), numAttached, PID, XrdLink::Poller, Pollers, TRACEI, XrdSysMutex::UnLock(), and XRD_NUMPOLLERS.

Referenced by XrdProtLoad::Process().

void XrdPoll::Detach ( XrdLink *  lp)
static

References doingAttach, XrdSysError::Emsg(), Exclude(), XrdLink::FD, XrdLink::ID, XrdSysMutex::Lock(), numAttached, PID, XrdLink::Poller, TRACEI, XrdSysMutex::UnLock(), and XrdLog.

Referenced by XrdLink::Close().

virtual void XrdPoll::Disable ( XrdLink *  lp,
const char *  etxt = 0 
)
pure virtual

Implemented in XrdPollE, XrdPollPoll, and XrdPollDev.

Referenced by XrdLinkScan::idleScan(), and XrdLink::Terminate().

virtual int XrdPoll::Enable ( XrdLink *  lp)
pure virtual

Implemented in XrdPollE, XrdPollPoll, and XrdPollDev.

Referenced by XrdLink::DoIt().

virtual void XrdPoll::Exclude ( XrdLink *  lp)
protectedpure virtual

Implemented in XrdPollE, XrdPollPoll, and XrdPollDev.

Referenced by Detach().

int XrdPoll::Finish ( XrdLink *  lp,
const char *  etxt = 0 
)
static

References XrdLink::Etext, XrdLink::FD, XrdLink::ProtoAlt, XrdLink::Protocol, and TRACEI.

Referenced by XrdPollDev::Disable(), XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollPoll::Restart(), XrdPollDev::Start(), XrdPollPoll::Start(), and XrdPollE::Start().

int XrdPoll::getRequest ( )
protected

References XrdSysError::Emsg(), PID, PipeBlen, PipeBuff, PipePoll, read(), ReqBuff, ReqFD, TRACE, and XrdLog.

Referenced by XrdPollDev::doRequests(), and XrdPollPoll::doRequests().

virtual int XrdPoll::Include ( XrdLink *  lp)
protectedpure virtual

Implemented in XrdPollE, XrdPollPoll, and XrdPollDev.

Referenced by Attach().

static void XrdPoll::Init ( XrdSysError *  eP,
XrdOucTrace *  tP,
XrdScheduler *  sP 
)
inlinestatic

References XrdLog, XrdSched, and XrdTrace.

Referenced by XrdConfig::Setup().

XrdPoll * XrdPoll::newPoller ( int  pollid,
int  numfd 
)
staticprotected

References close(), XrdSysError::Emsg(), fcntl(), open(), and XrdLog.

Referenced by Setup().

char * XrdPoll::Poll2Text ( short  events)
static

Referenced by XrdLink::Peek(), XrdLink::Recv(), XrdLink::RecvAll(), XrdPollDev::Start(), and XrdPollPoll::Start().

int XrdPoll::Setup ( int  numfd)
static

References XrdSysError::Emsg(), newPoller(), PID, XrdPollArg::Poller, Pollers, XrdPollArg::PollSync, XrdPollArg::retcode, XrdSysThread::Run(), TID, TRACE, XrdSysSemaphore::Wait(), XRD_NUMPOLLERS, XrdLog, XrdStartPolling(), and XRDSYSTHREAD_BIND.

Referenced by XrdConfig::Setup().

virtual void XrdPoll::Start ( XrdSysSemaphore *  syncp,
int &  rc 
)
pure virtual

Implemented in XrdPollE, XrdPollPoll, and XrdPollDev.

Referenced by XrdStartPolling().

int XrdPoll::Stats ( char *  buff,
int  blen,
int  do_sync = 0 
)
static

References numAttached, numEnabled, numEvents, numInterrupts, Pollers, and XRD_NUMPOLLERS.

Referenced by XrdStats::Stats().

Member Data Documentation

int XrdPoll::CmdFD
protected

Referenced by XrdPollPoll::Disable(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), XrdPollDev::sendCmd(), and XrdPoll().

XrdSysMutex XrdPoll::doingAttach
staticprivate

Referenced by Attach(), and Detach().

int XrdPoll::numAttached
private

Referenced by Attach(), Detach(), Stats(), and XrdPoll().

int XrdPoll::numEnabled
protected

Referenced by XrdPollDev::doRequests(), XrdPollPoll::doRequests(), XrdPollE::Enable(), Stats(), and XrdPoll().

int XrdPoll::numEvents
protected

Referenced by XrdPollDev::Start(), XrdPollPoll::Start(), XrdPollE::Start(), Stats(), and XrdPoll().

int XrdPoll::numInterrupts
protected

Referenced by XrdPollPoll::Start(), Stats(), and XrdPoll().

int XrdPoll::PID

Referenced by Attach(), Detach(), XrdPollDev::Disable(), XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollDev::doRequests(), XrdPollPoll::doRequests(), XrdPollE::Enable(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), getRequest(), XrdPollPoll::LogEvent(), XrdPollPoll::Restart(), and Setup().

int XrdPoll::PipeBlen
protected

Referenced by getRequest(), and XrdPoll().

char* XrdPoll::PipeBuff
protected

Referenced by getRequest(), and XrdPoll().

struct pollfd XrdPoll::PipePoll
protected

Referenced by getRequest(), and XrdPoll().

XrdPoll * XrdPoll::Pollers = {0, 0, 0}
static

Referenced by Attach(), Setup(), and Stats().

XrdSysMutex XrdPoll::PollPipe
protected

Referenced by XrdPollPoll::Disable(), XrdPollPoll::Enable(), XrdPollPoll::Exclude(), and XrdPollDev::sendCmd().

PipeData XrdPoll::ReqBuff
protected

Referenced by XrdPollDev::doRequests(), XrdPollPoll::doRequests(), getRequest(), and XrdPollPoll::LogEvent().

int XrdPoll::ReqFD
protected

Referenced by getRequest(), XrdPollDev::Start(), XrdPollPoll::Start(), and XrdPoll().

pthread_t XrdPoll::TID

Referenced by XrdPollPoll::Restart(), Setup(), and XrdPoll().

const char * XrdPoll::TraceID = "Poll"
staticprotected
XrdSysError * XrdPoll::XrdLog = 0
staticprotected

Referenced by Detach(), XrdPollDev::Disable(), XrdPollPoll::Disable(), XrdPollE::Disable(), XrdPollPoll::doDetach(), XrdPollDev::doRequests(), XrdPollPoll::doRequests(), XrdPollPoll::dqLink(), XrdPollDev::Enable(), XrdPollPoll::Enable(), XrdPollE::Enable(), XrdPollDev::Exclude(), XrdPollPoll::Exclude(), XrdPollE::Exclude(), getRequest(), XrdPollE::Include(), XrdPollPoll::Include(), Init(), XrdPollDev::LogEvent(), XrdPollPoll::LogEvent(), newPoller(), XrdPollPoll::Recover(), XrdPollE::remFD(), XrdPollPoll::Restart(), Setup(), XrdPollDev::Start(), XrdPollE::Start(), XrdPollPoll::Start(), and XrdPoll().

XrdScheduler * XrdPoll::XrdSched = 0
staticprotected

Referenced by XrdPollDev::Disable(), XrdPollE::Disable(), XrdPollPoll::Disable(), Init(), XrdPollPoll::Restart(), XrdPollDev::Start(), XrdPollPoll::Start(), and XrdPollE::Start().

XrdOucTrace * XrdPoll::XrdTrace = 0
staticprotected

Referenced by Init().

The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.3.1