ab_gp_standby_policy.c

Go to the documentation of this file.

#include "ab_gp_standby_policy.h"
 
#include <stddef.h>
 
bool ab_gp_session_adopt_allowed(uint32_t join_left, bool local_in_use, bool peer_in_use)
{
    return (join_left > 0U) && !local_in_use && peer_in_use;
}
 
bool ab_gp_stall_lost_contact(rte_timestamp_ms_t last_ms, rte_timestamp_ms_t now_ms, bool is_online,
                              rte_timestamp_ms_t *stalled_ms)
{
    bool lost = false;
 
    if ((last_ms != 0U) && is_online)
    {
        /* Unsigned 64-bit difference: now_ms < last_ms wraps to a large value (see the header, ISS-036). */
        const rte_timestamp_ms_t elapsed_ms = now_ms - last_ms;
 
        if (elapsed_ms > (rte_timestamp_ms_t)AB_GP_STALL_LOST_CONTACT_MS)
        {
            lost = true;
            if (stalled_ms != NULL)
            {
                *stalled_ms = elapsed_ms;
            }
        }
    }
    return lost;
}