Nmea2kCommunicationController.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_NMEA2K_NMEA2KCOMMUNICATIONCONTROLLER_HPP_
#define IV_SRC_COMMS_NMEA2K_NMEA2KCOMMUNICATIONCONTROLLER_HPP_
 
#include "ICommunicationController.hpp"
#include "can/CMessageCan.hpp"
#include "can/ICanCommunicationProtocol.hpp"
#include "comms/canJ1939/structs.hpp"
#include "comms/nmea2k/structs.hpp"
#include "containers/CircularQueue.hpp"
 
namespace iv::comms::nmea2k
{
 
class Nmea2kCommunicationController : public iv::comms::ICommunicationController
{
    friend class Nmea2kCommunicationControllerFrame;
 
public:
    Nmea2kCommunicationController() = delete;
    explicit Nmea2kCommunicationController(const std::shared_ptr<ICommunicationDriver> &driver,
                                           const std::shared_ptr<iv::model::comms::NetworkData> &networkData);
    Nmea2kCommunicationController(const Nmea2kCommunicationController &other) = delete;
    Nmea2kCommunicationController(Nmea2kCommunicationController &&other) = delete;
    ~Nmea2kCommunicationController() override = default;
 
    Nmea2kCommunicationController &operator=(const Nmea2kCommunicationController &other) = delete;
    Nmea2kCommunicationController &operator=(Nmea2kCommunicationController &&other) = delete;
 
private:
    bool frame() override;
 
    bool sendFrame();
 
    void receiveFrame();
 
    void trimOnGoingCommunications();
 
    void addChannel(const std::shared_ptr<iv::channels::AbstractChannel> &channel) override;
    void initialize() override;
 
    void sendMessage(const std::shared_ptr<CMessageCan> &message);
 
    void
    handleSinglePacketMessage(const std::vector<std::byte> &data,
                              std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> pgnAndAddress);
 
    void
    handleDataTransferMessage(const std::shared_ptr<CMessageCan> &message,
                              std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> pgnAndAddress);
 
    void handleConnectionManagementMessage(
            const std::shared_ptr<CMessageCan> &message,
            std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> pgnAndAddress);
 
    void handleBamProtocolConnectionMessage(
            const std::shared_ptr<CMessageCan> &message,
            std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> pgnAndAddress);
 
    void handleBamProtocolDataTransferMessage(const std::shared_ptr<CMessageCan> &message,
                                              iv::comms::canJ1939::onGoingCanJ1939MultiPacketCommunication &comm);
    void bindToChannel(
            const std::pair<iv::types::comms::pgn, std::optional<iv::types::comms::j1939SourceAddress>> pgnAndAddress,
            const std::vector<std::byte> &data);
    std::shared_ptr<iv::comms::can::ICanCommunicationProtocol> m_canProtocol;
    iv::types::timestamp m_lastHeartbeatTime;
    iv::types::timestamp m_lastTimestampReceived;
 
    iv::containers::CircularQueue<std::shared_ptr<CMessageCan>, 1000> m_sendQueue;
    std::map<std::pair<iv::types::comms::pgn, std::optional<iv::types::comms::j1939SourceAddress>>,
             std::vector<iv::comms::nmea2k::Nmea2kChannelBinding>>
            m_channelsOrderedByPgnAndAddress;
 
    std::map<iv::types::comms::j1939SourceAddress, iv::comms::canJ1939::onGoingCanJ1939MultiPacketCommunication>
            m_onGoingMultiPacketCommunications;
 
    std::mutex m_eraseCommsMutex;
};
 
}// namespace iv::comms::nmea2k
#endif//IV_SRC_COMMS_NMEA2K_NMEA2KCOMMUNICATIONCONTROLLER_HPP_