ab_gp_util_link_gate.c

Go to the documentation of this file.

#include "ab_gp_util_link_gate.h"
 
#include "../../common/common_config.h"
 
void ab_gp_util_link_gate_init(ab_gp_util_link_gate_t *gate)
{
    if (gate != NULL)
    {
        gate->ever_opened = false;
        gate->next_attempt_ms = 0U;
    }
}
 
bool ab_gp_util_link_gate_is_open(const ab_gp_util_link_gate_t *gate)
{
    bool open = false;
 
    if (gate != NULL)
    {
        open = gate->ever_opened;
    }
    return open;
}
 
bool ab_gp_util_link_gate_may_attempt(const ab_gp_util_link_gate_t *gate, rte_timestamp_ms_t now_ms)
{
    bool allowed = false;
 
    if (gate != NULL)
    {
        allowed = gate->ever_opened || (now_ms >= gate->next_attempt_ms);
    }
    return allowed;
}
 
void ab_gp_util_link_gate_on_attempt(ab_gp_util_link_gate_t *gate, rte_timestamp_ms_t now_ms)
{
    if ((gate != NULL) && !gate->ever_opened)
    {
        gate->next_attempt_ms = now_ms + (rte_timestamp_ms_t)RTE_EXAMPLE_UTIL_REOPEN_BACKOFF_MS;
    }
}
 
void ab_gp_util_link_gate_on_result(ab_gp_util_link_gate_t *gate, rte_status_t status, rte_timestamp_ms_t now_ms)
{
    if ((gate != NULL) && !gate->ever_opened)
    {
        if (status == RTE_STATUS_OK)
        {
            gate->ever_opened = true;
        }
        else
        {
            gate->next_attempt_ms = now_ms + (rte_timestamp_ms_t)RTE_EXAMPLE_UTIL_REOPEN_BACKOFF_MS;
        }
    }
}