BatschedNetworkListener.h
1 
10 #ifndef WRENCH_BATSCHEDNETWORKLISTENER_H
11 #define WRENCH_BATSCHEDNETWORKLISTENER_H
12 
13 #include <wrench/services/Service.h>
14 #include "BatchComputeServiceProperty.h"
15 
16 namespace wrench {
17 
18 
19  class BatchComputeService;
20 
21  /***********************/
23  /***********************/
24 
25 #ifdef ENABLE_BATSCHED
26 
29  class BatschedNetworkListener: public Service {
30 
31  public:
32 
33  BatschedNetworkListener(std::string hostname, std::shared_ptr<BatchComputeService> batch_service,
34  std::string batch_service_mailbox, std::string sched_port,
35  std::string data_to_send,std::map<std::string, std::string> property_list = {});
36  private:
37  std::map<std::string, std::string> default_property_values = {
38  };
39 
40  std::map<std::string, double> default_messagepayload_values = {
41  };
42 
43  BatschedNetworkListener(std::string, std::shared_ptr<BatchComputeService> batch_service, std::string batch_service_mailbox, std::string sched_port,
44  std::string data_to_send, std::map<std::string, std::string> property_list, std::string suffix);
45 
46 
47  int main() override;
48  std::string self_port;
49  std::string sched_port;
50  std::string data_to_send;
51  std::string reply_received;
52  std::shared_ptr<BatchComputeService> batch_service;
53  std::string batch_service_mailbox;
54 
55 
56 
57  void sendExecuteMessageToBatchComputeService(std::string answer_mailbox, std::string execute_job_reply_data);
58  void sendQueryAnswerMessageToBatchComputeService(double estimated_waiting_time);
59  void send_receive();
60  };
61 
62 #else // ENABLE_BATSCHED
63 
67 
68  };
69 #endif
70 
71  /***********************/
73  /***********************/
74 }
75 
76 
77 #endif //WRENCH_BATSCHEDNETWORKLISTENER_H
Definition: Alarm.cpp:20
An empty class to make Doxygen happy when Batsched is not enabled.
Definition: BatschedNetworkListener.h:66