Lines Matching refs:ls
44 int dlm_wait_function(struct dlm_ls *ls, int (*testfn) (struct dlm_ls *ls)) in dlm_wait_function() argument
50 rv = wait_event_timeout(ls->ls_wait_general, in dlm_wait_function()
51 testfn(ls) || dlm_recovery_stopped(ls), in dlm_wait_function()
57 if (dlm_recovery_stopped(ls)) { in dlm_wait_function()
58 log_debug(ls, "dlm_wait_function aborted"); in dlm_wait_function()
72 uint32_t dlm_recover_status(struct dlm_ls *ls) in dlm_recover_status() argument
75 spin_lock(&ls->ls_recover_lock); in dlm_recover_status()
76 status = ls->ls_recover_status; in dlm_recover_status()
77 spin_unlock(&ls->ls_recover_lock); in dlm_recover_status()
81 static void _set_recover_status(struct dlm_ls *ls, uint32_t status) in _set_recover_status() argument
83 ls->ls_recover_status |= status; in _set_recover_status()
86 void dlm_set_recover_status(struct dlm_ls *ls, uint32_t status) in dlm_set_recover_status() argument
88 spin_lock(&ls->ls_recover_lock); in dlm_set_recover_status()
89 _set_recover_status(ls, status); in dlm_set_recover_status()
90 spin_unlock(&ls->ls_recover_lock); in dlm_set_recover_status()
93 static int wait_status_all(struct dlm_ls *ls, uint32_t wait_status, in wait_status_all() argument
96 struct dlm_rcom *rc = ls->ls_recover_buf; in wait_status_all()
100 list_for_each_entry(memb, &ls->ls_nodes, list) { in wait_status_all()
103 if (dlm_recovery_stopped(ls)) { in wait_status_all()
108 error = dlm_rcom_status(ls, memb->nodeid, 0); in wait_status_all()
113 dlm_slot_save(ls, rc, memb); in wait_status_all()
126 static int wait_status_low(struct dlm_ls *ls, uint32_t wait_status, in wait_status_low() argument
129 struct dlm_rcom *rc = ls->ls_recover_buf; in wait_status_low()
130 int error = 0, delay = 0, nodeid = ls->ls_low_nodeid; in wait_status_low()
133 if (dlm_recovery_stopped(ls)) { in wait_status_low()
138 error = dlm_rcom_status(ls, nodeid, status_flags); in wait_status_low()
152 static int wait_status(struct dlm_ls *ls, uint32_t status) in wait_status() argument
157 if (ls->ls_low_nodeid == dlm_our_nodeid()) { in wait_status()
158 error = wait_status_all(ls, status, 0); in wait_status()
160 dlm_set_recover_status(ls, status_all); in wait_status()
162 error = wait_status_low(ls, status_all, 0); in wait_status()
167 int dlm_recover_members_wait(struct dlm_ls *ls) in dlm_recover_members_wait() argument
175 list_for_each_entry(memb, &ls->ls_nodes, list) { in dlm_recover_members_wait()
180 if (ls->ls_low_nodeid == dlm_our_nodeid()) { in dlm_recover_members_wait()
181 error = wait_status_all(ls, DLM_RS_NODES, 1); in dlm_recover_members_wait()
187 rv = dlm_slots_assign(ls, &num_slots, &slots_size, &slots, &gen); in dlm_recover_members_wait()
189 spin_lock(&ls->ls_recover_lock); in dlm_recover_members_wait()
190 _set_recover_status(ls, DLM_RS_NODES_ALL); in dlm_recover_members_wait()
191 ls->ls_num_slots = num_slots; in dlm_recover_members_wait()
192 ls->ls_slots_size = slots_size; in dlm_recover_members_wait()
193 ls->ls_slots = slots; in dlm_recover_members_wait()
194 ls->ls_generation = gen; in dlm_recover_members_wait()
195 spin_unlock(&ls->ls_recover_lock); in dlm_recover_members_wait()
197 dlm_set_recover_status(ls, DLM_RS_NODES_ALL); in dlm_recover_members_wait()
200 error = wait_status_low(ls, DLM_RS_NODES_ALL, DLM_RSF_NEED_SLOTS); in dlm_recover_members_wait()
204 dlm_slots_copy_in(ls); in dlm_recover_members_wait()
210 int dlm_recover_directory_wait(struct dlm_ls *ls) in dlm_recover_directory_wait() argument
212 return wait_status(ls, DLM_RS_DIR); in dlm_recover_directory_wait()
215 int dlm_recover_locks_wait(struct dlm_ls *ls) in dlm_recover_locks_wait() argument
217 return wait_status(ls, DLM_RS_LOCKS); in dlm_recover_locks_wait()
220 int dlm_recover_done_wait(struct dlm_ls *ls) in dlm_recover_done_wait() argument
222 return wait_status(ls, DLM_RS_DONE); in dlm_recover_done_wait()
237 static int recover_list_empty(struct dlm_ls *ls) in recover_list_empty() argument
241 spin_lock(&ls->ls_recover_list_lock); in recover_list_empty()
242 empty = list_empty(&ls->ls_recover_list); in recover_list_empty()
243 spin_unlock(&ls->ls_recover_list_lock); in recover_list_empty()
250 struct dlm_ls *ls = r->res_ls; in recover_list_add() local
252 spin_lock(&ls->ls_recover_list_lock); in recover_list_add()
254 list_add_tail(&r->res_recover_list, &ls->ls_recover_list); in recover_list_add()
255 ls->ls_recover_list_count++; in recover_list_add()
258 spin_unlock(&ls->ls_recover_list_lock); in recover_list_add()
263 struct dlm_ls *ls = r->res_ls; in recover_list_del() local
265 spin_lock(&ls->ls_recover_list_lock); in recover_list_del()
267 ls->ls_recover_list_count--; in recover_list_del()
268 spin_unlock(&ls->ls_recover_list_lock); in recover_list_del()
273 static void recover_list_clear(struct dlm_ls *ls) in recover_list_clear() argument
277 spin_lock(&ls->ls_recover_list_lock); in recover_list_clear()
278 list_for_each_entry_safe(r, s, &ls->ls_recover_list, res_recover_list) { in recover_list_clear()
282 ls->ls_recover_list_count--; in recover_list_clear()
285 if (ls->ls_recover_list_count != 0) { in recover_list_clear()
286 log_error(ls, "warning: recover_list_count %d", in recover_list_clear()
287 ls->ls_recover_list_count); in recover_list_clear()
288 ls->ls_recover_list_count = 0; in recover_list_clear()
290 spin_unlock(&ls->ls_recover_list_lock); in recover_list_clear()
293 static int recover_idr_empty(struct dlm_ls *ls) in recover_idr_empty() argument
297 spin_lock(&ls->ls_recover_idr_lock); in recover_idr_empty()
298 if (ls->ls_recover_list_count) in recover_idr_empty()
300 spin_unlock(&ls->ls_recover_idr_lock); in recover_idr_empty()
307 struct dlm_ls *ls = r->res_ls; in recover_idr_add() local
311 spin_lock(&ls->ls_recover_idr_lock); in recover_idr_add()
316 rv = idr_alloc(&ls->ls_recover_idr, r, 1, 0, GFP_NOWAIT); in recover_idr_add()
321 ls->ls_recover_list_count++; in recover_idr_add()
325 spin_unlock(&ls->ls_recover_idr_lock); in recover_idr_add()
332 struct dlm_ls *ls = r->res_ls; in recover_idr_del() local
334 spin_lock(&ls->ls_recover_idr_lock); in recover_idr_del()
335 idr_remove(&ls->ls_recover_idr, r->res_id); in recover_idr_del()
337 ls->ls_recover_list_count--; in recover_idr_del()
338 spin_unlock(&ls->ls_recover_idr_lock); in recover_idr_del()
343 static struct dlm_rsb *recover_idr_find(struct dlm_ls *ls, uint64_t id) in recover_idr_find() argument
347 spin_lock(&ls->ls_recover_idr_lock); in recover_idr_find()
348 r = idr_find(&ls->ls_recover_idr, (int)id); in recover_idr_find()
349 spin_unlock(&ls->ls_recover_idr_lock); in recover_idr_find()
353 static void recover_idr_clear(struct dlm_ls *ls) in recover_idr_clear() argument
358 spin_lock(&ls->ls_recover_idr_lock); in recover_idr_clear()
360 idr_for_each_entry(&ls->ls_recover_idr, r, id) { in recover_idr_clear()
361 idr_remove(&ls->ls_recover_idr, id); in recover_idr_clear()
364 ls->ls_recover_list_count--; in recover_idr_clear()
369 if (ls->ls_recover_list_count != 0) { in recover_idr_clear()
370 log_error(ls, "warning: recover_list_count %d", in recover_idr_clear()
371 ls->ls_recover_list_count); in recover_idr_clear()
372 ls->ls_recover_list_count = 0; in recover_idr_clear()
374 spin_unlock(&ls->ls_recover_idr_lock); in recover_idr_clear()
444 struct dlm_ls *ls = r->res_ls; in recover_master() local
452 is_removed = dlm_is_removed(ls, r->res_nodeid); in recover_master()
521 int dlm_recover_masters(struct dlm_ls *ls) in dlm_recover_masters() argument
526 int nodir = dlm_no_directory(ls); in dlm_recover_masters()
529 log_rinfo(ls, "dlm_recover_masters"); in dlm_recover_masters()
531 down_read(&ls->ls_root_sem); in dlm_recover_masters()
532 list_for_each_entry(r, &ls->ls_root_list, res_root_list) { in dlm_recover_masters()
533 if (dlm_recovery_stopped(ls)) { in dlm_recover_masters()
534 up_read(&ls->ls_root_sem); in dlm_recover_masters()
549 up_read(&ls->ls_root_sem); in dlm_recover_masters()
553 up_read(&ls->ls_root_sem); in dlm_recover_masters()
555 log_rinfo(ls, "dlm_recover_masters %u of %u", count, total); in dlm_recover_masters()
557 error = dlm_wait_function(ls, &recover_idr_empty); in dlm_recover_masters()
560 recover_idr_clear(ls); in dlm_recover_masters()
564 int dlm_recover_master_reply(struct dlm_ls *ls, struct dlm_rcom *rc) in dlm_recover_master_reply() argument
569 r = recover_idr_find(ls, rc->rc_id); in dlm_recover_master_reply()
571 log_error(ls, "dlm_recover_master_reply no id %llx", in dlm_recover_master_reply()
590 if (recover_idr_empty(ls)) in dlm_recover_master_reply()
591 wake_up(&ls->ls_wait_general); in dlm_recover_master_reply()
657 int dlm_recover_locks(struct dlm_ls *ls) in dlm_recover_locks() argument
662 down_read(&ls->ls_root_sem); in dlm_recover_locks()
663 list_for_each_entry(r, &ls->ls_root_list, res_root_list) { in dlm_recover_locks()
672 if (dlm_recovery_stopped(ls)) { in dlm_recover_locks()
674 up_read(&ls->ls_root_sem); in dlm_recover_locks()
680 up_read(&ls->ls_root_sem); in dlm_recover_locks()
686 up_read(&ls->ls_root_sem); in dlm_recover_locks()
688 log_rinfo(ls, "dlm_recover_locks %d out", count); in dlm_recover_locks()
690 error = dlm_wait_function(ls, &recover_list_empty); in dlm_recover_locks()
693 recover_list_clear(ls); in dlm_recover_locks()
819 struct dlm_ls *ls = r->res_ls; in recover_conversion() local
835 log_debug(ls, "recover_conversion %x set gr to rq %d", in recover_conversion()
839 log_debug(ls, "recover_conversion %x set gr %d", in recover_conversion()
856 void dlm_recover_rsbs(struct dlm_ls *ls) in dlm_recover_rsbs() argument
861 down_read(&ls->ls_root_sem); in dlm_recover_rsbs()
862 list_for_each_entry(r, &ls->ls_root_list, res_root_list) { in dlm_recover_rsbs()
883 up_read(&ls->ls_root_sem); in dlm_recover_rsbs()
886 log_rinfo(ls, "dlm_recover_rsbs %d done", count); in dlm_recover_rsbs()
891 int dlm_create_root_list(struct dlm_ls *ls) in dlm_create_root_list() argument
897 down_write(&ls->ls_root_sem); in dlm_create_root_list()
898 if (!list_empty(&ls->ls_root_list)) { in dlm_create_root_list()
899 log_error(ls, "root list not empty"); in dlm_create_root_list()
904 for (i = 0; i < ls->ls_rsbtbl_size; i++) { in dlm_create_root_list()
905 spin_lock(&ls->ls_rsbtbl[i].lock); in dlm_create_root_list()
906 for (n = rb_first(&ls->ls_rsbtbl[i].keep); n; n = rb_next(n)) { in dlm_create_root_list()
908 list_add(&r->res_root_list, &ls->ls_root_list); in dlm_create_root_list()
912 if (!RB_EMPTY_ROOT(&ls->ls_rsbtbl[i].toss)) in dlm_create_root_list()
913 log_error(ls, "dlm_create_root_list toss not empty"); in dlm_create_root_list()
914 spin_unlock(&ls->ls_rsbtbl[i].lock); in dlm_create_root_list()
917 up_write(&ls->ls_root_sem); in dlm_create_root_list()
921 void dlm_release_root_list(struct dlm_ls *ls) in dlm_release_root_list() argument
925 down_write(&ls->ls_root_sem); in dlm_release_root_list()
926 list_for_each_entry_safe(r, safe, &ls->ls_root_list, res_root_list) { in dlm_release_root_list()
930 up_write(&ls->ls_root_sem); in dlm_release_root_list()
933 void dlm_clear_toss(struct dlm_ls *ls) in dlm_clear_toss() argument
940 for (i = 0; i < ls->ls_rsbtbl_size; i++) { in dlm_clear_toss()
941 spin_lock(&ls->ls_rsbtbl[i].lock); in dlm_clear_toss()
942 for (n = rb_first(&ls->ls_rsbtbl[i].toss); n; n = next) { in dlm_clear_toss()
945 rb_erase(n, &ls->ls_rsbtbl[i].toss); in dlm_clear_toss()
949 spin_unlock(&ls->ls_rsbtbl[i].lock); in dlm_clear_toss()
953 log_rinfo(ls, "dlm_clear_toss %u done", count); in dlm_clear_toss()