30 static void free_channel_list(struct ksmbd_session *sess)  in free_channel_list()  argument
35 	xa_for_each(&sess->ksmbd_chann_list, index, chann) {  in free_channel_list()
36 		xa_erase(&sess->ksmbd_chann_list, index);  in free_channel_list()
40 	xa_destroy(&sess->ksmbd_chann_list);  in free_channel_list()
43 static void __session_rpc_close(struct ksmbd_session *sess,  in __session_rpc_close()  argument
48 	resp = ksmbd_rpc_close(sess, entry->id);  in __session_rpc_close()
57 static void ksmbd_session_rpc_clear_list(struct ksmbd_session *sess)  in ksmbd_session_rpc_clear_list()  argument
62 	xa_for_each(&sess->rpc_handle_list, index, entry) {  in ksmbd_session_rpc_clear_list()
63 		xa_erase(&sess->rpc_handle_list, index);  in ksmbd_session_rpc_clear_list()
64 		__session_rpc_close(sess, entry);  in ksmbd_session_rpc_clear_list()
67 	xa_destroy(&sess->rpc_handle_list);  in ksmbd_session_rpc_clear_list()
91 int ksmbd_session_rpc_open(struct ksmbd_session *sess, char *rpc_name)  in ksmbd_session_rpc_open()  argument
109 	xa_store(&sess->rpc_handle_list, entry->id, entry, GFP_KERNEL);  in ksmbd_session_rpc_open()
111 	resp = ksmbd_rpc_open(sess, entry->id);  in ksmbd_session_rpc_open()
118 	xa_erase(&sess->rpc_handle_list, entry->id);  in ksmbd_session_rpc_open()
125 void ksmbd_session_rpc_close(struct ksmbd_session *sess, int id)  in ksmbd_session_rpc_close()  argument
129 	entry = xa_erase(&sess->rpc_handle_list, id);  in ksmbd_session_rpc_close()
131 		__session_rpc_close(sess, entry);  in ksmbd_session_rpc_close()
134 int ksmbd_session_rpc_method(struct ksmbd_session *sess, int id)  in ksmbd_session_rpc_method()  argument
138 	entry = xa_load(&sess->rpc_handle_list, id);  in ksmbd_session_rpc_method()
142 void ksmbd_session_destroy(struct ksmbd_session *sess)  in ksmbd_session_destroy()  argument
144 	if (!sess)  in ksmbd_session_destroy()
147 	if (sess->user)  in ksmbd_session_destroy()
148 		ksmbd_free_user(sess->user);  in ksmbd_session_destroy()
150 	ksmbd_tree_conn_session_logoff(sess);  in ksmbd_session_destroy()
151 	ksmbd_destroy_file_table(&sess->file_table);  in ksmbd_session_destroy()
152 	ksmbd_session_rpc_clear_list(sess);  in ksmbd_session_destroy()
153 	free_channel_list(sess);  in ksmbd_session_destroy()
154 	kfree(sess->Preauth_HashValue);  in ksmbd_session_destroy()
155 	ksmbd_release_id(&session_ida, sess->id);  in ksmbd_session_destroy()
156 	kfree(sess);  in ksmbd_session_destroy()
161 	struct ksmbd_session *sess;  in __session_lookup()  local
163 	hash_for_each_possible(sessions_table, sess, hlist, id) {  in __session_lookup()
164 		if (id == sess->id) {  in __session_lookup()
165 			sess->last_active = jiffies;  in __session_lookup()
166 			return sess;  in __session_lookup()
175 	struct ksmbd_session *sess;  in ksmbd_expire_session()  local
178 	xa_for_each(&conn->sessions, id, sess) {  in ksmbd_expire_session()
179 		if (sess->state != SMB2_SESSION_VALID ||  in ksmbd_expire_session()
181 			       sess->last_active + SMB2_SESSION_TIMEOUT)) {  in ksmbd_expire_session()
182 			xa_erase(&conn->sessions, sess->id);  in ksmbd_expire_session()
183 			hash_del(&sess->hlist);  in ksmbd_expire_session()
184 			ksmbd_session_destroy(sess);  in ksmbd_expire_session()
192 			   struct ksmbd_session *sess)  in ksmbd_session_register()  argument
194 	sess->dialect = conn->dialect;  in ksmbd_session_register()
195 	memcpy(sess->ClientGUID, conn->ClientGUID, SMB2_CLIENT_GUID_SIZE);  in ksmbd_session_register()
197 	return xa_err(xa_store(&conn->sessions, sess->id, sess, GFP_KERNEL));  in ksmbd_session_register()
200 static int ksmbd_chann_del(struct ksmbd_conn *conn, struct ksmbd_session *sess)  in ksmbd_chann_del()  argument
204 	chann = xa_erase(&sess->ksmbd_chann_list, (long)conn);  in ksmbd_chann_del()
214 	struct ksmbd_session *sess;  in ksmbd_sessions_deregister()  local
222 		hash_for_each_safe(sessions_table, bkt, tmp, sess, hlist) {  in ksmbd_sessions_deregister()
223 			if (!ksmbd_chann_del(conn, sess) &&  in ksmbd_sessions_deregister()
224 			    xa_empty(&sess->ksmbd_chann_list)) {  in ksmbd_sessions_deregister()
225 				hash_del(&sess->hlist);  in ksmbd_sessions_deregister()
226 				ksmbd_session_destroy(sess);  in ksmbd_sessions_deregister()
233 	xa_for_each(&conn->sessions, id, sess) {  in ksmbd_sessions_deregister()
237 		xa_for_each(&sess->ksmbd_chann_list, chann_id, chann) {  in ksmbd_sessions_deregister()
242 		ksmbd_chann_del(conn, sess);  in ksmbd_sessions_deregister()
243 		if (xa_empty(&sess->ksmbd_chann_list)) {  in ksmbd_sessions_deregister()
244 			xa_erase(&conn->sessions, sess->id);  in ksmbd_sessions_deregister()
245 			hash_del(&sess->hlist);  in ksmbd_sessions_deregister()
246 			ksmbd_session_destroy(sess);  in ksmbd_sessions_deregister()
255 	struct ksmbd_session *sess;  in ksmbd_session_lookup()  local
258 	sess = xa_load(&conn->sessions, id);  in ksmbd_session_lookup()
259 	if (sess)  in ksmbd_session_lookup()
260 		sess->last_active = jiffies;  in ksmbd_session_lookup()
262 	return sess;  in ksmbd_session_lookup()
267 	struct ksmbd_session *sess;  in ksmbd_session_lookup_slowpath()  local
270 	sess = __session_lookup(id);  in ksmbd_session_lookup_slowpath()
271 	if (sess)  in ksmbd_session_lookup_slowpath()
272 		sess->last_active = jiffies;  in ksmbd_session_lookup_slowpath()
275 	return sess;  in ksmbd_session_lookup_slowpath()
281 	struct ksmbd_session *sess;  in ksmbd_session_lookup_all()  local
283 	sess = ksmbd_session_lookup(conn, id);  in ksmbd_session_lookup_all()
284 	if (!sess && conn->binding)  in ksmbd_session_lookup_all()
285 		sess = ksmbd_session_lookup_slowpath(id);  in ksmbd_session_lookup_all()
286 	if (sess && sess->state != SMB2_SESSION_VALID)  in ksmbd_session_lookup_all()
287 		sess = NULL;  in ksmbd_session_lookup_all()
288 	return sess;  in ksmbd_session_lookup_all()
294 	struct preauth_session *sess;  in ksmbd_preauth_session_alloc()  local
296 	sess = kmalloc(sizeof(struct preauth_session), GFP_KERNEL);  in ksmbd_preauth_session_alloc()
297 	if (!sess)  in ksmbd_preauth_session_alloc()
300 	sess->id = sess_id;  in ksmbd_preauth_session_alloc()
301 	memcpy(sess->Preauth_HashValue, conn->preauth_info->Preauth_HashValue,  in ksmbd_preauth_session_alloc()
303 	list_add(&sess->preauth_entry, &conn->preauth_sess_table);  in ksmbd_preauth_session_alloc()
305 	return sess;  in ksmbd_preauth_session_alloc()
334 static bool ksmbd_preauth_session_id_match(struct preauth_session *sess,  in ksmbd_preauth_session_id_match()  argument
337 	return sess->id == id;  in ksmbd_preauth_session_id_match()
343 	struct preauth_session *sess = NULL;  in ksmbd_preauth_session_lookup()  local
345 	list_for_each_entry(sess, &conn->preauth_sess_table, preauth_entry) {  in ksmbd_preauth_session_lookup()
346 		if (ksmbd_preauth_session_id_match(sess, id))  in ksmbd_preauth_session_lookup()
347 			return sess;  in ksmbd_preauth_session_lookup()
352 static int __init_smb2_session(struct ksmbd_session *sess)  in __init_smb2_session()  argument
358 	sess->id = id;  in __init_smb2_session()
364 	struct ksmbd_session *sess;  in __session_create()  local
370 	sess = kzalloc(sizeof(struct ksmbd_session), GFP_KERNEL);  in __session_create()
371 	if (!sess)  in __session_create()
374 	if (ksmbd_init_file_table(&sess->file_table))  in __session_create()
377 	sess->last_active = jiffies;  in __session_create()
378 	sess->state = SMB2_SESSION_IN_PROGRESS;  in __session_create()
379 	set_session_flag(sess, protocol);  in __session_create()
380 	xa_init(&sess->tree_conns);  in __session_create()
381 	xa_init(&sess->ksmbd_chann_list);  in __session_create()
382 	xa_init(&sess->rpc_handle_list);  in __session_create()
383 	sess->sequence_number = 1;  in __session_create()
384 	rwlock_init(&sess->tree_conns_lock);  in __session_create()
386 	ret = __init_smb2_session(sess);  in __session_create()
390 	ida_init(&sess->tree_conn_ida);  in __session_create()
393 	hash_add(sessions_table, &sess->hlist, sess->id);  in __session_create()
396 	return sess;  in __session_create()
399 	ksmbd_session_destroy(sess);  in __session_create()
408 int ksmbd_acquire_tree_conn_id(struct ksmbd_session *sess)  in ksmbd_acquire_tree_conn_id()  argument
412 	if (test_session_flag(sess, CIFDS_SESSION_FLAG_SMB2))  in ksmbd_acquire_tree_conn_id()
413 		id = ksmbd_acquire_smb2_tid(&sess->tree_conn_ida);  in ksmbd_acquire_tree_conn_id()
418 void ksmbd_release_tree_conn_id(struct ksmbd_session *sess, int id)  in ksmbd_release_tree_conn_id()  argument
421 		ksmbd_release_id(&sess->tree_conn_ida, id);  in ksmbd_release_tree_conn_id()