rte_ipc_request_reply.h

Go to the documentation of this file.

 
#ifndef RTE_IPC_REQUEST_REPLY_H
#define RTE_IPC_REQUEST_REPLY_H
 
#include "rte/utils/status/rte_status.h"
#include "rte/utils/types/rte_types.h"
#include "rte_ipc.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* ============================================================================
 * Request-Reply Channel (Server Side)
 * ========================================================================== */

typedef struct rte_ipc_rr_server_s *rte_ipc_rr_server_t;

typedef struct {
    const char *name;              
    size_t request_size;           
    size_t reply_size;             
    size_t queue_depth;            
} rte_ipc_rr_server_config_t;

typedef struct {
    uint32_t request_id;           
    uint8_t *request_data;         
    size_t request_size;           
} rte_ipc_rr_request_t;

rte_status_t rte_ipc_rr_server_create(rte_ipc_rr_server_t *handle_out,
                                         const rte_ipc_rr_server_config_t *config);

rte_status_t rte_ipc_rr_receive_request(rte_ipc_rr_server_t server,
                                           rte_ipc_rr_request_t *request_out,
                                           rte_duration_ms_t timeout_ms);

rte_status_t rte_ipc_rr_send_reply(rte_ipc_rr_server_t server,
                                      uint32_t request_id,
                                      const void *reply_data,
                                      size_t reply_size);

rte_status_t rte_ipc_rr_server_destroy(rte_ipc_rr_server_t server);
 
/* ============================================================================
 * Request-Reply Client (Client Side)
 * ========================================================================== */

typedef struct rte_ipc_rr_client_s *rte_ipc_rr_client_t;

typedef struct {
    const char *server_name;       
    size_t request_size;           
    size_t reply_size;             
} rte_ipc_rr_client_config_t;

rte_status_t rte_ipc_rr_client_create(rte_ipc_rr_client_t *handle_out,
                                         const rte_ipc_rr_client_config_t *config);

rte_status_t rte_ipc_rr_request(rte_ipc_rr_client_t client,
                                   const void *request_data,
                                   size_t request_size,
                                   void *reply_out,
                                   size_t reply_size,
                                   rte_duration_ms_t timeout_ms);

rte_status_t rte_ipc_rr_client_destroy(rte_ipc_rr_client_t client);
 
#ifdef __cplusplus
}
#endif
 
#endif /* RTE_IPC_REQUEST_REPLY_H */