Class to establish connection with Diagnostic Server. More...

#include <dm_conversation.h>

Inheritance diagram for diag::client::conversation::DmConversation:

Collaboration diagram for diag::client::conversation::DmConversation:

[legend]

Public Types
using	ConversationState = conversation_state_impl::ConversationState
	Type alias for conversation internal state. More...

using	SyncTimer = utility::sync_timer::SyncTimer< std::chrono::steady_clock >
	Type alias for synchronous timer. More...

Public Types inherited from diag::client::conversation::Conversation
using	IpAddress = DiagClientConversation::IpAddress
	Type alias for Ip address. More...

using	ConnectResult = DiagClientConversation::ConnectResult
	Type alias for Connection results. More...

using	DisconnectResult = DiagClientConversation::DisconnectResult
	Type alias for Disconnection results. More...

using	DiagError = DiagClientConversation::DiagError
	Type alias for Diagnostic results. More...

Public Member Functions
	DmConversation (std::string_view conversion_name, DMConversationType &conversion_identifier)
	Constructs an instance of DmConversation. More...

	DmConversation (const DmConversation &other) noexcept=delete
	Deleted copy assignment and copy constructor. More...

DmConversation &	operator= (const DmConversation &other) noexcept=delete

	DmConversation (DmConversation &&other) noexcept=delete
	Deleted move assignment and move constructor. More...

DmConversation &	operator= (DmConversation &&other) noexcept=delete

	~DmConversation () override
	Destructs an instance of DmConversation. More...

void	Startup () noexcept override
	Function to start the DmConversation. More...

void	Shutdown () noexcept override
	Function to shutdown the DmConversation. More...

void	RegisterConnection (std::unique_ptr<::uds_transport::Connection > connection) noexcept override
	Function to register the conversation to underlying transport protocol handler. More...

::uds_transport::ConversionHandler &	GetConversationHandler () noexcept override
	Function to get the conversation handler from conversation object. More...

ConnectResult	ConnectToDiagServer (std::uint16_t target_address, IpAddress host_ip_addr) noexcept override
	Function to connect to Diagnostic Server. More...

DisconnectResult	DisconnectFromDiagServer () noexcept override
	Function to disconnect from Diagnostic Server. More...

std::pair<::uds_transport::UdsTransportProtocolMgr::IndicationResult, ::uds_transport::UdsMessagePtr >	IndicateMessage (::uds_transport::UdsMessage::Address source_addr, ::uds_transport::UdsMessage::Address target_addr, ::uds_transport::UdsMessage::TargetAddressType type, ::uds_transport::ChannelID channel_id, std::size_t size, ::uds_transport::Priority priority, ::uds_transport::ProtocolKind protocol_kind, core_type::Span< std::uint8_t > payload_info) noexcept override
	Function to indicate a start of reception of message. More...

void	HandleMessage (::uds_transport::UdsMessagePtr message) noexcept override
	Function to Hands over a valid received Uds message. More...

Result< uds_message::UdsResponseMessagePtr, DiagError >	SendDiagnosticRequest (uds_message::UdsRequestMessageConstPtr message) noexcept override
	Function to send Diagnostic Request and get Diagnostic Response. More...

Public Member Functions inherited from diag::client::conversation::Conversation
	Conversation () noexcept=default
	Constructs an instance of Conversation. More...

	Conversation (const Conversation &other) noexcept=delete
	Deleted copy assignment and copy constructor. More...

Conversation &	operator= (const Conversation &other) noexcept=delete

	Conversation (Conversation &&other) noexcept=delete
	Deleted move assignment and move constructor. More...

Conversation &	operator= (Conversation &&other) noexcept=delete

virtual	~Conversation () noexcept=default
	Destructs an instance of Conversation. More...

virtual core_type::Result< diag::client::vehicle_info::VehicleInfoMessageResponseUniquePtr, DiagClient::VehicleInfoResponseError >	SendVehicleIdentificationRequest (vehicle_info::VehicleInfoListRequestType) noexcept
	Function to send vehicle identification request and get the Diagnostic Server list. More...

Private Types
enum class	SessionControlType : std::uint8_t { kDefaultSession = 0x01 , kProgrammingSession = 0x02 , kExtendedSession = 0x03 , kSystemSafetySession = 0x04 }
	Definitions of active diagnostic session. More...

