Source
96
96
int zbx_ipc_service_init_env(const char *path, char **error);
97
97
void zbx_ipc_service_free_env(void);
98
98
int zbx_ipc_service_start(zbx_ipc_service_t *service, const char *service_name, char **error);
99
99
int zbx_ipc_service_recv(zbx_ipc_service_t *service, const zbx_timespec_t *timeout, zbx_ipc_client_t **client,
100
100
zbx_ipc_message_t **message);
101
101
void zbx_ipc_service_alert(zbx_ipc_service_t *service);
102
102
void zbx_ipc_service_close(zbx_ipc_service_t *service);
103
103
104
104
int zbx_ipc_client_send(zbx_ipc_client_t *client, zbx_uint32_t code, const unsigned char *data, zbx_uint32_t size);
105
105
void zbx_ipc_client_close(zbx_ipc_client_t *client);
106
+
int zbx_ipc_client_get_fd(zbx_ipc_client_t *client);
106
107
107
108
void zbx_ipc_client_addref(zbx_ipc_client_t *client);
108
109
void zbx_ipc_client_release(zbx_ipc_client_t *client);
109
110
int zbx_ipc_client_connected(zbx_ipc_client_t *client);
110
111
zbx_uint64_t zbx_ipc_client_id(const zbx_ipc_client_t *client);
111
112
zbx_ipc_client_t *zbx_ipc_client_by_id(const zbx_ipc_service_t *service, zbx_uint64_t id);
112
113
void zbx_ipc_client_set_userdata(zbx_ipc_client_t *client, void *userdata);
113
114
void *zbx_ipc_client_get_userdata(zbx_ipc_client_t *client);
114
115
115
116
int zbx_ipc_socket_open(zbx_ipc_socket_t *csocket, const char *service_name, int timeout, char **error);