blob: 87e34e0dfc6b6e4f4d9cd843400c182e6805d15a (
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
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
|
#include "chart_config.h"
#include "proto/chart/v1/config.pb.h"
#include "libnetdata/libnetdata.h"
#include "schema_wrapper_utils.h"
void destroy_update_chart_config(struct update_chart_config *cfg)
{
freez(cfg->claim_id);
freez(cfg->node_id);
freez(cfg->hashes);
}
void destroy_chart_config_updated(struct chart_config_updated *cfg)
{
freez(cfg->type);
freez(cfg->family);
freez(cfg->context);
freez(cfg->title);
freez(cfg->plugin);
freez(cfg->module);
freez(cfg->units);
freez(cfg->config_hash);
}
struct update_chart_config parse_update_chart_config(const char *data, size_t len)
{
chart::v1::UpdateChartConfigs cfgs;
update_chart_config res;
memset(&res, 0, sizeof(res));
if (!cfgs.ParseFromArray(data, len))
return res;
res.claim_id = strdupz(cfgs.claim_id().c_str());
res.node_id = strdupz(cfgs.node_id().c_str());
// to not do bazillion tiny allocations for individual strings
// we calculate how much memory we will need for all of them
// and allocate at once
int hash_count = cfgs.config_hashes_size();
size_t total_strlen = 0;
for (int i = 0; i < hash_count; i++)
total_strlen += cfgs.config_hashes(i).length();
total_strlen += hash_count; //null bytes
res.hashes = (char**)callocz( 1,
(hash_count+1) * sizeof(char*) + //char * array incl. terminating NULL at the end
total_strlen //strings themselves incl. 1 null byte each
);
char* dest = ((char*)res.hashes) + (hash_count + 1 /* NULL ptr */) * sizeof(char *);
// now copy them strings
// null bytes handled by callocz
for (int i = 0; i < hash_count; i++) {
strcpy(dest, cfgs.config_hashes(i).c_str());
res.hashes[i] = dest;
dest += strlen(dest) + 1 /* end string null */;
}
return res;
}
char *generate_chart_configs_updated(size_t *len, const struct chart_config_updated *config_list, int list_size)
{
chart::v1::ChartConfigsUpdated configs;
for (int i = 0; i < list_size; i++) {
chart::v1::ChartConfigUpdated *config = configs.add_configs();
config->set_type(config_list[i].type);
if (config_list[i].family)
config->set_family(config_list[i].family);
config->set_context(config_list[i].context);
config->set_title(config_list[i].title);
config->set_priority(config_list[i].priority);
config->set_plugin(config_list[i].plugin);
if (config_list[i].module)
config->set_module(config_list[i].module);
switch (config_list[i].chart_type) {
case RRDSET_TYPE_LINE:
config->set_chart_type(chart::v1::LINE);
break;
case RRDSET_TYPE_AREA:
config->set_chart_type(chart::v1::AREA);
break;
case RRDSET_TYPE_STACKED:
config->set_chart_type(chart::v1::STACKED);
break;
default:
return NULL;
}
config->set_units(config_list[i].units);
config->set_config_hash(config_list[i].config_hash);
}
*len = PROTO_COMPAT_MSG_SIZE(configs);
char *bin = (char*)mallocz(*len);
configs.SerializeToArray(bin, *len);
return bin;
}
|
