1 // SPDX-License-Identifier: GPL-2.0-or-later
5  * Copyright (c) 2014 - 2018 ProfitBricks GmbH. All rights reserved.
6  * Copyright (c) 2018 - 2019 1&1 IONOS Cloud GmbH. All rights reserved.
7  * Copyright (c) 2019 - 2020 1&1 IONOS SE. All rights reserved.
12 #include "rtrs-clt.h"
16 	struct rtrs_clt_path *clt_path = to_clt_path(con->c.path);  in rtrs_clt_update_wc_stats()
17 	struct rtrs_clt_stats *stats = clt_path->stats;  in rtrs_clt_update_wc_stats()
22 	s = get_cpu_ptr(stats->pcpu_stats);  in rtrs_clt_update_wc_stats()
23 	if (con->cpu != cpu) {  in rtrs_clt_update_wc_stats()
24 		s->cpu_migr.to++;  in rtrs_clt_update_wc_stats()
27 		s = per_cpu_ptr(stats->pcpu_stats, con->cpu);  in rtrs_clt_update_wc_stats()
28 		atomic_inc(&s->cpu_migr.from);  in rtrs_clt_update_wc_stats()
30 	put_cpu_ptr(stats->pcpu_stats);  in rtrs_clt_update_wc_stats()
35 	this_cpu_inc(stats->pcpu_stats->rdma.failover_cnt);  in rtrs_clt_inc_failover_cnt()
47 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_stats_migration_from_cnt_to_str()
49 				  atomic_read(&s->cpu_migr.from));  in rtrs_clt_stats_migration_from_cnt_to_str()
66 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_stats_migration_to_cnt_to_str()
67 		used += sysfs_emit_at(buf, used, "%d ", s->cpu_migr.to);  in rtrs_clt_stats_migration_to_cnt_to_str()
77 	return sysfs_emit(buf, "%d %d\n", stats->reconnects.successful_cnt,  in rtrs_clt_stats_reconnects_to_str()
78 			  stats->reconnects.fail_cnt);  in rtrs_clt_stats_reconnects_to_str()
90 		r = &per_cpu_ptr(stats->pcpu_stats, cpu)->rdma;  in rtrs_clt_stats_rdma_to_str()
92 		sum.dir[READ].cnt	  += r->dir[READ].cnt;  in rtrs_clt_stats_rdma_to_str()
93 		sum.dir[READ].size_total  += r->dir[READ].size_total;  in rtrs_clt_stats_rdma_to_str()
94 		sum.dir[WRITE].cnt	  += r->dir[WRITE].cnt;  in rtrs_clt_stats_rdma_to_str()
95 		sum.dir[WRITE].size_total += r->dir[WRITE].size_total;  in rtrs_clt_stats_rdma_to_str()
96 		sum.failover_cnt	  += r->failover_cnt;  in rtrs_clt_stats_rdma_to_str()
101 			 sum.dir[WRITE].cnt, sum.dir[WRITE].size_total,  in rtrs_clt_stats_rdma_to_str()
102 			 atomic_read(&stats->inflight), sum.failover_cnt);  in rtrs_clt_stats_rdma_to_str()
110 int rtrs_clt_reset_rdma_stats(struct rtrs_clt_stats *stats, bool enable)  in rtrs_clt_reset_rdma_stats()  argument
115 	if (!enable)  in rtrs_clt_reset_rdma_stats()
116 		return -EINVAL;  in rtrs_clt_reset_rdma_stats()
119 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_reset_rdma_stats()
120 		memset(&s->rdma, 0, sizeof(s->rdma));  in rtrs_clt_reset_rdma_stats()
126 int rtrs_clt_reset_cpu_migr_stats(struct rtrs_clt_stats *stats, bool enable)  in rtrs_clt_reset_cpu_migr_stats()  argument
131 	if (!enable)  in rtrs_clt_reset_cpu_migr_stats()
132 		return -EINVAL;  in rtrs_clt_reset_cpu_migr_stats()
135 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_reset_cpu_migr_stats()
136 		memset(&s->cpu_migr, 0, sizeof(s->cpu_migr));  in rtrs_clt_reset_cpu_migr_stats()
142 int rtrs_clt_reset_reconnects_stat(struct rtrs_clt_stats *stats, bool enable)  in rtrs_clt_reset_reconnects_stat()  argument
144 	if (!enable)  in rtrs_clt_reset_reconnects_stat()
145 		return -EINVAL;  in rtrs_clt_reset_reconnects_stat()
147 	memset(&stats->reconnects, 0, sizeof(stats->reconnects));  in rtrs_clt_reset_reconnects_stat()
152 int rtrs_clt_reset_all_stats(struct rtrs_clt_stats *s, bool enable)  in rtrs_clt_reset_all_stats()  argument
154 	if (enable) {  in rtrs_clt_reset_all_stats()
155 		rtrs_clt_reset_rdma_stats(s, enable);  in rtrs_clt_reset_all_stats()
156 		rtrs_clt_reset_cpu_migr_stats(s, enable);  in rtrs_clt_reset_all_stats()
157 		rtrs_clt_reset_reconnects_stat(s, enable);  in rtrs_clt_reset_all_stats()
158 		atomic_set(&s->inflight, 0);  in rtrs_clt_reset_all_stats()
162 	return -EINVAL;  in rtrs_clt_reset_all_stats()
168 	this_cpu_inc(stats->pcpu_stats->rdma.dir[d].cnt);  in rtrs_clt_update_rdma_stats()
169 	this_cpu_add(stats->pcpu_stats->rdma.dir[d].size_total, size);  in rtrs_clt_update_rdma_stats()
174 	struct rtrs_clt_con *con = req->con;  in rtrs_clt_update_all_stats()
175 	struct rtrs_clt_path *clt_path = to_clt_path(con->c.path);  in rtrs_clt_update_all_stats()
176 	struct rtrs_clt_stats *stats = clt_path->stats;  in rtrs_clt_update_all_stats()
179 	len = req->usr_len + req->data_len;  in rtrs_clt_update_all_stats()
181 	if (req->mp_policy == MP_POLICY_MIN_INFLIGHT)  in rtrs_clt_update_all_stats()
182 		atomic_inc(&stats->inflight);  in rtrs_clt_update_all_stats()
187 	stats->pcpu_stats = alloc_percpu(typeof(*stats->pcpu_stats));  in rtrs_clt_init_stats()
188 	if (!stats->pcpu_stats)  in rtrs_clt_init_stats()
189 		return -ENOMEM;  in rtrs_clt_init_stats()
195 	stats->reconnects.successful_cnt = -1;  in rtrs_clt_init_stats()