3 #ifndef __ARC_JOBSUPERVISOR_H__
4 #define __ARC_JOBSUPERVISOR_H__
10 #include <arc/compute/JobControllerPlugin.h>
11 #include <arc/compute/EntityRetriever.h>
121 bool Retrieve(
const std::string& downloaddirprefix,
bool usejobname,
bool force, std::list<std::string>& downloaddirectories);
246 bool Resubmit(
int destination,
const std::list<Endpoint>& services, std::list<Job>& resubmittedJobs,
const std::list<std::string>& rejectedURLs = std::list<std::string>());
301 bool Migrate(
bool forcemigration,
const std::list<Endpoint>& services, std::list<Job>& migratedJobs,
const std::list<std::string>& rejectedURLs = std::list<std::string>());
348 const std::list<Job>& GetAllJobs()
const {
return jobs; }
349 std::list<Job> GetSelectedJobs()
const;
352 void SelectByStatus(
const std::list<std::string>& status);
353 void SelectByID(
const std::list<std::string>& ids);
355 void ClearSelection();
357 const std::list<std::string>& GetIDsProcessed()
const {
return processed; }
358 const std::list<std::string>& GetIDsNotProcessed()
const {
return notprocessed; }
361 const UserConfig& usercfg;
365 typedef std::map<JobControllerPlugin*, std::pair< std::list<Job*>, std::list<Job*> > > JobSelectionMap;
366 JobSelectionMap jcJobMap;
367 std::map<std::string, JobControllerPlugin*> loadedJCs;
369 std::list<std::string> processed, notprocessed;
371 JobControllerPluginLoader loader;
373 static Logger logger;
378 #endif // __ARC_JOBSUPERVISOR_H__