ab_ga_dispatch.c

Go to the documentation of this file.

#include "ab_ga_dispatch.h"
 
#include "ga_interface.h" /* every ab_gp_register_*() this module calls */
#include "../il/ab_ga_il.h"  /* ab_ga_il_on_route_context_changed()/_apply_envelope()/_build_outputs() */
#include "../ctc/ab_ga_ctc.h" /* ab_ga_ctc_on_route_context_changed()/_on_train_context_changed()/_build_outputs() */

typedef struct
{
    ab_gp_train_session_t *sessions;
    ab_gp_db_t             *db;
} ga_channel_ctx_t;
 
static ga_channel_ctx_t g_channel_ctx;

static void on_route_context_changed(const void *context, const ab_gp_route_context_t *ctx,
                                      ab_gp_route_update_type_t update_type);
static void on_train_context_changed(const void *context, const ab_gp_train_context_t *ctx,
                                      ab_gp_train_update_type_t update_type);
static uint8_t il_output_producer_trampoline(const void *context,
                                              ab_gp_il_pending_output_t out[AB_GP_IL_MAX_PENDING_OUTPUTS]);
static uint8_t ctc_output_producer_trampoline(const void *context,
                                               ab_gp_ctc_pending_output_t out[AB_GP_CTC_MAX_PENDING_OUTPUTS]);
static void il_output_confirm_trampoline(const void *context);
static void ctc_output_confirm_trampoline(const void *context);

rte_status_t ab_ga_dispatch_init(ab_gp_train_session_t *sessions, ab_gp_db_t *db)
{
    rte_status_t status;
 
    g_channel_ctx.sessions = sessions;
    g_channel_ctx.db = db;
 
    status = ab_gp_db_register_route_context_notify(on_route_context_changed, &g_channel_ctx);
    if (status != RTE_STATUS_OK)
    {
        return status;
    }
    status = ab_gp_register_train_context_notify(on_train_context_changed, NULL);
    if (status != RTE_STATUS_OK)
    {
        return status;
    }
    /* ab_ga_il_apply_envelope() itself matches ab_gp_il_envelope_handler_fn's
     * exact signature now (it takes/ignores the leading context param) -
     * registered directly, no trampoline needed; GP hands it fresh
     * sessions/db every call, so this module's own g_channel_ctx capture
     * above is not what it uses. */
    status = ab_gp_register_il_envelope_handler(ab_ga_il_apply_envelope, NULL);
    if (status != RTE_STATUS_OK)
    {
        return status;
    }
    status = ab_gp_register_il_output_producer(il_output_producer_trampoline, il_output_confirm_trampoline, NULL);
    if (status != RTE_STATUS_OK)
    {
        return status;
    }
    return ab_gp_register_ctc_output_producer(ctc_output_producer_trampoline, ctc_output_confirm_trampoline,
                                               &g_channel_ctx);
}
 
/****Local functions ****/

static void on_route_context_changed(const void *context, const ab_gp_route_context_t *ctx,
                                      ab_gp_route_update_type_t update_type)
{
    const ga_channel_ctx_t *ch = (const ga_channel_ctx_t *)context;
 
    ab_ga_il_on_route_context_changed(ch->sessions, ch->db, ctx, update_type);
    ab_ga_ctc_on_route_context_changed(ctx, update_type);
}

static void on_train_context_changed(const void *context, const ab_gp_train_context_t *ctx,
                                      ab_gp_train_update_type_t update_type)
{
    (void)context;
    ab_ga_ctc_on_train_context_changed(ctx, update_type);
}

static uint8_t il_output_producer_trampoline(const void *context,
                                              ab_gp_il_pending_output_t out[AB_GP_IL_MAX_PENDING_OUTPUTS])
{
    (void)context;
    return ab_ga_il_build_outputs(out);
}

static uint8_t ctc_output_producer_trampoline(const void *context,
                                               ab_gp_ctc_pending_output_t out[AB_GP_CTC_MAX_PENDING_OUTPUTS])
{
    const ga_channel_ctx_t *ch = (const ga_channel_ctx_t *)context;
 
    if (ch == NULL)
    {
        return 0U;
    }
    return ab_ga_ctc_build_outputs(ch->sessions, ch->db, out);
}

static void il_output_confirm_trampoline(const void *context)
{
    (void)context;
    ab_ga_il_confirm_outputs_sent();
}

static void ctc_output_confirm_trampoline(const void *context)
{
    const ga_channel_ctx_t *ch = (const ga_channel_ctx_t *)context;
    ab_gp_train_session_t  *sessions = NULL;
 
    if (ch != NULL)
    {
        sessions = ch->sessions;
    }
    ab_ga_ctc_confirm_outputs_sent(sessions);
}