10 #ifndef WRENCH_BATSCHEDNETWORKLISTENER_H
11 #define WRENCH_BATSCHEDNETWORKLISTENER_H
13 #include <wrench/services/Service.h>
14 #include "BatchComputeServiceProperty.h"
19 class BatchComputeService;
25 #ifdef ENABLE_BATSCHED
29 class BatschedNetworkListener:
public Service {
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 = {});
37 std::map<std::string, std::string> default_property_values = {
40 std::map<std::string, double> default_messagepayload_values = {
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);
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;
57 void sendExecuteMessageToBatchComputeService(std::string answer_mailbox, std::string execute_job_reply_data);
58 void sendQueryAnswerMessageToBatchComputeService(
double estimated_waiting_time);
62 #else // ENABLE_BATSCHED
77 #endif //WRENCH_BATSCHEDNETWORKLISTENER_H