enum class	SecurityLevelType : std::uint8_t { kLocked = 0x00 , kUnLocked = 0x01 }
	Definitions of active security level. More...

enum class	ActivityStatusType : uint8_t { kActive = 0x00 , kInactive = 0x01 }
	Definitions of current activity status. More...

Static Private Member Functions
static DiagClientConversation::DiagError	ConvertResponseType (::uds_transport::UdsTransportProtocolMgr::TransmissionResult result_type)
	Helper function to convert response type. More...

Private Attributes
ActivityStatusType	activity_status_
	Store the conversation activity status. More...

SessionControlType	active_session_
	Store the active diagnostic session. More...

SecurityLevelType	active_security_level_
	Store the active diagnostic security level. More...

std::uint32_t	rx_buffer_size_
	Store the size of reception buffer size setting. More...

std::uint16_t	p2_client_max_
	Store the maximum p2 client time. More...

std::uint16_t	p2_star_client_max_
	Store the maximum p2 star client time. More...

std::uint16_t	source_address_
	Store the logical source address of conversation. More...

std::uint16_t	target_address_
	Store the logical target address of remote server. More...

std::string	remote_address_
	Store the remote IP address of remote server. More...

std::string	conversation_name_
	Store the conversation name. More...

std::unique_ptr<::uds_transport::ConversionHandler >	dm_conversion_handler_
	Store the dm conversation handler. More...

std::unique_ptr<::uds_transport::Connection >	connection_ptr_
	Store the underlying transport protocol connection object. More...

SyncTimer	sync_timer_
	Store the synchronous timer. More...

::uds_transport::ByteVector	payload_rx_buffer_
	Store the received uds response. More...

conversation_state_impl::ConversationStateImpl	conversation_state_
	Store the conversation state. More...

Detailed Description

Class to establish connection with Diagnostic Server.

Definition at line 28 of file dm_conversation.h.

Member Typedef Documentation

◆ ConversationState

using diag::client::conversation::DmConversation::ConversationState = conversation_state_impl::ConversationState

Type alias for conversation internal state.

Definition at line 33 of file dm_conversation.h.

◆ SyncTimer

using diag::client::conversation::DmConversation::SyncTimer = utility::sync_timer::SyncTimer<std::chrono::steady_clock>

Type alias for synchronous timer.

Definition at line 37 of file dm_conversation.h.

Member Enumeration Documentation

◆ ActivityStatusType

enum diag::client::conversation::DmConversation::ActivityStatusType : uint8_t

strongprivate

Definitions of current activity status.

Enumerator
kActive
kInactive

Definition at line 180 of file dm_conversation.h.

180 : uint8_t { kActive = 0x00, kInactive = 0x01 };

◆ SecurityLevelType

enum diag::client::conversation::DmConversation::SecurityLevelType : std::uint8_t

strongprivate

Definitions of active security level.

Enumerator
kLocked
kUnLocked

Definition at line 172 of file dm_conversation.h.

                                : std::uint8_t {
     kLocked = 0x00,
     kUnLocked = 0x01,
   };

◆ SessionControlType

enum diag::client::conversation::DmConversation::SessionControlType : std::uint8_t

strongprivate

Definitions of active diagnostic session.

Enumerator
kDefaultSession
kProgrammingSession
kExtendedSession
kSystemSafetySession

Definition at line 162 of file dm_conversation.h.

                                 : std::uint8_t {
     kDefaultSession = 0x01,
     kProgrammingSession = 0x02,
     kExtendedSession = 0x03,
     kSystemSafetySession = 0x04
   };

Constructor & Destructor Documentation

◆ DmConversation() [1/3]

diag::client::conversation::DmConversation::DmConversation	(	std::string_view	conversion_name,
		DMConversationType &	conversion_identifier
	)

Constructs an instance of DmConversation.

Parameters

[in]	conversion_name	The name of conversation
[in]	conversion_identifier	The identifier consisting of conversation settings

