gateway_c_train_handler.h

Go to the documentation of this file.

#ifndef RTE_EXAMPLE_GATEWAY_C_TRAIN_HANDLER_H
#define RTE_EXAMPLE_GATEWAY_C_TRAIN_HANDLER_H

 
#include "gateway_c_types.h"
 
typedef struct
{
    /* --- TrainSim-facing (one multiplexed channel) --- */
    rte_channel_service_t sim_channel;
 
    /* --- A/B-facing (one dedicated relay channel per peer) --- */
    rte_channel_service_t relay_channel[GATEWAY_C_PEER_COUNT];
    uint8_t                relay_consecutive_timeout;
    rte_timestamp_ms_t    relay_down_since_ms[GATEWAY_C_PEER_COUNT];
    rte_timestamp_ms_t    send_down_since_ms[GATEWAY_C_PEER_COUNT]; 
    uint32_t               a_seen_this_cycle;
    unsigned int           a_stale_cycles;
    const char            *last_known_tag;
    gateway_c_dedup_t      dedup;
} gateway_c_train_handler_state_t;
 
rte_status_t gateway_c_train_handler_init(gateway_c_context_t *ctx);
void gateway_c_train_handler_execute(gateway_c_context_t *ctx, uint32_t cycle);
void gateway_c_train_handler_shutdown(void);
bool gateway_c_train_handler_check_link_down(rte_timestamp_ms_t threshold_ms, rte_timestamp_ms_t now_ms,
                                             char *out_which, size_t which_size);
 
#endif /* RTE_EXAMPLE_GATEWAY_C_TRAIN_HANDLER_H */