Lines Matching refs:msg
202 struct dlm_msg *msg; member
290 dlm_lowcomms_put_msg(mh->msg); in dlm_mhandle_release()
379 struct dlm_msg *msg; in dlm_send_ack() local
382 msg = dlm_lowcomms_new_msg(nodeid, mb_len, &ppc, NULL, NULL); in dlm_send_ack()
383 if (!msg) in dlm_send_ack()
394 dlm_lowcomms_commit_msg(msg); in dlm_send_ack()
395 dlm_lowcomms_put_msg(msg); in dlm_send_ack()
945 ret = dlm_lowcomms_resend_msg(mh->msg); in dlm_midcomms_unack_msg_resend()
981 struct dlm_msg *msg; in dlm_midcomms_get_msg_3_2() local
983 msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN, in dlm_midcomms_get_msg_3_2()
985 if (!msg) in dlm_midcomms_get_msg_3_2()
996 return msg; in dlm_midcomms_get_msg_3_2()
1007 struct dlm_msg *msg; in dlm_midcomms_get_mhandle() local
1029 msg = dlm_lowcomms_new_msg(nodeid, len, ppc, NULL, NULL); in dlm_midcomms_get_mhandle()
1030 if (!msg) { in dlm_midcomms_get_mhandle()
1040 msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, ppc); in dlm_midcomms_get_mhandle()
1041 if (!msg) { in dlm_midcomms_get_mhandle()
1052 mh->msg = msg; in dlm_midcomms_get_mhandle()
1093 dlm_lowcomms_commit_msg(mh->msg); in dlm_midcomms_commit_msg_3_2()
1108 dlm_lowcomms_commit_msg(mh->msg); in dlm_midcomms_commit_mhandle()
1109 dlm_lowcomms_put_msg(mh->msg); in dlm_midcomms_commit_mhandle()
1494 struct dlm_msg *msg; in dlm_midcomms_rawmsg_send() local
1500 msg = dlm_lowcomms_new_msg(node->nodeid, buflen, &msgbuf, in dlm_midcomms_rawmsg_send()
1502 if (!msg) in dlm_midcomms_rawmsg_send()
1506 dlm_lowcomms_commit_msg(msg); in dlm_midcomms_rawmsg_send()