Definition at line 105 of file dm_conversation.cpp.

     : Conversation{},
       activity_status_{ActivityStatusType::kInactive},
       active_session_{SessionControlType::kDefaultSession},
       active_security_level_{SecurityLevelType::kLocked},
       rx_buffer_size_{conversion_identifier.rx_buffer_size},
       p2_client_max_{conversion_identifier.p2_client_max},
       p2_star_client_max_{conversion_identifier.p2_star_client_max},
       source_address_{conversion_identifier.source_address},
       target_address_{},
       conversation_name_{conversion_name},
       dm_conversion_handler_{std::make_unique<DmConversationHandler>(conversion_identifier.handler_id, *this)} {
   (void) (active_session_);
   (void) (active_security_level_);
 }

References active_security_level_, and active_session_.

◆ DmConversation() [2/3]

diag::client::conversation::DmConversation::DmConversation ( const DmConversation & other )

deletenoexcept

Deleted copy assignment and copy constructor.

◆ DmConversation() [3/3]

diag::client::conversation::DmConversation::DmConversation ( DmConversation && other )

deletenoexcept

Deleted move assignment and move constructor.

◆ ~DmConversation()

diag::client::conversation::DmConversation::~DmConversation ( )

overridedefault

Destructs an instance of DmConversation.

Member Function Documentation

◆ ConnectToDiagServer()

DiagClientConversation::ConnectResult diag::client::conversation::DmConversation::ConnectToDiagServer	(	std::uint16_t	target_address,
		IpAddress	host_ip_addr
	)

overridevirtualnoexcept

Function to connect to Diagnostic Server.

Parameters

[in]	target_address	Logical address of the Remote server
[in]	host_ip_addr	IP address of the Remote server

Returns: ConnectResult Connection result returned

Reimplemented from diag::client::conversation::Conversation.

Definition at line 151 of file dm_conversation.cpp.

                                                                                                            {
   // create an uds message just to get the port number
   // source address required for Routing Activation
   uds_transport::ByteVector payload{};  // empty payload
   // Send Connect request to doip layer
   DiagClientConversation::ConnectResult const connection_result{static_cast<DiagClientConversation::ConnectResult>(
       connection_ptr_->ConnectToHost(std::make_unique<diag::client::uds_message::DmUdsMessage>(
           source_address_, target_address, host_ip_addr, payload)))};
   remote_address_ = host_ip_addr;
   target_address_ = target_address;
   if (connection_result == DiagClientConversation::ConnectResult::kConnectSuccess) {
     logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
         __FILE__, __LINE__, __func__, [this](std::stringstream &msg) {
           msg << "'" << conversation_name_ << "'"
               << "-> "
               << "Successfully connected to Server with IP <" << remote_address_ << ">"
               << " and LA= 0x" << std::hex << target_address_;
         });
   } else {
     logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogError(
         __FILE__, __LINE__, __func__, [this](std::stringstream &msg) {
           msg << "'" << conversation_name_ << "'"
               << "-> "
               << "Failed connecting to Server with IP <" << remote_address_ << ">"
               << " and LA= 0x" << std::hex << target_address_;
         });
   }
   return connection_result;
 }

References diag::client::logger::DiagClientLogger::GetDiagClientLogger(), and diag::client::conversation::DiagClientConversation::kConnectSuccess.

Here is the call graph for this function:

◆ ConvertResponseType()

DiagClientConversation::DiagError diag::client::conversation::DmConversation::ConvertResponseType ( ::uds_transport::UdsTransportProtocolMgr::TransmissionResult result_type )

staticprivate

Helper function to convert response type.

Parameters

[in] result_type The transmission result type

Returns: DiagResult The diagnostic result type

Definition at line 394 of file dm_conversation.cpp.

                                                                         {
   DiagClientConversation::DiagError ret_result{DiagClientConversation::DiagError::kDiagGenericFailure};
   switch (result_type) {
     case uds_transport::UdsTransportProtocolMgr::TransmissionResult::kTransmitFailed:
       ret_result = DiagClientConversation::DiagError::kDiagRequestSendFailed;
       break;
     case uds_transport::UdsTransportProtocolMgr::TransmissionResult::kNoTransmitAckReceived:
       ret_result = DiagClientConversation::DiagError::kDiagAckTimeout;
       break;
     case uds_transport::UdsTransportProtocolMgr::TransmissionResult::kNegTransmitAckReceived:
       ret_result = DiagClientConversation::DiagError::kDiagNegAckReceived;
       break;
     case uds_transport::UdsTransportProtocolMgr::TransmissionResult::kBusyProcessing:
       ret_result = DiagClientConversation::DiagError::kDiagBusyProcessing;
       break;
     default:
       ret_result = DiagClientConversation::DiagError::kDiagGenericFailure;
       break;
   }
   return ret_result;
 }

