SimToDuTInterface.h

 
#ifndef SIM_TO_DUT_INTERFACE_SIMTODUTINTERFACE_H
#define SIM_TO_DUT_INTERFACE_SIMTODUTINTERFACE_H
 
#include "DuT_Connectors/DuTConnector.h"
#include "Sim_Communication/SimComHandler.h"
#include <list>
#include <iterator>
 
namespace sim_interface {
    // Forward declaration to avoid looping
    class SimComHandler;
 
    class SimToDuTInterface {
    public:
        SimToDuTInterface();
 
        ~SimToDuTInterface();
 
        void addConnector(std::shared_ptr<dut_connector::DuTConnector> duTConnector);
 
        void setSimComHandler(SimComHandler *simComHandler);
 
        void run();
 
        friend std::ostream &operator<<(std::ostream &os, const SimToDuTInterface &interface);
 
        std::shared_ptr<SharedQueue<SimEvent>> getQueueDuTToSim();
 
        std::shared_ptr<SharedQueue<SimEvent>> getQueueSimToInterface();
 
    private:
        std::shared_ptr<SharedQueue<SimEvent>> queueDuTToSim;
        std::shared_ptr<SharedQueue<SimEvent>> queueSimToInterface;
        SimComHandler *simComHandler = nullptr;
        std::list<std::shared_ptr<dut_connector::DuTConnector>> duTConnectors;
        std::thread threadSimToInterface;
        std::thread threadDuTToSim;
        bool stopThreads = true;
 
        void sendEventToConnector(const SimEvent &event);
 
        void handleEventsFromSim();
 
        void handleEventsFromDuT();
    };
}
 
#endif //SIM_TO_DUT_INTERFACE_SIMTODUTINTERFACE_H