HTCondorNegotiatorService.h
1 
10 #ifndef WRENCH_HTCONDORNEGOTIATORSERVICE_H
11 #define WRENCH_HTCONDORNEGOTIATORSERVICE_H
12 
13 #include "wrench/services/Service.h"
14 #include "wrench/services/compute/ComputeService.h"
15 #include "wrench/services/compute/htcondor/HTCondorCentralManagerServiceMessagePayload.h"
16 #include "wrench/workflow/job/WorkflowJob.h"
17 
18 namespace wrench {
19 
20  /***********************/
22  /***********************/
27  private:
28  std::map<std::string, double> default_messagepayload_values = {
32  };
33 
34  public:
35 
37  double startup_overhead,
38  std::set<std::shared_ptr<ComputeService>> &compute_services,
39  std::map<std::shared_ptr<WorkflowJob>, std::shared_ptr<ComputeService>> &running_jobs,
40  std::vector<std::tuple<std::shared_ptr<WorkflowJob>, std::map<std::string, std::string>>> &pending_jobs,
41  std::string &reply_mailbox);
42 
44 
45  private:
46  int main() override;
47 
48  struct JobPriorityComparator {
49  bool operator()(std::tuple<std::shared_ptr<WorkflowJob>, std::map<std::string, std::string>> &lhs,
50  std::tuple<std::shared_ptr<WorkflowJob>, std::map<std::string, std::string>> &rhs);
51  };
52 
53  std::shared_ptr<ComputeService> pickTargetComputeService(std::shared_ptr<WorkflowJob> job, std::map<std::string, std::string> service_specific_arguments);
54  std::shared_ptr<ComputeService> pickTargetComputeServiceGridUniverse(std::shared_ptr<WorkflowJob> job, std::map<std::string, std::string> service_specific_arguments);
55  std::shared_ptr<ComputeService> pickTargetComputeServiceNonGridUniverse(std::shared_ptr<WorkflowJob> job, std::map<std::string, std::string> service_specific_arguments);
56 
58  double startup_overhead;
60  std::string reply_mailbox;
62  std::set<std::shared_ptr<ComputeService>> compute_services;
64  std::map<std::shared_ptr<WorkflowJob>, std::shared_ptr<ComputeService>> running_jobs;
66  std::vector<std::tuple<std::shared_ptr<WorkflowJob>, std::map<std::string, std::string>>> pending_jobs;
67  };
68 
69  /***********************/
71  /***********************/
72 }
73 
74 #endif //WRENCH_HTCONDORNEGOTIATORSERVICE_H
~HTCondorNegotiatorService()
Destructor.
Definition: HTCondorNegotiatorService.cpp:54
static const std::string DAEMON_STOPPED_MESSAGE_PAYLOAD
The number of bytes in the control message sent by the daemon to confirm it has terminated.
Definition: ServiceMessagePayload.h:33
HTCondorNegotiatorService(std::string &hostname, double startup_overhead, std::set< std::shared_ptr< ComputeService >> &compute_services, std::map< std::shared_ptr< WorkflowJob >, std::shared_ptr< ComputeService >> &running_jobs, std::vector< std::tuple< std::shared_ptr< WorkflowJob >, std::map< std::string, std::string >>> &pending_jobs, std::string &reply_mailbox)
Constructor.
Definition: HTCondorNegotiatorService.cpp:37
static const std::string HTCONDOR_NEGOTIATOR_DONE_MESSAGE_PAYLOAD
The number of bytes in the control message sent by the daemon to state that the negotiator has been c...
Definition: HTCondorCentralManagerServiceMessagePayload.h:27
Definition: Alarm.cpp:20
A HTCondor negotiator service.
Definition: HTCondorNegotiatorService.h:26
static const std::string STOP_DAEMON_MESSAGE_PAYLOAD
The number of bytes in the control message sent to the daemon to terminate it.
Definition: ServiceMessagePayload.h:31
std::string hostname
The name of the host on which the daemon is running.
Definition: S4U_Daemon.h:51
A service that can be added to the simulation and that can be used by a WMS when executing a workflow...
Definition: Service.h:26