sapi_ipc_request_reply.h

Go to the documentation of this file.

 
#ifndef SAFEAPI_IPC_REQUEST_REPLY_H
#define SAFEAPI_IPC_REQUEST_REPLY_H
 
#include "safeapi/utils/status/sapi_status.h"
#include "safeapi/utils/types/sapi_types.h"
#include "sapi_ipc.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
/* ============================================================================
 * Request-Reply Channel (Server Side)
 * ========================================================================== */

typedef struct sapi_ipc_rr_server_s *sapi_ipc_rr_server_t;

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

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

sapi_status_t sapi_ipc_rr_server_create(sapi_ipc_rr_server_t *handle_out,
                                         const sapi_ipc_rr_server_config_t *config);

sapi_status_t sapi_ipc_rr_receive_request(sapi_ipc_rr_server_t server,
                                           sapi_ipc_rr_request_t *request_out,
                                           sapi_duration_ms_t timeout_ms);

sapi_status_t sapi_ipc_rr_send_reply(sapi_ipc_rr_server_t server,
                                      uint32_t request_id,
                                      const void *reply_data,
                                      size_t reply_size);

sapi_status_t sapi_ipc_rr_server_destroy(sapi_ipc_rr_server_t server);
 
/* ============================================================================
 * Request-Reply Client (Client Side)
 * ========================================================================== */

typedef struct sapi_ipc_rr_client_s *sapi_ipc_rr_client_t;

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

sapi_status_t sapi_ipc_rr_client_create(sapi_ipc_rr_client_t *handle_out,
                                         const sapi_ipc_rr_client_config_t *config);

sapi_status_t sapi_ipc_rr_request(sapi_ipc_rr_client_t client,
                                   const void *request_data,
                                   size_t request_size,
                                   void *reply_out,
                                   size_t reply_size,
                                   sapi_duration_ms_t timeout_ms);

sapi_status_t sapi_ipc_rr_client_destroy(sapi_ipc_rr_client_t client);
 
#ifdef __cplusplus
}
#endif
 
#endif /* SAFEAPI_IPC_REQUEST_REPLY_H */