doip_tcp_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_TCP_CHANNEL_DOIP_TCP_CHANNEL_HANDLER_H_
#define DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_CHANNEL_TCP_CHANNEL_DOIP_TCP_CHANNEL_HANDLER_H_
 
#include <mutex>
 
#include "channel/tcp_channel/doip_diagnostic_message_handler.h"
#include "channel/tcp_channel/doip_routing_activation_handler.h"
#include "common/doip_message.h"
#include "sockets/socket_handler.h"
#include "uds_transport/protocol_mgr.h"
#include "uds_transport/uds_message.h"
 
namespace doip_client {
namespace channel {
namespace tcp_channel {
 
// Forward declaration
class DoipTcpChannel;
 
class DoipTcpChannelHandler final {
 public:
  using TcpMessagePtr = sockets::TcpSocketHandler::MessagePtr;
 
  DoipTcpChannelHandler(sockets::TcpSocketHandler &tcp_socket_handler, DoipTcpChannel &channel);
 
  void Start();
 
  void Stop();
 
  void Reset();
 
  auto SendRoutingActivationRequest(
      uds_transport::UdsMessageConstPtr routing_activation_request) noexcept
      -> uds_transport::UdsTransportProtocolMgr::ConnectionResult;
 
  auto SendDiagnosticRequest(uds_transport::UdsMessageConstPtr diagnostic_request) noexcept
      -> uds_transport::UdsTransportProtocolMgr::TransmissionResult;
 
  void HandleMessage(TcpMessagePtr tcp_rx_message) noexcept;
 
  auto IsRoutingActivated() noexcept -> bool;
 
 private:
  auto ProcessDoIPHeader(DoipMessage &doip_rx_message, std::uint8_t &nack_code) noexcept -> bool;
 
  auto ProcessDoIPPayloadLength(std::uint32_t payload_len, std::uint16_t payload_type) noexcept
      -> bool;
 
  void ProcessDoIPPayload(DoipMessage &doip_payload) noexcept;
 
  RoutingActivationHandler routing_activation_handler_;
 
  DiagnosticMessageHandler diagnostic_message_handler_;
 
  std::mutex channel_handler_lock;
};
 
}  // namespace tcp_channel
}  // namespace channel
}  // namespace doip_client
#endif  //DIAG_CLIENT_LIB_LIB_DOIP_CLIENT_CHANNEL_TCP_CHANNEL_DOIP_TCP_CHANNEL_HANDLER_H_