summaryrefslogtreecommitdiffstats
path: root/spawn/spawn.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 /spawn/spawn.c
parentAdding upstream version 1.40.1. (diff)
downloadnetdata-ab1bb5b7f1c3c3a7b240ab7fc8661459ecd7decb.tar.xz
netdata-ab1bb5b7f1c3c3a7b240ab7fc8661459ecd7decb.zip
Adding upstream version 1.41.0.upstream/1.41.0
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'spawn/spawn.c')
-rw-r--r--spawn/spawn.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/spawn/spawn.c b/spawn/spawn.c
index f326f8881..a9359da04 100644
--- a/spawn/spawn.c
+++ b/spawn/spawn.c
@@ -219,7 +219,7 @@ int create_spawn_server(uv_loop_t *loop, uv_pipe_t *spawn_channel, uv_process_t
ret = uv_spawn(loop, process, &options); /* execute the netdata binary again as the netdata user */
if (0 != ret) {
- error("uv_spawn (process: \"%s\") (user: %s) failed (%s).", exepath, user, uv_strerror(ret));
+ netdata_log_error("uv_spawn (process: \"%s\") (user: %s) failed (%s).", exepath, user, uv_strerror(ret));
fatal("Cannot start netdata without the spawn server.");
}
@@ -235,14 +235,14 @@ void spawn_init(void)
struct completion completion;
int error;
- info("Initializing spawn client.");
+ netdata_log_info("Initializing spawn client.");
init_spawn_cmd_queue();
completion_init(&completion);
error = uv_thread_create(&thread, spawn_client, &completion);
if (error) {
- error("uv_thread_create(): %s", uv_strerror(error));
+ netdata_log_error("uv_thread_create(): %s", uv_strerror(error));
goto after_error;
}
/* wait for spawn client thread to initialize */
@@ -253,7 +253,7 @@ void spawn_init(void)
if (spawn_thread_error) {
error = uv_thread_join(&thread);
if (error) {
- error("uv_thread_create(): %s", uv_strerror(error));
+ netdata_log_error("uv_thread_create(): %s", uv_strerror(error));
}
goto after_error;
}
@@ -268,15 +268,15 @@ void spawn_init(void)
char cmd[64];
sprintf(cmd, "echo CONCURRENT_STRESS_TEST %d 1>&2", j * CONCURRENT_SPAWNS + i + 1);
serial[i] = spawn_enq_cmd(cmd);
- info("Queued command %s for spawning.", cmd);
+ netdata_log_info("Queued command %s for spawning.", cmd);
}
int exit_status;
time_t exec_run_timestamp;
for (int i = 0; i < CONCURRENT_SPAWNS; ++i) {
- info("Started waiting for serial %llu exit status %d run timestamp %llu.", serial[i], exit_status,
+ netdata_log_info("Started waiting for serial %llu exit status %d run timestamp %llu.", serial[i], exit_status,
exec_run_timestamp);
spawn_wait_cmd(serial[i], &exit_status, &exec_run_timestamp);
- info("Finished waiting for serial %llu exit status %d run timestamp %llu.", serial[i], exit_status,
+ netdata_log_info("Finished waiting for serial %llu exit status %d run timestamp %llu.", serial[i], exit_status,
exec_run_timestamp);
}
}
@@ -285,5 +285,5 @@ void spawn_init(void)
return;
after_error:
- error("Failed to initialize spawn service. The alarms notifications will not be spawned.");
+ netdata_log_error("Failed to initialize spawn service. The alarms notifications will not be spawned.");
}