Definition at line 62 of file XrdProofSched.h.
|
| XrdProofSched (const char *name, XrdProofdManager *mgr, XrdProofGroupMgr *grpmgr, const char *cfn, XrdSysError *e=0) |
| Constructor. More...
|
|
virtual | ~XrdProofSched () |
|
int | CheckFrequency () const |
|
virtual int | Config (bool rcf=0) |
| Configure this instance using the content of file 'cfn'. More...
|
|
virtual int | DoDirective (XrdProofdDirective *d, char *val, XrdOucStream *cfg, bool rcf) |
| Update the priorities of the active sessions. More...
|
|
virtual void | DumpQueues (const char *prefix=0) |
| Dump the content of the waiting sessions queue. More...
|
|
virtual int | Enqueue (XrdProofdProofServ *xps, XrdProofQuery *query) |
| Queue a query in the session; if this is the first querym enqueue also the session. More...
|
|
virtual int | ExportInfo (XrdOucString &) |
| Fill sbuf with some info about our current status. More...
|
|
virtual XrdProofdProofServ * | FirstSession () |
| Get first valid session. More...
|
|
virtual int | GetWorkers (XrdProofdProofServ *xps, std::list< XrdProofWorker * > *, const char *) |
| Get a list of workers that can be used by session 'xps'. More...
|
|
virtual bool | IsValid () |
|
virtual int | MaxSessions () const |
|
const char * | Name () const |
|
XrdProofdPipe * | Pipe () |
|
virtual int | ProcessDirective (XrdProofdDirective *d, char *val, XrdOucStream *cfg, bool rcf) |
| Update the priorities of the active sessions. More...
|
|
virtual int | Reschedule () |
| Consider starting some query from the queue. More...
|
|
virtual int | UpdateProperties () |
|
virtual int | UpdateSession (XrdProofdProofServ *, int=0, void *=0) |
|
| XrdProofdConfig (const char *cfg=0, XrdSysError *edest=0) |
| Main constructor. More...
|
|
virtual | ~XrdProofdConfig () |
|
const char * | CfgFile () const |
|
void | SetCfgEDest (const char *cfg, XrdSysError *edest) |
| Set config file and error handler. More...
|
|
#include <XrdProofSched.h>
virtual XrdProofSched::~XrdProofSched |
( |
| ) |
|
|
inlinevirtual |
int XrdProofSched::CheckFrequency |
( |
| ) |
const |
|
inline |
int XrdProofSched::Config |
( |
bool |
rcf = 0 | ) |
|
|
virtual |
Configure this instance using the content of file 'cfn'.
Return 0 on success, -1 in case of failure (file does not exists or containing incoherent information).
Reimplemented from XrdProofdConfig.
Definition at line 238 of file XrdProofSched.cxx.
int XrdProofSched::DoDirective |
( |
XrdProofdDirective * |
d, |
|
|
char * |
val, |
|
|
XrdOucStream * |
cfg, |
|
|
bool |
rcf |
|
) |
| |
|
virtual |
int XrdProofSched::DoDirectiveResource |
( |
char * |
val, |
|
|
XrdOucStream * |
cfg, |
|
|
bool |
|
|
) |
| |
|
protectedvirtual |
int XrdProofSched::DoDirectiveSchedParam |
( |
char * |
val, |
|
|
XrdOucStream * |
cfg, |
|
|
bool |
|
|
) |
| |
|
protectedvirtual |
void XrdProofSched::DumpQueues |
( |
const char * |
prefix = 0 | ) |
|
|
virtual |
Queue a query in the session; if this is the first querym enqueue also the session.
Definition at line 278 of file XrdProofSched.cxx.
int XrdProofSched::ExportInfo |
( |
XrdOucString & |
sbuf | ) |
|
|
virtual |
Fill sbuf with some info about our current status.
Definition at line 756 of file XrdProofSched.cxx.
Get first valid session.
The dataset information can be used to assign workers.
Definition at line 322 of file XrdProofSched.cxx.
Calculate the number of workers to be used given the state of the cluster.
Definition at line 341 of file XrdProofSched.cxx.
Get a list of workers that can be used by session 'xps'.
The return code is: -1 Some failure occured; cannot continue 0 A new list has been assigned to the session 'xps' and returned in 'wrks' 1 The list currently assigned to the session is the one to be used 2 No worker could be assigned now; session should be queued
Definition at line 397 of file XrdProofSched.cxx.
virtual bool XrdProofSched::IsValid |
( |
| ) |
|
|
inlinevirtual |
virtual int XrdProofSched::MaxSessions |
( |
| ) |
const |
|
inlinevirtual |
const char* XrdProofSched::Name |
( |
| ) |
const |
|
inline |
int XrdProofSched::ProcessDirective |
( |
XrdProofdDirective * |
d, |
|
|
char * |
val, |
|
|
XrdOucStream * |
cfg, |
|
|
bool |
rcf |
|
) |
| |
|
virtual |
void XrdProofSched::RegisterDirectives |
( |
| ) |
|
|
protectedvirtual |
int XrdProofSched::Reschedule |
( |
| ) |
|
|
virtual |
Consider starting some query from the queue.
to be called after some resources are free (e.g. by a finished query) This method is doing the full transaction of finding the session to resume, assigning it workers and sending a resume message. In this way there is not possibility of interference with other GetWorkers return 0 in case of success and -1 in case of an error
Definition at line 702 of file XrdProofSched.cxx.
void XrdProofSched::ResetParameters |
( |
| ) |
|
|
protectedvirtual |
virtual int XrdProofSched::UpdateProperties |
( |
| ) |
|
|
inlinevirtual |
int XrdProofSched::fCheckFrequency |
|
protected |
int XrdProofSched::fMaxRunning |
|
protected |
int XrdProofSched::fMaxSessions |
|
protected |
int XrdProofSched::fMinForQuery |
|
protected |
int XrdProofSched::fNextWrk |
|
protected |
double XrdProofSched::fNodesFraction |
|
protected |
int XrdProofSched::fOptWrksPerUnit |
|
protected |
bool XrdProofSched::fUseFIFO |
|
protected |
bool XrdProofSched::fValid |
|
protected |
int XrdProofSched::fWorkerMax |
|
protected |
int XrdProofSched::fWorkerSel |
|
protected |
The documentation for this class was generated from the following files: