rbc_util_jru_payload.h

Go to the documentation of this file.

#ifndef RTE_EXAMPLE_RBC_UTIL_JRU_PAYLOAD_H
#define RTE_EXAMPLE_RBC_UTIL_JRU_PAYLOAD_H

 
#include <stdbool.h>
#include <stdio.h>
#include <string.h>
 
#include "rte/oal/log/rte_log.h"
 
#include "rbc_util_frame.h"
 
#ifdef __cplusplus
extern "C" {
#endif

static inline void rbc_util_jru_payload_encode(char *out, size_t out_size, rte_log_level_t level,
                                                const char *tag, const char *message)
{
    (void)snprintf(out, out_size, "%d|%s|%s", (int)level,
                   ((tag != NULL) && (tag[0] != '\0')) ? tag : "-",
                   (message != NULL) ? message : "-");
}

static inline bool rbc_util_jru_payload_decode(const char *payload, rte_log_level_t *out_level,
                                                char *tag_out, size_t tag_out_size, char *msg_out,
                                                size_t msg_out_size)
{
    const char *p1;
    const char *p2;
    size_t      tag_len;
    int         lvl;
 
    tag_out[0] = '\0';
    msg_out[0] = '\0';
    *out_level = RTE_LOG_LEVEL_INFO;
 
    if (payload == NULL)
    {
        return false;
    }
    p1 = strchr(payload, '|');
    if (p1 == NULL)
    {
        return false;
    }
    p2 = strchr(p1 + 1, '|');
    if (p2 == NULL)
    {
        return false;
    }
 
    lvl = 0;
    (void)sscanf(payload, "%d", &lvl);
    if ((lvl >= (int)RTE_LOG_LEVEL_DEBUG) && (lvl <= (int)RTE_LOG_LEVEL_ERROR))
    {
        *out_level = (rte_log_level_t)lvl;
    }
 
    tag_len = (size_t)(p2 - (p1 + 1));
    if (tag_len >= tag_out_size)
    {
        tag_len = tag_out_size - 1U;
    }
    (void)memcpy(tag_out, p1 + 1, tag_len);
    tag_out[tag_len] = '\0';
 
    (void)strncpy(msg_out, p2 + 1, msg_out_size - 1U);
    msg_out[msg_out_size - 1U] = '\0';
 
    return true;
}
 
#ifdef __cplusplus
} /* extern "C" */
#endif
 
#endif /* RTE_EXAMPLE_RBC_UTIL_JRU_PAYLOAD_H */