References uds_transport::UdsTransportProtocolMgr::kBusyProcessing, diag::client::conversation::DiagClientConversation::kDiagAckTimeout, diag::client::conversation::DiagClientConversation::kDiagBusyProcessing, diag::client::conversation::DiagClientConversation::kDiagGenericFailure, diag::client::conversation::DiagClientConversation::kDiagNegAckReceived, diag::client::conversation::DiagClientConversation::kDiagRequestSendFailed, uds_transport::UdsTransportProtocolMgr::kNegTransmitAckReceived, uds_transport::UdsTransportProtocolMgr::kNoTransmitAckReceived, and uds_transport::UdsTransportProtocolMgr::kTransmitFailed.

◆ DisconnectFromDiagServer()

DiagClientConversation::DisconnectResult diag::client::conversation::DmConversation::DisconnectFromDiagServer ( )

overridevirtualnoexcept

Function to disconnect from Diagnostic Server.

Returns: DisconnectResult Disconnection result returned

Reimplemented from diag::client::conversation::Conversation.

Definition at line 182 of file dm_conversation.cpp.

                                                                                          {
   DiagClientConversation::DisconnectResult ret_val{DiagClientConversation::DisconnectResult::kDisconnectFailed};
   // Check if already connected before disconnecting
   if (connection_ptr_->IsConnectToHost()) {
     // Send disconnect request to doip layer
     ret_val = static_cast<DiagClientConversation::DisconnectResult>(connection_ptr_->DisconnectFromHost());
     if (ret_val == DiagClientConversation::DisconnectResult::kDisconnectSuccess) {
       logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
           __FILE__, __LINE__, __func__, [this](std::stringstream &msg) {
             msg << "'" << conversation_name_ << "'"
                 << "-> "
                 << "Successfully disconnected from Server with IP <" << remote_address_ << ">"
                 << " and LA= 0x" << std::hex << target_address_;
           });
     } else {
       logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogWarn(
           __FILE__, __LINE__, __func__, [&](std::stringstream &msg) {
             msg << "'" << conversation_name_ << "'"
                 << "-> "
                 << "Failed to disconnect from Server with IP <" << remote_address_ << ">";
           });
     }
   } else {
     ret_val = DiagClientConversation::DisconnectResult::kAlreadyDisconnected;
   }
   return ret_val;
 }

References connection_ptr_, conversation_name_, diag::client::logger::DiagClientLogger::GetDiagClientLogger(), diag::client::conversation::DiagClientConversation::kAlreadyDisconnected, diag::client::conversation::DiagClientConversation::kDisconnectFailed, diag::client::conversation::DiagClientConversation::kDisconnectSuccess, remote_address_, and target_address_.

Here is the call graph for this function:

◆ GetConversationHandler()

uds_transport::ConversionHandler & diag::client::conversation::DmConversation::GetConversationHandler ( )

overridevirtualnoexcept

Function to get the conversation handler from conversation object.

Returns: ConversionHandler & The reference to conversation handler

Implements diag::client::conversation::Conversation.

Definition at line 326 of file dm_conversation.cpp.

                                                                                 {
   return *dm_conversion_handler_;
 }

References dm_conversion_handler_.

◆ HandleMessage()

void diag::client::conversation::DmConversation::HandleMessage ( ::uds_transport::UdsMessagePtr message )

overridevirtualnoexcept

Function to Hands over a valid received Uds message.

Parameters

[in] message The The Uds message ptr (unique_ptr semantics) with the request. Ownership of the UdsMessage is given back to the conversation here

Implements diag::client::conversation::Conversation.

Definition at line 388 of file dm_conversation.cpp.

                                                                               {
   if (message != nullptr) {
     conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagSuccess);
   }
 }

Referenced by diag::client::conversation::DmConversationHandler::HandleMessage().

Here is the caller graph for this function:

◆ IndicateMessage()

