blob: d848f81aff8c58a477eee42cd65da98848c180bb (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
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
|
