#include <XrdOlbPrepare.hh>


Public Member Functions | |
| int | Add (XrdOlbPrepArgs &pargs) |
| int | Del (char *reqid) |
| int | Exists (char *path) |
| void | Gone (char *path) |
| void | DoIt () |
| int | Pending () |
| void | Queue (XrdOlbPrepArgs *parg) |
| int | Reset () |
| int | setParms (int rcnt, int stime, int deco=0) |
| int | setParms (char *ifpgm, char *ifmsg=0) |
| int | setParms (XrdScheduler *sp) |
| int | setParms (XrdOucName2Name *n2n) |
| XrdOlbPrepare () | |
| ~XrdOlbPrepare () | |
Private Member Functions | |
| void | Scrub () |
| int | startIF () |
Private Attributes | |
| XrdSysMutex | PTMutex |
| XrdOucHash< char > | PTable |
| XrdOucStream | prepSched |
| XrdScheduler * | SchedP |
| XrdOucName2Name * | N2N |
| XrdOucMsubs * | prepMsg |
| time_t | lastemsg |
| pid_t | preppid |
| int | NumFiles |
| int | doEcho |
| int | resetcnt |
| int | scrub2rst |
| int | scrubtime |
| char * | prepif |
| XrdOlbPrepare::XrdOlbPrepare | ( | ) |
| XrdOlbPrepare::~XrdOlbPrepare | ( | ) | [inline] |
| int XrdOlbPrepare::Add | ( | XrdOlbPrepArgs & | pargs | ) |
References XrdOucHash< T >::Add(), Hash_data_is_key, index(), Info, XrdOucStream::isAlive(), XrdSysMutex::Lock(), XrdOucMsubs::maxElem, XrdOlbPrepArgs::mode, N2N, NumFiles, XrdOlbPrepArgs::path, prepif, prepMsg, prepSched, XrdOlbPrepArgs::prty, PTable, PTMutex, XrdOucStream::Put(), XrdOlbPrepArgs::reqid, Say, XrdOucMsubs::Subs(), XrdSysMutex::UnLock(), and XrdOlbPrepArgs::user.
| int XrdOlbPrepare::Del | ( | char * | reqid | ) |
References XrdOucStream::isAlive(), XrdSysMutex::Lock(), prepif, prepSched, PTMutex, XrdOucStream::Put(), Say, and XrdSysMutex::UnLock().
| void XrdOlbPrepare::DoIt | ( | ) | [inline, virtual] |
| int XrdOlbPrepare::Exists | ( | char * | path | ) |
References XrdOucHash< T >::Find(), XrdSysMutex::Lock(), NumFiles, PTable, PTMutex, and XrdSysMutex::UnLock().
| void XrdOlbPrepare::Gone | ( | char * | path | ) |
References XrdOucHash< T >::Del(), XrdSysMutex::Lock(), NumFiles, PTable, PTMutex, and XrdSysMutex::UnLock().
| int XrdOlbPrepare::Pending | ( | ) | [inline] |
References NumFiles.
| void XrdOlbPrepare::Queue | ( | XrdOlbPrepArgs * | parg | ) |
| int XrdOlbPrepare::Reset | ( | void | ) |
References XrdOucHash< T >::Add(), doEcho, XrdOucStream::Drain(), XrdOucStream::GetLine(), Hash_data_is_key, XrdOucStream::isAlive(), XrdOucStream::LastError(), NumFiles, prepif, prepSched, PTable, XrdOucHash< T >::Purge(), XrdOucStream::Put(), resetcnt, Say, scrub2rst, and startIF().
Referenced by Scrub().
| void XrdOlbPrepare::Scrub | ( | ) | [private] |
References XrdOucHash< T >::Apply(), XrdOucStream::isAlive(), XrdSysMutex::Lock(), prepSched, PTable, PTMutex, Reset(), scrub2rst, startIF(), XrdSysMutex::UnLock(), and XrdOlbScrubScan().
Referenced by DoIt().
| int XrdOlbPrepare::setParms | ( | XrdOucName2Name * | n2n | ) | [inline] |
References N2N.
| int XrdOlbPrepare::setParms | ( | char * | ifpgm, | |
| char * | ifmsg = 0 | |||
| ) |
References XrdOucMsubs::Parse(), prepif, prepMsg, and Say.
| int XrdOlbPrepare::setParms | ( | XrdScheduler * | sp | ) | [inline] |
References SchedP.
| int XrdOlbPrepare::setParms | ( | int | rcnt, | |
| int | stime, | |||
| int | deco = 0 | |||
| ) |
| int XrdOlbPrepare::startIF | ( | ) | [private] |
References DEBUG, EPNAME, XrdOucStream::Exec(), lastemsg, XrdOucStream::LastError(), prepif, prepSched, and Say.
int XrdOlbPrepare::doEcho [private] |
Referenced by Reset(), and setParms().
time_t XrdOlbPrepare::lastemsg [private] |
Referenced by startIF(), and XrdOlbPrepare().
XrdOucName2Name* XrdOlbPrepare::N2N [private] |
Referenced by Add(), and setParms().
int XrdOlbPrepare::NumFiles [private] |
char* XrdOlbPrepare::prepif [private] |
Referenced by Add(), Del(), DoIt(), Reset(), setParms(), startIF(), and XrdOlbPrepare().
XrdOucMsubs* XrdOlbPrepare::prepMsg [private] |
Referenced by Add(), and setParms().
pid_t XrdOlbPrepare::preppid [private] |
Referenced by XrdOlbPrepare().
XrdOucStream XrdOlbPrepare::prepSched [private] |
XrdOucHash<char> XrdOlbPrepare::PTable [private] |
XrdSysMutex XrdOlbPrepare::PTMutex [private] |
int XrdOlbPrepare::resetcnt [private] |
Referenced by Reset(), setParms(), and XrdOlbPrepare().
XrdScheduler* XrdOlbPrepare::SchedP [private] |
Referenced by DoIt(), setParms(), and XrdOlbPrepare().
int XrdOlbPrepare::scrub2rst [private] |
Referenced by Reset(), Scrub(), setParms(), and XrdOlbPrepare().
int XrdOlbPrepare::scrubtime [private] |
Referenced by DoIt(), setParms(), and XrdOlbPrepare().
1.7.1