std::pair< uds_transport::UdsTransportProtocolMgr::IndicationResult, uds_transport::UdsMessagePtr > diag::client::conversation::DmConversation::IndicateMessage	(	::uds_transport::UdsMessage::Address	source_addr,
		::uds_transport::UdsMessage::Address	target_addr,
		::uds_transport::UdsMessage::TargetAddressType	type,
		::uds_transport::ChannelID	channel_id,
		std::size_t	size,
		::uds_transport::Priority	priority,
		::uds_transport::ProtocolKind	protocol_kind,
		core_type::Span< std::uint8_t >	payload_info
	)

overridevirtualnoexcept

Function to indicate a start of reception of message.

This is called to indicate the reception of new message by underlying transport protocol handler

Parameters

[in]	source_addr	The UDS source address of message
[in]	target_addr	The UDS target address of message
[in]	type	The indication whether its is phys/func request
[in]	channel_id	The transport protocol channel on which message start happened
[in]	size	The size in bytes of the UdsMessage starting from SID
[in]	priority	The priority of the given message, used for prioritization of conversations
[in]	protocol_kind	The identifier of protocol kind associated to message
[in]	payload_info	The View onto the first received payload bytes, if any. This view shall be used only within this function call. It is recommended that the TP provides at least the first two bytes of the request message, so the DM can identify a functional TesterPresent

Returns: std::pair< IndicationResult, UdsMessagePtr > The pair of IndicationResult and a pointer to UdsMessage owned/created by DM core and returned to the handler to get filled

Implements diag::client::conversation::Conversation.

Definition at line 331 of file dm_conversation.cpp.

                                                                                  {
   std::pair<uds_transport::UdsTransportProtocolMgr::IndicationResult, uds_transport::UdsMessagePtr> ret_val{
       uds_transport::UdsTransportProtocolMgr::IndicationResult::kIndicationNOk, nullptr};
   // Verify the payload received :-
   if (!payload_info.empty()) {
     // Check for size, else kIndicationOverflow
     if (size <= rx_buffer_size_) {
       // Check for pending response
       // payload = 0x7F XX 0x78
       if (payload_info[0U] == 0x7F && payload_info[2U] == 0x78) {
         logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
             __FILE__, __LINE__, "", [&](std::stringstream &msg) {
               msg << "'" << conversation_name_ << "'"
                   << "-> "
                   << "Diagnostic pending response received in Conversation";
             });
         ret_val.first = uds_transport::UdsTransportProtocolMgr::IndicationResult::kIndicationPending;
         conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagRecvdPendingRes);
       } else {
         logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogDebug(
             __FILE__, __LINE__, "", [this](std::stringstream &msg) {
               msg << "'" << conversation_name_ << "'"
                   << "-> "
                   << "Diagnostic final response received in Conversation";
             });
         // positive or negative response, provide valid buffer
         // resize the global rx buffer
         payload_rx_buffer_.resize(size);
         ret_val.first = uds_transport::UdsTransportProtocolMgr::IndicationResult::kIndicationOk;
         ret_val.second = std::make_unique<diag::client::uds_message::DmUdsMessage>(source_address_, target_address_, "",
                                                                                    payload_rx_buffer_);
         conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagRecvdFinalRes);
       }
       sync_timer_.CancelWait();
     } else {
       logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogError(
           __FILE__, __LINE__, "", [&](std::stringstream &msg) {
             msg << "'" << conversation_name_ << "'"
                 << "-> "
                 << "Diagnostic Conversation Error Indication Overflow";
           });
       ret_val.first = uds_transport::UdsTransportProtocolMgr::IndicationResult::kIndicationOverflow;
     }
   } else {
     logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogError(
         __FILE__, __LINE__, "", [&](std::stringstream &msg) {
           msg << "'" << conversation_name_ << "'"
               << "-> "
               << "Diagnostic Conversation Rx Payload size 0 received";
         });
   }
   return ret_val;
 }

References diag::client::logger::DiagClientLogger::GetDiagClientLogger(), uds_transport::UdsTransportProtocolMgr::kIndicationNOk, uds_transport::UdsTransportProtocolMgr::kIndicationOk, uds_transport::UdsTransportProtocolMgr::kIndicationOverflow, and uds_transport::UdsTransportProtocolMgr::kIndicationPending.

Referenced by diag::client::conversation::DmConversationHandler::IndicateMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ operator=() [1/2]

DmConversation& diag::client::conversation::DmConversation::operator= ( const DmConversation & other )

deletenoexcept

◆ operator=() [2/2]

DmConversation& diag::client::conversation::DmConversation::operator= ( DmConversation && other )

