XrdFrmXfrQueue Class Reference

#include <XrdFrmXfrQueue.hh>

Collaboration diagram for XrdFrmXfrQueue:

Classes
struct	theQueue

Public Member Functions
	XrdFrmXfrQueue ()
	~XrdFrmXfrQueue ()

Static Public Member Functions
static int	Add (XrdFrcRequest *rP, XrdFrcReqFile *reqF, int theQ)
static void	Done (XrdFrmXfrJob *xP, const char *Msg)
static XrdFrmXfrJob *	Get (int ioQType)
static int	Init ()
static void	StopMon (void *parg)

Static Public Attributes
static const int	useInpQ = 1
static const int	useAnyQ = 0
static const int	useOutQ = -1

Static Private Member Functions
static XrdFrmXfrJob *	Pull (int ioQType)
static int	Notify (XrdFrcRequest *rP, int qN, int rc, const char *msg=0)
static void	Send2File (char *Dest, char *Msg, int Mln)
static void	Send2UDP (char *Dest, char *Msg, int Mln)
static int	Stopped (int qNum)
static const char *	xfrName (XrdFrcRequest &reqData, int isOut)

Static Private Attributes
static XrdSysMutex	hMutex
static XrdOucHash< XrdFrmXfrJob >	hTab
static XrdSysMutex	qMutex
static XrdSysSemaphore	qReady
static theQueue	xfrQ [XrdFrcRequest::numQ]

Constructor & Destructor Documentation

XrdFrmXfrQueue()

XrdFrmXfrQueue::XrdFrmXfrQueue ( )

inline

~XrdFrmXfrQueue()

XrdFrmXfrQueue::~XrdFrmXfrQueue ( )

inline

Member Function Documentation

Add()

static int XrdFrmXfrQueue::Add ( XrdFrcRequest * rP, XrdFrcReqFile * reqF, int theQ )

static

Done()

static void XrdFrmXfrQueue::Done ( XrdFrmXfrJob * xP, const char * Msg )

static

Get()

static XrdFrmXfrJob * XrdFrmXfrQueue::Get ( int ioQType )

static

Init()

static int XrdFrmXfrQueue::Init ( )

static

Notify()

static int XrdFrmXfrQueue::Notify ( XrdFrcRequest * rP, int qN, int rc, const char * msg = 0 )

staticprivate

Pull()

static XrdFrmXfrJob * XrdFrmXfrQueue::Pull ( int ioQType )

staticprivate

Send2File()

static void XrdFrmXfrQueue::Send2File ( char * Dest, char * Msg, int Mln )

staticprivate

Send2UDP()

static void XrdFrmXfrQueue::Send2UDP ( char * Dest, char * Msg, int Mln )

staticprivate

StopMon()

static void XrdFrmXfrQueue::StopMon ( void * parg )

static

Stopped()

static int XrdFrmXfrQueue::Stopped ( int qNum )

staticprivate

xfrName()

static const char * XrdFrmXfrQueue::xfrName ( XrdFrcRequest & reqData, int isOut )

staticprivate

Member Data Documentation

hMutex

XrdSysMutex XrdFrmXfrQueue::hMutex

staticprivate

hTab

XrdOucHash<XrdFrmXfrJob> XrdFrmXfrQueue::hTab

staticprivate

qMutex

XrdSysMutex XrdFrmXfrQueue::qMutex

staticprivate

qReady

XrdSysSemaphore XrdFrmXfrQueue::qReady

staticprivate

useAnyQ

const int XrdFrmXfrQueue::useAnyQ = 0

static

useInpQ

const int XrdFrmXfrQueue::useInpQ = 1

static

useOutQ

const int XrdFrmXfrQueue::useOutQ = -1

static

xfrQ

theQueue XrdFrmXfrQueue::xfrQ[XrdFrcRequest::numQ]

staticprivate

---

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

• XrdFrmXfrQueue.hh