blob: 93347328cd4cdacb8f1f01fb5c37fea351c1b619 (
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
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "exporting_engine.h"
static void exporting_main_cleanup(void *ptr) {
struct netdata_static_thread *static_thread = (struct netdata_static_thread *)ptr;
static_thread->enabled = NETDATA_MAIN_THREAD_EXITING;
info("cleaning up...");
static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
}
/**
* Exporting engine main
*
* The main thread used to control the exporting engine.
*
* @param ptr a pointer to netdata_static_structure.
*
* @return It always returns NULL.
*/
void *exporting_main(void *ptr)
{
netdata_thread_cleanup_push(exporting_main_cleanup, ptr);
struct engine *engine = read_exporting_config();
if (!engine) {
info("EXPORTING: no exporting connectors configured");
goto cleanup;
}
if (init_connectors(engine) != 0) {
error("EXPORTING: cannot initialize exporting connectors");
goto cleanup;
}
RRDSET *st_main_rusage = NULL;
RRDDIM *rd_main_user = NULL;
RRDDIM *rd_main_system = NULL;
create_main_rusage_chart(&st_main_rusage, &rd_main_user, &rd_main_system);
usec_t step_ut = localhost->rrd_update_every * USEC_PER_SEC;
heartbeat_t hb;
heartbeat_init(&hb);
while (!netdata_exit) {
heartbeat_next(&hb, step_ut);
engine->now = now_realtime_sec();
if (mark_scheduled_instances(engine)) {
if (prepare_buffers(engine) != 0) {
error("EXPORTING: cannot prepare data to send");
break;
}
}
if (notify_workers(engine) != 0) {
error("EXPORTING: cannot communicate with exporting connector instance working threads");
break;
}
send_main_rusage(st_main_rusage, rd_main_user, rd_main_system);
#ifdef UNIT_TESTING
break;
#endif
}
cleanup:
netdata_thread_cleanup_pop(1);
return NULL;
}
|