deletenoexcept

◆ RegisterConnection()

void diag::client::conversation::DmConversation::RegisterConnection ( std::unique_ptr<::uds_transport::Connection > connection )

overridevirtualnoexcept

Function to register the conversation to underlying transport protocol handler.

Parameters

[in] connection The conversation connection object

Implements diag::client::conversation::Conversation.

Definition at line 322 of file dm_conversation.cpp.

                                                                                                   {
   connection_ptr_ = std::move(connection);
 }

◆ SendDiagnosticRequest()

Result< uds_message::UdsResponseMessagePtr, DiagClientConversation::DiagError > diag::client::conversation::DmConversation::SendDiagnosticRequest ( uds_message::UdsRequestMessageConstPtr message )

overridevirtualnoexcept

Function to send Diagnostic Request and get Diagnostic Response.

Parameters

[in] message The diagnostic request message wrapped in a unique pointer

Returns: DiagResult The Result returned; uds_message::UdsResponseMessagePtr Diagnostic Response message received, null_ptr in case of error

Reimplemented from diag::client::conversation::Conversation.

Definition at line 210 of file dm_conversation.cpp.

                                                            {
   Result<uds_message::UdsResponseMessagePtr, DiagClientConversation::DiagError> result{
       Result<uds_message::UdsResponseMessagePtr, DiagClientConversation::DiagError>::FromError(
           DiagClientConversation::DiagError::kDiagRequestSendFailed)};
   if (message) {
     // fill the data
     uds_transport::ByteVector payload{message->GetPayload()};
     // Initiate Sending of diagnostic request
     uds_transport::UdsTransportProtocolMgr::TransmissionResult const transmission_result{
         connection_ptr_->Transmit(std::make_unique<diag::client::uds_message::DmUdsMessage>(
             source_address_, target_address_, message->GetHostIpAddress(), payload))};
     if (transmission_result == uds_transport::UdsTransportProtocolMgr::TransmissionResult::kTransmitOk) {
       // Diagnostic Request Sent successful
       logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
           __FILE__, __LINE__, __func__, [&](std::stringstream &msg) {
             msg << "'" << conversation_name_ << "'"
                 << "-> "
                 << "Diagnostic Request Sent & Positive Ack received";
           });
       conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagWaitForRes);
       // Wait P6Max / P2ClientMax
       sync_timer_.WaitForTimeout(
           [this, &result]() {
             result.EmplaceError(DiagClientConversation::DiagError::kDiagResponseTimeout);
             conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kIdle);
             logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
                 __FILE__, __LINE__, "", [&](std::stringstream &msg) {
                   msg << "'" << conversation_name_ << "'"
                       << "-> "
                       << "Diagnostic Response P2 Timeout happened after " << p2_client_max_ << " milliseconds";
                 });
           },
           [this]() {
             // pending or pos/neg response
             if (conversation_state_.GetConversationStateContext().GetActiveState().GetState() ==
                 ConversationState::kDiagRecvdFinalRes) {
               // pos/neg response received
             } else if (conversation_state_.GetConversationStateContext().GetActiveState().GetState() ==
                        ConversationState::kDiagRecvdPendingRes) {
               // first pending received
               conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagStartP2StarTimer);
             }
           },
           std::chrono::milliseconds{p2_client_max_});
  
       // Wait until final response or timeout
       while (conversation_state_.GetConversationStateContext().GetActiveState().GetState() !=
              ConversationState::kIdle) {
         // Check the active state
         switch (conversation_state_.GetConversationStateContext().GetActiveState().GetState()) {
           case ConversationState::kDiagRecvdPendingRes:
             conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kDiagStartP2StarTimer);
             break;
           case ConversationState::kDiagRecvdFinalRes:
             // do nothing
             break;
           case ConversationState::kDiagStartP2StarTimer:
             // wait P6Star/ P2 star client time
             sync_timer_.WaitForTimeout(
                 [this, &result]() {
                   logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(
                       __FILE__, __LINE__, "", [&](std::stringstream &msg) {
                         msg << "'" << conversation_name_ << "'"
                             << "-> "
                             << "Diagnostic Response P2 Star Timeout happened after " << p2_star_client_max_
                             << " milliseconds";
                         ;
                       });
                   result.EmplaceError(DiagClientConversation::DiagError::kDiagResponseTimeout);
                   conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kIdle);
                 },
                 [this]() {
                   // pending or pos/neg response
                   if (conversation_state_.GetConversationStateContext().GetActiveState().GetState() ==
                       ConversationState::kDiagRecvdFinalRes) {
                     // pos/neg response received
                   } else if (conversation_state_.GetConversationStateContext().GetActiveState().GetState() ==
                              ConversationState::kDiagRecvdPendingRes) {
                     // pending received again
                     conversation_state_.GetConversationStateContext().TransitionTo(
                         ConversationState::kDiagStartP2StarTimer);
                   }
                 },
                 std::chrono::milliseconds{p2_star_client_max_});
             break;
           case ConversationState::kDiagSuccess:
             // change state to idle, form the uds response and return
             result.EmplaceValue(std::make_unique<diag::client::uds_message::DmUdsResponse>(payload_rx_buffer_));
             conversation_state_.GetConversationStateContext().TransitionTo(ConversationState::kIdle);
             break;
           default:
             // nothing
             break;
         }
       }
     } else {
       // failure
       result.EmplaceError(ConvertResponseType(transmission_result));
     }
   } else {
     result.EmplaceError(DiagClientConversation::DiagError::kDiagInvalidParameter);
     logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogWarn(__FILE__, __LINE__, "",
                                                                         [&](std::stringstream &msg) {
                                                                           msg << "'" << conversation_name_ << "'"
                                                                               << "-> "
                                                                               << "Diagnostic Request message is empty";
                                                                         });
   }
   return result;
 }

