BatschedNetworkListener.h

 
#ifndef WRENCH_BATSCHEDNETWORKLISTENER_H
#define WRENCH_BATSCHEDNETWORKLISTENER_H
 
#include "wrench/services/Service.h"
#include "BatchComputeServiceProperty.h"
 
namespace wrench {
 
 
    class BatchComputeService;
 
    /***********************/
    /***********************/
 
#ifdef ENABLE_BATSCHED
 
    class BatschedNetworkListener: public Service {
 
    public:
 
        BatschedNetworkListener(std::string hostname, std::shared_ptr<BatchComputeService> batch_service,
                                simgrid::s4u::Mailbox *batch_service_mailbox, std::string sched_port,
                                std::string data_to_send,WRENCH_PROPERTY_COLLECTION_TYPE property_list = {});
    private:
        WRENCH_PROPERTY_COLLECTION_TYPE default_property_values = {
                };
 
WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE  default_messagepayload_values = {
                };
 
        BatschedNetworkListener(std::string, std::shared_ptr<BatchComputeService> batch_service, simgrid::s4u::Mailbox *batch_service_mailbox, std::string sched_port,
                             std::string data_to_send, WRENCH_PROPERTY_COLLECTION_TYPE property_list, std::string suffix);
 
 
        int main() override;
        std::string self_port;
        std::string sched_port;
        std::string data_to_send;
        std::string reply_received;
        std::shared_ptr<BatchComputeService> batch_service;
        simgrid::s4u::Mailbox *batch_service_mailbox;
 
        void sendExecuteMessageToBatchComputeService(simgrid::s4u::Mailbox *answer_mailbox, std::string execute_job_reply_data);
        void sendQueryAnswerMessageToBatchComputeService(double estimated_waiting_time);
        void send_receive();
    };
 
#else // ENABLE_BATSCHED
 
    class BatschedNetworkListener {
 
    };
#endif
 
    /***********************/
    /***********************/
}
 
 
#endif //WRENCH_BATSCHEDNETWORKLISTENER_H