diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2023-01-18 21:32:50 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-18 21:32:50 +0200 |
| commit | c1908d3163185cf65a139edeb11a165a10eca1e9 (patch) | |
| tree | 6fe69ef8cd5f5797253e0d583fe60d56c69ec3da /aclk | |
| parent | 51565d55e92b6f814a09ca87d3c77a40acba576c (diff) | |
DBENGINE v2 - improvements part 5 (#14289)
* cleanup journal v2 mounts periodically
* fix for last commit
* re-enable loading page from disk when the arrangement of pages requires it
* Remove unused statistics
* Estimate diskspace when the current datafile is full and queue a rotate command (Currently it will not attempt to estimate end size for journals)
Queue a command to check quota on startup per tier
* apps.plugin now exposes RSS chart
* shorter thread names to make debugging easier, since thread names can only be 15 characters
* more thread names fixes
* allow an apps_groups.conf target to be pid 0 or 1
Co-authored-by: Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com>
Diffstat (limited to 'aclk')
| -rw-r--r-- | aclk/aclk.c | 4 | ||||
| -rw-r--r-- | aclk/aclk_query.c | 4 | ||||
| -rw-r--r-- | aclk/aclk_stats.h | 2 |
3 files changed, 3 insertions, 7 deletions
diff --git a/aclk/aclk.c b/aclk/aclk.c index 04b81b9eb0..daa4a17642 100644 --- a/aclk/aclk.c +++ b/aclk/aclk.c @@ -731,8 +731,8 @@ void *aclk_main(void *ptr) stats_thread->client = mqttwss_client; aclk_stats_thread_prepare(query_threads.count, proto_hdl_cnt); netdata_thread_create( - stats_thread->thread, ACLK_STATS_THREAD_NAME, NETDATA_THREAD_OPTION_JOINABLE, aclk_stats_main_thread, - stats_thread); + stats_thread->thread, "ACLK_STATS", NETDATA_THREAD_OPTION_JOINABLE, aclk_stats_main_thread, + stats_thread); } // Keep reconnecting and talking until our time has come diff --git a/aclk/aclk_query.c b/aclk/aclk_query.c index 2d14badeef..3abe21b090 100644 --- a/aclk/aclk_query.c +++ b/aclk/aclk_query.c @@ -4,8 +4,6 @@ #include "aclk_stats.h" #include "aclk_tx_msgs.h" -#define ACLK_QUERY_THREAD_NAME "ACLK_Query" - #define WEB_HDR_ACCEPT_ENC "Accept-Encoding:" pthread_cond_t query_cond_wait = PTHREAD_COND_INITIALIZER; @@ -368,7 +366,7 @@ void aclk_query_threads_start(struct aclk_query_threads *query_threads, mqtt_wss query_threads->thread_list[i].idx = i; //thread needs to know its index for statistics query_threads->thread_list[i].client = client; - if(unlikely(snprintfz(thread_name, TASK_LEN_MAX, "%s_%d", ACLK_QUERY_THREAD_NAME, i) < 0)) + if(unlikely(snprintfz(thread_name, TASK_LEN_MAX, "ACLK_QRY[%d]", i) < 0)) error("snprintf encoding error"); netdata_thread_create( &query_threads->thread_list[i].thread, thread_name, NETDATA_THREAD_OPTION_JOINABLE, aclk_query_main_thread, diff --git a/aclk/aclk_stats.h b/aclk/aclk_stats.h index 783bdd3165..002ebcfa6b 100644 --- a/aclk/aclk_stats.h +++ b/aclk/aclk_stats.h @@ -8,8 +8,6 @@ #include "aclk_query_queue.h" #include "mqtt_wss_client.h" -#define ACLK_STATS_THREAD_NAME "ACLK_Stats" - extern netdata_mutex_t aclk_stats_mutex; #define ACLK_STATS_LOCK netdata_mutex_lock(&aclk_stats_mutex) |