Lines Matching refs:ls
29 static int enable_locking(struct dlm_ls *ls, uint64_t seq)
33 spin_lock(&ls->ls_recover_lock);
34 if (ls->ls_recover_seq == seq) {
35 set_bit(LSFL_RUNNING, &ls->ls_flags);
36 up_write(&ls->ls_in_recovery);
39 spin_unlock(&ls->ls_recover_lock);
43 static int ls_recover(struct dlm_ls *ls, struct dlm_recover *rv)
48 log_debug(ls, "recover %llx", (unsigned long long)rv->seq);
50 mutex_lock(&ls->ls_recoverd_active);
53 * Suspending and resuming dlm_astd ensures that no lkb's from this ls
65 dlm_create_root_list(ls);
71 dlm_clear_toss_list(ls);
78 error = dlm_recover_members(ls, rv, &neg);
80 log_debug(ls, "recover_members failed %d", error);
90 error = dlm_recover_directory(ls);
92 log_debug(ls, "recover_directory failed %d", error);
100 error = dlm_recover_directory_wait(ls);
102 log_debug(ls, "recover_directory_wait failed %d", error);
112 dlm_recover_waiters_pre(ls);
114 error = dlm_recovery_stopped(ls);
118 if (neg || dlm_no_directory(ls)) {
123 dlm_purge_locks(ls);
130 error = dlm_recover_masters(ls);
132 log_debug(ls, "recover_masters failed %d", error);
140 error = dlm_recover_locks(ls);
142 log_debug(ls, "recover_locks failed %d", error);
146 error = dlm_recover_locks_wait(ls);
148 log_debug(ls, "recover_locks_wait failed %d", error);
158 dlm_recover_rsbs(ls);
165 dlm_set_recover_status(ls, DLM_RS_LOCKS);
167 error = dlm_recover_locks_wait(ls);
169 log_debug(ls, "recover_locks_wait failed %d", error);
174 dlm_release_root_list(ls);
182 dlm_purge_requestqueue(ls);
184 dlm_set_recover_status(ls, DLM_RS_DONE);
185 error = dlm_recover_done_wait(ls);
187 log_debug(ls, "recover_done_wait failed %d", error);
191 dlm_clear_members_gone(ls);
193 error = enable_locking(ls, rv->seq);
195 log_debug(ls, "enable_locking failed %d", error);
199 error = dlm_process_requestqueue(ls);
201 log_debug(ls, "process_requestqueue failed %d", error);
205 error = dlm_recover_waiters_post(ls);
207 log_debug(ls, "recover_waiters_post failed %d", error);
211 dlm_grant_after_purge(ls);
215 log_debug(ls, "recover %llx done: %u ms",
218 mutex_unlock(&ls->ls_recoverd_active);
223 dlm_release_root_list(ls);
224 log_debug(ls, "recover %llx error %d",
226 mutex_unlock(&ls->ls_recoverd_active);
234 static void do_ls_recovery(struct dlm_ls *ls)
238 spin_lock(&ls->ls_recover_lock);
239 rv = ls->ls_recover_args;
240 ls->ls_recover_args = NULL;
241 if (rv && ls->ls_recover_seq == rv->seq)
242 clear_bit(LSFL_RECOVERY_STOP, &ls->ls_flags);
243 spin_unlock(&ls->ls_recover_lock);
246 ls_recover(ls, rv);
254 struct dlm_ls *ls;
256 ls = dlm_find_lockspace_local(arg);
257 if (!ls) {
264 if (!test_bit(LSFL_WORK, &ls->ls_flags))
268 if (test_and_clear_bit(LSFL_WORK, &ls->ls_flags))
269 do_ls_recovery(ls);
272 dlm_put_lockspace(ls);
276 void dlm_recoverd_kick(struct dlm_ls *ls)
278 set_bit(LSFL_WORK, &ls->ls_flags);
279 wake_up_process(ls->ls_recoverd_task);
282 int dlm_recoverd_start(struct dlm_ls *ls)
287 p = kthread_run(dlm_recoverd, ls, "dlm_recoverd");
291 ls->ls_recoverd_task = p;
295 void dlm_recoverd_stop(struct dlm_ls *ls)
297 kthread_stop(ls->ls_recoverd_task);
300 void dlm_recoverd_suspend(struct dlm_ls *ls)
302 wake_up(&ls->ls_wait_general);
303 mutex_lock(&ls->ls_recoverd_active);
306 void dlm_recoverd_resume(struct dlm_ls *ls)
308 mutex_unlock(&ls->ls_recoverd_active);