CanJ1939CommunicationController.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_CAN_CANJ1939COMMUNICATIONCONTROLLER_HPP_
#define IV_SRC_COMMS_CAN_CANJ1939COMMUNICATIONCONTROLLER_HPP_
 
#include "ICommunicationController.hpp"
#include "comms/can/PcanGatewayCommunicationProtocol.hpp"
#include "containers/CircularQueue.hpp"
#include "core/defines.hpp"
#include "structs.hpp"
 
namespace iv::comms::canJ1939
{
class CanJ1939CommunicationController : public iv::comms::ICommunicationController
{
    friend class CanJ1939CommunicationControllerFrame;
 
public:
    CanJ1939CommunicationController() = delete;
    explicit CanJ1939CommunicationController(const std::shared_ptr<ICommunicationDriver> &driver,
                                             const std::shared_ptr<iv::model::comms::NetworkData> &networkData);
    CanJ1939CommunicationController(const CanJ1939CommunicationController &other) = delete;
    CanJ1939CommunicationController(CanJ1939CommunicationController &&other) = delete;
    ~CanJ1939CommunicationController() override = default;
 
    CanJ1939CommunicationController &operator=(const CanJ1939CommunicationController &other) = delete;
    CanJ1939CommunicationController &operator=(CanJ1939CommunicationController &&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,
            const std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> &pgnAndAddress);
    void handleConnectionManagementMessage(
            const std::shared_ptr<CMessageCan> &message,
            const std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> &pgnAndAddress);
    void handleDataTransferMessage(
            const std::shared_ptr<CMessageCan> &message,
            const std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> &pgnAndAddress);
 
    void bindToChannel(
            const std::pair<iv::types::comms::pgn, std::optional<iv::types::comms::j1939SourceAddress>> &pgnAndAddress,
            const std::vector<std::byte> &data);
 
    void handleDm1Packet(std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> pgnAndAddress,
                         const std::vector<std::byte> &data);
 
    void handleDefaultStateDM1Channels();
 
    void bindDTC(std::optional<iv::types::comms::j1939SourceAddress> address, iv::types::comms::dtc data);
 
    void handleBamProtocolConnectionMessage(
            const std::shared_ptr<CMessageCan> &message,
            const std::pair<iv::types::comms::pgn, iv::types::comms::j1939SourceAddress> &pgnAndAddress);
 
    void handleBamProtocolDataTransferMessage(const std::shared_ptr<CMessageCan> &message,
                                              onGoingCanJ1939MultiPacketCommunication &comm);
 
    std::shared_ptr<iv::comms::can::ICanCommunicationProtocol> m_canProtocol;
 
    std::map<std::pair<iv::types::comms::pgn, std::optional<iv::types::comms::j1939SourceAddress>>,
             std::vector<iv::comms::canJ1939::CanJ1939ChannelBinding>>
            m_channelsOrderedByPgnAndAddress;
 
    std::map<std::pair<iv::types::comms::spn, std::optional<iv::types::comms::j1939SourceAddress>>,
             iv::comms::canJ1939::CanJ1939Dm1ChannelBinding>
            m_dm1ChannelsOrderedBySpnAndAddress;
 
    std::map<iv::types::comms::j1939SourceAddress, onGoingCanJ1939MultiPacketCommunication>
            m_onGoingMultiPacketCommunications;
    iv::containers::CircularQueue<std::shared_ptr<CMessageCan>, 1000> m_sendQueue;
 
    iv::types::timestamp m_lastHeartbeatTime;
    iv::types::timestamp m_lastTimestampReceived;
    std::mutex m_eraseCommsMutex;
};
}// namespace iv::comms::canJ1939
 
#endif//IV_SRC_COMMS_CAN_CANJ1939COMMUNICATIONCONTROLLER_HPP_