Lines Matching refs:message_lockres
82 struct dlm_lock_resource *message_lockres; member
624 struct dlm_lock_resource *message_lockres = cinfo->message_lockres; in recv_daemon() local
630 if (dlm_lock_sync(message_lockres, DLM_LOCK_CR)) { in recv_daemon()
637 memcpy(&msg, message_lockres->lksb.sb_lvbptr, sizeof(struct cluster_msg)); in recv_daemon()
647 ret = dlm_lock_sync(message_lockres, DLM_LOCK_PR); in recv_daemon()
656 ret = dlm_unlock_sync(message_lockres); in recv_daemon()
740 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_EX); in __sendmsg()
746 memcpy(cinfo->message_lockres->lksb.sb_lvbptr, (void *)cmsg, in __sendmsg()
749 error = dlm_lock_sync(cinfo->message_lockres, DLM_LOCK_CW); in __sendmsg()
773 error = dlm_unlock_sync(cinfo->message_lockres); in __sendmsg()
897 cinfo->message_lockres = lockres_init(mddev, "message", NULL, 1); in join()
898 if (!cinfo->message_lockres) in join()
952 lockres_free(cinfo->message_lockres); in join()
1015 lockres_free(cinfo->message_lockres); in leave()