diff options
| author | Timotej S <6674623+underhood@users.noreply.github.com> | 2020-11-26 17:26:01 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-11-26 17:26:01 +0100 |
| commit | f1db235a36d85f81c5a19a7087567405771874f7 (patch) | |
| tree | f99084d252e0af0496bf4776fa2c118f15dbee1a /aclk/aclk_rx_msgs.c | |
| parent | 4f867a58e5287e54aa5ecae023868615cafb9f93 (diff) | |
ACLK Child Availability Messages (#9918)
* new ACLK messages for Claiming MVP1
Diffstat (limited to 'aclk/aclk_rx_msgs.c')
| -rw-r--r-- | aclk/aclk_rx_msgs.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/aclk/aclk_rx_msgs.c b/aclk/aclk_rx_msgs.c index 85b0d74ac9..b90f60d9a8 100644 --- a/aclk/aclk_rx_msgs.c +++ b/aclk/aclk_rx_msgs.c @@ -38,13 +38,13 @@ static inline int aclk_v2_payload_get_query(const char *payload, struct aclk_req return 0; } -#define HTTP_CHECK_AGENT_INITIALIZED() ACLK_SHARED_STATE_LOCK;\ - if (unlikely(aclk_shared_state.agent_state == AGENT_INITIALIZING)) {\ +#define HTTP_CHECK_AGENT_INITIALIZED() rrdhost_aclk_state_lock(localhost);\ + if (unlikely(localhost->aclk_state.state == ACLK_HOST_INITIALIZING)) {\ debug(D_ACLK, "Ignoring \"http\" cloud request; agent not in stable state");\ - ACLK_SHARED_STATE_UNLOCK;\ + rrdhost_aclk_state_unlock(localhost);\ return 1;\ }\ - ACLK_SHARED_STATE_UNLOCK; + rrdhost_aclk_state_unlock(localhost); /* * Parse the incoming payload and queue a command if valid |