Orange Pi5 kernel

^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   3)  * RDMA Transport Layer
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   4)  *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   5)  * Copyright (c) 2014 - 2018 ProfitBricks GmbH. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   6)  * Copyright (c) 2018 - 2019 1&1 IONOS Cloud GmbH. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   7)  * Copyright (c) 2019 - 2020 1&1 IONOS SE. All rights reserved.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   8)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300   9) #undef pr_fmt
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  10) #define pr_fmt(fmt) KBUILD_MODNAME " L" __stringify(__LINE__) ": " fmt
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  11) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  12) #include "rtrs-pri.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  13) #include "rtrs-srv.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  14) #include "rtrs-log.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  15) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  16) static void rtrs_srv_release(struct kobject *kobj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  17) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  18) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  19) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  20) 	sess = container_of(kobj, struct rtrs_srv_sess, kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  21) 	kfree(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  22) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  23) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  24) static struct kobj_type ktype = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  25) 	.sysfs_ops	= &kobj_sysfs_ops,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  26) 	.release	= rtrs_srv_release,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  27) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  28) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  29) static ssize_t rtrs_srv_disconnect_show(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  30) 					 struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  31) 					 char *page)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  32) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  33) 	return scnprintf(page, PAGE_SIZE, "Usage: echo 1 > %s\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  34) 			 attr->attr.name);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  35) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  36) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  37) static ssize_t rtrs_srv_disconnect_store(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  38) 					  struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  39) 					  const char *buf, size_t count)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  40) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  41) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  42) 	struct rtrs_sess *s;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  43) 	char str[MAXHOSTNAMELEN];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  44) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  45) 	sess = container_of(kobj, struct rtrs_srv_sess, kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  46) 	s = &sess->s;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  47) 	if (!sysfs_streq(buf, "1")) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  48) 		rtrs_err(s, "%s: invalid value: '%s'\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  49) 			  attr->attr.name, buf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  50) 		return -EINVAL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  51) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  52) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  53) 	sockaddr_to_str((struct sockaddr *)&sess->s.dst_addr, str, sizeof(str));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  54) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  55) 	rtrs_info(s, "disconnect for path %s requested\n", str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  56) 	/* first remove sysfs itself to avoid deadlock */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  57) 	sysfs_remove_file_self(&sess->kobj, &attr->attr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  58) 	close_sess(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  59) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  60) 	return count;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  61) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  62) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  63) static struct kobj_attribute rtrs_srv_disconnect_attr =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  64) 	__ATTR(disconnect, 0644,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  65) 	       rtrs_srv_disconnect_show, rtrs_srv_disconnect_store);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  66) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  67) static ssize_t rtrs_srv_hca_port_show(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  68) 				       struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  69) 				       char *page)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  70) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  71) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  72) 	struct rtrs_con *usr_con;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  73) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  74) 	sess = container_of(kobj, typeof(*sess), kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  75) 	usr_con = sess->s.con[0];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  76) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  77) 	return scnprintf(page, PAGE_SIZE, "%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  78) 			 usr_con->cm_id->port_num);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  79) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  80) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  81) static struct kobj_attribute rtrs_srv_hca_port_attr =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  82) 	__ATTR(hca_port, 0444, rtrs_srv_hca_port_show, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  83) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  84) static ssize_t rtrs_srv_hca_name_show(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  85) 				       struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  86) 				       char *page)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  87) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  88) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  89) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  90) 	sess = container_of(kobj, struct rtrs_srv_sess, kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  91) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  92) 	return scnprintf(page, PAGE_SIZE, "%s\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  93) 			 sess->s.dev->ib_dev->name);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  94) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  95) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  96) static struct kobj_attribute rtrs_srv_hca_name_attr =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  97) 	__ATTR(hca_name, 0444, rtrs_srv_hca_name_show, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  98) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  99) static ssize_t rtrs_srv_src_addr_show(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) 				       struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) 				       char *page)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) 	int cnt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) 	sess = container_of(kobj, struct rtrs_srv_sess, kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) 	cnt = sockaddr_to_str((struct sockaddr *)&sess->s.dst_addr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) 			      page, PAGE_SIZE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) 	return cnt + scnprintf(page + cnt, PAGE_SIZE - cnt, "\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) static struct kobj_attribute rtrs_srv_src_addr_attr =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) 	__ATTR(src_addr, 0444, rtrs_srv_src_addr_show, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) static ssize_t rtrs_srv_dst_addr_show(struct kobject *kobj,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) 				       struct kobj_attribute *attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) 				       char *page)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) 	struct rtrs_srv_sess *sess;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) 	int cnt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) 	sess = container_of(kobj, struct rtrs_srv_sess, kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) 	cnt = sockaddr_to_str((struct sockaddr *)&sess->s.src_addr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) 			      page, PAGE_SIZE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) 	return cnt + scnprintf(page + cnt, PAGE_SIZE - cnt, "\n");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) static struct kobj_attribute rtrs_srv_dst_addr_attr =
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) 	__ATTR(dst_addr, 0444, rtrs_srv_dst_addr_show, NULL);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) static struct attribute *rtrs_srv_sess_attrs[] = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) 	&rtrs_srv_hca_name_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) 	&rtrs_srv_hca_port_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) 	&rtrs_srv_src_addr_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) 	&rtrs_srv_dst_addr_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) 	&rtrs_srv_disconnect_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) 	NULL,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) static const struct attribute_group rtrs_srv_sess_attr_group = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) 	.attrs = rtrs_srv_sess_attrs,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) STAT_ATTR(struct rtrs_srv_stats, rdma,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) 	  rtrs_srv_stats_rdma_to_str,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) 	  rtrs_srv_reset_rdma_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) static struct attribute *rtrs_srv_stats_attrs[] = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) 	&rdma_attr.attr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) 	NULL,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) static const struct attribute_group rtrs_srv_stats_attr_group = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) 	.attrs = rtrs_srv_stats_attrs,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) static int rtrs_srv_create_once_sysfs_root_folders(struct rtrs_srv_sess *sess)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) 	struct rtrs_srv *srv = sess->srv;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) 	int err = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) 	mutex_lock(&srv->paths_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) 	if (srv->dev_ref++) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) 		/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) 		 * Device needs to be registered only on the first session
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) 		 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) 		goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) 	srv->dev.class = rtrs_dev_class;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) 	err = dev_set_name(&srv->dev, "%s", sess->s.sessname);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) 	if (err)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) 		goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) 	/*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) 	 * Suppress user space notification until
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176) 	 * sysfs files are created
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) 	 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) 	dev_set_uevent_suppress(&srv->dev, true);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) 	err = device_add(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) 	if (err) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) 		pr_err("device_add(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) 		goto put;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) 	srv->kobj_paths = kobject_create_and_add("paths", &srv->dev.kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) 	if (!srv->kobj_paths) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) 		err = -ENOMEM;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) 		pr_err("kobject_create_and_add(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) 		device_del(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) 		put_device(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) 		goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) 	dev_set_uevent_suppress(&srv->dev, false);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) 	kobject_uevent(&srv->dev.kobj, KOBJ_ADD);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) 	goto unlock;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) put:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) 	put_device(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) unlock:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) 	mutex_unlock(&srv->paths_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) 	return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) static void
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) rtrs_srv_destroy_once_sysfs_root_folders(struct rtrs_srv_sess *sess)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) 	struct rtrs_srv *srv = sess->srv;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) 	mutex_lock(&srv->paths_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) 	if (!--srv->dev_ref) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) 		kobject_del(srv->kobj_paths);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212) 		kobject_put(srv->kobj_paths);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) 		mutex_unlock(&srv->paths_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) 		device_del(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) 		put_device(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) 	} else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) 		put_device(&srv->dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) 		mutex_unlock(&srv->paths_mutex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) static void rtrs_srv_sess_stats_release(struct kobject *kobj)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) 	struct rtrs_srv_stats *stats;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) 	stats = container_of(kobj, struct rtrs_srv_stats, kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) 	kfree(stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) static struct kobj_type ktype_stats = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) 	.sysfs_ops = &kobj_sysfs_ops,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) 	.release = rtrs_srv_sess_stats_release,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) static int rtrs_srv_create_stats_files(struct rtrs_srv_sess *sess)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) 	int err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) 	struct rtrs_sess *s = &sess->s;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) 	err = kobject_init_and_add(&sess->stats->kobj_stats, &ktype_stats,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) 				   &sess->kobj, "stats");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) 	if (err) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) 		rtrs_err(s, "kobject_init_and_add(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) 		kobject_put(&sess->stats->kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) 		return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) 	err = sysfs_create_group(&sess->stats->kobj_stats,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) 				 &rtrs_srv_stats_attr_group);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) 	if (err) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) 		rtrs_err(s, "sysfs_create_group(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) 		goto err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) 	return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) err:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) 	kobject_del(&sess->stats->kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) 	kobject_put(&sess->stats->kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) 	return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) int rtrs_srv_create_sess_files(struct rtrs_srv_sess *sess)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) 	struct rtrs_srv *srv = sess->srv;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) 	struct rtrs_sess *s = &sess->s;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268) 	char str[NAME_MAX];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) 	int err, cnt;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) 	cnt = sockaddr_to_str((struct sockaddr *)&sess->s.dst_addr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272) 			      str, sizeof(str));
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) 	cnt += scnprintf(str + cnt, sizeof(str) - cnt, "@");
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) 	sockaddr_to_str((struct sockaddr *)&sess->s.src_addr,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275) 			str + cnt, sizeof(str) - cnt);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) 	err = rtrs_srv_create_once_sysfs_root_folders(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) 	if (err)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) 		return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281) 	err = kobject_init_and_add(&sess->kobj, &ktype, srv->kobj_paths,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282) 				   "%s", str);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) 	if (err) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284) 		rtrs_err(s, "kobject_init_and_add(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285) 		goto destroy_root;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287) 	err = sysfs_create_group(&sess->kobj, &rtrs_srv_sess_attr_group);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) 	if (err) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) 		rtrs_err(s, "sysfs_create_group(): %d\n", err);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) 		goto put_kobj;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) 	err = rtrs_srv_create_stats_files(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) 	if (err)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294) 		goto remove_group;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296) 	return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) remove_group:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 299) 	sysfs_remove_group(&sess->kobj, &rtrs_srv_sess_attr_group);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 300) put_kobj:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 301) 	kobject_del(&sess->kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 302) destroy_root:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 303) 	kobject_put(&sess->kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 304) 	rtrs_srv_destroy_once_sysfs_root_folders(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 305) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 306) 	return err;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 307) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 308) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 309) void rtrs_srv_destroy_sess_files(struct rtrs_srv_sess *sess)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 310) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 311) 	if (sess->kobj.state_in_sysfs) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 312) 		kobject_del(&sess->stats->kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 313) 		kobject_put(&sess->stats->kobj_stats);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 314) 		sysfs_remove_group(&sess->kobj, &rtrs_srv_sess_attr_group);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 315) 		kobject_put(&sess->kobj);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 316) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 317) 		rtrs_srv_destroy_once_sysfs_root_folders(sess);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 318) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 319) }