cfm.c

Go to the documentation of this file.

#include "safecomm/cfm/cfm.h"
 
#include <string.h>
 
safecomm_status_t safecomm_cfm_from_config(const safecomm_config_t *cfg,
                                           const safecomm_transport_t *lower,
                                           safecomm_cfm_t *out)
{
    const char       *profile;
    uint32_t          u;
    safecomm_status_t st;
 
    if ((cfg == NULL) || (lower == NULL) || (out == NULL)
        || (lower->send == NULL) || (lower->recv == NULL))
    {
        return SAFECOMM_STATUS_INVALID_PARAM;
    }
    (void)memset(out, 0, sizeof(*out));
    out->lower = *lower;
 
    profile = safecomm_config_get_str(cfg, "cfm.profile");
    if (profile == NULL)
    {
        return SAFECOMM_STATUS_INVALID_PARAM;
    }
    if (strcmp(profile, "euroradio") == 0)
    {
        out->profile = SAFECOMM_CFM_PROFILE_EURORADIO;
    }
    else if (strcmp(profile, "rbc_rbc") == 0)
    {
        out->profile = SAFECOMM_CFM_PROFILE_RBC_RBC;
    }
    else
    {
        return SAFECOMM_STATUS_INVALID_PARAM;
    }
 
    {
        const char *host = safecomm_config_get_str(cfg, "cfm.peer_host");
        if ((host != NULL) && (strlen(host) < sizeof(out->peer_host)))
        {
            (void)strcpy(out->peer_host, host);
        }
    }
    st = safecomm_config_get_u32(cfg, "cfm.peer_port", &u);
    if ((st == SAFECOMM_STATUS_OK) && (u <= 0xFFFFU))
    {
        out->peer_port = (uint16_t)u;
    }
    st = safecomm_config_get_u32(cfg, "cfm.bind_port", &u);
    if ((st == SAFECOMM_STATUS_OK) && (u <= 0xFFFFU))
    {
        out->bind_port = (uint16_t)u;
    }
    st = safecomm_config_get_u32(cfg, "cfm.retry_ms", &out->retry_ms);
    (void)st;
 
    /* TODO(REQ-SC-CFM-003): finish once the bearer state machine exists. */
    return SAFECOMM_STATUS_NOT_IMPLEMENTED;
}
 
safecomm_status_t safecomm_cfm_transport(safecomm_cfm_t *cfm, safecomm_transport_t *out)
{
    if ((cfm == NULL) || (out == NULL))
    {
        return SAFECOMM_STATUS_INVALID_PARAM;
    }
    /* TODO(REQ-SC-CFM-008): wrap cfm->lower with framing + keep-alive +
     * reconnect and hand the SFM whole-PDU send/recv. */
    return SAFECOMM_STATUS_NOT_IMPLEMENTED;
}