3 #ifndef __ARC_JOBSUPERVISOR_H__
4 #define __ARC_JOBSUPERVISOR_H__
10 #include <arc/compute/JobControllerPlugin.h>
11 #include <arc/compute/EntityRetriever.h>
113 bool Retrieve(
const std::string& downloaddirprefix,
bool usejobname,
bool force, std::list<std::string>& downloaddirectories);
238 bool Resubmit(
int destination,
const std::list<Endpoint>& services, std::list<Job>& resubmittedJobs,
const std::list<std::string>& rejectedURLs = std::list<std::string>());
293 bool Migrate(
bool forcemigration,
const std::list<Endpoint>& services, std::list<Job>& migratedJobs,
const std::list<std::string>& rejectedURLs = std::list<std::string>());
340 const std::list<Job>& GetAllJobs()
const {
return jobs; }
341 std::list<Job> GetSelectedJobs()
const;
344 void SelectByStatus(
const std::list<std::string>& status);
345 void SelectByID(
const std::list<std::string>& ids);
347 void ClearSelection();
349 const std::list<std::string>& GetIDsProcessed()
const {
return processed; }
350 const std::list<std::string>& GetIDsNotProcessed()
const {
return notprocessed; }
353 const UserConfig& usercfg;
357 typedef std::map<JobControllerPlugin*, std::pair< std::list<Job*>, std::list<Job*> > > JobSelectionMap;
358 JobSelectionMap jcJobMap;
359 std::map<std::string, JobControllerPlugin*> loadedJCs;
361 std::list<std::string> processed, notprocessed;
363 JobControllerPluginLoader loader;
365 static Logger logger;
370 #endif // __ARC_JOBSUPERVISOR_H__