Lines Matching refs:dlm_lkb
78 static int send_request(struct dlm_rsb *r, struct dlm_lkb *lkb);
79 static int send_convert(struct dlm_rsb *r, struct dlm_lkb *lkb);
80 static int send_unlock(struct dlm_rsb *r, struct dlm_lkb *lkb);
81 static int send_cancel(struct dlm_rsb *r, struct dlm_lkb *lkb);
82 static int send_grant(struct dlm_rsb *r, struct dlm_lkb *lkb);
83 static int send_bast(struct dlm_rsb *r, struct dlm_lkb *lkb, int mode);
84 static int send_lookup(struct dlm_rsb *r, struct dlm_lkb *lkb);
86 static int _request_lock(struct dlm_rsb *r, struct dlm_lkb *lkb);
87 static int _cancel_lock(struct dlm_rsb *r, struct dlm_lkb *lkb);
88 static void __receive_convert_reply(struct dlm_rsb *r, struct dlm_lkb *lkb,
92 static void del_timeout(struct dlm_lkb *lkb);
162 void dlm_print_lkb(struct dlm_lkb *lkb) in dlm_print_lkb()
183 struct dlm_lkb *lkb; in dlm_dump_rsb()
220 static inline int can_be_queued(struct dlm_lkb *lkb) in can_be_queued()
225 static inline int force_blocking_asts(struct dlm_lkb *lkb) in force_blocking_asts()
230 static inline int is_demoted(struct dlm_lkb *lkb) in is_demoted()
235 static inline int is_altmode(struct dlm_lkb *lkb) in is_altmode()
240 static inline int is_granted(struct dlm_lkb *lkb) in is_granted()
251 static inline int is_process_copy(struct dlm_lkb *lkb) in is_process_copy()
256 static inline int is_master_copy(struct dlm_lkb *lkb) in is_master_copy()
261 static inline int middle_conversion(struct dlm_lkb *lkb) in middle_conversion()
269 static inline int down_conversion(struct dlm_lkb *lkb) in down_conversion()
274 static inline int is_overlap_unlock(struct dlm_lkb *lkb) in is_overlap_unlock()
279 static inline int is_overlap_cancel(struct dlm_lkb *lkb) in is_overlap_cancel()
284 static inline int is_overlap(struct dlm_lkb *lkb) in is_overlap()
290 static void queue_cast(struct dlm_rsb *r, struct dlm_lkb *lkb, int rv) in queue_cast()
316 static inline void queue_cast_overlap(struct dlm_rsb *r, struct dlm_lkb *lkb) in queue_cast_overlap()
322 static void queue_bast(struct dlm_rsb *r, struct dlm_lkb *lkb, int rqmode) in queue_bast()
1188 static void attach_lkb(struct dlm_rsb *r, struct dlm_lkb *lkb) in attach_lkb()
1194 static void detach_lkb(struct dlm_lkb *lkb) in detach_lkb()
1202 static int _create_lkb(struct dlm_ls *ls, struct dlm_lkb **lkb_ret, in _create_lkb()
1205 struct dlm_lkb *lkb; 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()
1249 struct dlm_lkb *lkb; in find_lkb()
1263 struct dlm_lkb *lkb = container_of(kref, struct dlm_lkb, lkb_ref); in kill_lkb()
1274 static int __put_lkb(struct dlm_ls *ls, struct dlm_lkb *lkb) in __put_lkb()
1296 int dlm_put_lkb(struct dlm_lkb *lkb) in dlm_put_lkb()
1310 static inline void hold_lkb(struct dlm_lkb *lkb) in hold_lkb()
1317 struct dlm_lkb *lkb = container_of(kref, struct dlm_lkb, lkb_ref); in unhold_lkb_assert()
1327 static inline void unhold_lkb(struct dlm_lkb *lkb) in unhold_lkb()
1335 struct dlm_lkb *lkb = NULL, *iter; in lkb_add_ordered()
1350 static void add_lkb(struct dlm_rsb *r, struct dlm_lkb *lkb, int status) in add_lkb()
1384 static void del_lkb(struct dlm_rsb *r, struct dlm_lkb *lkb) in del_lkb()
1391 static void move_lkb(struct dlm_rsb *r, struct dlm_lkb *lkb, int sts) in move_lkb()
1419 static int add_to_waiters(struct dlm_lkb *lkb, int mstype, int to_nodeid) in add_to_waiters()
1476 static int _remove_from_waiters(struct dlm_lkb *lkb, int mstype, in _remove_from_waiters()
1563 static int remove_from_waiters(struct dlm_lkb *lkb, int mstype) in remove_from_waiters()
1577 static int remove_from_waiters_ms(struct dlm_lkb *lkb, struct dlm_message *ms) in remove_from_waiters_ms()
1787 static void add_timeout(struct dlm_lkb *lkb) in add_timeout()
1811 static void del_timeout(struct dlm_lkb *lkb) in del_timeout()
1832 struct dlm_lkb *lkb = NULL, *iter; in dlm_scan_timeout()
1899 struct dlm_lkb *lkb; in dlm_adjust_timeouts()
1909 static void add_timeout(struct dlm_lkb *lkb) { } in add_timeout()
1910 static void del_timeout(struct dlm_lkb *lkb) { } in del_timeout()
1915 static void set_lvb_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in set_lvb_lock()
1966 static void set_lvb_unlock(struct dlm_rsb *r, struct dlm_lkb *lkb) in set_lvb_unlock()
1995 static void set_lvb_lock_pc(struct dlm_rsb *r, struct dlm_lkb *lkb, in set_lvb_lock_pc()
2026 static void _remove_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _remove_lock()
2035 static void remove_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in remove_lock()
2041 static void remove_lock_pc(struct dlm_rsb *r, struct dlm_lkb *lkb) in remove_lock_pc()
2050 static int revert_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in revert_lock()
2077 static int revert_lock_pc(struct dlm_rsb *r, struct dlm_lkb *lkb) in revert_lock_pc()
2082 static void _grant_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _grant_lock()
2096 static void grant_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in grant_lock()
2102 static void grant_lock_pc(struct dlm_rsb *r, struct dlm_lkb *lkb, in grant_lock_pc()
2113 static void grant_lock_pending(struct dlm_rsb *r, struct dlm_lkb *lkb) in grant_lock_pending()
2130 static void munge_demoted(struct dlm_lkb *lkb) in munge_demoted()
2141 static void munge_altmode(struct dlm_lkb *lkb, struct dlm_message *ms) in munge_altmode()
2160 static inline int first_in_list(struct dlm_lkb *lkb, struct list_head *head) in first_in_list()
2162 struct dlm_lkb *first = list_entry(head->next, struct dlm_lkb, in first_in_list()
2172 static int queue_conflict(struct list_head *head, struct dlm_lkb *lkb) in queue_conflict()
2174 struct dlm_lkb *this; in queue_conflict()
2226 static int conversion_deadlock_detect(struct dlm_rsb *r, struct dlm_lkb *lkb2) in conversion_deadlock_detect()
2228 struct dlm_lkb *lkb1; in conversion_deadlock_detect()
2265 static int _can_be_granted(struct dlm_rsb *r, struct dlm_lkb *lkb, int now, in _can_be_granted()
2411 static int can_be_granted(struct dlm_rsb *r, struct dlm_lkb *lkb, int now, in can_be_granted()
2476 struct dlm_lkb *lkb, *s; in grant_pending_convert()
2545 struct dlm_lkb *lkb, *s; in grant_pending_wait()
2567 static int lock_requires_bast(struct dlm_lkb *gr, int high, int cw) in lock_requires_bast()
2583 struct dlm_lkb *lkb, *s; in grant_pending_locks()
2617 static int modes_require_bast(struct dlm_lkb *gr, struct dlm_lkb *rq) in modes_require_bast()
2632 struct dlm_lkb *lkb) in send_bast_queue()
2634 struct dlm_lkb *gr; in send_bast_queue()
2647 static void send_blocking_asts(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_blocking_asts()
2652 static void send_blocking_asts_all(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_blocking_asts_all()
2677 static int set_master(struct dlm_rsb *r, struct dlm_lkb *lkb) in set_master()
2728 struct dlm_lkb *lkb, *safe; in process_lookup_list()
2741 struct dlm_lkb *lkb; in confirm_master()
2763 lkb = list_entry(r->res_lookup.next, struct dlm_lkb, in confirm_master()
2866 static int validate_lock_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in validate_lock_args()
2934 static int validate_unlock_args(struct dlm_lkb *lkb, struct dlm_args *args) in validate_unlock_args()
3085 static int do_request(struct dlm_rsb *r, struct dlm_lkb *lkb) in do_request()
3108 static void do_request_effects(struct dlm_rsb *r, struct dlm_lkb *lkb, in do_request_effects()
3122 static int do_convert(struct dlm_rsb *r, struct dlm_lkb *lkb) in do_convert()
3177 static void do_convert_effects(struct dlm_rsb *r, struct dlm_lkb *lkb, in do_convert_effects()
3195 static int do_unlock(struct dlm_rsb *r, struct dlm_lkb *lkb) in do_unlock()
3202 static void do_unlock_effects(struct dlm_rsb *r, struct dlm_lkb *lkb, in do_unlock_effects()
3210 static int do_cancel(struct dlm_rsb *r, struct dlm_lkb *lkb) in do_cancel()
3222 static void do_cancel_effects(struct dlm_rsb *r, struct dlm_lkb *lkb, in do_cancel_effects()
3236 static int _request_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _request_lock()
3265 static int _convert_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _convert_lock()
3284 static int _unlock_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _unlock_lock()
3303 static int _cancel_lock(struct dlm_rsb *r, struct dlm_lkb *lkb) in _cancel_lock()
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()
3434 struct dlm_lkb *lkb; in dlm_lock()
3491 struct dlm_lkb *lkb; in dlm_unlock()
3584 static int create_message(struct dlm_rsb *r, struct dlm_lkb *lkb, in create_message()
3620 static void send_args(struct dlm_rsb *r, struct dlm_lkb *lkb, in send_args()
3664 static int send_common(struct dlm_rsb *r, struct dlm_lkb *lkb, int mstype) in send_common()
3692 static int send_request(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_request()
3697 static int send_convert(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_convert()
3719 static int send_unlock(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_unlock()
3724 static int send_cancel(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_cancel()
3729 static int send_grant(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_grant()
3750 static int send_bast(struct dlm_rsb *r, struct dlm_lkb *lkb, int mode) in send_bast()
3771 static int send_lookup(struct dlm_rsb *r, struct dlm_lkb *lkb) in send_lookup()
3819 static int send_common_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, in send_common_reply()
3841 static int send_request_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, int rv) in send_request_reply()
3846 static int send_convert_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, int rv) in send_convert_reply()
3851 static int send_unlock_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, int rv) in send_unlock_reply()
3856 static int send_cancel_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, int rv) in send_cancel_reply()
3886 static void receive_flags(struct dlm_lkb *lkb, struct dlm_message *ms) in receive_flags()
3894 static void receive_flags_reply(struct dlm_lkb *lkb, struct dlm_message *ms) in receive_flags_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()
3988 struct dlm_lkb *lkb = &ls->ls_stub_lkb; in setup_stub_lkb()
3996 static int validate_message(struct dlm_lkb *lkb, struct dlm_message *ms) in validate_message()
4109 struct dlm_lkb *lkb; in receive_request()
4202 struct dlm_lkb *lkb; in receive_convert()
4258 struct dlm_lkb *lkb; in receive_unlock()
4310 struct dlm_lkb *lkb; in receive_cancel()
4346 struct dlm_lkb *lkb; in receive_grant()
4377 struct dlm_lkb *lkb; in receive_bast()
4518 struct dlm_lkb *lkb; in receive_request_reply()
4637 static void __receive_convert_reply(struct dlm_rsb *r, struct dlm_lkb *lkb, in __receive_convert_reply()
4682 static void _receive_convert_reply(struct dlm_lkb *lkb, struct dlm_message *ms) in _receive_convert_reply()
4707 struct dlm_lkb *lkb; in receive_convert_reply()
4719 static void _receive_unlock_reply(struct dlm_lkb *lkb, struct dlm_message *ms) in _receive_unlock_reply()
4757 struct dlm_lkb *lkb; in receive_unlock_reply()
4769 static void _receive_cancel_reply(struct dlm_lkb *lkb, struct dlm_message *ms) in _receive_cancel_reply()
4808 struct dlm_lkb *lkb; in receive_cancel_reply()
4822 struct dlm_lkb *lkb; in receive_lookup_reply()
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()
5172 struct dlm_lkb *lkb, *safe; in dlm_recover_waiters_pre()
5281 static struct dlm_lkb *find_resend_waiter(struct dlm_ls *ls) in find_resend_waiter()
5283 struct dlm_lkb *lkb = NULL, *iter; in find_resend_waiter()
5316 struct dlm_lkb *lkb; in dlm_recover_waiters_post()
5418 struct dlm_lkb *lkb, *safe; in purge_mstcpy_list()
5451 struct dlm_lkb *lkb, *safe; in purge_dead_list()
5598 static struct dlm_lkb *search_remid_list(struct list_head *head, int nodeid, in search_remid_list()
5601 struct dlm_lkb *lkb; in search_remid_list()
5610 static struct dlm_lkb *search_remid(struct dlm_rsb *r, int nodeid, in search_remid()
5613 struct dlm_lkb *lkb; in search_remid()
5628 static int receive_rcom_lock_args(struct dlm_ls *ls, struct dlm_lkb *lkb, in receive_rcom_lock_args()
5683 struct dlm_lkb *lkb; in dlm_recover_master_copy()
5763 struct dlm_lkb *lkb; in dlm_recover_process_copy()
5836 struct dlm_lkb *lkb; in dlm_user_request()
5916 struct dlm_lkb *lkb; in dlm_user_convert()
5984 struct dlm_lkb *lkb = NULL, *iter; in dlm_user_adopt_orphan()
6048 struct dlm_lkb *lkb; in dlm_user_unlock()
6100 struct dlm_lkb *lkb; in dlm_user_cancel()
6140 struct dlm_lkb *lkb; 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()
6236 struct dlm_lkb *lkb = NULL; in del_proc_lock()
6242 lkb = list_entry(proc->locks.next, struct dlm_lkb, lkb_ownqueue); in del_proc_lock()
6266 struct dlm_lkb *lkb, *safe; in dlm_clear_proc_locks()
6309 struct dlm_lkb *lkb, *safe; in purge_proc_locks()
6315 lkb = list_entry(proc->locks.next, struct dlm_lkb, in purge_proc_locks()
6351 struct dlm_lkb *lkb, *safe; in do_purge()
6403 struct dlm_lkb *lkb; in dlm_debug_add_lkb()
6447 struct dlm_lkb *lkb; in dlm_debug_add_lkb_to_waiters()