summaryrefslogtreecommitdiffstats
path: root/aclk/aclk_tx_msgs.c
diff options
context:
space:
mode:
Diffstat (limited to 'aclk/aclk_tx_msgs.c')
-rw-r--r--aclk/aclk_tx_msgs.c30
1 files changed, 15 insertions, 15 deletions
diff --git a/aclk/aclk_tx_msgs.c b/aclk/aclk_tx_msgs.c
index 26e20dfb2c..03440aeeb0 100644
--- a/aclk/aclk_tx_msgs.c
+++ b/aclk/aclk_tx_msgs.c
@@ -218,19 +218,19 @@ uint16_t aclk_send_agent_connection_update(mqtt_wss_client client, int reachable
.capabilities = aclk_get_agent_capas()
};
- rrdhost_aclk_state_lock(localhost);
- if (unlikely(!localhost->aclk_state.claimed_id)) {
+ rrdhost_aclk_state_lock(rrdb.localhost);
+ if (unlikely(!rrdb.localhost->aclk_state.claimed_id)) {
netdata_log_error("Internal error. Should not come here if not claimed");
- rrdhost_aclk_state_unlock(localhost);
+ rrdhost_aclk_state_unlock(rrdb.localhost);
return 0;
}
- if (localhost->aclk_state.prev_claimed_id)
- conn.claim_id = localhost->aclk_state.prev_claimed_id;
+ if (rrdb.localhost->aclk_state.prev_claimed_id)
+ conn.claim_id = rrdb.localhost->aclk_state.prev_claimed_id;
else
- conn.claim_id = localhost->aclk_state.claimed_id;
+ conn.claim_id = rrdb.localhost->aclk_state.claimed_id;
char *msg = generate_update_agent_connection(&len, &conn);
- rrdhost_aclk_state_unlock(localhost);
+ rrdhost_aclk_state_unlock(rrdb.localhost);
if (!msg) {
netdata_log_error("Error generating agent::v1::UpdateAgentConnection payload");
@@ -238,9 +238,9 @@ uint16_t aclk_send_agent_connection_update(mqtt_wss_client client, int reachable
}
pid = aclk_send_bin_message_subtopic_pid(client, msg, len, ACLK_TOPICID_AGENT_CONN, "UpdateAgentConnection");
- if (localhost->aclk_state.prev_claimed_id) {
- freez(localhost->aclk_state.prev_claimed_id);
- localhost->aclk_state.prev_claimed_id = NULL;
+ if (rrdb.localhost->aclk_state.prev_claimed_id) {
+ freez(rrdb.localhost->aclk_state.prev_claimed_id);
+ rrdb.localhost->aclk_state.prev_claimed_id = NULL;
}
return pid;
}
@@ -253,16 +253,16 @@ char *aclk_generate_lwt(size_t *size) {
.capabilities = NULL
};
- rrdhost_aclk_state_lock(localhost);
- if (unlikely(!localhost->aclk_state.claimed_id)) {
+ rrdhost_aclk_state_lock(rrdb.localhost);
+ if (unlikely(!rrdb.localhost->aclk_state.claimed_id)) {
netdata_log_error("Internal error. Should not come here if not claimed");
- rrdhost_aclk_state_unlock(localhost);
+ rrdhost_aclk_state_unlock(rrdb.localhost);
return NULL;
}
- conn.claim_id = localhost->aclk_state.claimed_id;
+ conn.claim_id = rrdb.localhost->aclk_state.claimed_id;
char *msg = generate_update_agent_connection(size, &conn);
- rrdhost_aclk_state_unlock(localhost);
+ rrdhost_aclk_state_unlock(rrdb.localhost);
if (!msg)
netdata_log_error("Error generating agent::v1::UpdateAgentConnection payload for LWT");