Lines Matching refs:message_lockres
82 struct dlm_lock_resource *message_lockres;
628 struct dlm_lock_resource *message_lockres = cinfo->message_lockres;
634 if (dlm_lock_sync(message_lockres, DLM_LOCK_CR)) {
640 /* read lvb and wake up thread to process this message_lockres */
641 memcpy(&msg, message_lockres->lksb.sb_lvbptr, sizeof(struct cluster_msg));
650 /*up-convert to PR on message_lockres*/
651 ret = dlm_lock_sync(message_lockres, DLM_LOCK_PR);
659 /*release CR on message_lockres*/
660 ret = dlm_unlock_sync(message_lockres);
744 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_EX);
750 memcpy(cinfo->message_lockres->lksb.sb_lvbptr, (void *)cmsg,
753 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_CW);
777 error = dlm_unlock_sync(cinfo->message_lockres);
902 cinfo->message_lockres = lockres_init(mddev, "message", NULL, 1);
903 if (!cinfo->message_lockres)
957 lockres_free(cinfo->message_lockres);
1020 lockres_free(cinfo->message_lockres);