RTU.cpp

Go to the documentation of this file.

#include "Module.h"

Rtu::Rtu(Bus* prmBus, Logger* prmLogger) : Module(prmBus)
{
        logger = prmLogger;
}

void Rtu::FrameMove(float fElapsedTime)
{
        for (UINT i = 0; i < bus->commandStream.size(); i++)
        {
                Command command = bus->commandStream.at(i);
                if (command.delay != 0.0f) continue;

                if (command.name == "PushToTalkDepress")
                {
                        UINT location = static_cast<UINT>(command.ivalue);
                        if (location + 1 > bus->Transmitting.size())
                        {
                                logger->Log("Rtu::FrameMove DCU BUS transmitting location failure", Logger::Error);
                                break;
                        }

                        if (!bus->Transmitting.at(location))
                        {
                                bus->Transmitting.at(location) = true;

                                Command newCommand;
                                newCommand.name = "RtuTransmit";
                                newCommand.bvalue = true;
                                bus->commandStream.push_back(newCommand);
                        }
                        bus->commandStream.erase(bus->commandStream.begin() + i);
                }
                else if (command.name == "PushToTalkRelease")
                {
                        UINT location = static_cast<UINT>(command.ivalue);
                        if (location + 1 > bus->Transmitting.size())
                        {
                                logger->Log("Rtu::FrameMove DCU BUS transmitting location failure", Logger::Error);
                                break;
                        }

                        if (bus->Transmitting.at(location)) // only release if it was me
                        {
                                bus->Transmitting.at(location) = false;

                                Command newCommand;
                                newCommand.name = "RtuTransmit";
                                newCommand.bvalue = false;
                                bus->commandStream.push_back(newCommand);
                        }
                        bus->commandStream.erase(bus->commandStream.begin() + i);
                }
        }
}