|
Public Member Functions |
| XrdFrmXfrQueue () |
| ~XrdFrmXfrQueue () |
Static Public Member Functions |
int | Add (XrdFrmRequest *rP, XrdFrmReqFile *reqF, int theQ) |
void | Done (XrdFrmXfrJob *xP, const char *Msg) |
XrdFrmXfrJob * | Get () |
int | Init () |
void | StopMon (void *parg) |
Static Private Member Functions |
XrdFrmXfrJob * | Pull () |
int | Notify (XrdFrmRequest *rP, int qN, int rc, const char *msg=0) |
void | Send2File (char *Dest, char *Msg, int Mln) |
void | Send2UDP (char *Dest, char *Msg, int Mln) |
int | Stopped (int qNum) |
const char * | xfrName (XrdFrmRequest &reqData, int isOut) |
Static Private Attributes |
XrdSysMutex | hMutex |
XrdOucHash< XrdFrmXfrJob > | hTab |
XrdSysMutex | qMutex |
XrdSysSemaphore | qReady |
theQueue | xfrQ [XrdFrmRequest::numQ] |