References core_type::Result< T, E >::FromError(), diag::client::logger::DiagClientLogger::GetDiagClientLogger(), diag::client::conversation::DiagClientConversation::kDiagInvalidParameter, diag::client::conversation::DiagClientConversation::kDiagRequestSendFailed, diag::client::conversation::DiagClientConversation::kDiagResponseTimeout, and uds_transport::UdsTransportProtocolMgr::kTransmitOk.

Here is the call graph for this function:

◆ Shutdown()

void diag::client::conversation::DmConversation::Shutdown ( )

overridevirtualnoexcept

Function to shutdown the DmConversation.

Implements diag::client::conversation::Conversation.

Definition at line 138 of file dm_conversation.cpp.

                                        {
   // shutdown connection
   connection_ptr_->Stop();
   // Change the state to InActive
   activity_status_ = ActivityStatusType::kInactive;
   logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(__FILE__, __LINE__, __func__,
                                                                       [&](std::stringstream &msg) {
                                                                         msg << "'" << conversation_name_ << "'"
                                                                             << "-> "
                                                                             << "Shutdown completed";
                                                                       });
 }

References activity_status_, connection_ptr_, conversation_name_, diag::client::logger::DiagClientLogger::GetDiagClientLogger(), and kInactive.

Here is the call graph for this function:

◆ Startup()

void diag::client::conversation::DmConversation::Startup ( )

overridevirtualnoexcept

Function to start the DmConversation.

Implements diag::client::conversation::Conversation.

Definition at line 123 of file dm_conversation.cpp.

                                       {
   // initialize the connection
   connection_ptr_->Initialize();
   // start the connection
   connection_ptr_->Start();
   // Change the state to Active
   activity_status_ = ActivityStatusType::kActive;
   logger::DiagClientLogger::GetDiagClientLogger().GetLogger().LogInfo(__FILE__, __LINE__, __func__,
                                                                       [&](std::stringstream &msg) {
                                                                         msg << "'" << conversation_name_ << "'"
                                                                             << "-> "
                                                                             << "Startup completed";
                                                                       });
 }

References activity_status_, connection_ptr_, conversation_name_, diag::client::logger::DiagClientLogger::GetDiagClientLogger(), and kActive.

Here is the call graph for this function:

Member Data Documentation

◆ active_security_level_

SecurityLevelType diag::client::conversation::DmConversation::active_security_level_

private

Store the active diagnostic security level.

Definition at line 206 of file dm_conversation.h.

Referenced by DmConversation().

◆ active_session_

SessionControlType diag::client::conversation::DmConversation::active_session_

private

Store the active diagnostic session.

Definition at line 201 of file dm_conversation.h.

Referenced by DmConversation().

◆ activity_status_

