ab_gp_saf_train.h

Go to the documentation of this file.

#ifndef AB_GP_SAF_TRAIN_H
#define AB_GP_SAF_TRAIN_H
 
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#include "safecomm/saf/saf.h"
#include "../../common/common_config.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define AB_GP_SAF_ENVELOPE_HEADER 4U
#define AB_GP_SAF_FRAME_MAX ((size_t)RBC_TRAIN_ENVELOPE_WIRE_SIZE - (size_t)AB_GP_SAF_ENVELOPE_HEADER)
#define AB_GP_SAF_PDU_MAX (AB_GP_SAF_FRAME_MAX - (size_t)SAFECOMM_SAF_DATA_OVERHEAD)
#define AB_GP_SAF_PEER_RB_SIZE (1U + SAFECOMM_MAC_RAND_LEN + SAFECOMM_MAC_RAND_LEN)
#define AB_GP_SAF_KEYS_MAX 16U

typedef struct
{
    safecomm_saf_conn_t conn;
    bool    au1_parked;                         
    uint8_t au1[SAFECOMM_SAF_AU1_LEN];
    bool    rb_parked;                          
    uint8_t rb_ra[SAFECOMM_MAC_RAND_LEN];
    uint8_t rb[SAFECOMM_MAC_RAND_LEN];
} ab_gp_saf_train_slot_t;

typedef struct
{
    bool     enabled;
    bool     is_role_a;
    uint32_t rbc_etcs_id;
    ab_gp_saf_train_slot_t slots[RTE_EXAMPLE_MAX_TRAINS];
} ab_gp_saf_train_t;

typedef enum
{
    AB_GP_SAF_ACTION_NONE = 0,     
    AB_GP_SAF_ACTION_REPLY,        
    AB_GP_SAF_ACTION_APP,          
    AB_GP_SAF_ACTION_REJECTED,     
    AB_GP_SAF_ACTION_DISCONNECTED  
} ab_gp_saf_action_t;

typedef struct
{
    ab_gp_saf_action_t action;
    safecomm_status_t  status;
    uint8_t  frame[SAFECOMM_SAF_AU2_LEN];        
    size_t   frame_len;
    uint8_t  app[AB_GP_SAF_PDU_MAX];
    size_t   app_len;
    bool     share_rb;                           
    uint8_t  rb_share[AB_GP_SAF_PEER_RB_SIZE];
} ab_gp_saf_result_t;

void ab_gp_saf_keys_clear(void);

bool ab_gp_saf_keys_install(uint32_t peer_etcs_id, const uint8_t kmac[SAFECOMM_MAC_KEY_LEN]);

bool ab_gp_saf_keys_load_file(const char *path, uint32_t *out_count);

void ab_gp_saf_train_init(ab_gp_saf_train_t *s, bool enabled, bool is_role_a, uint32_t rbc_etcs_id);

void ab_gp_saf_train_on_frame(ab_gp_saf_train_t *s, uint8_t train_id, const uint8_t *frame, size_t frame_len,
                              uint32_t now_ms, ab_gp_saf_result_t *out);

void ab_gp_saf_train_on_peer_rb(ab_gp_saf_train_t *s, const uint8_t *payload, size_t size, uint32_t now_ms,
                                ab_gp_saf_result_t *out);

bool ab_gp_saf_train_wrap(ab_gp_saf_train_t *s, uint8_t train_id, const uint8_t *pdu, size_t pdu_len,
                          uint8_t *out_frame, size_t out_cap, size_t *out_len);

uint32_t ab_gp_saf_train_supervise(ab_gp_saf_train_t *s, uint32_t now_ms);

bool ab_gp_saf_train_is_connected(const ab_gp_saf_train_t *s, uint8_t train_id);

bool ab_gp_saf_envelope_encode(uint8_t train_id, const uint8_t *frame, size_t frame_len,
                               uint8_t out[RBC_TRAIN_ENVELOPE_WIRE_SIZE]);

bool ab_gp_saf_envelope_decode(const uint8_t env[RBC_TRAIN_ENVELOPE_WIRE_SIZE], uint8_t *out_train_id,
                               const uint8_t **out_frame, size_t *out_len);
 
#ifdef __cplusplus
}
#endif
 
#endif /* AB_GP_SAF_TRAIN_H */