Lines Matching defs:ls
54 struct dlm_ls *ls = lkb->lkb_resource->res_ls;
79 log_debug(ls, "skip %x add bast %llu mode %d "
101 log_error(ls, "no callbacks %x %llu flags %x mode %d sb %d %x",
112 int dlm_rem_lkb_callback(struct dlm_ls *ls, struct dlm_lkb *lkb,
147 log_debug(ls, "skip %x bast %llu mode %d "
176 struct dlm_ls *ls = lkb->lkb_resource->res_ls;
201 mutex_lock(&ls->ls_cb_mutex);
202 if (test_bit(LSFL_CB_DELAY, &ls->ls_flags)) {
203 list_add(&lkb->lkb_cb_list, &ls->ls_cb_delay);
205 queue_work(ls->ls_callback_wq, &lkb->lkb_cb_work);
207 mutex_unlock(&ls->ls_cb_mutex);
216 struct dlm_ls *ls = lkb->lkb_resource->res_ls;
227 log_error(ls, "dlm_callback_work %x no work", lkb->lkb_id);
233 rv = dlm_rem_lkb_callback(ls, lkb, &callbacks[i], &resid);
240 log_error(ls, "dlm_callback_work %x resid %d", lkb->lkb_id,
268 int dlm_callback_start(struct dlm_ls *ls)
270 ls->ls_callback_wq = alloc_workqueue("dlm_callback",
272 if (!ls->ls_callback_wq) {
279 void dlm_callback_stop(struct dlm_ls *ls)
281 if (ls->ls_callback_wq)
282 destroy_workqueue(ls->ls_callback_wq);
285 void dlm_callback_suspend(struct dlm_ls *ls)
287 mutex_lock(&ls->ls_cb_mutex);
288 set_bit(LSFL_CB_DELAY, &ls->ls_flags);
289 mutex_unlock(&ls->ls_cb_mutex);
291 if (ls->ls_callback_wq)
292 flush_workqueue(ls->ls_callback_wq);
297 void dlm_callback_resume(struct dlm_ls *ls)
302 clear_bit(LSFL_CB_DELAY, &ls->ls_flags);
304 if (!ls->ls_callback_wq)
308 mutex_lock(&ls->ls_cb_mutex);
309 list_for_each_entry_safe(lkb, safe, &ls->ls_cb_delay, lkb_cb_list) {
311 queue_work(ls->ls_callback_wq, &lkb->lkb_cb_work);
316 mutex_unlock(&ls->ls_cb_mutex);
319 log_rinfo(ls, "dlm_callback_resume %d", count);