ActivityStatusType diag::client::conversation::DmConversation::activity_status_

private

Store the conversation activity status.

Definition at line 196 of file dm_conversation.h.

Referenced by Shutdown(), and Startup().

◆ connection_ptr_

std::unique_ptr<::uds_transport::Connection> diag::client::conversation::DmConversation::connection_ptr_

private

Store the underlying transport protocol connection object.

Definition at line 251 of file dm_conversation.h.

Referenced by DisconnectFromDiagServer(), Shutdown(), and Startup().

◆ conversation_name_

std::string diag::client::conversation::DmConversation::conversation_name_

private

Store the conversation name.

Definition at line 241 of file dm_conversation.h.

Referenced by DisconnectFromDiagServer(), Shutdown(), and Startup().

◆ conversation_state_

conversation_state_impl::ConversationStateImpl diag::client::conversation::DmConversation::conversation_state_

private

Store the conversation state.

Definition at line 266 of file dm_conversation.h.

◆ dm_conversion_handler_

std::unique_ptr<::uds_transport::ConversionHandler> diag::client::conversation::DmConversation::dm_conversion_handler_

private

Store the dm conversation handler.

Definition at line 246 of file dm_conversation.h.

Referenced by GetConversationHandler().

◆ p2_client_max_

std::uint16_t diag::client::conversation::DmConversation::p2_client_max_

private

Store the maximum p2 client time.

Definition at line 216 of file dm_conversation.h.

◆ p2_star_client_max_

std::uint16_t diag::client::conversation::DmConversation::p2_star_client_max_

private

Store the maximum p2 star client time.

Definition at line 221 of file dm_conversation.h.

◆ payload_rx_buffer_

::uds_transport::ByteVector diag::client::conversation::DmConversation::payload_rx_buffer_

private

Store the received uds response.

Definition at line 261 of file dm_conversation.h.

◆ remote_address_

std::string diag::client::conversation::DmConversation::remote_address_

private

Store the remote IP address of remote server.

Definition at line 236 of file dm_conversation.h.

Referenced by DisconnectFromDiagServer().

◆ rx_buffer_size_

std::uint32_t diag::client::conversation::DmConversation::rx_buffer_size_

private

Store the size of reception buffer size setting.

Definition at line 211 of file dm_conversation.h.

◆ source_address_

std::uint16_t diag::client::conversation::DmConversation::source_address_

private

Store the logical source address of conversation.

Definition at line 226 of file dm_conversation.h.

◆ sync_timer_

SyncTimer diag::client::conversation::DmConversation::sync_timer_

private

Store the synchronous timer.

Definition at line 256 of file dm_conversation.h.

◆ target_address_

std::uint16_t diag::client::conversation::DmConversation::target_address_

private

Store the logical target address of remote server.

Definition at line 231 of file dm_conversation.h.

Referenced by DisconnectFromDiagServer().

The documentation for this class was generated from the following files:

/home/runner/work/diag-client-lib/diag-client-lib/diag-client-lib/appl/src/dcm/conversation/dm_conversation.h
/home/runner/work/diag-client-lib/diag-client-lib/diag-client-lib/appl/src/dcm/conversation/dm_conversation.cpp

Public Types

Public Member Functions

Private Types

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ ConversationState

◆ SyncTimer

Member Enumeration Documentation

◆ ActivityStatusType

◆ SecurityLevelType

◆ SessionControlType

Constructor & Destructor Documentation

◆ DmConversation() [1/3]

◆ DmConversation() [2/3]

◆ DmConversation() [3/3]

◆ ~DmConversation()

Member Function Documentation

◆ ConnectToDiagServer()

◆ ConvertResponseType()

◆ DisconnectFromDiagServer()

◆ GetConversationHandler()

◆ HandleMessage()

◆ IndicateMessage()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ RegisterConnection()

◆ SendDiagnosticRequest()

◆ Shutdown()

◆ Startup()

Member Data Documentation

◆ active_security_level_

◆ active_session_

◆ activity_status_

◆ connection_ptr_

◆ conversation_name_

◆ conversation_state_

◆ dm_conversion_handler_

◆ p2_client_max_

◆ p2_star_client_max_

◆ payload_rx_buffer_

◆ remote_address_

◆ rx_buffer_size_

◆ source_address_

◆ sync_timer_

◆ target_address_