NetworkProximityMessage.h

 
#ifndef WRENCH_NETWORKPROXIMITYMESSAGE_H
#define WRENCH_NETWORKPROXIMITYMESSAGE_H
 
#include <wrench/services/network_proximity/NetworkProximityDaemon.h>
#include <wrench/services/ServiceMessage.h>
 
namespace wrench {
 
    /***********************/
    /***********************/
 
    class NetworkProximityMessage : public ServiceMessage {
    protected:
        NetworkProximityMessage(std::string name, double payload);
 
    };
 
 
    class NetworkProximityLookupRequestMessage : public NetworkProximityMessage {
    public:
        NetworkProximityLookupRequestMessage(std::string answer_mailbox, std::pair<std::string, std::string> hosts,
                                             double payload);
 
        std::string answer_mailbox;
        std::pair<std::string, std::string> hosts;
    };
 
 
    class NetworkProximityLookupAnswerMessage : public NetworkProximityMessage {
    public:
        NetworkProximityLookupAnswerMessage(std::pair<std::string, std::string> hosts, double proximity_value,
                                            double timestamp, double payload);
 
        std::pair<std::string, std::string> hosts;
        double proximity_value;
        double timestamp;
    };
 
 
    class NetworkProximityComputeAnswerMessage : public NetworkProximityMessage {
    public:
        NetworkProximityComputeAnswerMessage(std::pair<std::string, std::string> hosts, double proximity_value,
                                             double payload);
 
        std::pair<std::string, std::string> hosts;
        double proximity_value;
    };
 
    class NetworkProximityTransferMessage : public NetworkProximityMessage {
    public:
        NetworkProximityTransferMessage(double payload);
 
    };
 
    class NextContactDaemonRequestMessage : public NetworkProximityMessage {
    public:
        NextContactDaemonRequestMessage(std::shared_ptr<NetworkProximityDaemon> daemon, double payload);
 
        std::shared_ptr<NetworkProximityDaemon> daemon;
    };
 
    class NextContactDaemonAnswerMessage : public NetworkProximityMessage {
    public:
        NextContactDaemonAnswerMessage(std::string next_host_to_send,
                                       std::shared_ptr<NetworkProximityDaemon> next_daemon_to_send,
                                       std::string next_mailbox_to_send, double payload);
 
        std::string next_host_to_send;
 
        std::shared_ptr<NetworkProximityDaemon> next_daemon_to_send;
 
        std::string next_mailbox_to_send;
    };
 
    class CoordinateLookupRequestMessage : public NetworkProximityMessage {
    public:
        CoordinateLookupRequestMessage(std::string answer_mailbox, std::string requested_host, double payload);
 
        std::string answer_mailbox;
 
        std::string requested_host;
    };
 
    class CoordinateLookupAnswerMessage : public NetworkProximityMessage {
    public:
        CoordinateLookupAnswerMessage(std::string requested_host, bool success, std::pair<double, double> xy_coordinate,
                                      double timestamp, double payload);
 
        std::string requested_host;
 
        bool success;
 
        std::pair<double, double> xy_coordinate;
        double timestamp;
    };
 
    /***********************/
    /***********************/
}
 
 
#endif //WRENCH_NETWORKPROXIMITYMESSAGE_H