rte_channel.h

Go to the documentation of this file.

 
#ifndef RTE_CHANNEL_LINK_H
#define RTE_CHANNEL_LINK_H
 
#include <stdint.h>
#include <stdbool.h>
#include <stddef.h>
 
#include "rte/utils/status/rte_status.h"
 
#ifdef __cplusplus
extern "C" {
#endif

typedef struct {
    uint32_t send_count;
    uint32_t send_error_count;
    uint32_t receive_count;
    uint32_t receive_error_count;
    bool is_healthy;
    rte_status_t last_error;
} rte_channel_health_t;

typedef rte_status_t (*rte_channel_send_fn)(void *channel_handle,
                                               const void *data,
                                               size_t data_size);

typedef rte_status_t (*rte_channel_recv_fn)(void *channel_handle,
                                               void *data,
                                               size_t data_size,
                                               uint32_t timeout_ms);

typedef struct {
    void *channel_handle;
    rte_channel_send_fn send;
    rte_channel_recv_fn recv;
    const char *name;
} rte_channel_config_t;

typedef struct {
    rte_channel_config_t config;  
    rte_channel_health_t health;  
    bool initialized;                    
} rte_channel_storage_t;

typedef rte_channel_storage_t rte_channel_t;

rte_status_t rte_channel_init(rte_channel_storage_t *storage,
                                       const rte_channel_config_t *config);

rte_status_t rte_channel_send(rte_channel_t *handle,
                                       const void *data,
                                       size_t data_size);

rte_status_t rte_channel_receive(rte_channel_t *handle,
                                          void *data,
                                          size_t data_size,
                                          uint32_t timeout_ms);

rte_status_t rte_channel_get_health(const rte_channel_t *handle,
                                             rte_channel_health_t *out_health);

const char *rte_channel_get_name(const rte_channel_t *handle);

rte_status_t rte_channel_set_healthy(rte_channel_t *handle,
                                              bool is_healthy);

rte_status_t rte_channel_destroy(rte_channel_t *handle);
 
#ifdef __cplusplus
}
#endif

 
#endif /* RTE_CHANNEL_LINK_H */