Lines Matching refs:message_lockres
82 struct dlm_lock_resource *message_lockres; member
628 struct dlm_lock_resource *message_lockres = cinfo->message_lockres; in recv_daemon() local
634 if (dlm_lock_sync(message_lockres, DLM_LOCK_CR)) { in recv_daemon()
641 memcpy(&msg, message_lockres->lksb.sb_lvbptr, sizeof(struct cluster_msg)); in recv_daemon()
651 ret = dlm_lock_sync(message_lockres, DLM_LOCK_PR); in recv_daemon()
660 ret = dlm_unlock_sync(message_lockres); in recv_daemon()
744 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_EX); in __sendmsg()
750 memcpy(cinfo->message_lockres->lksb.sb_lvbptr, (void *)cmsg, in __sendmsg()
753 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_CW); in __sendmsg()
777 error = dlm_unlock_sync(cinfo->message_lockres); in __sendmsg()
902 cinfo->message_lockres = lockres_init(mddev, "message", NULL, 1); in join()
903 if (!cinfo->message_lockres) in join()
957 lockres_free(cinfo->message_lockres); in join()
1020 lockres_free(cinfo->message_lockres); in leave()