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
  9extern bool disable_send_metrics;
 10
 11enum 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 */
 35struct 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 */
 48struct 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 */
 60struct 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 */
 72struct 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
 83struct ceph_metric_head {
 84	__le32 num;	/* the number of metrics that will be sent */
 85} __packed;
 86
 87/* This is the global metrics */
 88struct 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
122static 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
131extern int ceph_metric_init(struct ceph_client_metric *m);
132extern void ceph_metric_destroy(struct ceph_client_metric *m);
133
134static inline void ceph_update_cap_hit(struct ceph_client_metric *m)
135{
136	percpu_counter_inc(&m->i_caps_hit);
137}
138
139static inline void ceph_update_cap_mis(struct ceph_client_metric *m)
140{
141	percpu_counter_inc(&m->i_caps_mis);
142}
143
144extern void ceph_update_read_latency(struct ceph_client_metric *m,
145				     ktime_t r_start, ktime_t r_end,
146				     int rc);
147extern void ceph_update_write_latency(struct ceph_client_metric *m,
148				      ktime_t r_start, ktime_t r_end,
149				      int rc);
150extern 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 */