|
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] |