ab_gp_proc_text_message.c

Go to the documentation of this file.

 
#include "ab_gp_proc_text_message.h"
#include "rte/oal/memory/rte_mem_util.h"
#include "rte/utils/string/rte_string.h"
 
/* REQ-ID: RBC_ERTMS_TXT_001 - Text Message Context Initialization */
void ab_gp_proc_text_message_init(ab_gp_ertms_train_context_t *ctx)
{
    if (ctx == NULL)
    {
        return;
    }
 
    ctx->text_msg.has_pending_msg = false;
    ctx->text_msg.nid_textmessage = 0U;
    ctx->text_msg.q_textclass = 0U;
    ctx->text_msg.q_textconfirm = 0U;
    ctx->text_msg.duration_s = 0U;
    ctx->text_msg.ack_received = false;
    ctx->text_msg.ack_timestamp_ms = 0U;
}
 
/* REQ-ID: RBC_ERTMS_TXT_002 - Dispatch Driver Text Message */
bool ab_gp_proc_text_message_send(ab_gp_ertms_train_context_t *ctx,
                                  uint8_t nid_textmessage,
                                  uint8_t q_textclass,
                                  uint8_t q_textconfirm,
                                  uint32_t duration_s,
                                  const char *text,
                                  rbc_packet_72_text_message_t *out_p72)
{
    rte_string_t str;
 
    if ((ctx == NULL) || (out_p72 == NULL) || (text == NULL) || (nid_textmessage == 0U))
    {
        return false;
    }
 
    ctx->text_msg.has_pending_msg = true;
    ctx->text_msg.nid_textmessage = nid_textmessage;
    ctx->text_msg.q_textclass = q_textclass;
    ctx->text_msg.q_textconfirm = q_textconfirm;
    ctx->text_msg.duration_s = duration_s;
    ctx->text_msg.ack_received = false;
    ctx->text_msg.ack_timestamp_ms = 0U;
 
    out_p72->ack_required = (q_textconfirm != 0U);
    out_p72->duration_s = duration_s;
 
    /* Safely copy bounded string using rte_string_t */
    rte_mem_set(out_p72->text, 0, sizeof(out_p72->text));
    if (rte_string_init(&str, out_p72->text, sizeof(out_p72->text)) == RTE_STATUS_OK)
    {
        (void)rte_string_copy(&str, text);
        (void)rte_string_c_str(&str, NULL);
    }
 
    return true;
}
 
/* REQ-ID: RBC_ERTMS_TXT_003 - Driver Confirmation Handling */
bool ab_gp_proc_text_message_handle_ack(ab_gp_ertms_train_context_t *ctx,
                                        uint8_t nid_textmessage,
                                        uint32_t timestamp_ms)
{
    if ((ctx == NULL) || (nid_textmessage == 0U))
    {
        return false;
    }
 
    if (ctx->text_msg.has_pending_msg && (ctx->text_msg.nid_textmessage == nid_textmessage))
    {
        ctx->text_msg.ack_received = true;
        ctx->text_msg.ack_timestamp_ms = timestamp_ms;
        ctx->text_msg.has_pending_msg = false;
        return true;
    }
 
    return false;
}
 
/* REQ-ID: RBC_ERTMS_TXT_004 - Pending Confirmation Query */
bool ab_gp_proc_text_message_is_pending_ack(const ab_gp_ertms_train_context_t *ctx)
{
    if (ctx == NULL)
    {
        return false;
    }
 
    return (ctx->text_msg.has_pending_msg && (ctx->text_msg.q_textconfirm != 0U) && !ctx->text_msg.ack_received);
}