ipcserver.h

Go to the documentation of this file.

#pragma once

#ifdef __cplusplus
extern "C" {
#endif

#include<libtransistor/types.h>
#include<libtransistor/ipc.h>
#include<libtransistor/waiter.h>

#define MAX_SERVICE_PORTS 63
#define MAX_SERVICE_SESSIONS 63 
#define MAX_DOMAIN_OBJECTS 512 

struct ipc_server_object_t;
struct ipc_server_domain_t;
struct ipc_server_session_t;
struct ipc_server;

typedef struct ipc_server_object_t {
    void *userdata; 

    bool is_domain_object; 
    uint32_t domain_id; 
    struct ipc_server_domain_t *owning_domain; 
    struct ipc_server_session_t *owning_session; 
    
    // raw_data points to SFCI
    void (*dispatch)(struct ipc_server_object_t *obj, ipc_message_t *msg, uint32_t request_id);

    void (*close)(struct ipc_server_object_t *obj);
} ipc_server_object_t;

typedef struct ipc_server_domain_t {
    ipc_server_object_t *objects[MAX_DOMAIN_OBJECTS]; 
    struct ipc_server_session_t *owning_session; 
} ipc_server_domain_t;

typedef enum {
    IPC_SESSION_STATE_INVALID, 
    IPC_SESSION_STATE_INITIALIZING, 
    IPC_SESSION_STATE_LISTENING, 
    IPC_SESSION_STATE_PROCESSING, 
    IPC_SESSION_STATE_ERRORED, 
} ipc_server_session_state_t;

typedef struct ipc_server_session_t {
    session_h handle; 
    session_h client_handle; 
    bool is_domain; 
    ipc_server_object_t hipc_manager_object; 
    ipc_server_object_t *active_object; 
    ipc_server_object_t *object; 
    ipc_server_domain_t domain; 
    ipc_server_session_state_t state; 
    struct ipc_server_t *owning_server; 
    uint8_t message_buffer[0x100]; 
    
    uint8_t *pointer_buffer;
    size_t pointer_buffer_size;
    
    wait_record_t *wait_record;
} ipc_server_session_t;

/*
  you are expected to initialize `userdata`, `dispatch`, and `close`.
  libtransistor will initialize all other fields.
 */
typedef result_t (*ipc_server_object_factory_t)(ipc_server_object_t **obj, void *userdata);

typedef struct ipc_server_port_t {
    port_h port;
    ipc_server_object_factory_t factory;
    void *userdata;
    wait_record_t *wait_record;
    struct ipc_server_t *server;
} ipc_server_port_t;

typedef struct ipc_server_t {
    ipc_server_port_t *ports;
    uint32_t num_ports;
    uint32_t max_ports;
    
    ipc_server_session_t *sessions;
    uint32_t max_sessions;

    size_t pointer_buffer_size;
    uint8_t *pointer_buffers;
    
    waiter_t *waiter;
} ipc_server_t;

result_t ipc_server_create(ipc_server_t *srv, waiter_t *waiter);
result_t ipc_server_create_ex(ipc_server_t *srv, waiter_t *waiter, uint32_t max_ports, uint32_t max_sessions, size_t pointer_buffer_size);
result_t ipc_server_add_port(ipc_server_t *srv, port_h port, ipc_server_object_factory_t object_factory, void *userdata);
result_t ipc_server_create_session(ipc_server_t *srv, session_h server_side, session_h client_side, ipc_server_object_t *object);
result_t ipc_server_accept_session(ipc_server_t *srv, ipc_server_port_t *port);
result_t ipc_server_destroy(ipc_server_t *srv);

result_t ipc_server_object_register(ipc_server_object_t *owner, ipc_server_object_t *new_object);
result_t ipc_server_object_reply(ipc_server_object_t *obj, const ipc_response_t *rs);
result_t ipc_server_object_close(ipc_server_object_t *obj);

result_t ipc_server_domain_add_object(ipc_server_domain_t *domain, ipc_server_object_t *object);
result_t ipc_server_domain_get_object(ipc_server_domain_t *domain, uint32_t object_id, ipc_server_object_t **object);
result_t ipc_server_domain_destroy(ipc_server_domain_t *domain);

result_t ipc_server_session_receive(ipc_server_session_t *sess);
result_t ipc_server_session_close(ipc_server_session_t *sess);

#ifdef __cplusplus
}
#endif