BatschedNetworkListener.h
1 
10 #ifndef WRENCH_BATSCHEDNETWORKLISTENER_H
11 #define WRENCH_BATSCHEDNETWORKLISTENER_H
12 
13 #include <wrench/services/Service.h>
14 #include "BatchServiceProperty.h"
15 
16 namespace wrench {
17 
18 
19  class BatchService;
20 
21  /***********************/
23  /***********************/
24 
29 
30  public:
31 
32  BatschedNetworkListener(std::string hostname, BatchService *batch_service, std::string batch_service_mailbox, std::string sched_port,
33  std::string data_to_send,std::map<std::string, std::string> property_list = {});
34 
35 
36  private:
37  std::map<std::string, std::string> default_property_values = {
38  };
39 
40  std::map<std::string, std::string> default_messagepayload_values = {
41  };
42 
43  BatschedNetworkListener(std::string, BatchService *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  BatchService *batch_service;
53  std::string batch_service_mailbox;
54 
55 
56 
57  void sendExecuteMessageToBatchService(std::string answer_mailbox, std::string execute_job_reply_data);
58  void sendQueryAnswerMessageToBatchService(double estimated_waiting_time);
59  void send_receive();
60  };
61 
62  /***********************/
64  /***********************/
65 }
66 
67 
68 #endif //WRENCH_BATSCHEDNETWORKLISTENER_H
A batch-scheduled compute service that manages a set of compute hosts and controls access to their re...
Definition: BatchService.h:47
std::map< std::string, std::string > property_list
The service&#39;s property list.
Definition: Service.h:104
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
A helper service that handles all interaction with Batsched.
Definition: BatschedNetworkListener.h:28
std::string hostname
The name of the host on which the daemon is running.
Definition: S4U_Daemon.h:47
Definition: TerminalOutput.cpp:15