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