summaryrefslogtreecommitdiffstats
path: root/daemon/event_loop.c
diff options
context:
space:
mode:
Diffstat (limited to 'daemon/event_loop.c')
-rw-r--r--daemon/event_loop.c66
1 files changed, 0 insertions, 66 deletions
diff --git a/daemon/event_loop.c b/daemon/event_loop.c
deleted file mode 100644
index 93bac97d0..000000000
--- a/daemon/event_loop.c
+++ /dev/null
@@ -1,66 +0,0 @@
-// SPDX-License-Identifier: GPL-3.0-or-later
-
-#include <daemon/main.h>
-#include "event_loop.h"
-
-// Register workers
-void register_libuv_worker_jobs() {
- static __thread bool registered = false;
-
- if(likely(registered))
- return;
-
- registered = true;
-
- worker_register("LIBUV");
-
- // generic
- worker_register_job_name(UV_EVENT_WORKER_INIT, "worker init");
-
- // query related
- worker_register_job_name(UV_EVENT_DBENGINE_QUERY, "query");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_CACHE_LOOKUP, "extent cache");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_MMAP, "extent mmap");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_DECOMPRESSION, "extent decompression");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_PAGE_LOOKUP, "page lookup");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_PAGE_POPULATION, "page populate");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_PAGE_ALLOCATION, "page allocate");
-
- // flushing related
- worker_register_job_name(UV_EVENT_DBENGINE_FLUSH_MAIN_CACHE, "flush main");
- worker_register_job_name(UV_EVENT_DBENGINE_EXTENT_WRITE, "extent write");
- worker_register_job_name(UV_EVENT_DBENGINE_FLUSHED_TO_OPEN, "flushed to open");
-
- // datafile full
- worker_register_job_name(UV_EVENT_DBENGINE_JOURNAL_INDEX_WAIT, "jv2 index wait");
- worker_register_job_name(UV_EVENT_DBENGINE_JOURNAL_INDEX, "jv2 indexing");
-
- // db rotation related
- worker_register_job_name(UV_EVENT_DBENGINE_DATAFILE_DELETE_WAIT, "datafile delete wait");
- worker_register_job_name(UV_EVENT_DBENGINE_DATAFILE_DELETE, "datafile deletion");
- worker_register_job_name(UV_EVENT_DBENGINE_FIND_ROTATED_METRICS, "find rotated metrics");
- worker_register_job_name(UV_EVENT_DBENGINE_FIND_REMAINING_RETENTION, "find remaining retention");
- worker_register_job_name(UV_EVENT_DBENGINE_POPULATE_MRG, "update retention");
-
- // other dbengine events
- worker_register_job_name(UV_EVENT_DBENGINE_EVICT_MAIN_CACHE, "evict main");
- worker_register_job_name(UV_EVENT_DBENGINE_BUFFERS_CLEANUP, "dbengine buffers cleanup");
- worker_register_job_name(UV_EVENT_DBENGINE_QUIESCE, "dbengine quiesce");
- worker_register_job_name(UV_EVENT_DBENGINE_SHUTDOWN, "dbengine shutdown");
-
- // metadata
- worker_register_job_name(UV_EVENT_HOST_CONTEXT_LOAD, "metadata load host context");
- worker_register_job_name(UV_EVENT_METADATA_STORE, "metadata store host");
- worker_register_job_name(UV_EVENT_METADATA_CLEANUP, "metadata cleanup");
- worker_register_job_name(UV_EVENT_METADATA_ML_LOAD, "metadata load ml models");
-
- // netdatacli
- worker_register_job_name(UV_EVENT_SCHEDULE_CMD, "schedule command");
-
- static int workers = 0;
- int worker_id = __atomic_add_fetch(&workers, 1, __ATOMIC_RELAXED);
-
- char buf[NETDATA_THREAD_TAG_MAX + 1];
- snprintfz(buf, NETDATA_THREAD_TAG_MAX, "UV_WORKER[%d]", worker_id);
- uv_thread_set_name_np(pthread_self(), buf);
-}