gateway_c_selfstatus.c

Go to the documentation of this file.

#include "gateway_c_selfstatus.h"
 
#include <stdio.h>
#include <string.h>
 
#include "rte/oal/log/rte_log.h"
#include "rte/oal/timer/rte_timer.h"
#include "rte/redundancy/channel_service/rte_channel_service.h"
 
#include "common/common_config.h"
#include "common/rbc_util_frame.h"
#include "common/site_config.h"
 
static rte_channel_service_t s_broker;
static bool                   s_have_broker;
static rte_timestamp_ms_t    s_last_ms;
static uint8_t                s_seq;
 
void gateway_c_selfstatus_init(const char *broker_channel_name)
{
    rte_status_t status;
 
    if ((broker_channel_name == NULL) || (broker_channel_name[0] == '\0'))
    {
        return;
    }
    status = rte_channel_service_setup(&s_broker, broker_channel_name);
    if (status != RTE_STATUS_OK)
    {
        rte_log_write_event(RTE_LOG_LEVEL_WARNING, "-", 0U, "GW", "-", "STATUS",
                              "broker link setup failed", broker_channel_name);
        return;
    }
    s_have_broker = true;
    s_last_ms = 0U;
}
 
void gateway_c_selfstatus_tick(const gateway_c_context_t *ctx, uint32_t cycle, const char *log_tag,
                                uint8_t src_id)
{
    char                payload[96];
    uint8_t             frame[RBC_UTIL_FRAME_SIZE];
    rte_timestamp_ms_t now = 0U;
    const char         *site;
 
    if (ctx == NULL)
    {
        return;
    }
    (void)rte_timer_now(&now);
    if ((cycle != 1U)
        && ((now - s_last_ms) < (rte_timestamp_ms_t)RTE_EXAMPLE_STATUS_PERIOD_MS))
    {
        return;
    }
    s_last_ms = now;
    site = site_config_name(ctx->site);
 
    (void)snprintf(payload, sizeof(payload), "unit=GW-%s/%s up=1", log_tag, site);
 
    rte_log_write_event(RTE_LOG_LEVEL_INFO, site, cycle, log_tag, "-", "STATUS", "self", payload);
 
    if (s_have_broker)
    {
        s_seq++;
        rbc_util_frame_encode(frame, RBC_UTIL_MSG_PUBLISH, src_id, (uint16_t)RBC_UTIL_TOPIC_STATUS,
                              s_seq, payload);
        (void)rte_channel_service_send(&s_broker, frame, RBC_UTIL_FRAME_SIZE, 0U);
    }
}
 
void gateway_c_selfstatus_publish(uint8_t src_id, const char *payload)
{
    uint8_t frame[RBC_UTIL_FRAME_SIZE];
 
    if (!s_have_broker || (payload == NULL))
    {
        return;
    }
    s_seq++;
    rbc_util_frame_encode(frame, RBC_UTIL_MSG_PUBLISH, src_id, (uint16_t)RBC_UTIL_TOPIC_STATUS, s_seq, payload);
    (void)rte_channel_service_send(&s_broker, frame, RBC_UTIL_FRAME_SIZE, 0U);
}
 
void gateway_c_selfstatus_shutdown(void)
{
    if (s_have_broker)
    {
        (void)rte_channel_service_close(&s_broker);
        s_have_broker = false;
    }
}