sapi_dual_msgchannel.h

Go to the documentation of this file.

#ifndef SAPI_DUAL_MSGCHANNEL_H
#define SAPI_DUAL_MSGCHANNEL_H
 
#include <stdint.h>
 
#include "safeapi/redundancy/checksum/sapi_checksum.h"
#include "safeapi/oal/netlink/sapi_netlink.h"
#include "safeapi/utils/status/sapi_status.h"
#include "safeapi/utils/types/sapi_types.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define SAPI_DUAL_MSGCHANNEL_MAX_PAYLOAD 248U

typedef struct sapi_dual_msgchannel_s
{
    sapi_netlink_handle_t link;      
    uint32_t              sender_id;      
    uint32_t              expected_peer_id; 
    uint32_t              next_sequence;   
    uint32_t              expected_sequence; 
} sapi_dual_msgchannel_t;

typedef struct sapi_dual_msgchannel_config_s
{
    sapi_netlink_handle_t link;
    uint32_t sender_id;
    uint32_t expected_peer_id;
} sapi_dual_msgchannel_config_t;

sapi_status_t sapi_dual_msgchannel_init(sapi_dual_msgchannel_t *channel,
                                         const sapi_dual_msgchannel_config_t *config);

sapi_status_t sapi_dual_msgchannel_send(sapi_dual_msgchannel_t *channel,
                                         const uint8_t *payload,
                                         uint8_t payload_size,
                                         sapi_duration_ms_t timeout_ms,
                                         uint32_t *out_sequence);

sapi_status_t sapi_dual_msgchannel_receive(sapi_dual_msgchannel_t *channel,
                                            uint8_t *out_payload,
                                            uint8_t payload_max_size,
                                            sapi_duration_ms_t timeout_ms,
                                            uint8_t *out_payload_size,
                                            uint32_t *out_sequence);

sapi_status_t sapi_dual_msgchannel_reset_sequence(sapi_dual_msgchannel_t *channel);
 
#ifdef __cplusplus
}
#endif
 
#endif /* SAPI_DUAL_MSGCHANNEL_H */