ab_gp_site_status.c

Go to the documentation of this file.

#include "ab_gp_site_status.h"
 
#include <stdio.h>
 
bool ab_gp_site_status_ready_for_online(const ab_gp_channel_context_t *ctx)
{
    const bool relay_recent = (ctx->cyc_cycle >= ctx->last_relay_rx_cycle) && ((ctx->cyc_cycle - ctx->last_relay_rx_cycle) <= 10U) &&
                              (ctx->last_relay_rx_cycle > 0U);
 
    /* The inter-site negotiation link is deliberately not part of readiness: a dispatcher-confirmed takeover happens
     * exactly when that link is silent, and serving trains needs the Gateway relay, not the negotiation link. */
    return relay_recent;
}
 
void ab_gp_site_status_collect(const ab_gp_channel_context_t *ctx, ab_gp_site_status_t *out)
{
    rte_site_role_status_t role;
 
    rte_site_role_get_status(&ctx->site_role, &role);
    out->role_online = ctx->is_online;
    out->role_faulted = ctx->own_faulted;
    out->link_up = role.link_up;
    out->peer_answering = role.peer_answering;
    out->peer_online_now = role.peer_online_now;
    out->sibling_known = ctx->peer_site_state.known;
    out->sibling_online = ctx->peer_site_state.known && (ctx->peer_site_state.bytes[0] != 0U);
    out->standby_warm = role.standby_warm;
    out->standby_healthy = role.standby_healthy;
    out->last_reason = role.last_reason;
    if (!ctx->is_online && !ctx->own_faulted && role.peer_unresponsive)
    {
        out->waiting_for = AB_GP_SITE_WAIT_DISPATCHER;
    }
    else if (!ctx->is_online && (role.last_reason == RTE_SITE_ROLE_REASON_WAITING_READY))
    {
        out->waiting_for = AB_GP_SITE_WAIT_READY;
    }
    else if (!role.link_up)
    {
        out->waiting_for = AB_GP_SITE_WAIT_LINK;
    }
    else
    {
        out->waiting_for = AB_GP_SITE_WAIT_NOTHING;
    }
}
 
size_t ab_gp_site_status_append_text(const ab_gp_site_status_t *st, char *buf, size_t size)
{
    const char *wait = "none";
    int n;
 
    if (st->waiting_for == AB_GP_SITE_WAIT_DISPATCHER)
    {
        wait = "dispatcher";
    }
    else if (st->waiting_for == AB_GP_SITE_WAIT_LINK)
    {
        wait = "link";
    }
    else if (st->waiting_for == AB_GP_SITE_WAIT_READY)
    {
        wait = "ready";
    }
    n = snprintf(buf, size, " site_wait=%s site_why=%s", wait, rte_site_role_reason_token(st->last_reason));
    return ((n > 0) && ((size_t)n < size)) ? (size_t)n : 0U;
}