summaryrefslogtreecommitdiffstats
path: root/exporting/exporting_engine.c
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2023-07-20 04:49:55 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2023-07-20 04:49:55 +0000
commitab1bb5b7f1c3c3a7b240ab7fc8661459ecd7decb (patch)
tree7a900833aad3ccc685712c6c2a7d87576d54f427 /exporting/exporting_engine.c
parentAdding upstream version 1.40.1. (diff)
downloadnetdata-upstream/1.41.0.tar.xz
netdata-upstream/1.41.0.zip
Adding upstream version 1.41.0.upstream/1.41.0
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'exporting/exporting_engine.c')
-rw-r--r--exporting/exporting_engine.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/exporting/exporting_engine.c b/exporting/exporting_engine.c
index 8f957c7c5..f42a36e92 100644
--- a/exporting/exporting_engine.c
+++ b/exporting/exporting_engine.c
@@ -124,7 +124,7 @@ 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...");
+ netdata_log_info("cleaning up...");
if (!engine) {
static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
@@ -139,17 +139,17 @@ static void exporting_main_cleanup(void *ptr)
for (struct instance *instance = engine->instance_root; instance; instance = instance->next) {
if (!instance->exited) {
found++;
- info("stopping worker for instance %s", instance->config.name);
+ netdata_log_info("stopping worker for instance %s", instance->config.name);
uv_mutex_unlock(&instance->mutex);
instance->data_is_ready = 1;
uv_cond_signal(&instance->cond_var);
} else
- info("found stopped worker for instance %s", instance->config.name);
+ netdata_log_info("found stopped worker for instance %s", instance->config.name);
}
while (found && max > 0) {
max -= step;
- info("Waiting %d exporting connectors to finish...", found);
+ netdata_log_info("Waiting %d exporting connectors to finish...", found);
sleep_usec(step);
found = 0;
@@ -178,12 +178,12 @@ void *exporting_main(void *ptr)
engine = read_exporting_config();
if (!engine) {
- info("EXPORTING: no exporting connectors configured");
+ netdata_log_info("EXPORTING: no exporting connectors configured");
goto cleanup;
}
if (init_connectors(engine) != 0) {
- error("EXPORTING: cannot initialize exporting connectors");
+ netdata_log_error("EXPORTING: cannot initialize exporting connectors");
send_statistics("EXPORTING_START", "FAIL", "-");
goto cleanup;
}