Lines Matching defs:msg_info
863 void hmdfs_response_wakeup(struct sendmsg_wait_queue *msg_info,
866 msg_info->ret = ret_code;
867 msg_info->size = data_len;
868 msg_info->buf = buf;
869 atomic_set(&msg_info->valid, MSG_Q_END_RECV);
870 wake_up_interruptible(&msg_info->response_q);
873 static int hmdfs_readfile_slice(struct sendmsg_wait_queue *msg_info,
878 struct file_recv_info *recv_info = &msg_info->recv_info;
913 struct sendmsg_wait_queue *msg_info = NULL;
920 msg_info = (struct sendmsg_wait_queue *)hmdfs_find_msg_head(desp->peer,
922 if (!msg_info || atomic_read(&msg_info->valid) != MSG_Q_SEND) {
933 ret = hmdfs_readfile_slice(msg_info, desp);
934 pstate = &msg_info->recv_info.state;
940 hmdfs_response_wakeup(msg_info, ret, sizeof(struct hmdfs_head_cmd),
943 msg_info->start, jiffies);
945 if (msg_info)
946 msg_put(msg_info);
966 struct sendmsg_wait_queue *msg_info = NULL;
979 msg_info = (struct sendmsg_wait_queue *)msg_head;
980 if (atomic_read(&msg_info->valid) == MSG_Q_SEND) {
981 hmdfs_response_wakeup(msg_info,
986 msg_info->start, jiffies);
990 msg_put(msg_info);