1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
// 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");
worker_register_job_name(UV_EVENT_READ_PAGE_CB, "read page cb");
worker_register_job_name(UV_EVENT_READ_EXTENT_CB, "read extent cb");
worker_register_job_name(UV_EVENT_COMMIT_PAGE_CB, "commit cb");
worker_register_job_name(UV_EVENT_FLUSH_PAGES_CB, "flush cb");
worker_register_job_name(UV_EVENT_PAGE_LOOKUP, "page lookup");
worker_register_job_name(UV_EVENT_PAGE_POPULATION, "populate page");
worker_register_job_name(UV_EVENT_EXT_DECOMPRESSION, "extent decompression");
worker_register_job_name(UV_EVENT_READ_MMAP_EXTENT, "read extent (mmap)");
worker_register_job_name(UV_EVENT_EXTENT_PROCESSING, "extent processing");
worker_register_job_name(UV_EVENT_METADATA_STORE, "store host metadata");
worker_register_job_name(UV_EVENT_JOURNAL_INDEX_WAIT, "journal v2 wait");
worker_register_job_name(UV_EVENT_JOURNAL_INDEX, "journal v2 indexing");
worker_register_job_name(UV_EVENT_SCHEDULE_CMD, "schedule command");
worker_register_job_name(UV_EVENT_METADATA_CLEANUP, "metadata cleanup");
worker_register_job_name(UV_EVENT_EXTENT_CACHE, "extent cache");
worker_register_job_name(UV_EVENT_EXTENT_MMAP, "extent mmap");
worker_register_job_name(UV_EVENT_PAGE_DISPATCH, "dispatch page list");
worker_register_job_name(UV_EVENT_FLUSH_CALLBACK, "flush callback");
worker_register_job_name(UV_EVENT_FLUSH_MAIN, "flush main");
worker_register_job_name(UV_EVENT_FLUSH_OPEN, "flush open");
worker_register_job_name(UV_EVENT_EVICT_MAIN, "evict main");
worker_register_job_name(UV_EVENT_DELETING_FILE, "delete datafiles");
worker_register_job_name(UV_EVENT_ANALYZE_V2, "analyze journalfile");
worker_register_job_name(UV_EVENT_RETENTION_V2, "calculate retention");
worker_register_job_name(UV_EVENT_RETENTION_UPDATE, "update retention");
worker_register_job_name(UV_EVENT_DATAFILE_ACQUIRE, "datafile acquire");
worker_register_job_name(UV_EVENT_DATAFILE_DELETE, "datafile deletion");
worker_register_job_name(UV_EVENT_FLUSHED_TO_OPEN, "flushed to open");
worker_register_job_name(UV_EVENT_PREP_QUERY, "prep query");
worker_register_job_name(UV_EVENT_WORKER_INIT, "worker init");
uv_thread_set_name_np(pthread_self(), "LIBUV_WORKER");
}
|
