71 	struct rnbd_srv_sess_dev	*sess_dev;  member
76 	struct rnbd_srv_sess_dev *sess_dev;  in rnbd_sess_dev_release()  local
78 	sess_dev = container_of(kref, struct rnbd_srv_sess_dev, kref);  in rnbd_sess_dev_release()
79 	complete(sess_dev->destroy_comp);  in rnbd_sess_dev_release()
82 static inline void rnbd_put_sess_dev(struct rnbd_srv_sess_dev *sess_dev)  in rnbd_put_sess_dev()  argument
84 	kref_put(&sess_dev->kref, rnbd_sess_dev_release);  in rnbd_put_sess_dev()
90 	struct rnbd_srv_sess_dev *sess_dev = rnbd_priv->sess_dev;  in rnbd_endio()  local
92 	rnbd_put_sess_dev(sess_dev);  in rnbd_endio()
102 	struct rnbd_srv_sess_dev *sess_dev;  in rnbd_get_sess_dev()  local
106 	sess_dev = xa_load(&srv_sess->index_idr, dev_id);  in rnbd_get_sess_dev()
107 	if (sess_dev)  in rnbd_get_sess_dev()
108 		ret = kref_get_unless_zero(&sess_dev->kref);  in rnbd_get_sess_dev()
111 	if (!sess_dev || !ret)  in rnbd_get_sess_dev()
114 	return sess_dev;  in rnbd_get_sess_dev()
123 	struct rnbd_srv_sess_dev *sess_dev;  in process_rdma()  local
136 	sess_dev = rnbd_get_sess_dev(dev_id, srv_sess);  in process_rdma()
137 	if (IS_ERR(sess_dev)) {  in process_rdma()
144 	priv->sess_dev = sess_dev;  in process_rdma()
148 	bio = rnbd_bio_map_kern(data, sess_dev->rnbd_dev->ibd_bio_set, datalen, GFP_KERNEL);  in process_rdma()
151 		rnbd_srv_err(sess_dev, "Failed to generate bio, err: %d\n", err);  in process_rdma()
156 	io->dev = sess_dev->rnbd_dev;  in process_rdma()
167 	bio_set_dev(bio, sess_dev->rnbd_dev->bdev);  in process_rdma()
174 	rnbd_put_sess_dev(sess_dev);  in process_rdma()
207 void rnbd_destroy_sess_dev(struct rnbd_srv_sess_dev *sess_dev, bool keep_id)  in rnbd_destroy_sess_dev()  argument
215 		xa_cmpxchg(&sess_dev->sess->index_idr, sess_dev->device_id,  in rnbd_destroy_sess_dev()
216 			   sess_dev, NULL, 0);  in rnbd_destroy_sess_dev()
218 		xa_erase(&sess_dev->sess->index_idr, sess_dev->device_id);  in rnbd_destroy_sess_dev()
221 	sess_dev->destroy_comp = &dc;  in rnbd_destroy_sess_dev()
222 	rnbd_put_sess_dev(sess_dev);  in rnbd_destroy_sess_dev()
225 	rnbd_dev_close(sess_dev->rnbd_dev);  in rnbd_destroy_sess_dev()
226 	list_del(&sess_dev->sess_list);  in rnbd_destroy_sess_dev()
227 	mutex_lock(&sess_dev->dev->lock);  in rnbd_destroy_sess_dev()
228 	list_del(&sess_dev->dev_list);  in rnbd_destroy_sess_dev()
229 	if (sess_dev->open_flags & FMODE_WRITE)  in rnbd_destroy_sess_dev()
230 		sess_dev->dev->open_write_cnt--;  in rnbd_destroy_sess_dev()
231 	mutex_unlock(&sess_dev->dev->lock);  in rnbd_destroy_sess_dev()
233 	rnbd_put_srv_dev(sess_dev->dev);  in rnbd_destroy_sess_dev()
235 	rnbd_srv_info(sess_dev, "Device closed\n");  in rnbd_destroy_sess_dev()
236 	kfree(sess_dev);  in rnbd_destroy_sess_dev()
241 	struct rnbd_srv_sess_dev *sess_dev, *tmp;  in destroy_sess()  local
247 	list_for_each_entry_safe(sess_dev, tmp, &srv_sess->sess_dev_list,  in destroy_sess()
249 		rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in destroy_sess()
331 void rnbd_srv_sess_dev_force_close(struct rnbd_srv_sess_dev *sess_dev,  in rnbd_srv_sess_dev_force_close()  argument
334 	struct rnbd_srv_session	*sess = sess_dev->sess;  in rnbd_srv_sess_dev_force_close()
336 	sess_dev->keep_id = true;  in rnbd_srv_sess_dev_force_close()
341 	sysfs_remove_file_self(&sess_dev->kobj, &attr->attr);  in rnbd_srv_sess_dev_force_close()
342 	rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in rnbd_srv_sess_dev_force_close()
351 	struct rnbd_srv_sess_dev *sess_dev;  in process_msg_close()  local
353 	sess_dev = rnbd_get_sess_dev(le32_to_cpu(close_msg->device_id),  in process_msg_close()
355 	if (IS_ERR(sess_dev))  in process_msg_close()
358 	rnbd_put_sess_dev(sess_dev);  in process_msg_close()
360 	rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in process_msg_close()
414 	struct rnbd_srv_sess_dev *sess_dev;  in rnbd_sess_dev_alloc()  local
417 	sess_dev = kzalloc(sizeof(*sess_dev), GFP_KERNEL);  in rnbd_sess_dev_alloc()
418 	if (!sess_dev)  in rnbd_sess_dev_alloc()
421 	error = xa_alloc(&srv_sess->index_idr, &sess_dev->device_id, sess_dev,  in rnbd_sess_dev_alloc()
425 		kfree(sess_dev);  in rnbd_sess_dev_alloc()
429 	return sess_dev;  in rnbd_sess_dev_alloc()
543 					struct rnbd_srv_sess_dev *sess_dev)  in rnbd_srv_fill_msg_open_rsp()  argument
545 	struct rnbd_dev *rnbd_dev = sess_dev->rnbd_dev;  in rnbd_srv_fill_msg_open_rsp()
550 		cpu_to_le32(sess_dev->device_id);  in rnbd_srv_fill_msg_open_rsp()
681 	struct rnbd_srv_sess_dev *sess_dev;  in find_srv_sess_dev()  local
686 	list_for_each_entry(sess_dev, &srv_sess->sess_dev_list, sess_list)  in find_srv_sess_dev()
687 		if (!strcmp(sess_dev->pathname, dev_name))  in find_srv_sess_dev()
688 			return sess_dev;  in find_srv_sess_dev()