S4U_PendingCommunication.h

 
#ifndef WRENCH_S4U_PENDINGCOMMUNICATION_H
#define WRENCH_S4U_PENDINGCOMMUNICATION_H
 
 
#include <vector>
#include <simgrid/s4u/Comm.hpp>
#include "wrench/util/MessageManager.h"
 
//#include "S4U_PendingCommunication.h"
 
namespace wrench {
 
    class SimulationMessage;
 
    /*******************/
    /*******************/
 
    class S4U_PendingCommunication {
    public:
 
        enum OperationType {
            SENDING,
            RECEIVING
        };
 
        S4U_PendingCommunication(simgrid::s4u::Mailbox *mailbox, OperationType operation_type) : mailbox(mailbox), operation_type(operation_type) {}
 
        std::unique_ptr<SimulationMessage> wait();
        std::unique_ptr<SimulationMessage> wait(double timeout);
 
        static unsigned long waitForSomethingToHappen(
                std::vector<std::shared_ptr<S4U_PendingCommunication>> pending_comms,
                double timeout);
 
        static unsigned long waitForSomethingToHappen(
                std::vector<S4U_PendingCommunication*> pending_comms,
                double timeout);
 
//        ~S4U_PendingCommunication() default;
 
        simgrid::s4u::CommPtr comm_ptr;
        std::unique_ptr<SimulationMessage> simulation_message;
        simgrid::s4u::Mailbox *mailbox;
        OperationType operation_type;
    };
 
    /*******************/
    /*******************/
 
};
 
 
#endif //WRENCH_S4U_PENDINGCOMMUNICATION_H