diff options
Diffstat (limited to 'src/aclk/aclk_query.h')
| -rw-r--r-- | src/aclk/aclk_query.h | 29 |
1 files changed, 5 insertions, 24 deletions
diff --git a/src/aclk/aclk_query.h b/src/aclk/aclk_query.h index 900583237..04cb460d0 100644 --- a/src/aclk/aclk_query.h +++ b/src/aclk/aclk_query.h @@ -9,30 +9,11 @@ #include "aclk_query_queue.h" -extern pthread_cond_t query_cond_wait; -extern pthread_mutex_t query_lock_wait; -#define QUERY_THREAD_WAKEUP pthread_cond_signal(&query_cond_wait) -#define QUERY_THREAD_WAKEUP_ALL pthread_cond_broadcast(&query_cond_wait) - -// TODO -//extern volatile int aclk_connected; - -struct aclk_query_thread { - ND_THREAD *thread; - int idx; - mqtt_wss_client client; -}; - -struct aclk_query_threads { - struct aclk_query_thread *thread_list; - int count; -}; - -void aclk_query_threads_start(struct aclk_query_threads *query_threads, mqtt_wss_client client); -void aclk_query_threads_cleanup(struct aclk_query_threads *query_threads); - -const char *aclk_query_get_name(aclk_query_type_t qt, int unknown_ok); - int mark_pending_req_cancelled(const char *msg_id); +void aclk_execute_query(aclk_query_t query); +void aclk_query_init(mqtt_wss_client client); +int http_api_v2(mqtt_wss_client client, aclk_query_t query); +int send_bin_msg(mqtt_wss_client client, aclk_query_t query); + #endif //NETDATA_AGENT_CLOUD_LINK_H |