| H A D | lock.c | 537 * rsb's on the toss list who's dir_nodeid is not local can have stale
547 int dir_nodeid, int from_nodeid, find_rsb_dir()
559 if (from_nodeid == dir_nodeid) find_rsb_dir()
583 (from_other && (dir_nodeid == our_nodeid))) { find_rsb_dir()
616 * we are the dir_nodeid or were the master) No other thread find_rsb_dir()
625 from_nodeid, r->res_master_nodeid, dir_nodeid, find_rsb_dir()
673 r->res_dir_nodeid = dir_nodeid; find_rsb_dir()
685 if (from_other && (dir_nodeid != our_nodeid)) { find_rsb_dir()
688 from_nodeid, dir_nodeid, our_nodeid, r->res_name); find_rsb_dir()
697 from_nodeid, dir_nodeid, r->res_name); find_rsb_dir()
700 if (dir_nodeid == our_nodeid) { find_rsb_dir()
706 /* set_master will send_lookup to dir_nodeid */ find_rsb_dir()
726 int dir_nodeid, int from_nodeid, find_rsb_nodir()
768 from_nodeid, r->res_master_nodeid, dir_nodeid); find_rsb_nodir()
775 (dir_nodeid == our_nodeid)) { find_rsb_nodir()
779 our_nodeid, r->res_master_nodeid, dir_nodeid); find_rsb_nodir()
805 r->res_dir_nodeid = dir_nodeid; find_rsb_nodir()
806 r->res_master_nodeid = dir_nodeid; find_rsb_nodir()
807 r->res_nodeid = (dir_nodeid == our_nodeid) ? 0 : dir_nodeid; find_rsb_nodir()
822 int dir_nodeid; find_rsb() local
830 dir_nodeid = dlm_hash2nodeid(ls, hash); find_rsb()
833 return find_rsb_nodir(ls, name, len, hash, b, dir_nodeid, find_rsb()
836 return find_rsb_dir(ls, name, len, hash, b, dir_nodeid, find_rsb()
920 int dir_nodeid, error, toss_list = 0; dlm_master_lookup() local
934 dir_nodeid = dlm_hash2nodeid(ls, hash); dlm_master_lookup()
935 if (dir_nodeid != our_nodeid) { dlm_master_lookup()
937 from_nodeid, dir_nodeid, our_nodeid, hash, dlm_master_lookup()
4020 int rv, dir_nodeid; send_repeat_remove() local
4028 dir_nodeid = dlm_hash2nodeid(ls, hash); send_repeat_remove()
4030 log_error(ls, "send_repeat_remove dir %d %s", dir_nodeid, name); send_repeat_remove()
4056 dir_nodeid, DLM_MSG_REMOVE, &ms, &mh); send_repeat_remove()
4388 int rv, len, dir_nodeid, from_nodeid; receive_remove() local
4400 dir_nodeid = dlm_hash2nodeid(ls, ms->m_hash); receive_remove()
4401 if (dir_nodeid != dlm_our_nodeid()) { receive_remove()
4403 from_nodeid, dir_nodeid); receive_remove()
5099 int dir_nodeid) waiter_needs_recovery()
5121 int dir_nodeid; dlm_recover_waiters_pre() local
5133 dir_nodeid = dlm_dir_nodeid(lkb->lkb_resource); dlm_recover_waiters_pre()
5140 "lkb_nodeid %d wait_nodeid %d dir_nodeid %d", dlm_recover_waiters_pre()
5147 dir_nodeid); dlm_recover_waiters_pre()
5158 if (!waiter_needs_recovery(ls, lkb, dir_nodeid)) dlm_recover_waiters_pre()
5292 "lkb_nodeid %d wait_nodeid %d dir_nodeid %d " dlm_recover_waiters_post()
5349 "dir_nodeid %d overlap %d %d", dlm_recover_waiters_post()
545 find_rsb_dir(struct dlm_ls *ls, char *name, int len, uint32_t hash, uint32_t b, int dir_nodeid, int from_nodeid, unsigned int flags, struct dlm_rsb **r_ret) find_rsb_dir() argument
724 find_rsb_nodir(struct dlm_ls *ls, char *name, int len, uint32_t hash, uint32_t b, int dir_nodeid, int from_nodeid, unsigned int flags, struct dlm_rsb **r_ret) find_rsb_nodir() argument
5098 waiter_needs_recovery(struct dlm_ls *ls, struct dlm_lkb *lkb, int dir_nodeid) waiter_needs_recovery() argument
|