Lines Matching refs:dlm_ls
91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid);
205 static inline void dlm_lock_recovery(struct dlm_ls *ls) in dlm_lock_recovery()
210 void dlm_unlock_recovery(struct dlm_ls *ls) in dlm_unlock_recovery()
215 int dlm_lock_recovery_try(struct dlm_ls *ls) in dlm_lock_recovery_try()
353 struct dlm_ls *ls = r->res_ls; in put_rsb()
368 static int pre_rsb_struct(struct dlm_ls *ls) in pre_rsb_struct()
404 static int get_rsb_struct(struct dlm_ls *ls, const void *name, int len, in get_rsb_struct()
550 static int find_rsb_dir(struct dlm_ls *ls, const void *name, int len, in find_rsb_dir()
728 static int find_rsb_nodir(struct dlm_ls *ls, const void *name, int len, in find_rsb_nodir()
822 static int find_rsb(struct dlm_ls *ls, const void *name, int len, in find_rsb()
848 static int validate_master_nodeid(struct dlm_ls *ls, struct dlm_rsb *r, in validate_master_nodeid()
888 static void __dlm_master_lookup(struct dlm_ls *ls, struct dlm_rsb *r, int our_nodeid, in __dlm_master_lookup()
999 int dlm_master_lookup(struct dlm_ls *ls, int from_nodeid, char *name, int len, in dlm_master_lookup()
1104 static void dlm_dump_rsb_hash(struct dlm_ls *ls, uint32_t hash) in dlm_dump_rsb_hash()
1121 void dlm_dump_rsb_name(struct dlm_ls *ls, char *name, int len) in dlm_dump_rsb_name()
1147 struct dlm_ls *ls = r->res_ls; in toss_rsb()
1202 static int _create_lkb(struct dlm_ls *ls, struct dlm_lkb **lkb_ret, in _create_lkb()
1242 static int create_lkb(struct dlm_ls *ls, struct dlm_lkb **lkb_ret) in create_lkb()
1247 static int find_lkb(struct dlm_ls *ls, uint32_t lkid, struct dlm_lkb **lkb_ret) in find_lkb()
1274 static int __put_lkb(struct dlm_ls *ls, struct dlm_lkb *lkb) in __put_lkb()
1298 struct dlm_ls *ls; in dlm_put_lkb()
1421 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in add_to_waiters()
1479 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in _remove_from_waiters()
1565 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in remove_from_waiters()
1579 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in remove_from_waiters_ms()
1601 struct dlm_ls *ls = r->res_ls; in wait_pending_remove()
1621 static void shrink_bucket(struct dlm_ls *ls, int b) in shrink_bucket()
1774 void dlm_scan_rsbs(struct dlm_ls *ls) in dlm_scan_rsbs()
1789 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in add_timeout()
1813 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in del_timeout()
1829 void dlm_scan_timeout(struct dlm_ls *ls) in dlm_scan_timeout()
1897 void dlm_adjust_timeouts(struct dlm_ls *ls) in dlm_adjust_timeouts()
2866 static int validate_lock_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in validate_lock_args()
2936 struct dlm_ls *ls = lkb->lkb_resource->res_ls; in validate_unlock_args()
3325 static int request_lock(struct dlm_ls *ls, struct dlm_lkb *lkb, in request_lock()
3352 static int convert_lock(struct dlm_ls *ls, struct dlm_lkb *lkb, in convert_lock()
3374 static int unlock_lock(struct dlm_ls *ls, struct dlm_lkb *lkb, in unlock_lock()
3396 static int cancel_lock(struct dlm_ls *ls, struct dlm_lkb *lkb, in cancel_lock()
3433 struct dlm_ls *ls; in dlm_lock()
3490 struct dlm_ls *ls; in dlm_unlock()
3552 static int _create_message(struct dlm_ls *ls, int mb_len, in _create_message()
3861 static int send_lookup_reply(struct dlm_ls *ls, struct dlm_message *ms_in, in send_lookup_reply()
3910 static int receive_lvb(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_lvb()
3938 static int receive_request_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_request_args()
3960 static int receive_convert_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_convert_args()
3975 static int receive_unlock_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_unlock_args()
3986 static void setup_stub_lkb(struct dlm_ls *ls, struct dlm_message *ms) in setup_stub_lkb()
4047 static void send_repeat_remove(struct dlm_ls *ls, char *ms_name, int len) in send_repeat_remove()
4107 static int receive_request(struct dlm_ls *ls, struct dlm_message *ms) in receive_request()
4200 static int receive_convert(struct dlm_ls *ls, struct dlm_message *ms) in receive_convert()
4256 static int receive_unlock(struct dlm_ls *ls, struct dlm_message *ms) in receive_unlock()
4308 static int receive_cancel(struct dlm_ls *ls, struct dlm_message *ms) in receive_cancel()
4344 static int receive_grant(struct dlm_ls *ls, struct dlm_message *ms) in receive_grant()
4375 static int receive_bast(struct dlm_ls *ls, struct dlm_message *ms) in receive_bast()
4403 static void receive_lookup(struct dlm_ls *ls, struct dlm_message *ms) in receive_lookup()
4423 static void receive_remove(struct dlm_ls *ls, struct dlm_message *ms) in receive_remove()
4511 static void receive_purge(struct dlm_ls *ls, struct dlm_message *ms) in receive_purge()
4516 static int receive_request_reply(struct dlm_ls *ls, struct dlm_message *ms) in receive_request_reply()
4705 static int receive_convert_reply(struct dlm_ls *ls, struct dlm_message *ms) in receive_convert_reply()
4755 static int receive_unlock_reply(struct dlm_ls *ls, struct dlm_message *ms) in receive_unlock_reply()
4806 static int receive_cancel_reply(struct dlm_ls *ls, struct dlm_message *ms) in receive_cancel_reply()
4820 static void receive_lookup_reply(struct dlm_ls *ls, struct dlm_message *ms) in receive_lookup_reply()
4899 static void _receive_message(struct dlm_ls *ls, struct dlm_message *ms, in _receive_message()
5035 static void dlm_receive_message(struct dlm_ls *ls, struct dlm_message *ms, in dlm_receive_message()
5058 void dlm_receive_message_saved(struct dlm_ls *ls, struct dlm_message *ms, in dlm_receive_message_saved()
5072 struct dlm_ls *ls; in dlm_receive_buffer()
5124 static void recover_convert_waiter(struct dlm_ls *ls, struct dlm_lkb *lkb, in recover_convert_waiter()
5152 static int waiter_needs_recovery(struct dlm_ls *ls, struct dlm_lkb *lkb, in waiter_needs_recovery()
5170 void dlm_recover_waiters_pre(struct dlm_ls *ls) in dlm_recover_waiters_pre()
5281 static struct dlm_lkb *find_resend_waiter(struct dlm_ls *ls) in find_resend_waiter()
5314 int dlm_recover_waiters_post(struct dlm_ls *ls) in dlm_recover_waiters_post()
5415 static void purge_mstcpy_list(struct dlm_ls *ls, struct dlm_rsb *r, in purge_mstcpy_list()
5440 struct dlm_ls *ls = r->res_ls; in dlm_purge_mstcpy_locks()
5447 static void purge_dead_list(struct dlm_ls *ls, struct dlm_rsb *r, in purge_dead_list()
5482 void dlm_recover_purge(struct dlm_ls *ls) in dlm_recover_purge()
5524 static struct dlm_rsb *find_grant_rsb(struct dlm_ls *ls, int bucket) in find_grant_rsb()
5564 void dlm_recover_grant(struct dlm_ls *ls) in dlm_recover_grant()
5628 static int receive_rcom_lock_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_rcom_lock_args()
5679 int dlm_recover_master_copy(struct dlm_ls *ls, struct dlm_rcom *rc) in dlm_recover_master_copy()
5759 int dlm_recover_process_copy(struct dlm_ls *ls, struct dlm_rcom *rc) in dlm_recover_process_copy()
5828 int dlm_user_request(struct dlm_ls *ls, struct dlm_user_args *ua, in dlm_user_request()
5832 int dlm_user_request(struct dlm_ls *ls, struct dlm_user_args *ua, in dlm_user_request()
5908 int dlm_user_convert(struct dlm_ls *ls, struct dlm_user_args *ua_tmp, in dlm_user_convert()
5912 int dlm_user_convert(struct dlm_ls *ls, struct dlm_user_args *ua_tmp, in dlm_user_convert()
5980 int dlm_user_adopt_orphan(struct dlm_ls *ls, struct dlm_user_args *ua_tmp, in dlm_user_adopt_orphan()
6045 int dlm_user_unlock(struct dlm_ls *ls, struct dlm_user_args *ua_tmp, in dlm_user_unlock()
6097 int dlm_user_cancel(struct dlm_ls *ls, struct dlm_user_args *ua_tmp, in dlm_user_cancel()
6138 int dlm_user_deadlock(struct dlm_ls *ls, uint32_t flags, uint32_t lkid) in dlm_user_deadlock()
6192 static int orphan_proc_lock(struct dlm_ls *ls, struct dlm_lkb *lkb) in orphan_proc_lock()
6215 static int unlock_proc_lock(struct dlm_ls *ls, struct dlm_lkb *lkb) in unlock_proc_lock()
6233 static struct dlm_lkb *del_proc_lock(struct dlm_ls *ls, in del_proc_lock()
6264 void dlm_clear_proc_locks(struct dlm_ls *ls, struct dlm_user_proc *proc) in dlm_clear_proc_locks()
6307 static void purge_proc_locks(struct dlm_ls *ls, struct dlm_user_proc *proc) in purge_proc_locks()
6349 static void do_purge(struct dlm_ls *ls, int nodeid, int pid) in do_purge()
6364 static int send_purge(struct dlm_ls *ls, int nodeid, int pid) in send_purge()
6380 int dlm_user_purge(struct dlm_ls *ls, struct dlm_user_proc *proc, in dlm_user_purge()
6399 int dlm_debug_add_lkb(struct dlm_ls *ls, uint32_t lkb_id, char *name, int len, in dlm_debug_add_lkb()
6444 int dlm_debug_add_lkb_to_waiters(struct dlm_ls *ls, uint32_t lkb_id, in dlm_debug_add_lkb_to_waiters()