cs_config.c

Go to the documentation of this file.

#include "cs_config.h"
 
#include <stdio.h>
#include <string.h>
 
#include "safecomm/ale/ale.h"
#include "safecomm/config/config.h"

static void cfg_u32(const safecomm_config_t *c, const char *key, uint32_t lo, uint32_t hi, uint32_t *out)
{
    uint32_t v = 0U;
 
    if (safecomm_config_get_u32(c, key, &v) == SAFECOMM_STATUS_OK)
    {
        if ((v >= lo) && (v <= hi))
        {
            *out = v;
        }
        else
        {
            (void)fprintf(stderr, "commserver: %s=%u out of [%u,%u], keeping %u\n",
                          key, v, lo, hi, *out);
        }
    }
}
 
static void cfg_host(const safecomm_config_t *c, const char *key, char *out, size_t cap)
{
    const char *s = safecomm_config_get_str(c, key);
 
    if ((s != NULL) && (strlen(s) < cap))
    {
        (void)strcpy(out, s);
    }
}
 
int load_cfg(const char *path, cs_cfg_t *cfg)
{
    safecomm_config_t raw;
    uint32_t          u;
 
    (void)memset(cfg, 0, sizeof(*cfg));
    (void)strcpy(cfg->west_host, "127.0.0.1");
    (void)strcpy(cfg->east_host, "127.0.0.1");
    (void)strcpy(cfg->listen_host, "0.0.0.0");
    cfg->west_port          = 15010U;
    cfg->east_port          = 15110U;
    cfg->listen_port        = 16010U;
    cfg->message_size       = 96U;
    cfg->connect_timeout_ms = 4000U;
    cfg->idle_ms            = 5U;
 
    if (safecomm_config_load(path, &raw) != SAFECOMM_STATUS_OK)
    {
        (void)fprintf(stderr, "commserver: cannot load config '%s'\n", path);
        return -1;
    }
 
    cfg_host(&raw, "rbc.west_host", cfg->west_host, sizeof(cfg->west_host));
    cfg_host(&raw, "rbc.east_host", cfg->east_host, sizeof(cfg->east_host));
    cfg_host(&raw, "train.listen_host", cfg->listen_host, sizeof(cfg->listen_host));
 
    u = cfg->west_port;          cfg_u32(&raw, "rbc.west_port", 1U, 65535U, &u);          cfg->west_port = (uint16_t)u;
    u = cfg->east_port;          cfg_u32(&raw, "rbc.east_port", 1U, 65535U, &u);          cfg->east_port = (uint16_t)u;
    u = cfg->listen_port;        cfg_u32(&raw, "train.listen_port", 1U, 65535U, &u);      cfg->listen_port = (uint16_t)u;
    u = cfg->message_size;       cfg_u32(&raw, "rbc.message_size", 1U, CS_MSG_MAX, &u);   cfg->message_size = (uint16_t)u;
    cfg_u32(&raw, "rbc.connect_timeout_ms", 100U, 60000U, &cfg->connect_timeout_ms);
    cfg_u32(&raw, "poll.idle_ms", 0U, 1000U, &cfg->idle_ms);
 
    /* safecomm::ale is linked and its config path is honoured; the stub's
     * single-route relay does not need the peer table yet. */
    {
        safecomm_ale_t ale;
        if (safecomm_ale_from_config(&raw, &ale) == SAFECOMM_STATUS_OK)
        {
            (void)fprintf(stderr, "commserver: ALE peer map loaded (%u peers)\n", ale.peer_count);
        }
    }
    return 0;
}