diff options
Diffstat (limited to '')
| -rw-r--r-- | src/aclk/aclk_query_queue.h (renamed from aclk/aclk_query_queue.h) | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/aclk/aclk_query_queue.h b/src/aclk/aclk_query_queue.h index 5983561a6..4a4a36a3f 100644 --- a/aclk/aclk_query_queue.h +++ b/src/aclk/aclk_query_queue.h @@ -55,7 +55,7 @@ struct aclk_query { struct timeval created_tv; usec_t created; int timeout; - aclk_query_t next; + aclk_query_t prev, next; // TODO maybe remove? int version; @@ -75,12 +75,13 @@ void aclk_queue_flush(void); void aclk_queue_lock(void); void aclk_queue_unlock(void); -#define QUEUE_IF_PAYLOAD_PRESENT(query) \ +#define QUEUE_IF_PAYLOAD_PRESENT(query) do { \ if (likely(query->data.bin_payload.payload)) { \ aclk_queue_query(query); \ } else { \ - netdata_log_error("Failed to generate payload (%s)", __FUNCTION__); \ + nd_log(NDLS_DAEMON, NDLP_ERR, "Failed to generate payload"); \ aclk_query_free(query); \ - } + } \ +} while(0) #endif /* NETDATA_ACLK_QUERY_QUEUE_H */ |