ab_ga_ertms_il_interface.h

 
#ifndef AB_GA_ERTMS_IL_INTERFACE_H
#define AB_GA_ERTMS_IL_INTERFACE_H
 
#include "../ab_ga_ertms_types.h"
#include "ab_ga_ertms_il_types.h"
 
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* ========================================================================= */
/* Interlocking Vital Protocol Message Types                                 */
/* ========================================================================= */
 
#define RBC_IL_MSG_KEEPALIVE_REQ              0x01U
#define RBC_IL_MSG_KEEPALIVE_ACK              0x02U
#define RBC_IL_MSG_ROUTE_STATUS_UPDATE        0x10U
#define RBC_IL_MSG_TRACK_OCCUPANCY_UPDATE     0x11U
#define RBC_IL_MSG_POINT_STATUS_UPDATE        0x12U
#define RBC_IL_MSG_SIGNAL_ASPECT_UPDATE       0x13U
#define RBC_IL_MSG_LX_STATUS_UPDATE           0x14U
#define RBC_IL_MSG_EMERGENCY_STOP_COMMAND     0x1FU
 
#define RBC_IL_MSG_TRAIN_FOOTPRINT_UPDATE     0x20U
#define RBC_IL_MSG_SECTION_RELEASE_REQUEST    0x21U
#define RBC_IL_MSG_MA_CONFIRMATION            0x22U
#define RBC_IL_MSG_EMERGENCY_STOP_ACK         0x2FU
 
/* ========================================================================= */
/* Vital Message Header (EN 50159 / SIL 4 Safety Envelope)                   */
/* ========================================================================= */
typedef struct rbc_il_header_s
{
    rbc_nid_ixl_t      nid_ixl;         
    rbc_nid_rbc_t      nid_rbc;         
    uint32_t           sequence_number; 
    rbc_timestamp_ms_t timestamp_ms;    
    uint8_t            msg_type;        
} rbc_il_header_t;
 
/* ========================================================================= */
/* Interlocking -> RBC Inbound Messages                                      */
/* ========================================================================= */
 
typedef struct rbc_il_msg_route_status_s
{
    rbc_il_header_t     header;
    rbc_il_route_info_t route;
} rbc_il_msg_route_status_t;
 
typedef struct rbc_il_msg_track_occupancy_s
{
    rbc_il_header_t         header;
    uint8_t                 count;
    rbc_il_section_status_t sections[RBC_IL_MAX_ROUTE_SECTIONS];
} rbc_il_msg_track_occupancy_t;
 
typedef struct rbc_il_msg_point_status_s
{
    rbc_il_header_t       header;
    rbc_il_point_status_t point;
} rbc_il_msg_point_status_t;
 
typedef struct rbc_il_msg_signal_aspect_s
{
    rbc_il_header_t        header;
    rbc_il_signal_status_t signal;
} rbc_il_msg_signal_aspect_t;
 
typedef struct rbc_il_msg_lx_status_s
{
    rbc_il_header_t    header;
    rbc_il_lx_status_t lx;
} rbc_il_msg_lx_status_t;
 
typedef struct rbc_il_msg_emergency_stop_s
{
    rbc_il_header_t   header;
    rbc_nid_section_t section_id;
    bool              all_tracks;
} rbc_il_msg_emergency_stop_t;
 
typedef struct rbc_il_msg_keepalive_s
{
    rbc_il_header_t header;
} rbc_il_msg_keepalive_t;
 
/* ========================================================================= */
/* RBC -> Interlocking Outbound Messages                                     */
/* ========================================================================= */
 
typedef struct rbc_il_msg_train_footprint_s
{
    rbc_il_header_t   header;
    rbc_nid_engine_t  nid_engine;
    rbc_nid_section_t front_section;
    rbc_nid_section_t rear_section;
    bool              train_integrity_confirmed;
} rbc_il_msg_train_footprint_t;
 
typedef struct rbc_il_msg_section_release_request_s
{
    rbc_il_header_t   header;
    rbc_nid_route_t   route_id;
    rbc_nid_section_t section_id;
    rbc_nid_engine_t  nid_engine;
} rbc_il_msg_section_release_request_t;
 
typedef struct rbc_il_msg_ma_confirmation_s
{
    rbc_il_header_t  header;
    rbc_nid_route_t  route_id;
    rbc_nid_engine_t nid_engine;
    rbc_distance_m_t eoa_offset_m;
} rbc_il_msg_ma_confirmation_t;
 
/* ========================================================================= */
/* Unified Generic Message Containers & Handlers                             */
/* ========================================================================= */
 
typedef struct rbc_il_inbound_msg_s
{
    uint8_t msg_type;
    union
    {
        rbc_il_msg_keepalive_t       keepalive;
        rbc_il_msg_route_status_t    route_status;
        rbc_il_msg_track_occupancy_t track_occupancy;
        rbc_il_msg_point_status_t    point_status;
        rbc_il_msg_signal_aspect_t   signal_aspect;
        rbc_il_msg_lx_status_t       lx_status;
        rbc_il_msg_emergency_stop_t  emergency_stop;
    } payload;
} rbc_il_inbound_msg_t;
 
typedef struct rbc_il_outbound_msg_s
{
    uint8_t msg_type;
    union
    {
        rbc_il_msg_keepalive_t               keepalive_ack;
        rbc_il_msg_train_footprint_t         train_footprint;
        rbc_il_msg_section_release_request_t section_release;
        rbc_il_msg_ma_confirmation_t         ma_confirmation;
    } payload;
} rbc_il_outbound_msg_t;

typedef void (*rbc_il_on_message_received_fn)(const rbc_il_inbound_msg_t *msg, void *user_context);

typedef int (*rbc_il_send_message_fn)(rbc_nid_ixl_t nid_ixl,
                                      const rbc_il_outbound_msg_t *msg,
                                      void *user_context);
 
#ifdef __cplusplus
}
#endif
 
#endif /* RBC_IL_INTERFACE_H */