diff options
Diffstat (limited to '')
-rw-r--r-- | src/ipc/ipc-connection.h | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/src/ipc/ipc-connection.h b/src/ipc/ipc-connection.h new file mode 100644 index 0000000..d848f81 --- /dev/null +++ b/src/ipc/ipc-connection.h @@ -0,0 +1,46 @@ +#ifndef IPC_CONNECTION_H +#define IPC_CONNECTION_H + +#include "ipc-group.h" + +struct ipc_connection_cmd { + unsigned int tag; + struct ipc_connection *conn; + + ipc_cmd_callback_t *callback; + void *context; +}; + +struct ipc_connection { + struct ipc_group *group; + /* prev/next within group */ + struct ipc_connection *prev, *next; + + unsigned int id; + pid_t pid; + + int fd; + struct io *io; + struct istream *input; + struct ostream *output; + + unsigned int cmd_tag_counter; + + /* running commands */ + ARRAY(struct ipc_connection_cmd *) cmds; + + bool version_received:1; + bool handshake_received:1; +}; + +struct ipc_connection *ipc_connection_create(int listen_fd, int fd); +void ipc_connection_destroy(struct ipc_connection **conn, + bool log_error, const char *error); + +struct ipc_connection * +ipc_connection_lookup_id(struct ipc_group *group, unsigned int id); + +void ipc_connection_cmd(struct ipc_connection *conn, const char *cmd, + ipc_cmd_callback_t *callback, void *context); + +#endif |