NetworkConnection.h

#ifndef WRENCH_NETWORKCONNECTION_H
#define WRENCH_NETWORKCONNECTION_H


#include <string>
#include <memory>
#include <wrench/simgrid_S4U_util/S4U_PendingCommunication.h>
#include <wrench/workflow/execution_events/FailureCause.h>

namespace wrench {

    /***********************/
    /***********************/

    class WorkflowFile;
    class SimulationTimestampFileCopyStart;

    class NetworkConnection {

    public:

        enum NetworkConnectionType {
            INCOMING_DATA,
            OUTGOING_DATA,
            INCOMING_CONTROL
        };

        NetworkConnection(int type, WorkflowFile* file, std::string file_partition, std::string mailbox, std::string ack_mailbox, SimulationTimestampFileCopyStart *start_timestamp = nullptr);
        bool start();
        bool hasFailed();
        std::unique_ptr<SimulationMessage> getMessage();

        int type;
        WorkflowFile *file;
        std::string file_partition;
        std::string mailbox;
        std::unique_ptr<S4U_PendingCommunication> comm;
        std::shared_ptr<FailureCause> failure_cause;
        std::string ack_mailbox;
        SimulationTimestampFileCopyStart *start_timestamp;
    };

    /***********************/
    /***********************/

};


#endif //WRENCH_NETWORKCONNECTION_H