Public Methods | |
Constructors/Destructor | |
virtual | ~JobCollection () |
Destructor. | |
JobCollection () | |
Instantiates an empty JobCollection object. | |
JobCollection (const Job &job, unsigned int n) | |
Instantiates a collection with n copies of a job (the Job has to be of JOB__AD type). More... | |
JobCollection (const std::vector< Job > &jobs) | |
Instantiates a JobCollection object from a vector of Job. More... | |
Jobs insertion/remotion handling | |
bool | empty () |
Check the size of the collection. More... | |
unsigned int | size () |
void | insert (const Job &job) |
Insert a new Job to the collection. More... | |
void | remove (const Job &job) |
Remove a specified Job from the collection Delete the specified job from the collection (if the id has been set) Delete the last occurrence of the job from the collection (if the ad has not been set). More... | |
void | clear () |
Deletes all elements from the collection. | |
void | setLoggerLevel (int level) |
Se the verbosity level for NS debug default value = 0 (no verbosity) max value = 6 (dreadful verbosity, print screen). More... | |
void | setCredPath (const std::string cp) |
Set a different Proxy certificate from the default one. More... | |
void | unsetCredPath () |
Set the Proxy certificate as default. | |
void | setMaxThreadNumber (unsigned int maxThread) |
This method is used to override the MAX_THREAD_NUMBER macro variable. More... | |
Iteration action | |
std::vector< Job >::iterator | begin () |
std::vector< Job >::iterator | end () |
Operation | |
CollectionResult | submit (const std::string &ns_host, int ns_port, std::vector< std::pair< std::string, int > > lbAddrs, const std::string &ce_id="") |
Submit method. More... | |
CollectionResult | cancel () |
Cancel the job from the NS Cancel all the jobs belonging to the collection. More... | |
CollectionResult | getStatus () |
Retrieve the status information from the LB. More... | |
CollectionResult | getOutput (const std::string &dir_path) |
Get the output files of the jobs. More... |
A JobCollection has the main purpose of allowing the execution of collective operations on sets of independent jobs. The JobCollection class is just a logical container, and both not yet submitted and already submitted jobs can be inserted in it. A job collection is somehow orthogonal wrt a job cluster being a set of dependent jobs (e.g. all jobs spawned by the same father process). The allowed operations are:
|
Instantiates a collection with n copies of a job (the Job has to be of JOB__AD type).
|
|
Instantiates a JobCollection object from a vector of Job.
|
|
|
|
Cancel the job from the NS Cancel all the jobs belonging to the collection. A job can be cancelled only when it is not yet finished
|
|
Check the size of the collection.
|
|
|
|
Get the output files of the jobs.
|
|
Retrieve the status information from the LB.
|
|
Insert a new Job to the collection.
|
|
Remove a specified Job from the collection Delete the specified job from the collection (if the id has been set) Delete the last occurrence of the job from the collection (if the ad has not been set).
|
|
Set a different Proxy certificate from the default one.
|
|
Se the verbosity level for NS debug default value = 0 (no verbosity) max value = 6 (dreadful verbosity, print screen).
|
|
This method is used to override the MAX_THREAD_NUMBER macro variable.
|
|
|
|
Submit method.
|