libipc/libipc.h

#ifndef LIBIPC
#define LIBIPC

#include <stdint.h>

enum event_types {
	  ERROR = 0         // A problem occured.
	, CONNECTION = 1    // New user.
	, DISCONNECTION = 2 // User disconnected.
	, MESSAGE_RX = 3    // New message.
	, MESSAGE_TX = 4    // Message sent.
	, TIMER = 5         // Timeout in the poll(2) function.
	, EXTERNAL = 6      // Message received from a non IPC socket.
	, SWITCH_RX = 7     // Message received from a switched FD.
	, SWITCH_TX = 8     // Message sent to a switched fd.
};

// Return type of callback functions when switching.
enum cb_event_types {
	  CB_NO_ERROR = 0      // No error. A message was generated.
	, CB_ERROR = 1         // Generic error.
	, CB_FD_CLOSING = 2    // The fd is closing.
	, CB_IGNORE = 3        // The message should be ignored (protocol specific).
};

int ipc_context_init (void** ptr);
int ipc_service_init (void* ctx, int* servicefd, const char* service_name, uint16_t service_name_len);
int ipc_connect_service (void* ctx, int* servicefd, const char* service_name, uint16_t service_name_len);
void ipc_context_deinit (void** ctx);
int ipc_write (void* ctx, int servicefd, char* mcontent, uint32_t mlen);
int ipc_schedule (void* ctx, int servicefd, const char* mcontent, uint32_t mlen);
int ipc_read_fd (void* ctx, int fd, char* buffer, size_t* buflen);
int ipc_read (void* ctx, size_t index, char* buffer, size_t* buflen);
int ipc_wait_event(void* ctx, char* t, size_t* index, int* originfd, char* buffer, size_t* buflen);
void ipc_context_timer (void* ctx, int timer);
int ipc_close_fd (void* ctx, int fd);
int ipc_close (void* ctx, size_t index);
int ipc_close_all (void* ctx);

// Switch functions (for "protocol" services, such as TCPd).
int ipc_add_external (void* ctx, int newfd);
int ipc_add_switch (void* ctx, int fd1, int fd2);

// Returned "char" is a cb_event_types enum.
int ipc_set_switch_callbacks (void* ctx, int fd
  , char (*in (int orig, const char *payload, uint32_t *mlen))
  , char (*out(int dest,       char *payload, uint32_t  mlen)));

#endif