Lines Matching refs:mstype

862 static int msg_reply_type(int mstype)  in msg_reply_type()  argument
864 switch (mstype) { in msg_reply_type()
952 static int add_to_waiters(struct dlm_lkb *lkb, int mstype, int to_nodeid) in add_to_waiters() argument
960 (is_overlap_cancel(lkb) && (mstype == DLM_MSG_CANCEL))) { in add_to_waiters()
966 switch (mstype) { in add_to_waiters()
981 lkb->lkb_id, lkb->lkb_wait_type, mstype, in add_to_waiters()
991 lkb->lkb_wait_type = mstype; in add_to_waiters()
999 lkb->lkb_id, error, lkb->lkb_flags, mstype, in add_to_waiters()
1010 static int _remove_from_waiters(struct dlm_lkb *lkb, int mstype, in _remove_from_waiters() argument
1016 if (is_overlap_unlock(lkb) && (mstype == DLM_MSG_UNLOCK_REPLY)) { in _remove_from_waiters()
1023 if (is_overlap_cancel(lkb) && (mstype == DLM_MSG_CANCEL_REPLY)) { in _remove_from_waiters()
1033 if ((mstype == DLM_MSG_CANCEL_REPLY) && in _remove_from_waiters()
1048 if ((mstype == DLM_MSG_CONVERT_REPLY) && in _remove_from_waiters()
1068 lkb->lkb_id, mstype, lkb->lkb_flags); in _remove_from_waiters()
1079 lkb->lkb_id, mstype, lkb->lkb_wait_type); in _remove_from_waiters()
1094 static int remove_from_waiters(struct dlm_lkb *lkb, int mstype) in remove_from_waiters() argument
1100 error = _remove_from_waiters(lkb, mstype, NULL); in remove_from_waiters()
2889 int to_nodeid, int mstype, in _create_message() argument
2915 ms->m_type = mstype; in _create_message()
2923 int to_nodeid, int mstype, in create_message() argument
2929 switch (mstype) { in create_message()
2945 return _create_message(r->res_ls, mb_len, to_nodeid, mstype, in create_message()
3003 static int send_common(struct dlm_rsb *r, struct dlm_lkb *lkb, int mstype) in send_common() argument
3011 error = add_to_waiters(lkb, mstype, to_nodeid); in send_common()
3015 error = create_message(r, lkb, to_nodeid, mstype, &ms, &mh); in send_common()
3027 remove_from_waiters(lkb, msg_reply_type(mstype)); in send_common()
3159 int mstype, int rv) in send_common_reply() argument
3167 error = create_message(r, lkb, to_nodeid, mstype, &ms, &mh); in send_common_reply()
3660 int error, mstype, result; in receive_request_reply() local
3677 mstype = lkb->lkb_wait_type; in receive_request_reply()
3684 if (mstype == DLM_MSG_LOOKUP) { in receive_request_reply()
4354 int error = 0, mstype, err, oc, ou; in dlm_recover_waiters_post() local
4371 mstype = lkb->lkb_wait_type; in dlm_recover_waiters_post()
4377 lkb->lkb_id, lkb->lkb_nodeid, mstype, r->res_nodeid); in dlm_recover_waiters_post()
4395 switch (mstype) { in dlm_recover_waiters_post()
4414 switch (mstype) { in dlm_recover_waiters_post()
4431 lkb->lkb_id, mstype, lkb->lkb_flags, oc, ou); in dlm_recover_waiters_post()