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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
/*
** Copyright (C) 2001-2025 Zabbix SIA
**
** This program is free software: you can redistribute it and/or modify it under the terms of
** the GNU Affero General Public License as published by the Free Software Foundation, version 3.
**
** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
** See the GNU Affero General Public License for more details.
**
** You should have received a copy of the GNU Affero General Public License along with this program.
** If not, see <https://www.gnu.org/licenses/>.
**/
#ifndef ZABBIX_AVAILABILITY_H
#define ZABBIX_AVAILABILITY_H
#include "zbxtypes.h"
#include "zbxdbhigh.h"
#include "zbxipcservice.h"
#include "zbxthreads.h"
/* agent (ZABBIX, SNMP, IPMI, JMX) availability data */
typedef struct
{
/* flags specifying which fields are set, see ZBX_FLAGS_AGENT_STATUS_* defines */
unsigned char flags;
/* agent availability fields */
unsigned char available;
char *error;
int errors_from;
int disable_until;
}
zbx_agent_availability_t;
#define ZBX_FLAGS_AGENT_STATUS_NONE 0x00000000
#define ZBX_FLAGS_AGENT_STATUS_AVAILABLE 0x00000001
#define ZBX_FLAGS_AGENT_STATUS_ERROR 0x00000002
#define ZBX_FLAGS_AGENT_STATUS_ERRORS_FROM 0x00000004
#define ZBX_FLAGS_AGENT_STATUS_DISABLE_UNTIL 0x00000008
#define ZBX_FLAGS_AGENT_STATUS (ZBX_FLAGS_AGENT_STATUS_AVAILABLE | \
ZBX_FLAGS_AGENT_STATUS_ERROR | \
ZBX_FLAGS_AGENT_STATUS_ERRORS_FROM | \
ZBX_FLAGS_AGENT_STATUS_DISABLE_UNTIL)
typedef struct
{
zbx_uint64_t interfaceid;
zbx_agent_availability_t agent;
/* ensure chronological order in case of flapping interface availability */
int id;
}
zbx_interface_availability_t;
ZBX_PTR_VECTOR_DECL(availability_ptr, zbx_interface_availability_t *)
int zbx_interface_availability_compare_func(const void *d1, const void *d2);
void zbx_availability_send(zbx_uint32_t code, unsigned char *data, zbx_uint32_t size, zbx_ipc_message_t *response);
void zbx_availabilities_flush(const zbx_vector_availability_ptr_t *interface_availabilities);
typedef struct
{
zbx_hashset_t hosts;
zbx_hashset_t queue;
zbx_hashset_t proxy_avail;
double last_status_refresh;
double last_proxy_avail_refresh;
}
zbx_avail_active_hb_cache_t;
typedef struct
{
zbx_uint64_t hostid;
int lastaccess_active;
int heartbeat_freq;
int active_status;
}
zbx_host_active_avail_t;
typedef struct
{
zbx_uint64_t hostid;
int status;
}
zbx_proxy_hostdata_t;
ZBX_PTR_VECTOR_DECL(proxy_hostdata_ptr, zbx_proxy_hostdata_t *)
void zbx_availability_serialize_json_hostdata(zbx_vector_proxy_hostdata_ptr_t *hostdata, struct zbx_json *j);
int zbx_get_active_agent_availability(zbx_uint64_t hostid);
void zbx_interface_availability_init(zbx_interface_availability_t *availability, zbx_uint64_t interfaceid);
void zbx_interface_availability_clean(zbx_interface_availability_t *ia);
void zbx_interface_availability_free(zbx_interface_availability_t *availability);
void zbx_agent_availability_init(zbx_agent_availability_t *agent, unsigned char available, const char *error,
int errors_from, int disable_until);
int zbx_interface_availability_is_set(const zbx_interface_availability_t *ia);
void zbx_db_update_interface_availabilities(const zbx_vector_availability_ptr_t *interface_availabilities);
void zbx_availability_serialize_interface(unsigned char **data, size_t *data_alloc, size_t *data_offset,
const zbx_interface_availability_t *interface_availability);
void zbx_availability_deserialize(const unsigned char *data, zbx_uint32_t size,
zbx_vector_availability_ptr_t *interface_availabilities);
void zbx_availability_deserialize_active_hb(const unsigned char *data, zbx_host_active_avail_t *avail);
zbx_uint32_t zbx_availability_serialize_active_heartbeat(unsigned char **data, zbx_uint64_t hostid,
int heartbeat_freq);
zbx_uint32_t zbx_availability_serialize_hostdata(unsigned char **data, zbx_hashset_t *queue);
void zbx_availability_deserialize_hostdata(const unsigned char *data, zbx_vector_proxy_hostdata_ptr_t *hostdata);
zbx_uint32_t zbx_availability_serialize_active_status_request(unsigned char **data, zbx_uint64_t hostid);
void zbx_availability_deserialize_active_status_request(const unsigned char *data, zbx_uint64_t *hostid);
zbx_uint32_t zbx_availability_serialize_active_status_response(unsigned char **data, int status);
void zbx_availability_deserialize_active_status_response(const unsigned char *data, int *status);
zbx_uint32_t zbx_availability_serialize_proxy_hostdata(unsigned char **data, zbx_vector_proxy_hostdata_ptr_t *hosts,
zbx_uint64_t proxyid);
void zbx_availability_deserialize_proxy_hostdata(const unsigned char *data,
zbx_vector_proxy_hostdata_ptr_t *hostdata, zbx_uint64_t *proxyid);
zbx_uint32_t zbx_availability_serialize_hostids(unsigned char **data, zbx_vector_uint64_t *hostids);
void zbx_availability_deserialize_hostids(const unsigned char *data, zbx_vector_uint64_t *hostids);
void zbx_availability_deserialize_active_proxy_hb_update(const unsigned char *data, zbx_uint64_t *hostid);
ZBX_THREAD_ENTRY(zbx_availability_manager_thread, args);
#endif /* ZABBIX_AVAILABILITY_H */
|
