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;  in rnbd_get_sess_dev()  local
94 	sess_dev = xa_load(&srv_sess->index_idr, dev_id);  in rnbd_get_sess_dev()
95 	if (sess_dev)  in rnbd_get_sess_dev()
96 		ret = kref_get_unless_zero(&sess_dev->kref);  in rnbd_get_sess_dev()
102 	return sess_dev;  in rnbd_get_sess_dev()
108 	struct rnbd_srv_sess_dev *sess_dev = rnbd_priv->sess_dev;  in rnbd_dev_bi_end_io()  local
110 	rnbd_put_sess_dev(sess_dev);  in rnbd_dev_bi_end_io()
123 	struct rnbd_srv_sess_dev *sess_dev;  in process_rdma()  local
137 	sess_dev = rnbd_get_sess_dev(dev_id, srv_sess);  in process_rdma()
138 	if (IS_ERR(sess_dev)) {  in process_rdma()
140 				   srv_sess->sessname, dev_id, sess_dev);  in process_rdma()
145 	priv->sess_dev = sess_dev;  in process_rdma()
148 	bio = bio_alloc(file_bdev(sess_dev->bdev_file), !!datalen,  in process_rdma()
164 			rnbd_srv_err_rl(sess_dev,  in process_rdma()
186 	rnbd_put_sess_dev(sess_dev);  in process_rdma()
219 void rnbd_destroy_sess_dev(struct rnbd_srv_sess_dev *sess_dev, bool keep_id)  in rnbd_destroy_sess_dev()  argument
227 		xa_cmpxchg(&sess_dev->sess->index_idr, sess_dev->device_id,  in rnbd_destroy_sess_dev()
228 			   sess_dev, NULL, 0);  in rnbd_destroy_sess_dev()
230 		xa_erase(&sess_dev->sess->index_idr, sess_dev->device_id);  in rnbd_destroy_sess_dev()
233 	sess_dev->destroy_comp = &dc;  in rnbd_destroy_sess_dev()
234 	rnbd_put_sess_dev(sess_dev);  in rnbd_destroy_sess_dev()
237 	fput(sess_dev->bdev_file);  in rnbd_destroy_sess_dev()
238 	mutex_lock(&sess_dev->dev->lock);  in rnbd_destroy_sess_dev()
239 	list_del(&sess_dev->dev_list);  in rnbd_destroy_sess_dev()
240 	if (!sess_dev->readonly)  in rnbd_destroy_sess_dev()
241 		sess_dev->dev->open_write_cnt--;  in rnbd_destroy_sess_dev()
242 	mutex_unlock(&sess_dev->dev->lock);  in rnbd_destroy_sess_dev()
244 	rnbd_put_srv_dev(sess_dev->dev);  in rnbd_destroy_sess_dev()
246 	rnbd_srv_info(sess_dev, "Device closed\n");  in rnbd_destroy_sess_dev()
247 	kfree(sess_dev);  in rnbd_destroy_sess_dev()
252 	struct rnbd_srv_sess_dev *sess_dev;  in destroy_sess()  local
261 	xa_for_each(&srv_sess->index_idr, index, sess_dev)  in destroy_sess()
262 		rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in destroy_sess()
334 void rnbd_srv_sess_dev_force_close(struct rnbd_srv_sess_dev *sess_dev,  in rnbd_srv_sess_dev_force_close()  argument
337 	struct rnbd_srv_session	*sess = sess_dev->sess;  in rnbd_srv_sess_dev_force_close()
343 	sess_dev->keep_id = true;  in rnbd_srv_sess_dev_force_close()
345 	sysfs_remove_file_self(&sess_dev->kobj, &attr->attr);  in rnbd_srv_sess_dev_force_close()
346 	rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in rnbd_srv_sess_dev_force_close()
355 	struct rnbd_srv_sess_dev *sess_dev;  in process_msg_close()  local
359 	sess_dev = rnbd_get_sess_dev(le32_to_cpu(close_msg->device_id),  in process_msg_close()
361 	if (IS_ERR(sess_dev))  in process_msg_close()
364 	rnbd_put_sess_dev(sess_dev);  in process_msg_close()
366 	rnbd_srv_destroy_dev_session_sysfs(sess_dev);  in process_msg_close()
422 	struct rnbd_srv_sess_dev *sess_dev;  in rnbd_sess_dev_alloc()  local
425 	sess_dev = kzalloc_obj(*sess_dev);  in rnbd_sess_dev_alloc()
426 	if (!sess_dev)  in rnbd_sess_dev_alloc()
429 	error = xa_alloc(&srv_sess->index_idr, &sess_dev->device_id, sess_dev,  in rnbd_sess_dev_alloc()
433 		kfree(sess_dev);  in rnbd_sess_dev_alloc()
437 	return sess_dev;  in rnbd_sess_dev_alloc()
550 					struct rnbd_srv_sess_dev *sess_dev)  in rnbd_srv_fill_msg_open_rsp()  argument
552 	struct block_device *bdev = file_bdev(sess_dev->bdev_file);  in rnbd_srv_fill_msg_open_rsp()
557 	rsp->device_id = cpu_to_le32(sess_dev->device_id);  in rnbd_srv_fill_msg_open_rsp()
678 	struct rnbd_srv_sess_dev *sess_dev;  in find_srv_sess_dev()  local
684 	xa_for_each(&srv_sess->index_idr, index, sess_dev)  in find_srv_sess_dev()
685 		if (!strcmp(sess_dev->pathname, dev_name))  in find_srv_sess_dev()
686 			return sess_dev;  in find_srv_sess_dev()