gateway_c_logctl.c

Go to the documentation of this file.

#include "gateway_c_logctl.h"
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
 
#include "safeapi/oal/log/sapi_log.h"
 
#include "common/rbc_wire_types.h"
#include "common/site_config.h"
#include "gateway_c_il_handler.h"

#define GATEWAY_C_LOGCTL_LINE_MAX 16U

static int s_applied_level = -1;

static bool gateway_c_logctl_read_level(const char *path, sapi_log_level_t *out_level);
 

void gateway_c_logctl_poll(gateway_c_context_t *ctx)
{
    const char      *path = getenv("SAPI_RBC_LOG_LEVEL_FILE");
    sapi_log_level_t  level;
 
    if ((ctx == NULL) || (path == NULL))
    {
        return;
    }
    if (!gateway_c_logctl_read_level(path, &level))
    {
        return; /* missing file, empty, or unrecognised - leave things be */
    }
    if ((int)level == s_applied_level)
    {
        return; /* unchanged since last apply */
    }
 
    s_applied_level = (int)level;
    sapi_log_set_level(level);
 
    {
        uint8_t frame[RBC_ENVELOPE_WIRE_SIZE];
 
        rbc_envelope_write_set_log_level(frame, (uint8_t)level);
        gateway_c_il_handler_broadcast_to_ab(frame);
    }
 
    sapi_log_write_event(level, site_config_name(ctx->site), 0U, "GW", "A,B", "LOG_LEVEL",
                          "applied + broadcast", sapi_log_level_to_string(level));
}
 
 
/****Local functions ****/
 
static bool gateway_c_logctl_read_level(const char *path, sapi_log_level_t *out_level)
{
    FILE  *fp;
    char   line[GATEWAY_C_LOGCTL_LINE_MAX];
    size_t i;
    bool   ok = false;
 
    fp = fopen(path, "r");
    if (fp == NULL)
    {
        return false;
    }
    if (fgets(line, (int)sizeof(line), fp) != NULL)
    {
        /* Trim the first trailing CR/LF/space so "DEBUG\n" parses. */
        for (i = 0U; i < sizeof(line); i++)
        {
            if (line[i] == '\0')
            {
                break;
            }
            if ((line[i] == '\n') || (line[i] == '\r') || (line[i] == ' ') || (line[i] == '\t'))
            {
                line[i] = '\0';
                break;
            }
        }
        ok = (sapi_log_level_from_string(line, out_level) == SAPI_STATUS_OK);
    }
    (void)fclose(fp);
    return ok;
}