rte_dual_msgchannel.h

Go to the documentation of this file.

#ifndef RTE_DUAL_MSGCHANNEL_H
#define RTE_DUAL_MSGCHANNEL_H
 
#include <stdint.h>
 
#include "rte/redundancy/checksum/rte_checksum.h"
#include "rte/oal/netlink/rte_netlink.h"
#include "rte/utils/status/rte_status.h"
#include "rte/utils/types/rte_types.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define RTE_DUAL_MSGCHANNEL_MAX_PAYLOAD 248U

typedef struct rte_dual_msgchannel_s
{
    rte_netlink_handle_t link;      
    uint32_t              sender_id;      
    uint32_t              expected_peer_id; 
    uint32_t              next_sequence;   
    uint32_t              expected_sequence; 
    bool                  resync_on_sequence_error; 
} rte_dual_msgchannel_t;

typedef struct rte_dual_msgchannel_config_s
{
    rte_netlink_handle_t link;
    uint32_t sender_id;
    uint32_t expected_peer_id;
} rte_dual_msgchannel_config_t;

rte_status_t rte_dual_msgchannel_set_resync_on_sequence_error(rte_dual_msgchannel_t *channel, bool enable);

rte_status_t rte_dual_msgchannel_init(rte_dual_msgchannel_t *channel,
                                         const rte_dual_msgchannel_config_t *config);

rte_status_t rte_dual_msgchannel_send(rte_dual_msgchannel_t *channel,
                                         const uint8_t *payload,
                                         uint8_t payload_size,
                                         rte_duration_ms_t timeout_ms,
                                         uint32_t *out_sequence);

rte_status_t rte_dual_msgchannel_receive(rte_dual_msgchannel_t *channel,
                                            uint8_t *out_payload,
                                            uint8_t payload_max_size,
                                            rte_duration_ms_t timeout_ms,
                                            uint8_t *out_payload_size,
                                            uint32_t *out_sequence);

rte_status_t rte_dual_msgchannel_reset_sequence(rte_dual_msgchannel_t *channel);
 
#ifdef __cplusplus
}
#endif
 
#endif /* RTE_DUAL_MSGCHANNEL_H */