1 /* SPDX-License-Identifier: GPL-2.0 */
19 	struct ceph_client_metric *m = &mdsc->metric;  in ceph_mdsc_send_metrics()  local
20 	u64 nr_caps = atomic64_read(&m->total_caps);  in ceph_mdsc_send_metrics()
33 		       s->s_mds);  in ceph_mdsc_send_metrics()
37 	head = msg->front.iov_base;  in ceph_mdsc_send_metrics()
41 	cap->type = cpu_to_le32(CLIENT_METRIC_TYPE_CAP_INFO);  in ceph_mdsc_send_metrics()
42 	cap->ver = 1;  in ceph_mdsc_send_metrics()
43 	cap->compat = 1;  in ceph_mdsc_send_metrics()
44 	cap->data_len = cpu_to_le32(sizeof(*cap) - 10);  in ceph_mdsc_send_metrics()
45 	cap->hit = cpu_to_le64(percpu_counter_sum(&mdsc->metric.i_caps_hit));  in ceph_mdsc_send_metrics()
46 	cap->mis = cpu_to_le64(percpu_counter_sum(&mdsc->metric.i_caps_mis));  in ceph_mdsc_send_metrics()
47 	cap->total = cpu_to_le64(nr_caps);  in ceph_mdsc_send_metrics()
52 	read->type = cpu_to_le32(CLIENT_METRIC_TYPE_READ_LATENCY);  in ceph_mdsc_send_metrics()
53 	read->ver = 1;  in ceph_mdsc_send_metrics()
54 	read->compat = 1;  in ceph_mdsc_send_metrics()
55 	read->data_len = cpu_to_le32(sizeof(*read) - 10);  in ceph_mdsc_send_metrics()
56 	sum = m->read_latency_sum;  in ceph_mdsc_send_metrics()
58 	read->sec = cpu_to_le32(ts.tv_sec);  in ceph_mdsc_send_metrics()
59 	read->nsec = cpu_to_le32(ts.tv_nsec);  in ceph_mdsc_send_metrics()
64 	write->type = cpu_to_le32(CLIENT_METRIC_TYPE_WRITE_LATENCY);  in ceph_mdsc_send_metrics()
65 	write->ver = 1;  in ceph_mdsc_send_metrics()
66 	write->compat = 1;  in ceph_mdsc_send_metrics()
67 	write->data_len = cpu_to_le32(sizeof(*write) - 10);  in ceph_mdsc_send_metrics()
68 	sum = m->write_latency_sum;  in ceph_mdsc_send_metrics()
70 	write->sec = cpu_to_le32(ts.tv_sec);  in ceph_mdsc_send_metrics()
71 	write->nsec = cpu_to_le32(ts.tv_nsec);  in ceph_mdsc_send_metrics()
76 	meta->type = cpu_to_le32(CLIENT_METRIC_TYPE_METADATA_LATENCY);  in ceph_mdsc_send_metrics()
77 	meta->ver = 1;  in ceph_mdsc_send_metrics()
78 	meta->compat = 1;  in ceph_mdsc_send_metrics()
79 	meta->data_len = cpu_to_le32(sizeof(*meta) - 10);  in ceph_mdsc_send_metrics()
80 	sum = m->metadata_latency_sum;  in ceph_mdsc_send_metrics()
82 	meta->sec = cpu_to_le32(ts.tv_sec);  in ceph_mdsc_send_metrics()
83 	meta->nsec = cpu_to_le32(ts.tv_nsec);  in ceph_mdsc_send_metrics()
86 	put_unaligned_le32(items, &head->num);  in ceph_mdsc_send_metrics()
87 	msg->front.iov_len = len;  in ceph_mdsc_send_metrics()
88 	msg->hdr.version = cpu_to_le16(1);  in ceph_mdsc_send_metrics()
89 	msg->hdr.compat_version = cpu_to_le16(1);  in ceph_mdsc_send_metrics()
90 	msg->hdr.front_len = cpu_to_le32(msg->front.iov_len);  in ceph_mdsc_send_metrics()
92 	     ceph_client_gid(mdsc->fsc->client), s->s_mds);  in ceph_mdsc_send_metrics()
93 	ceph_con_send(&s->s_con, msg);  in ceph_mdsc_send_metrics()
104 	mutex_lock(&mdsc->mutex);  in metric_get_session()
105 	for (i = 0; i < mdsc->max_sessions; i++) {  in metric_get_session()
116 		    test_bit(CEPHFS_FEATURE_METRIC_COLLECT, &s->s_features)) {  in metric_get_session()
117 			mdsc->metric.session = s;  in metric_get_session()
123 	mutex_unlock(&mdsc->mutex);  in metric_get_session()
128 	struct ceph_client_metric *m =  in metric_delayed_work()  local
131 		container_of(m, struct ceph_mds_client, metric);  in metric_delayed_work()
133 	if (mdsc->stopping)  in metric_delayed_work()
136 	if (!m->session || !check_session_state(m->session)) {  in metric_delayed_work()
137 		if (m->session) {  in metric_delayed_work()
138 			ceph_put_mds_session(m->session);  in metric_delayed_work()
139 			m->session = NULL;  in metric_delayed_work()
143 	if (m->session) {  in metric_delayed_work()
144 		ceph_mdsc_send_metrics(mdsc, m->session);  in metric_delayed_work()
145 		metric_schedule_delayed(m);  in metric_delayed_work()
149 int ceph_metric_init(struct ceph_client_metric *m)  in ceph_metric_init()  argument
153 	if (!m)  in ceph_metric_init()
154 		return -EINVAL;  in ceph_metric_init()
156 	atomic64_set(&m->total_dentries, 0);  in ceph_metric_init()
157 	ret = percpu_counter_init(&m->d_lease_hit, 0, GFP_KERNEL);  in ceph_metric_init()
161 	ret = percpu_counter_init(&m->d_lease_mis, 0, GFP_KERNEL);  in ceph_metric_init()
165 	atomic64_set(&m->total_caps, 0);  in ceph_metric_init()
166 	ret = percpu_counter_init(&m->i_caps_hit, 0, GFP_KERNEL);  in ceph_metric_init()
170 	ret = percpu_counter_init(&m->i_caps_mis, 0, GFP_KERNEL);  in ceph_metric_init()
174 	spin_lock_init(&m->read_latency_lock);  in ceph_metric_init()
175 	m->read_latency_sq_sum = 0;  in ceph_metric_init()
176 	m->read_latency_min = KTIME_MAX;  in ceph_metric_init()
177 	m->read_latency_max = 0;  in ceph_metric_init()
178 	m->total_reads = 0;  in ceph_metric_init()
179 	m->read_latency_sum = 0;  in ceph_metric_init()
181 	spin_lock_init(&m->write_latency_lock);  in ceph_metric_init()
182 	m->write_latency_sq_sum = 0;  in ceph_metric_init()
183 	m->write_latency_min = KTIME_MAX;  in ceph_metric_init()
184 	m->write_latency_max = 0;  in ceph_metric_init()
185 	m->total_writes = 0;  in ceph_metric_init()
186 	m->write_latency_sum = 0;  in ceph_metric_init()
188 	spin_lock_init(&m->metadata_latency_lock);  in ceph_metric_init()
189 	m->metadata_latency_sq_sum = 0;  in ceph_metric_init()
190 	m->metadata_latency_min = KTIME_MAX;  in ceph_metric_init()
191 	m->metadata_latency_max = 0;  in ceph_metric_init()
192 	m->total_metadatas = 0;  in ceph_metric_init()
193 	m->metadata_latency_sum = 0;  in ceph_metric_init()
195 	atomic64_set(&m->opened_files, 0);  in ceph_metric_init()
196 	ret = percpu_counter_init(&m->opened_inodes, 0, GFP_KERNEL);  in ceph_metric_init()
199 	ret = percpu_counter_init(&m->total_inodes, 0, GFP_KERNEL);  in ceph_metric_init()
203 	m->session = NULL;  in ceph_metric_init()
204 	INIT_DELAYED_WORK(&m->delayed_work, metric_delayed_work);  in ceph_metric_init()
209 	percpu_counter_destroy(&m->opened_inodes);  in ceph_metric_init()
211 	percpu_counter_destroy(&m->i_caps_mis);  in ceph_metric_init()
213 	percpu_counter_destroy(&m->i_caps_hit);  in ceph_metric_init()
215 	percpu_counter_destroy(&m->d_lease_mis);  in ceph_metric_init()
217 	percpu_counter_destroy(&m->d_lease_hit);  in ceph_metric_init()
222 void ceph_metric_destroy(struct ceph_client_metric *m)  in ceph_metric_destroy()  argument
224 	if (!m)  in ceph_metric_destroy()
227 	percpu_counter_destroy(&m->total_inodes);  in ceph_metric_destroy()
228 	percpu_counter_destroy(&m->opened_inodes);  in ceph_metric_destroy()
229 	percpu_counter_destroy(&m->i_caps_mis);  in ceph_metric_destroy()
230 	percpu_counter_destroy(&m->i_caps_hit);  in ceph_metric_destroy()
231 	percpu_counter_destroy(&m->d_lease_mis);  in ceph_metric_destroy()
232 	percpu_counter_destroy(&m->d_lease_hit);  in ceph_metric_destroy()
234 	cancel_delayed_work_sync(&m->delayed_work);  in ceph_metric_destroy()
236 	if (m->session)  in ceph_metric_destroy()
237 		ceph_put_mds_session(m->session);  in ceph_metric_destroy()
257 	/* the sq is (lat - old_avg) * (lat - new_avg) */  in __update_latency()
258 	avg = DIV64_U64_ROUND_CLOSEST((lsum - lat), (total - 1));  in __update_latency()
259 	sq = lat - avg;  in __update_latency()
261 	sq = sq * (lat - avg);  in __update_latency()
265 void ceph_update_read_latency(struct ceph_client_metric *m,  in ceph_update_read_latency()  argument
271 	if (unlikely(rc < 0 && rc != -ENOENT && rc != -ETIMEDOUT))  in ceph_update_read_latency()
274 	spin_lock(&m->read_latency_lock);  in ceph_update_read_latency()
275 	__update_latency(&m->total_reads, &m->read_latency_sum,  in ceph_update_read_latency()
276 			 &m->read_latency_min, &m->read_latency_max,  in ceph_update_read_latency()
277 			 &m->read_latency_sq_sum, lat);  in ceph_update_read_latency()
278 	spin_unlock(&m->read_latency_lock);  in ceph_update_read_latency()
281 void ceph_update_write_latency(struct ceph_client_metric *m,  in ceph_update_write_latency()  argument
287 	if (unlikely(rc && rc != -ETIMEDOUT))  in ceph_update_write_latency()
290 	spin_lock(&m->write_latency_lock);  in ceph_update_write_latency()
291 	__update_latency(&m->total_writes, &m->write_latency_sum,  in ceph_update_write_latency()
292 			 &m->write_latency_min, &m->write_latency_max,  in ceph_update_write_latency()
293 			 &m->write_latency_sq_sum, lat);  in ceph_update_write_latency()
294 	spin_unlock(&m->write_latency_lock);  in ceph_update_write_latency()
297 void ceph_update_metadata_latency(struct ceph_client_metric *m,  in ceph_update_metadata_latency()  argument
303 	if (unlikely(rc && rc != -ENOENT))  in ceph_update_metadata_latency()
306 	spin_lock(&m->metadata_latency_lock);  in ceph_update_metadata_latency()
307 	__update_latency(&m->total_metadatas, &m->metadata_latency_sum,  in ceph_update_metadata_latency()
308 			 &m->metadata_latency_min, &m->metadata_latency_max,  in ceph_update_metadata_latency()
309 			 &m->metadata_latency_sq_sum, lat);  in ceph_update_metadata_latency()
310 	spin_unlock(&m->metadata_latency_lock);  in ceph_update_metadata_latency()