diff options
Diffstat (limited to 'database')
| -rw-r--r-- | database/rrdcontext.c | 2 | ||||
| -rw-r--r-- | database/sqlite/sqlite_aclk_alert.c | 6 | ||||
| -rw-r--r-- | database/sqlite/sqlite_aclk_chart.c | 16 | ||||
| -rw-r--r-- | database/sqlite/sqlite_aclk_node.c | 4 |
4 files changed, 14 insertions, 14 deletions
diff --git a/database/rrdcontext.c b/database/rrdcontext.c index 639fac68e9..cac7b4706b 100644 --- a/database/rrdcontext.c +++ b/database/rrdcontext.c @@ -2176,7 +2176,7 @@ void *rrdcontext_main(void *ptr) { worker_is_busy(WORKER_JOB_QUEUED); usec_t dispatch_ut = rrdcontext_queued_dispatch_ut(rc, now_ut); - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if(unlikely(now_ut >= dispatch_ut) && claim_id) { worker_is_busy(WORKER_JOB_CHECK); diff --git a/database/sqlite/sqlite_aclk_alert.c b/database/sqlite/sqlite_aclk_alert.c index 70c4cbd579..c5c06a4943 100644 --- a/database/sqlite/sqlite_aclk_alert.c +++ b/database/sqlite/sqlite_aclk_alert.c @@ -224,7 +224,7 @@ void aclk_push_alert_event(struct aclk_database_worker_config *wc, struct aclk_d return; } - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; @@ -449,7 +449,7 @@ void aclk_push_alarm_health_log(struct aclk_database_worker_config *wc, struct a #else int rc; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; @@ -911,7 +911,7 @@ void aclk_push_alert_snapshot_event(struct aclk_database_worker_config *wc, stru if (unlikely(!wc->alerts_snapshot_id)) return; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; diff --git a/database/sqlite/sqlite_aclk_chart.c b/database/sqlite/sqlite_aclk_chart.c index 089e42c9c6..658d8da252 100644 --- a/database/sqlite/sqlite_aclk_chart.c +++ b/database/sqlite/sqlite_aclk_chart.c @@ -143,7 +143,7 @@ int aclk_add_chart_event(struct aclk_database_worker_config *wc, struct aclk_dat int rc = 0; CHECK_SQLITE_CONNECTION(db_meta); - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); RRDSET *st = cmd.data; @@ -222,7 +222,7 @@ void aclk_process_dimension_deletion(struct aclk_database_worker_config *wc, str if (uuid_parse(wc->host_guid, host_id)) return; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (!claim_id) return; @@ -281,7 +281,7 @@ int aclk_add_dimension_event(struct aclk_database_worker_config *wc, struct aclk struct aclk_chart_dimension_data *aclk_cd_data = cmd.data; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (!claim_id) goto cleanup; @@ -308,7 +308,7 @@ void aclk_send_chart_event(struct aclk_database_worker_config *wc, struct aclk_d return; } - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; @@ -736,7 +736,7 @@ void aclk_start_streaming(char *node_id, uint64_t sequence_id, time_t created_at wc->chart_reset_count); chart_reset_t chart_reset; - chart_reset.claim_id = is_agent_claimed(); + chart_reset.claim_id = get_agent_claimid(); if (chart_reset.claim_id) { chart_reset.node_id = node_id; chart_reset.reason = SEQ_ID_NOT_EXISTS; @@ -825,7 +825,7 @@ void aclk_update_retention(struct aclk_database_worker_config *wc) if (!aclk_connected) return; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; @@ -1076,7 +1076,7 @@ void queue_dimension_to_aclk(RRDDIM *rd, time_t last_updated) if (unlikely(!wc)) return; - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; @@ -1120,7 +1120,7 @@ void queue_dimension_to_aclk(RRDDIM *rd, time_t last_updated) void aclk_send_dimension_update(RRDDIM *rd) { - char *claim_id = is_agent_claimed(); + char *claim_id = get_agent_claimid(); if (unlikely(!claim_id)) return; diff --git a/database/sqlite/sqlite_aclk_node.c b/database/sqlite/sqlite_aclk_node.c index dda659bb46..cc16dc8aac 100644 --- a/database/sqlite/sqlite_aclk_node.c +++ b/database/sqlite/sqlite_aclk_node.c @@ -39,7 +39,7 @@ void sql_build_node_collectors(struct aclk_database_worker_config *wc) DICTIONARY *dict = dictionary_create(DICTIONARY_FLAG_SINGLE_THREADED); upd_node_collectors.node_id = wc->node_id; - upd_node_collectors.claim_id = is_agent_claimed(); + upd_node_collectors.claim_id = get_agent_claimid(); upd_node_collectors.node_collectors = collectors_from_charts(wc->host, dict); aclk_update_node_collectors(&upd_node_collectors); @@ -68,7 +68,7 @@ void sql_build_node_info(struct aclk_database_worker_config *wc, struct aclk_dat rrd_rdlock(); node_info.node_id = wc->node_id; - node_info.claim_id = is_agent_claimed(); + node_info.claim_id = get_agent_claimid(); node_info.machine_guid = wc->host_guid; node_info.child = (wc->host != localhost); node_info.ml_info.ml_capable = ml_capable(localhost); |