ulp/rtrs/rtrs-clt-stats.c

17 	struct rtrs_clt_stats *stats = clt_path->stats;
22 	s = get_cpu_ptr(stats->pcpu_stats);
27 		s = per_cpu_ptr(stats->pcpu_stats, con->cpu);
30 	put_cpu_ptr(stats->pcpu_stats);
33 void rtrs_clt_inc_failover_cnt(struct rtrs_clt_stats *stats)
35 	this_cpu_inc(stats->pcpu_stats->rdma.failover_cnt);
38 int rtrs_clt_stats_migration_from_cnt_to_str(struct rtrs_clt_stats *stats, char *buf)
47 		s = per_cpu_ptr(stats->pcpu_stats, cpu);
57 int rtrs_clt_stats_migration_to_cnt_to_str(struct rtrs_clt_stats *stats, char *buf)
66 		s = per_cpu_ptr(stats->pcpu_stats, cpu);
75 int rtrs_clt_stats_reconnects_to_str(struct rtrs_clt_stats *stats, char *buf)
77 	return sysfs_emit(buf, "%d %d\n", stats->reconnects.successful_cnt,
78 			  stats->reconnects.fail_cnt);
81 ssize_t rtrs_clt_stats_rdma_to_str(struct rtrs_clt_stats *stats, char *page)
90 		r = &per_cpu_ptr(stats->pcpu_stats, cpu)->rdma;
102 			 atomic_read(&stats->inflight), sum.failover_cnt);
110 int rtrs_clt_reset_rdma_stats(struct rtrs_clt_stats *stats, bool enable)
119 		s = per_cpu_ptr(stats->pcpu_stats, cpu);
126 int rtrs_clt_reset_cpu_migr_stats(struct rtrs_clt_stats *stats, bool enable)
135 		s = per_cpu_ptr(stats->pcpu_stats, cpu);
142 int rtrs_clt_reset_reconnects_stat(struct rtrs_clt_stats *stats, bool enable)
147 	memset(&stats->reconnects, 0, sizeof(stats->reconnects));
165 static inline void rtrs_clt_update_rdma_stats(struct rtrs_clt_stats *stats,
168 	this_cpu_inc(stats->pcpu_stats->rdma.dir[d].cnt);
169 	this_cpu_add(stats->pcpu_stats->rdma.dir[d].size_total, size);
176 	struct rtrs_clt_stats *stats = clt_path->stats;
180 	rtrs_clt_update_rdma_stats(stats, len, dir);
182 		atomic_inc(&stats->inflight);
185 int rtrs_clt_init_stats(struct rtrs_clt_stats *stats)
187 	stats->pcpu_stats = alloc_percpu(typeof(*stats->pcpu_stats));
188 	if (!stats->pcpu_stats)
195 	stats->reconnects.successful_cnt = -1;