1*4882a593Smuzhiyun /* SPDX-License-Identifier: GPL-2.0 */
2*4882a593Smuzhiyun #ifndef _FS_CEPH_MDS_METRIC_H
3*4882a593Smuzhiyun #define _FS_CEPH_MDS_METRIC_H
4*4882a593Smuzhiyun
5*4882a593Smuzhiyun #include <linux/types.h>
6*4882a593Smuzhiyun #include <linux/percpu_counter.h>
7*4882a593Smuzhiyun #include <linux/ktime.h>
8*4882a593Smuzhiyun
9*4882a593Smuzhiyun extern bool disable_send_metrics;
10*4882a593Smuzhiyun
11*4882a593Smuzhiyun enum ceph_metric_type {
12*4882a593Smuzhiyun CLIENT_METRIC_TYPE_CAP_INFO,
13*4882a593Smuzhiyun CLIENT_METRIC_TYPE_READ_LATENCY,
14*4882a593Smuzhiyun CLIENT_METRIC_TYPE_WRITE_LATENCY,
15*4882a593Smuzhiyun CLIENT_METRIC_TYPE_METADATA_LATENCY,
16*4882a593Smuzhiyun CLIENT_METRIC_TYPE_DENTRY_LEASE,
17*4882a593Smuzhiyun
18*4882a593Smuzhiyun CLIENT_METRIC_TYPE_MAX = CLIENT_METRIC_TYPE_DENTRY_LEASE,
19*4882a593Smuzhiyun };
20*4882a593Smuzhiyun
21*4882a593Smuzhiyun /*
22*4882a593Smuzhiyun * This will always have the highest metric bit value
23*4882a593Smuzhiyun * as the last element of the array.
24*4882a593Smuzhiyun */
25*4882a593Smuzhiyun #define CEPHFS_METRIC_SPEC_CLIENT_SUPPORTED { \
26*4882a593Smuzhiyun CLIENT_METRIC_TYPE_CAP_INFO, \
27*4882a593Smuzhiyun CLIENT_METRIC_TYPE_READ_LATENCY, \
28*4882a593Smuzhiyun CLIENT_METRIC_TYPE_WRITE_LATENCY, \
29*4882a593Smuzhiyun CLIENT_METRIC_TYPE_METADATA_LATENCY, \
30*4882a593Smuzhiyun \
31*4882a593Smuzhiyun CLIENT_METRIC_TYPE_MAX, \
32*4882a593Smuzhiyun }
33*4882a593Smuzhiyun
34*4882a593Smuzhiyun /* metric caps header */
35*4882a593Smuzhiyun struct ceph_metric_cap {
36*4882a593Smuzhiyun __le32 type; /* ceph metric type */
37*4882a593Smuzhiyun
38*4882a593Smuzhiyun __u8 ver;
39*4882a593Smuzhiyun __u8 compat;
40*4882a593Smuzhiyun
41*4882a593Smuzhiyun __le32 data_len; /* length of sizeof(hit + mis + total) */
42*4882a593Smuzhiyun __le64 hit;
43*4882a593Smuzhiyun __le64 mis;
44*4882a593Smuzhiyun __le64 total;
45*4882a593Smuzhiyun } __packed;
46*4882a593Smuzhiyun
47*4882a593Smuzhiyun /* metric read latency header */
48*4882a593Smuzhiyun struct ceph_metric_read_latency {
49*4882a593Smuzhiyun __le32 type; /* ceph metric type */
50*4882a593Smuzhiyun
51*4882a593Smuzhiyun __u8 ver;
52*4882a593Smuzhiyun __u8 compat;
53*4882a593Smuzhiyun
54*4882a593Smuzhiyun __le32 data_len; /* length of sizeof(sec + nsec) */
55*4882a593Smuzhiyun __le32 sec;
56*4882a593Smuzhiyun __le32 nsec;
57*4882a593Smuzhiyun } __packed;
58*4882a593Smuzhiyun
59*4882a593Smuzhiyun /* metric write latency header */
60*4882a593Smuzhiyun struct ceph_metric_write_latency {
61*4882a593Smuzhiyun __le32 type; /* ceph metric type */
62*4882a593Smuzhiyun
63*4882a593Smuzhiyun __u8 ver;
64*4882a593Smuzhiyun __u8 compat;
65*4882a593Smuzhiyun
66*4882a593Smuzhiyun __le32 data_len; /* length of sizeof(sec + nsec) */
67*4882a593Smuzhiyun __le32 sec;
68*4882a593Smuzhiyun __le32 nsec;
69*4882a593Smuzhiyun } __packed;
70*4882a593Smuzhiyun
71*4882a593Smuzhiyun /* metric metadata latency header */
72*4882a593Smuzhiyun struct ceph_metric_metadata_latency {
73*4882a593Smuzhiyun __le32 type; /* ceph metric type */
74*4882a593Smuzhiyun
75*4882a593Smuzhiyun __u8 ver;
76*4882a593Smuzhiyun __u8 compat;
77*4882a593Smuzhiyun
78*4882a593Smuzhiyun __le32 data_len; /* length of sizeof(sec + nsec) */
79*4882a593Smuzhiyun __le32 sec;
80*4882a593Smuzhiyun __le32 nsec;
81*4882a593Smuzhiyun } __packed;
82*4882a593Smuzhiyun
83*4882a593Smuzhiyun struct ceph_metric_head {
84*4882a593Smuzhiyun __le32 num; /* the number of metrics that will be sent */
85*4882a593Smuzhiyun } __packed;
86*4882a593Smuzhiyun
87*4882a593Smuzhiyun /* This is the global metrics */
88*4882a593Smuzhiyun struct ceph_client_metric {
89*4882a593Smuzhiyun atomic64_t total_dentries;
90*4882a593Smuzhiyun struct percpu_counter d_lease_hit;
91*4882a593Smuzhiyun struct percpu_counter d_lease_mis;
92*4882a593Smuzhiyun
93*4882a593Smuzhiyun atomic64_t total_caps;
94*4882a593Smuzhiyun struct percpu_counter i_caps_hit;
95*4882a593Smuzhiyun struct percpu_counter i_caps_mis;
96*4882a593Smuzhiyun
97*4882a593Smuzhiyun spinlock_t read_latency_lock;
98*4882a593Smuzhiyun u64 total_reads;
99*4882a593Smuzhiyun ktime_t read_latency_sum;
100*4882a593Smuzhiyun ktime_t read_latency_sq_sum;
101*4882a593Smuzhiyun ktime_t read_latency_min;
102*4882a593Smuzhiyun ktime_t read_latency_max;
103*4882a593Smuzhiyun
104*4882a593Smuzhiyun spinlock_t write_latency_lock;
105*4882a593Smuzhiyun u64 total_writes;
106*4882a593Smuzhiyun ktime_t write_latency_sum;
107*4882a593Smuzhiyun ktime_t write_latency_sq_sum;
108*4882a593Smuzhiyun ktime_t write_latency_min;
109*4882a593Smuzhiyun ktime_t write_latency_max;
110*4882a593Smuzhiyun
111*4882a593Smuzhiyun spinlock_t metadata_latency_lock;
112*4882a593Smuzhiyun u64 total_metadatas;
113*4882a593Smuzhiyun ktime_t metadata_latency_sum;
114*4882a593Smuzhiyun ktime_t metadata_latency_sq_sum;
115*4882a593Smuzhiyun ktime_t metadata_latency_min;
116*4882a593Smuzhiyun ktime_t metadata_latency_max;
117*4882a593Smuzhiyun
118*4882a593Smuzhiyun /* The total number of directories and files that are opened */
119*4882a593Smuzhiyun atomic64_t opened_files;
120*4882a593Smuzhiyun
121*4882a593Smuzhiyun /* The total number of inodes that have opened files or directories */
122*4882a593Smuzhiyun struct percpu_counter opened_inodes;
123*4882a593Smuzhiyun struct percpu_counter total_inodes;
124*4882a593Smuzhiyun
125*4882a593Smuzhiyun struct ceph_mds_session *session;
126*4882a593Smuzhiyun struct delayed_work delayed_work; /* delayed work */
127*4882a593Smuzhiyun };
128*4882a593Smuzhiyun
metric_schedule_delayed(struct ceph_client_metric * m)129*4882a593Smuzhiyun static inline void metric_schedule_delayed(struct ceph_client_metric *m)
130*4882a593Smuzhiyun {
131*4882a593Smuzhiyun if (disable_send_metrics)
132*4882a593Smuzhiyun return;
133*4882a593Smuzhiyun
134*4882a593Smuzhiyun /* per second */
135*4882a593Smuzhiyun schedule_delayed_work(&m->delayed_work, round_jiffies_relative(HZ));
136*4882a593Smuzhiyun }
137*4882a593Smuzhiyun
138*4882a593Smuzhiyun extern int ceph_metric_init(struct ceph_client_metric *m);
139*4882a593Smuzhiyun extern void ceph_metric_destroy(struct ceph_client_metric *m);
140*4882a593Smuzhiyun
ceph_update_cap_hit(struct ceph_client_metric * m)141*4882a593Smuzhiyun static inline void ceph_update_cap_hit(struct ceph_client_metric *m)
142*4882a593Smuzhiyun {
143*4882a593Smuzhiyun percpu_counter_inc(&m->i_caps_hit);
144*4882a593Smuzhiyun }
145*4882a593Smuzhiyun
ceph_update_cap_mis(struct ceph_client_metric * m)146*4882a593Smuzhiyun static inline void ceph_update_cap_mis(struct ceph_client_metric *m)
147*4882a593Smuzhiyun {
148*4882a593Smuzhiyun percpu_counter_inc(&m->i_caps_mis);
149*4882a593Smuzhiyun }
150*4882a593Smuzhiyun
151*4882a593Smuzhiyun extern void ceph_update_read_latency(struct ceph_client_metric *m,
152*4882a593Smuzhiyun ktime_t r_start, ktime_t r_end,
153*4882a593Smuzhiyun int rc);
154*4882a593Smuzhiyun extern void ceph_update_write_latency(struct ceph_client_metric *m,
155*4882a593Smuzhiyun ktime_t r_start, ktime_t r_end,
156*4882a593Smuzhiyun int rc);
157*4882a593Smuzhiyun extern void ceph_update_metadata_latency(struct ceph_client_metric *m,
158*4882a593Smuzhiyun ktime_t r_start, ktime_t r_end,
159*4882a593Smuzhiyun int rc);
160*4882a593Smuzhiyun #endif /* _FS_CEPH_MDS_METRIC_H */
161