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_sess *sess = to_clt_sess(con->c.sess);  in rtrs_clt_update_wc_stats()
17 	struct rtrs_clt_stats *stats = sess->stats;  in rtrs_clt_update_wc_stats()
19 	int cpu;  in rtrs_clt_update_wc_stats()  local
21 	cpu = raw_smp_processor_id();  in rtrs_clt_update_wc_stats()
22 	s = this_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()
36 	s = this_cpu_ptr(stats->pcpu_stats);  in rtrs_clt_inc_failover_cnt()
37 	s->rdma.failover_cnt++;  in rtrs_clt_inc_failover_cnt()
46 	int cpu;  in rtrs_clt_stats_migration_cnt_to_str()  local
49 	for_each_possible_cpu(cpu)  in rtrs_clt_stats_migration_cnt_to_str()
50 		used += scnprintf(buf + used, len - used, " CPU%u", cpu);  in rtrs_clt_stats_migration_cnt_to_str()
52 	used += scnprintf(buf + used, len - used, "\nfrom:");  in rtrs_clt_stats_migration_cnt_to_str()
53 	for_each_possible_cpu(cpu) {  in rtrs_clt_stats_migration_cnt_to_str()
54 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_stats_migration_cnt_to_str()
55 		used += scnprintf(buf + used, len - used, " %d",  in rtrs_clt_stats_migration_cnt_to_str()
56 				  atomic_read(&s->cpu_migr.from));  in rtrs_clt_stats_migration_cnt_to_str()
59 	used += scnprintf(buf + used, len - used, "\nto  :");  in rtrs_clt_stats_migration_cnt_to_str()
60 	for_each_possible_cpu(cpu) {  in rtrs_clt_stats_migration_cnt_to_str()
61 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_stats_migration_cnt_to_str()
62 		used += scnprintf(buf + used, len - used, " %d",  in rtrs_clt_stats_migration_cnt_to_str()
63 				  s->cpu_migr.to);  in rtrs_clt_stats_migration_cnt_to_str()
65 	used += scnprintf(buf + used, len - used, "\n");  in rtrs_clt_stats_migration_cnt_to_str()
74 			 stats->reconnects.successful_cnt,  in rtrs_clt_stats_reconnects_to_str()
75 			 stats->reconnects.fail_cnt);  in rtrs_clt_stats_reconnects_to_str()
83 	int cpu;  in rtrs_clt_stats_rdma_to_str()  local
87 	for_each_possible_cpu(cpu) {  in rtrs_clt_stats_rdma_to_str()
88 		r = &per_cpu_ptr(stats->pcpu_stats, cpu)->rdma;  in rtrs_clt_stats_rdma_to_str()
90 		sum.dir[READ].cnt	  += r->dir[READ].cnt;  in rtrs_clt_stats_rdma_to_str()
91 		sum.dir[READ].size_total  += r->dir[READ].size_total;  in rtrs_clt_stats_rdma_to_str()
92 		sum.dir[WRITE].cnt	  += r->dir[WRITE].cnt;  in rtrs_clt_stats_rdma_to_str()
93 		sum.dir[WRITE].size_total += r->dir[WRITE].size_total;  in rtrs_clt_stats_rdma_to_str()
94 		sum.failover_cnt	  += r->failover_cnt;  in rtrs_clt_stats_rdma_to_str()
98 			 sum.dir[READ].cnt, sum.dir[READ].size_total,  in rtrs_clt_stats_rdma_to_str()
100 			 atomic_read(&stats->inflight), sum.failover_cnt);  in rtrs_clt_stats_rdma_to_str()
112 	int cpu;  in rtrs_clt_reset_rdma_stats()  local
115 		return -EINVAL;  in rtrs_clt_reset_rdma_stats()
117 	for_each_possible_cpu(cpu) {  in rtrs_clt_reset_rdma_stats()
118 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_reset_rdma_stats()
119 		memset(&s->rdma, 0, sizeof(s->rdma));  in rtrs_clt_reset_rdma_stats()
128 	int cpu;  in rtrs_clt_reset_cpu_migr_stats()  local
131 		return -EINVAL;  in rtrs_clt_reset_cpu_migr_stats()
133 	for_each_possible_cpu(cpu) {  in rtrs_clt_reset_cpu_migr_stats()
134 		s = per_cpu_ptr(stats->pcpu_stats, cpu);  in rtrs_clt_reset_cpu_migr_stats()
135 		memset(&s->cpu_migr, 0, sizeof(s->cpu_migr));  in rtrs_clt_reset_cpu_migr_stats()
144 		return -EINVAL;  in rtrs_clt_reset_reconnects_stat()
146 	memset(&stats->reconnects, 0, sizeof(stats->reconnects));  in rtrs_clt_reset_reconnects_stat()
157 		atomic_set(&s->inflight, 0);  in rtrs_clt_reset_all_stats()
161 	return -EINVAL;  in rtrs_clt_reset_all_stats()
169 	s = this_cpu_ptr(stats->pcpu_stats);  in rtrs_clt_update_rdma_stats()
170 	s->rdma.dir[d].cnt++;  in rtrs_clt_update_rdma_stats()
171 	s->rdma.dir[d].size_total += size;  in rtrs_clt_update_rdma_stats()
176 	struct rtrs_clt_con *con = req->con;  in rtrs_clt_update_all_stats()
177 	struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess);  in rtrs_clt_update_all_stats()
178 	struct rtrs_clt_stats *stats = sess->stats;  in rtrs_clt_update_all_stats()
181 	len = req->usr_len + req->data_len;  in rtrs_clt_update_all_stats()
183 	if (req->mp_policy == MP_POLICY_MIN_INFLIGHT)  in rtrs_clt_update_all_stats()
184 		atomic_inc(&stats->inflight);  in rtrs_clt_update_all_stats()
189 	stats->pcpu_stats = alloc_percpu(typeof(*stats->pcpu_stats));  in rtrs_clt_init_stats()
190 	if (!stats->pcpu_stats)  in rtrs_clt_init_stats()
191 		return -ENOMEM;  in rtrs_clt_init_stats()
197 	stats->reconnects.successful_cnt = -1;  in rtrs_clt_init_stats()