861 void hmdfs_response_wakeup(struct sendmsg_wait_queue *msg_info,  in hmdfs_response_wakeup()  argument
864 	msg_info->ret = ret_code;  in hmdfs_response_wakeup()
865 	msg_info->size = data_len;  in hmdfs_response_wakeup()
866 	msg_info->buf = buf;  in hmdfs_response_wakeup()
867 	atomic_set(&msg_info->valid, MSG_Q_END_RECV);  in hmdfs_response_wakeup()
868 	wake_up_interruptible(&msg_info->response_q);  in hmdfs_response_wakeup()
871 static int hmdfs_readfile_slice(struct sendmsg_wait_queue *msg_info,  in hmdfs_readfile_slice()  argument
876 	struct file_recv_info *recv_info = &msg_info->recv_info;  in hmdfs_readfile_slice()
906 	struct sendmsg_wait_queue *msg_info = NULL;  in hmdfs_file_response_work_fn()  local
913 	msg_info = (struct sendmsg_wait_queue *)hmdfs_find_msg_head(desp->peer,  in hmdfs_file_response_work_fn()
915 	if (!msg_info || atomic_read(&msg_info->valid) != MSG_Q_SEND) {  in hmdfs_file_response_work_fn()
926 	ret = hmdfs_readfile_slice(msg_info, desp);  in hmdfs_file_response_work_fn()
927 	pstate = &msg_info->recv_info.state;  in hmdfs_file_response_work_fn()
933 	hmdfs_response_wakeup(msg_info, ret, sizeof(struct hmdfs_head_cmd),  in hmdfs_file_response_work_fn()
936 				 msg_info->start, jiffies);  in hmdfs_file_response_work_fn()
938 	if (msg_info)  in hmdfs_file_response_work_fn()
939 		msg_put(msg_info);  in hmdfs_file_response_work_fn()
959 	struct sendmsg_wait_queue *msg_info = NULL;  in hmdfs_response_handle_sync()  local
972 		msg_info = (struct sendmsg_wait_queue *)msg_head;  in hmdfs_response_handle_sync()
973 		if (atomic_read(&msg_info->valid) == MSG_Q_SEND) {  in hmdfs_response_handle_sync()
974 			hmdfs_response_wakeup(msg_info,  in hmdfs_response_handle_sync()
979 						 msg_info->start, jiffies);  in hmdfs_response_handle_sync()
983 		msg_put(msg_info);  in hmdfs_response_handle_sync()