1 /* SPDX-License-Identifier: GPL-2.0 */
2 #ifndef _FS_CEPH_MDS_METRIC_H
3 #define _FS_CEPH_MDS_METRIC_H
5 #include <linux/types.h>
6 #include <linux/percpu_counter.h>
7 #include <linux/ktime.h>
9 extern bool disable_send_metrics
;
11 enum ceph_metric_type
{
12 CLIENT_METRIC_TYPE_CAP_INFO
,
13 CLIENT_METRIC_TYPE_READ_LATENCY
,
14 CLIENT_METRIC_TYPE_WRITE_LATENCY
,
15 CLIENT_METRIC_TYPE_METADATA_LATENCY
,
16 CLIENT_METRIC_TYPE_DENTRY_LEASE
,
17 CLIENT_METRIC_TYPE_OPENED_FILES
,
18 CLIENT_METRIC_TYPE_PINNED_ICAPS
,
19 CLIENT_METRIC_TYPE_OPENED_INODES
,
20 CLIENT_METRIC_TYPE_READ_IO_SIZES
,
21 CLIENT_METRIC_TYPE_WRITE_IO_SIZES
,
23 CLIENT_METRIC_TYPE_MAX
= CLIENT_METRIC_TYPE_WRITE_IO_SIZES
,
27 * This will always have the highest metric bit value
28 * as the last element of the array.
30 #define CEPHFS_METRIC_SPEC_CLIENT_SUPPORTED { \
31 CLIENT_METRIC_TYPE_CAP_INFO, \
32 CLIENT_METRIC_TYPE_READ_LATENCY, \
33 CLIENT_METRIC_TYPE_WRITE_LATENCY, \
34 CLIENT_METRIC_TYPE_METADATA_LATENCY, \
35 CLIENT_METRIC_TYPE_DENTRY_LEASE, \
36 CLIENT_METRIC_TYPE_OPENED_FILES, \
37 CLIENT_METRIC_TYPE_PINNED_ICAPS, \
38 CLIENT_METRIC_TYPE_OPENED_INODES, \
39 CLIENT_METRIC_TYPE_READ_IO_SIZES, \
40 CLIENT_METRIC_TYPE_WRITE_IO_SIZES, \
42 CLIENT_METRIC_TYPE_MAX, \
45 struct ceph_metric_header
{
46 __le32 type
; /* ceph metric type */
49 __le32 data_len
; /* length of sizeof(hit + mis + total) */
52 /* metric caps header */
53 struct ceph_metric_cap
{
54 struct ceph_metric_header header
;
60 /* metric read latency header */
61 struct ceph_metric_read_latency
{
62 struct ceph_metric_header header
;
67 /* metric write latency header */
68 struct ceph_metric_write_latency
{
69 struct ceph_metric_header header
;
74 /* metric metadata latency header */
75 struct ceph_metric_metadata_latency
{
76 struct ceph_metric_header header
;
81 /* metric dentry lease header */
82 struct ceph_metric_dlease
{
83 struct ceph_metric_header header
;
89 /* metric opened files header */
90 struct ceph_opened_files
{
91 struct ceph_metric_header header
;
96 /* metric pinned i_caps header */
97 struct ceph_pinned_icaps
{
98 struct ceph_metric_header header
;
103 /* metric opened inodes header */
104 struct ceph_opened_inodes
{
105 struct ceph_metric_header header
;
106 __le64 opened_inodes
;
110 /* metric read io size header */
111 struct ceph_read_io_size
{
112 struct ceph_metric_header header
;
117 /* metric write io size header */
118 struct ceph_write_io_size
{
119 struct ceph_metric_header header
;
124 struct ceph_metric_head
{
125 __le32 num
; /* the number of metrics that will be sent */
128 /* This is the global metrics */
129 struct ceph_client_metric
{
130 atomic64_t total_dentries
;
131 struct percpu_counter d_lease_hit
;
132 struct percpu_counter d_lease_mis
;
134 atomic64_t total_caps
;
135 struct percpu_counter i_caps_hit
;
136 struct percpu_counter i_caps_mis
;
138 spinlock_t read_metric_lock
;
143 ktime_t read_latency_sum
;
144 ktime_t read_latency_sq_sum
;
145 ktime_t read_latency_min
;
146 ktime_t read_latency_max
;
148 spinlock_t write_metric_lock
;
153 ktime_t write_latency_sum
;
154 ktime_t write_latency_sq_sum
;
155 ktime_t write_latency_min
;
156 ktime_t write_latency_max
;
158 spinlock_t metadata_metric_lock
;
160 ktime_t metadata_latency_sum
;
161 ktime_t metadata_latency_sq_sum
;
162 ktime_t metadata_latency_min
;
163 ktime_t metadata_latency_max
;
165 /* The total number of directories and files that are opened */
166 atomic64_t opened_files
;
168 /* The total number of inodes that have opened files or directories */
169 struct percpu_counter opened_inodes
;
170 struct percpu_counter total_inodes
;
172 struct ceph_mds_session
*session
;
173 struct delayed_work delayed_work
; /* delayed work */
176 static inline void metric_schedule_delayed(struct ceph_client_metric
*m
)
178 if (disable_send_metrics
)
182 schedule_delayed_work(&m
->delayed_work
, round_jiffies_relative(HZ
));
185 extern int ceph_metric_init(struct ceph_client_metric
*m
);
186 extern void ceph_metric_destroy(struct ceph_client_metric
*m
);
188 static inline void ceph_update_cap_hit(struct ceph_client_metric
*m
)
190 percpu_counter_inc(&m
->i_caps_hit
);
193 static inline void ceph_update_cap_mis(struct ceph_client_metric
*m
)
195 percpu_counter_inc(&m
->i_caps_mis
);
198 extern void ceph_update_read_metrics(struct ceph_client_metric
*m
,
199 ktime_t r_start
, ktime_t r_end
,
200 unsigned int size
, int rc
);
201 extern void ceph_update_write_metrics(struct ceph_client_metric
*m
,
202 ktime_t r_start
, ktime_t r_end
,
203 unsigned int size
, int rc
);
204 extern void ceph_update_metadata_metrics(struct ceph_client_metric
*m
,
205 ktime_t r_start
, ktime_t r_end
,
207 #endif /* _FS_CEPH_MDS_METRIC_H */