diff options
| author | Andris Zeila <andris.zeila@zabbix.com> | 2016-12-19 14:05:33 +0300 |
|---|---|---|
| committer | Andris Zeila <andris.zeila@zabbix.com> | 2016-12-19 14:05:33 +0300 |
| commit | 5224a5ae7e65328f029b9031e67a3234310d536c (patch) | |
| tree | 80d34cc7acb2cf7885f9b0ba1805eecad8ccfce6 /include/zbxipcservice.h | |
| parent | b6976281e424bb8190aa70c46b44ba1a682aca7d (diff) | |
.......PS. [ZBXNEXT-3386] added timeout to _recv() function
Diffstat (limited to 'include/zbxipcservice.h')
| -rw-r--r-- | include/zbxipcservice.h | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/include/zbxipcservice.h b/include/zbxipcservice.h index e5fb347e91e..dc00f57f354 100644 --- a/include/zbxipcservice.h +++ b/include/zbxipcservice.h @@ -36,6 +36,7 @@ typedef struct struct event_base *ev; struct event *ev_listener; + struct event *ev_timer; /* the unix socket path */ char *path; @@ -54,7 +55,8 @@ zbx_ipc_service_t; int zbx_ipc_service_init_env(const char *path, char **error); void zbx_ipc_service_free_env(); int zbx_ipc_service_start(zbx_ipc_service_t *service, const char *service_name, char **error); -void zbx_ipc_service_recv(zbx_ipc_service_t *service, zbx_ipc_client_t **client, zbx_ipc_message_t **message); +void zbx_ipc_service_recv(zbx_ipc_service_t *service, int timeout, zbx_ipc_client_t **client, + zbx_ipc_message_t **message); void zbx_ipc_service_close(zbx_ipc_service_t *service); int zbx_ipc_client_send(zbx_ipc_client_t *client, zbx_uint32_t code, const char *data, zbx_uint32_t size); @@ -67,6 +69,7 @@ int zbx_ipc_socket_read(zbx_ipc_socket_t *csocket, zbx_ipc_message_t *message); void zbx_ipc_message_free(zbx_ipc_message_t *message); void zbx_ipc_message_clean(zbx_ipc_message_t *message); +void zbx_ipc_message_init(zbx_ipc_message_t *message); #endif |