site_config.c

Go to the documentation of this file.

#include <stdlib.h>
#include <string.h>
 
#include "site_config.h"
#include "common_config.h"





static uint16_t site_port_base(rte_example_site_t site);
static uint16_t relay_port_offset(rte_example_relay_kind_t kind, uint16_t train_base,
                                   uint16_t il_base, uint16_t ctc_base, uint16_t util_base);
 

bool site_config_parse(const char *arg, rte_example_site_t *out_site)
{
    if ((arg == NULL) || (out_site == NULL))
    {
        return false;
    }
    if ((strcmp(arg, "WEST") == 0) || (strcmp(arg, "west") == 0))
    {
        *out_site = RTE_EXAMPLE_SITE_WEST;
        return true;
    }
    if ((strcmp(arg, "EAST") == 0) || (strcmp(arg, "east") == 0))
    {
        *out_site = RTE_EXAMPLE_SITE_EAST;
        return true;
    }
    return false;
}
 
const char *site_config_name(rte_example_site_t site)
{
    return (site == RTE_EXAMPLE_SITE_WEST) ? "WEST" : "EAST";
}
 
uint16_t site_config_ab_port(rte_example_site_t site)
{
    return (uint16_t)(site_port_base(site) + (uint16_t)RTE_EXAMPLE_AB_PORT_OFFSET);
}
 
uint16_t site_config_ab_crosscompare_port(rte_example_site_t site)
{
    return (uint16_t)(site_port_base(site) + (uint16_t)RTE_EXAMPLE_AB_CROSSCOMPARE_PORT_OFFSET);
}
 
uint16_t site_config_c_port_for_a(rte_example_site_t site, rte_example_relay_kind_t kind)
{
    return (uint16_t)(site_port_base(site)
                       + relay_port_offset(kind, (uint16_t)RTE_EXAMPLE_C_FOR_A_TRAIN_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_A_IL_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_A_CTC_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_A_UTIL_PORT_OFFSET));
}
 
uint16_t site_config_c_port_for_b(rte_example_site_t site, rte_example_relay_kind_t kind)
{
    return (uint16_t)(site_port_base(site)
                       + relay_port_offset(kind, (uint16_t)RTE_EXAMPLE_C_FOR_B_TRAIN_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_B_IL_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_B_CTC_PORT_OFFSET,
                                            (uint16_t)RTE_EXAMPLE_C_FOR_B_UTIL_PORT_OFFSET));
}
 
uint16_t site_config_c_port_for_train(rte_example_site_t site)
{
    return (uint16_t)(site_port_base(site) + (uint16_t)RTE_EXAMPLE_C_FOR_TRAIN_PORT_OFFSET);
}
 
uint16_t site_config_c_port_for_il(rte_example_site_t site)
{
    return (uint16_t)(site_port_base(site) + (uint16_t)RTE_EXAMPLE_C_FOR_IL_PORT_OFFSET);
}
 
uint16_t site_config_c_port_for_ctc(rte_example_site_t site)
{
    return (uint16_t)(site_port_base(site) + (uint16_t)RTE_EXAMPLE_C_FOR_CTC_PORT_OFFSET);
}
 
uint16_t site_config_c_port_for_broker(rte_example_site_t site, rte_example_relay_kind_t gw_kind)
{
    uint16_t off;
 
    switch (gw_kind)
    {
        case RTE_EXAMPLE_RELAY_KIND_IL:
            off = (uint16_t)RTE_EXAMPLE_C_FOR_BROKER_IL_PORT_OFFSET;
            break;
        case RTE_EXAMPLE_RELAY_KIND_CTC:
            off = (uint16_t)RTE_EXAMPLE_C_FOR_BROKER_CTC_PORT_OFFSET;
            break;
        case RTE_EXAMPLE_RELAY_KIND_TRAIN:
        default:
            off = (uint16_t)RTE_EXAMPLE_C_FOR_BROKER_TRAIN_PORT_OFFSET;
            break;
    }
    return (uint16_t)(site_port_base(site) + off);
}
 
const char *site_config_host(const char *env_var_name)
{
    const char *value = getenv(env_var_name);
 
    return ((value != NULL) && (value[0] != '\0')) ? value : RTE_EXAMPLE_LOCALHOST;
}
 
 
/****Local functions ****/
 
static uint16_t site_port_base(rte_example_site_t site)
{
    return (site == RTE_EXAMPLE_SITE_WEST) ? (uint16_t)RTE_EXAMPLE_WEST_PORT_BASE
                                                : (uint16_t)RTE_EXAMPLE_EAST_PORT_BASE;
}
 
static uint16_t relay_port_offset(rte_example_relay_kind_t kind, uint16_t train_base,
                                   uint16_t il_base, uint16_t ctc_base, uint16_t util_base)
{
    uint16_t base;
 
    switch (kind)
    {
        case RTE_EXAMPLE_RELAY_KIND_TRAIN:
            base = train_base;
            break;
        case RTE_EXAMPLE_RELAY_KIND_IL:
            base = il_base;
            break;
        case RTE_EXAMPLE_RELAY_KIND_UTIL:
            base = util_base;
            break;
        case RTE_EXAMPLE_RELAY_KIND_CTC:
        default:
            base = ctc_base;
            break;
    }
    return base;
}