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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "rrdengine.h"
void print_page_cache_descr(struct rrdeng_page_cache_descr *page_cache_descr)
{
char uuid_str[37];
char str[512];
int pos = 0;
uuid_unparse_lower(*page_cache_descr->id, uuid_str);
pos += snprintfz(str, 512 - pos, "page(%p) id=%s\n"
"--->len:%"PRIu32" time:%"PRIu64"->%"PRIu64" xt_offset:",
page_cache_descr->page, uuid_str,
page_cache_descr->page_length,
(uint64_t)page_cache_descr->start_time,
(uint64_t)page_cache_descr->end_time);
if (!page_cache_descr->extent) {
pos += snprintfz(str + pos, 512 - pos, "N/A");
} else {
pos += snprintfz(str + pos, 512 - pos, "%"PRIu64, page_cache_descr->extent->offset);
}
snprintfz(str + pos, 512 - pos, " flags:0x%2.2lX refcnt:%u\n\n", page_cache_descr->flags, page_cache_descr->refcnt);
fputs(str, stderr);
}
int check_file_properties(uv_file file, uint64_t *file_size, size_t min_size)
{
int ret;
uv_fs_t req;
uv_stat_t* s;
ret = uv_fs_fstat(NULL, &req, file, NULL);
if (ret < 0) {
fatal("uv_fs_fstat: %s\n", uv_strerror(ret));
}
assert(req.result == 0);
s = req.ptr;
if (!(s->st_mode & S_IFREG)) {
error("Not a regular file.\n");
uv_fs_req_cleanup(&req);
return UV_EINVAL;
}
if (s->st_size < min_size) {
error("File length is too short.\n");
uv_fs_req_cleanup(&req);
return UV_EINVAL;
}
*file_size = s->st_size;
uv_fs_req_cleanup(&req);
return 0;
}
char *get_rrdeng_statistics(struct rrdengine_instance *ctx, char *str, size_t size)
{
struct page_cache *pg_cache;
pg_cache = &ctx->pg_cache;
snprintfz(str, size,
"metric_API_producers: %ld\n"
"metric_API_consumers: %ld\n"
"page_cache_total_pages: %ld\n"
"page_cache_populated_pages: %ld\n"
"page_cache_commited_pages: %ld\n"
"page_cache_insertions: %ld\n"
"page_cache_deletions: %ld\n"
"page_cache_hits: %ld\n"
"page_cache_misses: %ld\n"
"page_cache_backfills: %ld\n"
"page_cache_evictions: %ld\n"
"compress_before_bytes: %ld\n"
"compress_after_bytes: %ld\n"
"decompress_before_bytes: %ld\n"
"decompress_after_bytes: %ld\n"
"io_write_bytes: %ld\n"
"io_write_requests: %ld\n"
"io_read_bytes: %ld\n"
"io_read_requests: %ld\n"
"io_write_extent_bytes: %ld\n"
"io_write_extents: %ld\n"
"io_read_extent_bytes: %ld\n"
"io_read_extents: %ld\n"
"datafile_creations: %ld\n"
"datafile_deletions: %ld\n"
"journalfile_creations: %ld\n"
"journalfile_deletions: %ld\n",
(long)ctx->stats.metric_API_producers,
(long)ctx->stats.metric_API_consumers,
(long)pg_cache->page_descriptors,
(long)pg_cache->populated_pages,
(long)pg_cache->commited_page_index.nr_commited_pages,
(long)ctx->stats.pg_cache_insertions,
(long)ctx->stats.pg_cache_deletions,
(long)ctx->stats.pg_cache_hits,
(long)ctx->stats.pg_cache_misses,
(long)ctx->stats.pg_cache_backfills,
(long)ctx->stats.pg_cache_evictions,
(long)ctx->stats.before_compress_bytes,
(long)ctx->stats.after_compress_bytes,
(long)ctx->stats.before_decompress_bytes,
(long)ctx->stats.after_decompress_bytes,
(long)ctx->stats.io_write_bytes,
(long)ctx->stats.io_write_requests,
(long)ctx->stats.io_read_bytes,
(long)ctx->stats.io_read_requests,
(long)ctx->stats.io_write_extent_bytes,
(long)ctx->stats.io_write_extents,
(long)ctx->stats.io_read_extent_bytes,
(long)ctx->stats.io_read_extents,
(long)ctx->stats.datafile_creations,
(long)ctx->stats.datafile_deletions,
(long)ctx->stats.journalfile_creations,
(long)ctx->stats.journalfile_deletions
);
return str;
}
|
