54 	struct dlm_ls *ls = lkb->lkb_resource->res_ls;  in dlm_add_lkb_callback()  local
79 				log_debug(ls, "skip %x add bast %llu mode %d "  in dlm_add_lkb_callback()
101 		log_error(ls, "no callbacks %x %llu flags %x mode %d sb %d %x",  in dlm_add_lkb_callback()
112 int dlm_rem_lkb_callback(struct dlm_ls *ls, struct dlm_lkb *lkb,  in dlm_rem_lkb_callback()  argument
147 			log_debug(ls, "skip %x bast %llu mode %d "  in dlm_rem_lkb_callback()
176 	struct dlm_ls *ls = lkb->lkb_resource->res_ls;  in dlm_add_cb()  local
201 		if (test_bit(LSFL_CB_DELAY, &ls->ls_flags)) {  in dlm_add_cb()
202 			mutex_lock(&ls->ls_cb_mutex);  in dlm_add_cb()
203 			list_add(&lkb->lkb_cb_list, &ls->ls_cb_delay);  in dlm_add_cb()
204 			mutex_unlock(&ls->ls_cb_mutex);  in dlm_add_cb()
206 			queue_work(ls->ls_callback_wq, &lkb->lkb_cb_work);  in dlm_add_cb()
216 	struct dlm_ls *ls = lkb->lkb_resource->res_ls;  in dlm_callback_work()  local
227 		log_error(ls, "dlm_callback_work %x no work", lkb->lkb_id);  in dlm_callback_work()
233 		rv = dlm_rem_lkb_callback(ls, lkb, &callbacks[i], &resid);  in dlm_callback_work()
240 		log_error(ls, "dlm_callback_work %x resid %d", lkb->lkb_id,  in dlm_callback_work()
268 int dlm_callback_start(struct dlm_ls *ls)  in dlm_callback_start()  argument
270 	ls->ls_callback_wq = alloc_workqueue("dlm_callback",  in dlm_callback_start()
272 	if (!ls->ls_callback_wq) {  in dlm_callback_start()
279 void dlm_callback_stop(struct dlm_ls *ls)  in dlm_callback_stop()  argument
281 	if (ls->ls_callback_wq)  in dlm_callback_stop()
282 		destroy_workqueue(ls->ls_callback_wq);  in dlm_callback_stop()
285 void dlm_callback_suspend(struct dlm_ls *ls)  in dlm_callback_suspend()  argument
287 	set_bit(LSFL_CB_DELAY, &ls->ls_flags);  in dlm_callback_suspend()
289 	if (ls->ls_callback_wq)  in dlm_callback_suspend()
290 		flush_workqueue(ls->ls_callback_wq);  in dlm_callback_suspend()
295 void dlm_callback_resume(struct dlm_ls *ls)  in dlm_callback_resume()  argument
300 	clear_bit(LSFL_CB_DELAY, &ls->ls_flags);  in dlm_callback_resume()
302 	if (!ls->ls_callback_wq)  in dlm_callback_resume()
306 	mutex_lock(&ls->ls_cb_mutex);  in dlm_callback_resume()
307 	list_for_each_entry_safe(lkb, safe, &ls->ls_cb_delay, lkb_cb_list) {  in dlm_callback_resume()
309 		queue_work(ls->ls_callback_wq, &lkb->lkb_cb_work);  in dlm_callback_resume()
314 	mutex_unlock(&ls->ls_cb_mutex);  in dlm_callback_resume()
317 		log_rinfo(ls, "dlm_callback_resume %d", count);  in dlm_callback_resume()