diff options
| author | Emmanuel Vasilakis <mrzammler@mm.st> | 2022-10-13 11:21:23 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-13 11:21:23 +0300 |
| commit | fb86ddd70d14f7943e0314b02235ce3cbca5cb2d (patch) | |
| tree | 4bf1ad1646573361dcf3f87cfb6522e3a0f76266 /aclk | |
| parent | 61767a8a08d089962ff82e45b3e459c8bd05b0c4 (diff) | |
Count currently streaming senders on the localhost (#13755)
rebased
Diffstat (limited to 'aclk')
| -rw-r--r-- | aclk/aclk.c | 7 | ||||
| -rw-r--r-- | aclk/aclk.h | 1 |
2 files changed, 8 insertions, 0 deletions
diff --git a/aclk/aclk.c b/aclk/aclk.c index 4646f3c2d4..12dcb57da1 100644 --- a/aclk/aclk.c +++ b/aclk/aclk.c @@ -1182,3 +1182,10 @@ void add_aclk_host_labels(void) { rrdlabels_add(labels, "_aclk_available", "false", RRDLABEL_SRC_AUTO|RRDLABEL_SRC_ACLK); #endif } + +void aclk_queue_node_info(RRDHOST *host) { + struct aclk_database_worker_config *wc = (struct aclk_database_worker_config *) host->dbsync_worker; + if (likely(wc)) { + wc->node_info_send = 1; + } +} diff --git a/aclk/aclk.h b/aclk/aclk.h index 061977c0b8..0cecb2d9d5 100644 --- a/aclk/aclk.h +++ b/aclk/aclk.h @@ -54,5 +54,6 @@ void aclk_send_bin_msg(char *msg, size_t msg_len, enum aclk_topics subtopic, con char *aclk_state(void); char *aclk_state_json(void); void add_aclk_host_labels(void); +void aclk_queue_node_info(RRDHOST *host); #endif /* ACLK_H */ |