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
|
/*
** Zabbix
** Copyright (C) 2001-2022 Zabbix SIA
**
** This program is free software; you can redistribute it and/or modify
** it under the terms of the GNU General Public License as published by
** the Free Software Foundation; either version 2 of the License, or
** (at your option) any later version.
**
** 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 General Public License for more details.
**
** You should have received a copy of the GNU General Public License
** along with this program; if not, write to the Free Software
** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
**/
#ifndef ZABBIX_CACHEHISTORY_H
#define ZABBIX_CACHEHISTORY_H
#include "zbxcacheconfig.h"
#include "zbxshmem.h"
#define ZBX_SYNC_DONE 0
#define ZBX_SYNC_MORE 1
extern zbx_uint64_t CONFIG_HISTORY_CACHE_SIZE;
extern zbx_uint64_t CONFIG_HISTORY_INDEX_CACHE_SIZE;
extern zbx_uint64_t CONFIG_TRENDS_CACHE_SIZE;
/* value_avg_t structure is used for item average value trend calculations. */
/* */
/* For double values the average value is calculated on the fly with the */
/* following formula: avg = (dbl * count + value) / (count + 1) and stored */
/* into dbl member. */
/* For uint64 values the item values are summed into ui64 member and the */
/* average value is calculated before flushing trends to database: */
/* avg = ui64 / count */
typedef union
{
double dbl;
zbx_uint128_t ui64;
}
value_avg_t;
typedef struct
{
zbx_uint64_t itemid;
history_value_t value_min;
value_avg_t value_avg;
history_value_t value_max;
int clock;
int num;
int disable_from;
unsigned char value_type;
}
ZBX_DC_TREND;
typedef struct
{
zbx_uint64_t history_counter; /* the total number of processed values */
zbx_uint64_t history_float_counter; /* the number of processed float values */
zbx_uint64_t history_uint_counter; /* the number of processed uint values */
zbx_uint64_t history_str_counter; /* the number of processed str values */
zbx_uint64_t history_log_counter; /* the number of processed log values */
zbx_uint64_t history_text_counter; /* the number of processed text values */
zbx_uint64_t notsupported_counter; /* the number of processed not supported items */
}
ZBX_DC_STATS;
/* the write cache statistics */
typedef struct
{
ZBX_DC_STATS stats;
zbx_uint64_t history_free;
zbx_uint64_t history_total;
zbx_uint64_t index_free;
zbx_uint64_t index_total;
zbx_uint64_t trend_free;
zbx_uint64_t trend_total;
}
zbx_wcache_info_t;
void zbx_sync_history_cache(int *values_num, int *triggers_num, int *more);
void zbx_log_sync_history_cache_progress(void);
#define ZBX_SYNC_NONE 0
#define ZBX_SYNC_ALL 1
int init_database_cache(char **error);
void free_database_cache(int);
void change_proxy_history_count(int change_count);
void reset_proxy_history_count(int reset);
int get_proxy_history_count(void);
#define ZBX_STATS_HISTORY_COUNTER 0
#define ZBX_STATS_HISTORY_FLOAT_COUNTER 1
#define ZBX_STATS_HISTORY_UINT_COUNTER 2
#define ZBX_STATS_HISTORY_STR_COUNTER 3
#define ZBX_STATS_HISTORY_LOG_COUNTER 4
#define ZBX_STATS_HISTORY_TEXT_COUNTER 5
#define ZBX_STATS_NOTSUPPORTED_COUNTER 6
#define ZBX_STATS_HISTORY_TOTAL 7
#define ZBX_STATS_HISTORY_USED 8
#define ZBX_STATS_HISTORY_FREE 9
#define ZBX_STATS_HISTORY_PUSED 10
#define ZBX_STATS_HISTORY_PFREE 11
#define ZBX_STATS_TREND_TOTAL 12
#define ZBX_STATS_TREND_USED 13
#define ZBX_STATS_TREND_FREE 14
#define ZBX_STATS_TREND_PUSED 15
#define ZBX_STATS_TREND_PFREE 16
#define ZBX_STATS_HISTORY_INDEX_TOTAL 17
#define ZBX_STATS_HISTORY_INDEX_USED 18
#define ZBX_STATS_HISTORY_INDEX_FREE 19
#define ZBX_STATS_HISTORY_INDEX_PUSED 20
#define ZBX_STATS_HISTORY_INDEX_PFREE 21
void *DCget_stats(int request);
void DCget_stats_all(zbx_wcache_info_t *wcache_info);
zbx_uint64_t DCget_nextid(const char *table_name, int num);
void DCupdate_interfaces_availability(void);
void zbx_hc_get_diag_stats(zbx_uint64_t *items_num, zbx_uint64_t *values_num);
void zbx_hc_get_mem_stats(zbx_shmem_stats_t *data, zbx_shmem_stats_t *index);
void zbx_hc_get_items(zbx_vector_uint64_pair_t *items);
int zbx_db_trigger_queue_locked(void);
void zbx_db_trigger_queue_unlock(void);
int zbx_hc_check_proxy(zbx_uint64_t proxyid);
#endif
|
