summaryrefslogtreecommitdiffstats
path: root/streaming/sender.c
diff options
context:
space:
mode:
authorCosta Tsaousis <costa@netdata.cloud>2022-12-09 18:55:30 +0200
committerGitHub <noreply@github.com>2022-12-09 18:55:30 +0200
commitc0d1d167c4108398400ea31a6bbf58e18d717132 (patch)
tree88ecc5ed574047b1a7843a263b250a33e6f36cd5 /streaming/sender.c
parent8328d31b065f18c66bd3982044abfe52e81ffcbc (diff)
don't log too much about streaming connections (#14117)
Diffstat (limited to 'streaming/sender.c')
-rw-r--r--streaming/sender.c16
1 files changed, 9 insertions, 7 deletions
diff --git a/streaming/sender.c b/streaming/sender.c
index 62097e39f6..a67f6f2175 100644
--- a/streaming/sender.c
+++ b/streaming/sender.c
@@ -222,8 +222,6 @@ static void rrdpush_sender_thread_send_custom_host_variables(RRDHOST *host) {
// resets all the chart, so that their definitions
// will be resent to the central netdata
static void rrdpush_sender_thread_reset_all_charts(RRDHOST *host) {
- error("Clearing stream_collected_metrics flag in charts of host %s", rrdhost_hostname(host));
-
RRDSET *st;
rrdset_foreach_read(st, host) {
rrdset_flag_clear(st, RRDSET_FLAG_UPSTREAM_EXPOSED | RRDSET_FLAG_SENDER_REPLICATION_IN_PROGRESS);
@@ -418,13 +416,17 @@ static inline bool rrdpush_sender_validate_response(RRDHOST *host, struct sender
return true;
}
- error("STREAM %s [send to %s]: %s.", rrdhost_hostname(host), s->connected_to, error);
-
worker_is_busy(worker_job_id);
rrdpush_sender_thread_close_socket(host);
host->destination->last_error = error;
host->destination->last_handshake = version;
host->destination->postpone_reconnection_until = now_realtime_sec() + delay;
+
+ char buf[LOG_DATE_LENGTH];
+ log_date(buf, LOG_DATE_LENGTH, host->destination->postpone_reconnection_until);
+ error("STREAM %s [send to %s]: %s - will retry in %ld secs, at %s",
+ rrdhost_hostname(host), s->connected_to, error, delay, buf);
+
return false;
}
@@ -449,11 +451,11 @@ static bool rrdpush_sender_thread_connect_to_parent(RRDHOST *host, int default_p
);
if(unlikely(s->rrdpush_sender_socket == -1)) {
- error("STREAM %s [send to %s]: could not connect to parent node at this time.", rrdhost_hostname(host), host->rrdpush_send_destination);
+ // error("STREAM %s [send to %s]: could not connect to parent node at this time.", rrdhost_hostname(host), host->rrdpush_send_destination);
return false;
}
- info("STREAM %s [send to %s]: initializing communication...", rrdhost_hostname(host), s->connected_to);
+ // info("STREAM %s [send to %s]: initializing communication...", rrdhost_hostname(host), s->connected_to);
#ifdef ENABLE_HTTPS
if(netdata_ssl_client_ctx){
@@ -657,7 +659,7 @@ static bool rrdpush_sender_thread_connect_to_parent(RRDHOST *host, int default_p
return false;
}
- info("STREAM %s [send to %s]: waiting response from remote netdata...", rrdhost_hostname(host), s->connected_to);
+ // info("STREAM %s [send to %s]: waiting response from remote netdata...", rrdhost_hostname(host), s->connected_to);
bytes = recv_timeout(
#ifdef ENABLE_HTTPS