88  * @work:     smb work containing server thread information
92 static inline int check_conn_state(struct ksmbd_work *work)  in check_conn_state()  argument
96 	if (ksmbd_conn_exiting(work->conn) ||  in check_conn_state()
97 	    ksmbd_conn_need_reconnect(work->conn)) {  in check_conn_state()
98 		rsp_hdr = work->response_buf;  in check_conn_state()
108 static int __process_request(struct ksmbd_work *work, struct ksmbd_conn *conn,  in __process_request()  argument
115 	if (check_conn_state(work))  in __process_request()
118 	if (ksmbd_verify_smb_message(work)) {  in __process_request()
119 		conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER);  in __process_request()
123 	command = conn->ops->get_cmd_val(work);  in __process_request()
128 		conn->ops->set_rsp_status(work, STATUS_INVALID_PARAMETER);  in __process_request()
135 		conn->ops->set_rsp_status(work, STATUS_NOT_IMPLEMENTED);  in __process_request()
139 	if (work->sess && conn->ops->is_sign_req(work, command)) {  in __process_request()
140 		ret = conn->ops->check_sign_req(work);  in __process_request()
142 			conn->ops->set_rsp_status(work, STATUS_ACCESS_DENIED);  in __process_request()
147 	ret = cmds->proc(work);  in __process_request()
158 	if (work->send_no_response)  in __process_request()
163 static void __handle_ksmbd_work(struct ksmbd_work *work,  in __handle_ksmbd_work()  argument
171 	    conn->ops->is_transform_hdr(work->request_buf)) {  in __handle_ksmbd_work()
172 		rc = conn->ops->decrypt_req(work);  in __handle_ksmbd_work()
175 		work->encrypted = true;  in __handle_ksmbd_work()
178 	if (conn->ops->allocate_rsp_buf(work))  in __handle_ksmbd_work()
181 	rc = conn->ops->init_rsp_hdr(work);  in __handle_ksmbd_work()
184 		conn->ops->set_rsp_status(work, STATUS_INVALID_HANDLE);  in __handle_ksmbd_work()
190 			rc = conn->ops->check_user_session(work);  in __handle_ksmbd_work()
193 					conn->ops->set_rsp_status(work,  in __handle_ksmbd_work()
196 					conn->ops->set_rsp_status(work,  in __handle_ksmbd_work()
200 				rc = conn->ops->get_ksmbd_tcon(work);  in __handle_ksmbd_work()
203 						conn->ops->set_rsp_status(work,  in __handle_ksmbd_work()
206 						conn->ops->set_rsp_status(work,  in __handle_ksmbd_work()
213 		rc = __process_request(work, conn, &command);  in __handle_ksmbd_work()
223 			rc = conn->ops->set_rsp_credits(work);  in __handle_ksmbd_work()
226 				conn->ops->set_rsp_status(work,  in __handle_ksmbd_work()
232 		is_chained = is_chained_smb2_message(work);  in __handle_ksmbd_work()
234 		if (work->sess &&  in __handle_ksmbd_work()
235 		    (work->sess->sign || smb3_11_final_sess_setup_resp(work) ||  in __handle_ksmbd_work()
236 		     conn->ops->is_sign_req(work, command)))  in __handle_ksmbd_work()
237 			conn->ops->set_sign_rsp(work);  in __handle_ksmbd_work()
241 	if (work->tcon)  in __handle_ksmbd_work()
242 		ksmbd_tree_connect_put(work->tcon);  in __handle_ksmbd_work()
243 	smb3_preauth_hash_rsp(work);  in __handle_ksmbd_work()
244 	if (work->sess)  in __handle_ksmbd_work()
245 		ksmbd_user_session_put(work->sess);  in __handle_ksmbd_work()
246 	if (work->sess && work->sess->enc && work->encrypted &&  in __handle_ksmbd_work()
248 		rc = conn->ops->encrypt_resp(work);  in __handle_ksmbd_work()
250 			conn->ops->set_rsp_status(work, STATUS_DATA_ERROR);  in __handle_ksmbd_work()
253 	ksmbd_conn_write(work);  in __handle_ksmbd_work()
257  * handle_ksmbd_work() - process pending smb work requests
258  * @wk:	smb work containing request command buffer
260  * called by kworker threads to processing remaining smb work requests
264 	struct ksmbd_work *work = container_of(wk, struct ksmbd_work, work);  in handle_ksmbd_work()  local
265 	struct ksmbd_conn *conn = work->conn;  in handle_ksmbd_work()
269 	__handle_ksmbd_work(work, conn);  in handle_ksmbd_work()
271 	ksmbd_conn_try_dequeue_request(work);  in handle_ksmbd_work()
272 	ksmbd_free_work_struct(work);  in handle_ksmbd_work()
288  * read remaining data from socket create and submit work.
292 	struct ksmbd_work *work;  in queue_ksmbd_work()  local
304 	work = ksmbd_alloc_work_struct();  in queue_ksmbd_work()
305 	if (!work) {  in queue_ksmbd_work()
306 		pr_err("allocation for work failed\n");  in queue_ksmbd_work()
310 	work->conn = conn;  in queue_ksmbd_work()
311 	work->request_buf = conn->request_buf;  in queue_ksmbd_work()
314 	ksmbd_conn_enqueue_request(work);  in queue_ksmbd_work()
318 	INIT_WORK(&work->work, handle_ksmbd_work);  in queue_ksmbd_work()
319 	ksmbd_queue_work(work);  in queue_ksmbd_work()
392 static void server_ctrl_handle_work(struct work_struct *work)  in server_ctrl_handle_work()  argument
396 	ctrl = container_of(work, struct server_ctrl_struct, ctrl_work);  in server_ctrl_handle_work()
407 		pr_err("Unknown server work type: %d\n", ctrl->type);  in server_ctrl_handle_work()