Lines Matching defs:msg_id
76 idr_remove(&con->msg_idr, msg_wq->head.msg_id);
219 head.msg_id = cmd->msg_id;
241 idr_remove(&peer->msg_idr, mp->head.msg_id);
341 head.msg_id = cpu_to_le32(mp->head.msg_id);
449 head->msg_id = cpu_to_le32(msg_wq->head.msg_id);
461 hmdfs_err_ratelimited("send err sm->device_id, %lld, msg_id %u",
462 con->device_id, head->msg_id);
488 hmdfs_err("timeout err sm->device_id %lld, msg_id %d cmd %d",
489 con->device_id, head->msg_id,
534 head.msg_id = cmd->msg_id;
609 idr_remove(&peer->msg_idr, asw->head.msg_id);
626 hmdfs_err_ratelimited("timeout and release page, msg_id:%u",
627 async_work->head.msg_id);
681 hmdfs_err("alloc msg_id failed, err %d", ret);
684 head.msg_id = cpu_to_le32(async_work->head.msg_id);
691 hmdfs_err("queue_delayed_work failed, msg_id %u", head.msg_id);
696 hmdfs_err("send err sm->device_id, %lld, msg_id %u",
697 con->device_id, head.msg_id);
921 le32_to_cpu(desp->head->msg_id), desp->head->operations);
926 le32_to_cpu(desp->head->msg_id));
969 u32 msg_id = le32_to_cpu(head->msg_id);
973 msg_head = hmdfs_find_msg_head(con, msg_id, head->operations);
1010 hmdfs_err("receive incorrect msg type %d msg_id %d cmd %d",
1011 msg_head->type, msg_id, cmd);
1019 hmdfs_info("cannot find msg_id %d cmd %d", msg_id, cmd);
1078 hmdfs_info("Message %d has been abandoned", hmdfs_head->msg_id);
1108 hmdfs_err("cancel parasite work err msg_id=%d cmd=%d",
1109 mp->head.msg_id, mp->req.operations.command);
1117 hmdfs_err("cancel async work err msg_id=%d",
1118 async_work->head.msg_id);