rte_ipc_pubsub.h

Go to the documentation of this file.

 
#ifndef RTE_IPC_PUBSUB_H
#define RTE_IPC_PUBSUB_H
 
#include "rte/utils/status/rte_status.h"
#include "rte/utils/types/rte_types.h"
#include "rte_ipc.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* ============================================================================
 * Publish-Subscribe Topic
 * ========================================================================== */

typedef struct rte_ipc_pubsub_topic_s *rte_ipc_pubsub_topic_t;

typedef struct {
    const char *topic_name;        
    size_t message_size;           
    size_t max_subscribers;        
} rte_ipc_pubsub_topic_config_t;

rte_status_t rte_ipc_pubsub_topic_create(rte_ipc_pubsub_topic_t *topic_out,
                                            const rte_ipc_pubsub_topic_config_t *config);

rte_status_t rte_ipc_pubsub_publish(rte_ipc_pubsub_topic_t topic,
                                       const void *message,
                                       size_t message_size);

rte_status_t rte_ipc_pubsub_topic_destroy(rte_ipc_pubsub_topic_t topic);
 
/* ============================================================================
 * Subscriber (Receiver Side)
 * ========================================================================== */

typedef struct rte_ipc_pubsub_subscriber_s *rte_ipc_pubsub_subscriber_t;

typedef struct {
    const char *subscriber_name;   
    rte_ipc_pubsub_topic_t topic; 
    size_t queue_depth;            
} rte_ipc_pubsub_subscriber_config_t;

rte_status_t rte_ipc_pubsub_subscribe(rte_ipc_pubsub_subscriber_t *subscriber_out,
                                         const rte_ipc_pubsub_subscriber_config_t *config);

rte_status_t rte_ipc_pubsub_receive(rte_ipc_pubsub_subscriber_t subscriber,
                                       void *message_out,
                                       size_t message_size,
                                       rte_duration_ms_t timeout_ms);

rte_status_t rte_ipc_pubsub_unsubscribe(rte_ipc_pubsub_subscriber_t subscriber);
 
#ifdef __cplusplus
}
#endif
 
#endif /* RTE_IPC_PUBSUB_H */