#include <XrdFrmXfrQueue.hh>
List of all members.
Classes |
struct | theQueue |
Public Member Functions |
| XrdFrmXfrQueue () |
| ~XrdFrmXfrQueue () |
Static Public Member Functions |
static int | Add (XrdFrmRequest *rP, XrdFrmReqFile *reqF, int theQ) |
static void | Done (XrdFrmXfrJob *xP, const char *Msg) |
static XrdFrmXfrJob * | Get () |
static int | Init () |
static void | StopMon (void *parg) |
Static Private Member Functions |
static XrdFrmXfrJob * | Pull () |
static int | Notify (XrdFrmRequest *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 (XrdFrmRequest &reqData, int isOut) |
Static Private Attributes |
static XrdSysMutex | hMutex |
static XrdOucHash< XrdFrmXfrJob > | hTab |
static XrdSysMutex | qMutex |
static XrdSysSemaphore | qReady |
static theQueue | xfrQ [XrdFrmRequest::numQ] |
Constructor & Destructor Documentation
XrdFrmXfrQueue::XrdFrmXfrQueue |
( |
| ) |
[inline] |
XrdFrmXfrQueue::~XrdFrmXfrQueue |
( |
| ) |
[inline] |
Member Function Documentation
References XrdFrm::Config, XrdFrmReqFile::Del(), XrdSysError::Emsg(), Hash_keep, XrdFrmRequest::LFN, XrdFrmRequest::LFO, XrdFrmConfig::LocalPath(), XrdFrmRequest::msgFail, XrdFrmRequest::msgSucc, XrdFrmXfrJob::Next, XrdFrmXfrJob::NoteList, XrdFrmRequest::Notify, XrdFrmRequest::numQ, XrdFrmRequest::Options, XrdFrmRequest::outQ, XrdFrmXfrJob::PFN, XrdFrmXfrJob::pfnEnd, XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, XrdSysError::Say(), XrdFrm::Say, stat(), XrdFrm::Trace, TRACE_Debug, XrdFrmXfrJob::Type, XrdFrmRequest::User, XrdFrmConfig::Verbose, and XrdOucTrace::What.
Referenced by XrdFrmReqBoss::Process(), and XrdFrmMigrate::Queue().
void XrdFrmXfrQueue::Done |
( |
XrdFrmXfrJob * |
xP, |
|
|
const char * |
Msg |
|
) |
| [static] |
References XrdFrmReqFile::Del(), XrdFrmXfrJob::Next, XrdOucTList::next, XrdFrmXfrJob::NoteList, XrdFrmRequest::Notify, XrdFrmXfrJob::qNum, XrdFrmXfrJob::reqData, XrdFrmXfrJob::reqFile, XrdFrmXfrJob::reqFQ, XrdFrmXfrJob::RetCode, and XrdOucTList::text.
Referenced by XrdFrmTransfer::Start().
int XrdFrmXfrQueue::Init |
( |
| ) |
[static] |
int XrdFrmXfrQueue::Notify |
( |
XrdFrmRequest * |
rP, |
|
|
int |
qN, |
|
|
int |
rc, |
|
|
const char * |
msg = 0 |
|
) |
| [static, private] |
void XrdFrmXfrQueue::Send2File |
( |
char * |
Dest, |
|
|
char * |
Msg, |
|
|
int |
Mln |
|
) |
| [static, private] |
void XrdFrmXfrQueue::Send2UDP |
( |
char * |
Dest, |
|
|
char * |
Msg, |
|
|
int |
Mln |
|
) |
| [static, private] |
void XrdFrmXfrQueue::StopMon |
( |
void * |
parg | ) |
[static] |
References XrdFrmXfrQueue::theQueue::Alert, XrdSysError::Emsg(), XrdFrmXfrQueue::theQueue::File, XrdFrmXfrQueue::theQueue::First, XrdFrmXfrQueue::theQueue::Name, XrdFrmXfrJob::Next, XrdFrm::Say, XrdSysTimer::Snooze(), stat(), XrdFrmXfrQueue::theQueue::Stop, and XrdSysSemaphore::Wait().
Referenced by InitStop().
int XrdFrmXfrQueue::Stopped |
( |
int |
qNum | ) |
[static, private] |
const char * XrdFrmXfrQueue::xfrName |
( |
XrdFrmRequest & |
reqData, |
|
|
int |
isOut |
|
) |
| [static, private] |
Member Data Documentation
The documentation for this class was generated from the following files: