doip_udp_channel_handler.h

Go to the documentation of this file.

/* Diagnostic Client library
 * Copyright (C) 2024  Avijit Dey
 *
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 */
#ifndef DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_CHANNEL_UDP_CHANNEL_DOIP_UDP_CHANNEL_HANDLER_H_
#define DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_CHANNEL_UDP_CHANNEL_DOIP_UDP_CHANNEL_HANDLER_H_
 
#include "channel/udp_channel/doip_vehicle_discovery_handler.h"
#include "channel/udp_channel/doip_vehicle_identification_handler.h"
#include "common/doip_message.h"
#include "sockets/udp_socket_handler.h"
#include "uds_transport/protocol_mgr.h"
#include "uds_transport/uds_message.h"
 
namespace doip_client {
namespace channel {
namespace udp_channel {
 
// Forward declaration
class DoipUdpChannel;
 
class DoipUdpChannelHandler final {
 public:
  using UdpMessagePtr = sockets::UdpSocketHandler::UdpMessagePtr;
 
  DoipUdpChannelHandler(sockets::UdpSocketHandler &udp_socket_handler_broadcast,
                        sockets::UdpSocketHandler &udp_socket_handler_unicast, DoipUdpChannel &channel);
 
  auto SendVehicleIdentificationRequest(uds_transport::UdsMessageConstPtr vehicle_identification_request) noexcept
      -> uds_transport::UdsTransportProtocolMgr::TransmissionResult;
 
  void HandleMessageUnicast(UdpMessagePtr udp_rx_message) noexcept;
 
  void HandleMessageBroadcast(UdpMessagePtr udp_rx_message) noexcept;
 
 private:
  auto ProcessDoIPHeader(DoipMessage &doip_rx_message, std::uint8_t &nack_code) noexcept -> bool;
 
  static auto ProcessDoIPPayloadLength(std::uint32_t payload_len, std::uint16_t payload_type) noexcept -> bool;
 
  void ProcessDoIPPayload(DoipMessage &doip_payload,
                          DoipMessage::RxSocketType socket_type = DoipMessage::RxSocketType::kUnicast);
 
  VehicleDiscoveryHandler vehicle_discovery_handler_;
 
  VehicleIdentificationHandler vehicle_identification_handler_;
 
  std::mutex channel_handler_lock;
};
}  // namespace udp_channel
}  // namespace channel
}  // namespace doip_client
 
#endif  //DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_CHANNEL_UDP_CHANNEL_DOIP_UDP_CHANNEL_HANDLER_H_