| /linux/fs/dlm/ |
| H A D | recoverd.c | 23 static int dlm_create_masters_list(struct dlm_ls *ls) in dlm_create_masters_list() argument
28 write_lock_bh(&ls->ls_masters_lock); in dlm_create_masters_list()
29 if (!list_empty(&ls->ls_masters_list)) { in dlm_create_masters_list()
30 log_error(ls, "root list not empty"); in dlm_create_masters_list()
35 read_lock_bh(&ls->ls_rsbtbl_lock); in dlm_create_masters_list()
36 list_for_each_entry(r, &ls->ls_slow_active, res_slow_list) { in dlm_create_masters_list()
40 list_add(&r->res_masters_list, &ls->ls_masters_list); in dlm_create_masters_list()
43 read_unlock_bh(&ls->ls_rsbtbl_lock); in dlm_create_masters_list()
45 write_unlock_bh(&ls->ls_masters_lock); in dlm_create_masters_list()
49 static void dlm_release_masters_list(struct dlm_ls *ls) in dlm_release_masters_list() argument
61 dlm_create_root_list(struct dlm_ls * ls,struct list_head * root_list) dlm_create_root_list() argument
92 enable_locking(struct dlm_ls * ls,uint64_t seq) enable_locking() argument
122 ls_recover(struct dlm_ls * ls,struct dlm_recover * rv) ls_recover() argument
347 do_ls_recovery(struct dlm_ls * ls) do_ls_recovery() argument
392 struct dlm_ls *ls; dlm_recoverd() local
440 dlm_recoverd_start(struct dlm_ls * ls) dlm_recoverd_start() argument
453 dlm_recoverd_stop(struct dlm_ls * ls) dlm_recoverd_stop() argument
458 dlm_recoverd_suspend(struct dlm_ls * ls) dlm_recoverd_suspend() argument
464 dlm_recoverd_resume(struct dlm_ls * ls) dlm_recoverd_resume() argument
[all...] |
| H A D | lockspace.c | 33 static ssize_t dlm_control_store(struct dlm_ls *ls, const char *buf, size_t len) in dlm_control_store() argument
41 ls = dlm_find_lockspace_local(ls); in dlm_control_store()
42 if (!ls) in dlm_control_store()
47 dlm_ls_stop(ls); in dlm_control_store()
50 dlm_ls_start(ls); in dlm_control_store()
55 dlm_put_lockspace(ls); in dlm_control_store()
59 static ssize_t dlm_event_store(struct dlm_ls *ls, const char *buf, size_t len) in dlm_event_store() argument
61 int rc = kstrtoint(buf, 0, &ls->ls_uevent_result); in dlm_event_store()
65 set_bit(LSFL_UEVENT_WAIT, &ls in dlm_event_store()
70 dlm_id_show(struct dlm_ls * ls,char * buf) dlm_id_show() argument
75 dlm_id_store(struct dlm_ls * ls,const char * buf,size_t len) dlm_id_store() argument
84 dlm_nodir_show(struct dlm_ls * ls,char * buf) dlm_nodir_show() argument
89 dlm_nodir_store(struct dlm_ls * ls,const char * buf,size_t len) dlm_nodir_store() argument
101 dlm_recover_status_show(struct dlm_ls * ls,char * buf) dlm_recover_status_show() argument
107 dlm_recover_nodeid_show(struct dlm_ls * ls,char * buf) dlm_recover_nodeid_show() argument
164 struct dlm_ls *ls = container_of(kobj, struct dlm_ls, ls_kobj); dlm_attr_show() local
172 struct dlm_ls *ls = container_of(kobj, struct dlm_ls, ls_kobj); dlm_attr_store() local
189 do_uevent(struct dlm_ls * ls,int in) do_uevent() argument
211 const struct dlm_ls *ls = container_of(kobj, struct dlm_ls, ls_kobj); dlm_uevent() local
243 struct dlm_ls *ls; dlm_find_lockspace_global() local
261 struct dlm_ls *ls = lockspace; dlm_find_lockspace_local() local
269 struct dlm_ls *ls; dlm_find_lockspace_device() local
284 dlm_put_lockspace(struct dlm_ls * ls) dlm_put_lockspace() argument
290 remove_lockspace(struct dlm_ls * ls) remove_lockspace() argument
336 struct dlm_ls *ls = container_of(work, struct dlm_ls, ls_free_work); free_lockspace() local
361 struct dlm_ls *ls; new_lockspace() local
674 lockspace_busy(struct dlm_ls * ls,int force) lockspace_busy() argument
701 release_lockspace(struct dlm_ls * ls,int force) release_lockspace() argument
794 struct dlm_ls *ls; dlm_release_lockspace() local
815 struct dlm_ls *ls; dlm_stop_lockspaces() local
[all...] |
| H A D | member.c | 28 void dlm_slot_save(struct dlm_ls *ls, struct dlm_rcom *rc, in dlm_slot_save() argument
40 void dlm_slots_copy_out(struct dlm_ls *ls, struct dlm_rcom *rc) in dlm_slots_copy_out() argument
50 for (i = 0; i < ls->ls_slots_size; i++) { in dlm_slots_copy_out()
51 slot = &ls->ls_slots[i]; in dlm_slots_copy_out()
62 static void log_slots(struct dlm_ls *ls, uint32_t gen, int num_slots, in log_slots() argument
94 log_rinfo(ls, "generation %u slots %d%s", gen, num_slots, line); in log_slots()
97 int dlm_slots_copy_in(struct dlm_ls *ls) in dlm_slots_copy_in() argument
100 struct dlm_rcom *rc = ls->ls_recover_buf; in dlm_slots_copy_in()
111 if (gen <= ls->ls_generation) { in dlm_slots_copy_in()
112 log_error(ls, "dlm_slots_copy_i in dlm_slots_copy_in()
160 dlm_slots_assign(struct dlm_ls * ls,int * num_slots,int * slots_size,struct dlm_slot ** slots_out,uint32_t * gen_out) dlm_slots_assign() argument
286 add_ordered_member(struct dlm_ls * ls,struct dlm_member * new) add_ordered_member() argument
325 dlm_add_member(struct dlm_ls * ls,struct dlm_config_node * node) dlm_add_member() argument
360 dlm_is_member(struct dlm_ls * ls,int nodeid) dlm_is_member() argument
367 dlm_is_removed(struct dlm_ls * ls,int nodeid) dlm_is_removed() argument
398 dlm_clear_members(struct dlm_ls * ls) dlm_clear_members() argument
404 dlm_clear_members_gone(struct dlm_ls * ls) dlm_clear_members_gone() argument
409 make_member_array(struct dlm_ls * ls) make_member_array() argument
454 ping_members(struct dlm_ls * ls,uint64_t seq) ping_members() argument
474 dlm_lsop_recover_prep(struct dlm_ls * ls) dlm_lsop_recover_prep() argument
481 dlm_lsop_recover_slot(struct dlm_ls * ls,struct dlm_member * memb) dlm_lsop_recover_slot() argument
507 dlm_lsop_recover_done(struct dlm_ls * ls) dlm_lsop_recover_done() argument
550 dlm_recover_members(struct dlm_ls * ls,struct dlm_recover * rv,int * neg_out) dlm_recover_members() argument
620 dlm_ls_stop(struct dlm_ls * ls) dlm_ls_stop() argument
712 dlm_ls_start(struct dlm_ls * ls) dlm_ls_start() argument
[all...] |
| H A D | recover.c | 42 int dlm_wait_function(struct dlm_ls *ls, int (*testfn) (struct dlm_ls *ls)) in dlm_wait_function() argument
48 rv = wait_event_timeout(ls->ls_wait_general, in dlm_wait_function()
49 testfn(ls) || dlm_recovery_stopped(ls), in dlm_wait_function()
53 if (test_bit(LSFL_RCOM_WAIT, &ls->ls_flags)) { in dlm_wait_function()
54 log_debug(ls, "dlm_wait_function timed out"); in dlm_wait_function()
59 if (dlm_recovery_stopped(ls)) { in dlm_wait_function()
60 log_debug(ls, "dlm_wait_function aborted"); in dlm_wait_function()
74 uint32_t dlm_recover_status(struct dlm_ls *ls) in dlm_recover_status() argument
83 _set_recover_status(struct dlm_ls * ls,uint32_t status) _set_recover_status() argument
88 dlm_set_recover_status(struct dlm_ls * ls,uint32_t status) dlm_set_recover_status() argument
95 wait_status_all(struct dlm_ls * ls,uint32_t wait_status,int save_slots,uint64_t seq) wait_status_all() argument
128 wait_status_low(struct dlm_ls * ls,uint32_t wait_status,uint32_t status_flags,uint64_t seq) wait_status_low() argument
154 wait_status(struct dlm_ls * ls,uint32_t status,uint64_t seq) wait_status() argument
169 dlm_recover_members_wait(struct dlm_ls * ls,uint64_t seq) dlm_recover_members_wait() argument
213 dlm_recover_directory_wait(struct dlm_ls * ls,uint64_t seq) dlm_recover_directory_wait() argument
218 dlm_recover_locks_wait(struct dlm_ls * ls,uint64_t seq) dlm_recover_locks_wait() argument
223 dlm_recover_done_wait(struct dlm_ls * ls,uint64_t seq) dlm_recover_done_wait() argument
240 recover_list_empty(struct dlm_ls * ls) recover_list_empty() argument
253 struct dlm_ls *ls = r->res_ls; recover_list_add() local
266 struct dlm_ls *ls = r->res_ls; recover_list_del() local
276 recover_list_clear(struct dlm_ls * ls) recover_list_clear() argument
296 recover_xa_empty(struct dlm_ls * ls) recover_xa_empty() argument
310 struct dlm_ls *ls = r->res_ls; recover_xa_add() local
338 struct dlm_ls *ls = r->res_ls; recover_xa_del() local
349 recover_xa_find(struct dlm_ls * ls,uint64_t id) recover_xa_find() argument
359 recover_xa_clear(struct dlm_ls * ls) recover_xa_clear() argument
450 struct dlm_ls *ls = r->res_ls; recover_master() local
528 dlm_recover_masters(struct dlm_ls * ls,uint64_t seq,const struct list_head * root_list) dlm_recover_masters() argument
567 dlm_recover_master_reply(struct dlm_ls * ls,const struct dlm_rcom * rc) dlm_recover_master_reply() argument
661 dlm_recover_locks(struct dlm_ls * ls,uint64_t seq,const struct list_head * root_list) dlm_recover_locks() argument
819 struct dlm_ls *ls = r->res_ls; recover_conversion() local
864 dlm_recover_rsbs(struct dlm_ls * ls,const struct list_head * root_list) dlm_recover_rsbs() argument
895 dlm_clear_inactive(struct dlm_ls * ls) dlm_clear_inactive() argument
[all...] |
| H A D | rcom.c | 25 static int rcom_response(struct dlm_ls *ls) in rcom_response() argument
27 return test_bit(LSFL_RCOM_READY, &ls->ls_flags); in rcom_response()
30 static void _create_rcom(struct dlm_ls *ls, int to_nodeid, int type, int len, in _create_rcom() argument
39 rc->rc_header.u.h_lockspace = cpu_to_le32(ls->ls_global_id); in _create_rcom()
50 static int create_rcom(struct dlm_ls *ls, int to_nodeid, int type, int len, in create_rcom() argument
65 _create_rcom(ls, to_nodeid, type, len, rc_ret, mb, mb_len, seq); in create_rcom()
70 static int create_rcom_stateless(struct dlm_ls *ls, int to_nodeid, int type, in create_rcom_stateless() argument
85 _create_rcom(ls, to_nodeid, type, len, rc_ret, mb, mb_len, seq); in create_rcom_stateless()
101 static void set_rcom_status(struct dlm_ls *ls, struct rcom_status *rs, in set_rcom_status() argument
111 static void set_rcom_config(struct dlm_ls *ls, struc argument
122 check_rcom_config(struct dlm_ls * ls,struct dlm_rcom * rc,int nodeid) check_rcom_config() argument
144 allow_sync_reply(struct dlm_ls * ls,__le64 * new_seq) allow_sync_reply() argument
152 disallow_sync_reply(struct dlm_ls * ls) disallow_sync_reply() argument
171 dlm_rcom_status(struct dlm_ls * ls,int nodeid,uint32_t status_flags,uint64_t seq) dlm_rcom_status() argument
223 receive_rcom_status(struct dlm_ls * ls,const struct dlm_rcom * rc_in,uint64_t seq) receive_rcom_status() argument
286 receive_sync_reply(struct dlm_ls * ls,const struct dlm_rcom * rc_in) receive_sync_reply() argument
307 dlm_rcom_names(struct dlm_ls * ls,int nodeid,char * last_name,int last_len,uint64_t seq) dlm_rcom_names() argument
336 receive_rcom_names(struct dlm_ls * ls,const struct dlm_rcom * rc_in,uint64_t seq) receive_rcom_names() argument
364 struct dlm_ls *ls = r->res_ls; dlm_send_rcom_lookup() local
379 receive_rcom_lookup(struct dlm_ls * ls,const struct dlm_rcom * rc_in,uint64_t seq) receive_rcom_lookup() argument
411 receive_rcom_lookup_reply(struct dlm_ls * ls,const struct dlm_rcom * rc_in) receive_rcom_lookup_reply() argument
449 struct dlm_ls *ls = r->res_ls; dlm_send_rcom_lock() local
473 receive_rcom_lock(struct dlm_ls * ls,const struct dlm_rcom * rc_in,uint64_t seq) receive_rcom_lock() argument
582 dlm_receive_rcom(struct dlm_ls * ls,const struct dlm_rcom * rc,int nodeid) dlm_receive_rcom() argument
[all...] |
| H A D | dir.c | 33 int dlm_hash2nodeid(struct dlm_ls *ls, uint32_t hash) in dlm_hash2nodeid() argument
37 if (ls->ls_num_nodes == 1) in dlm_hash2nodeid()
40 node = (hash >> 16) % ls->ls_total_weight; in dlm_hash2nodeid()
41 return ls->ls_node_array[node]; in dlm_hash2nodeid()
50 void dlm_recover_dir_nodeid(struct dlm_ls *ls, const struct list_head *root_list) in dlm_recover_dir_nodeid() argument
55 r->res_dir_nodeid = dlm_hash2nodeid(ls, r->res_hash); in dlm_recover_dir_nodeid()
59 int dlm_recover_directory(struct dlm_ls *ls, uint64_t seq) in dlm_recover_directory() argument
67 log_rinfo(ls, "dlm_recover_directory"); in dlm_recover_directory()
69 if (dlm_no_directory(ls)) in dlm_recover_directory()
76 list_for_each_entry(memb, &ls in dlm_recover_directory()
197 find_rsb_root(struct dlm_ls * ls,const char * name,int len) find_rsb_root() argument
236 drop_dir_ctx(struct dlm_ls * ls,int nodeid) drop_dir_ctx() argument
252 lookup_dir_dump(struct dlm_ls * ls,int nodeid) lookup_dir_dump() argument
268 init_dir_dump(struct dlm_ls * ls,int nodeid) init_dir_dump() argument
297 dlm_copy_master_names(struct dlm_ls * ls,const char * inbuf,int inlen,char * outbuf,int outlen,int nodeid) dlm_copy_master_names() argument
[all...] |
| H A D | lock.c | 16 request_lock(ls, lkb)
17 convert_lock(ls, lkb)
18 unlock_lock(ls, lkb)
19 cancel_lock(ls, lkb)
91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid);
204 void dlm_lock_recovery(struct dlm_ls *ls) in dlm_lock_recovery() argument
206 down_read(&ls->ls_in_recovery); in dlm_lock_recovery()
209 void dlm_unlock_recovery(struct dlm_ls *ls) in dlm_unlock_recovery() argument
211 up_read(&ls->ls_in_recovery); in dlm_unlock_recovery()
214 int dlm_lock_recovery_try(struct dlm_ls *ls) in dlm_lock_recovery_try() argument
375 struct dlm_ls *ls = r->res_ls; put_rsb() local
393 enable_scan_timer(struct dlm_ls * ls,unsigned long jiffies) enable_scan_timer() argument
405 resume_scan_timer(struct dlm_ls * ls) resume_scan_timer() argument
419 del_scan(struct dlm_ls * ls,struct dlm_rsb * r) del_scan() argument
458 add_scan(struct dlm_ls * ls,struct dlm_rsb * r) add_scan() argument
512 struct dlm_ls *ls = timer_container_of(ls, timer, ls_scan_timer); dlm_rsb_scan() local
598 get_rsb_struct(struct dlm_ls * ls,const void * name,int len,struct dlm_rsb ** r_ret) get_rsb_struct() argument
694 find_rsb_dir(struct dlm_ls * ls,const void * name,int len,uint32_t hash,int dir_nodeid,int from_nodeid,unsigned int flags,struct dlm_rsb ** r_ret) find_rsb_dir() argument
918 find_rsb_nodir(struct dlm_ls * ls,const void * name,int len,uint32_t hash,int dir_nodeid,int from_nodeid,unsigned int flags,struct dlm_rsb ** r_ret) find_rsb_nodir() argument
1081 find_rsb(struct dlm_ls * ls,const void * name,int len,int from_nodeid,unsigned int flags,struct dlm_rsb ** r_ret) find_rsb() argument
1109 validate_master_nodeid(struct dlm_ls * ls,struct dlm_rsb * r,int from_nodeid) validate_master_nodeid() argument
1149 __dlm_master_lookup(struct dlm_ls * ls,struct dlm_rsb * r,int our_nodeid,int from_nodeid,bool is_inactive,unsigned int flags,int * r_nodeid,int * result) __dlm_master_lookup() argument
1260 _dlm_master_lookup(struct dlm_ls * ls,int from_nodeid,const char * name,int len,unsigned int flags,int * r_nodeid,int * result) _dlm_master_lookup() argument
1394 dlm_master_lookup(struct dlm_ls * ls,int from_nodeid,const char * name,int len,unsigned int flags,int * r_nodeid,int * result) dlm_master_lookup() argument
1404 dlm_dump_rsb_hash(struct dlm_ls * ls,uint32_t hash) dlm_dump_rsb_hash() argument
1416 dlm_dump_rsb_name(struct dlm_ls * ls,const char * name,int len) dlm_dump_rsb_name() argument
1434 struct dlm_ls *ls = r->res_ls; deactivate_rsb() local
1500 _create_lkb(struct dlm_ls * ls,struct dlm_lkb ** lkb_ret,unsigned long start,unsigned long end) _create_lkb() argument
1537 create_lkb(struct dlm_ls * ls,struct dlm_lkb ** lkb_ret) create_lkb() argument
1542 find_lkb(struct dlm_ls * ls,uint32_t lkid,struct dlm_lkb ** lkb_ret) find_lkb() argument
1579 __put_lkb(struct dlm_ls * ls,struct dlm_lkb * lkb) __put_lkb() argument
1603 struct dlm_ls *ls; dlm_put_lkb() local
1724 struct dlm_ls *ls = lkb->lkb_resource->res_ls; add_to_waiters() local
1773 struct dlm_ls *ls = lkb->lkb_resource->res_ls; _remove_from_waiters() local
1858 struct dlm_ls *ls = lkb->lkb_resource->res_ls; remove_from_waiters() local
1877 struct dlm_ls *ls = lkb->lkb_resource->res_ls; remove_from_waiters_ms() local
2829 validate_lock_args(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_args * args) validate_lock_args() argument
2894 struct dlm_ls *ls = lkb->lkb_resource->res_ls; validate_unlock_args() local
3275 request_lock(struct dlm_ls * ls,struct dlm_lkb * lkb,const void * name,int len,struct dlm_args * args) request_lock() argument
3302 convert_lock(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_args * args) convert_lock() argument
3324 unlock_lock(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_args * args) unlock_lock() argument
3346 cancel_lock(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_args * args) cancel_lock() argument
3383 struct dlm_ls *ls; dlm_lock() local
3435 struct dlm_ls *ls; dlm_unlock() local
3497 _create_message(struct dlm_ls * ls,int mb_len,int to_nodeid,int mstype,struct dlm_message ** ms_ret,struct dlm_mhandle ** mh_ret) _create_message() argument
3800 send_lookup_reply(struct dlm_ls * ls,const struct dlm_message * ms_in,int ret_nodeid,int rv) send_lookup_reply() argument
3850 receive_lvb(struct dlm_ls * ls,struct dlm_lkb * lkb,const struct dlm_message * ms) receive_lvb() argument
3878 receive_request_args(struct dlm_ls * ls,struct dlm_lkb * lkb,const struct dlm_message * ms) receive_request_args() argument
3900 receive_convert_args(struct dlm_ls * ls,struct dlm_lkb * lkb,const struct dlm_message * ms) receive_convert_args() argument
3915 receive_unlock_args(struct dlm_ls * ls,struct dlm_lkb * lkb,const struct dlm_message * ms) receive_unlock_args() argument
3926 setup_local_lkb(struct dlm_ls * ls,const struct dlm_message * ms) setup_local_lkb() argument
3988 receive_request(struct dlm_ls * ls,const struct dlm_message * ms) receive_request() argument
4067 receive_convert(struct dlm_ls * ls,const struct dlm_message * ms) receive_convert() argument
4123 receive_unlock(struct dlm_ls * ls,const struct dlm_message * ms) receive_unlock() argument
4175 receive_cancel(struct dlm_ls * ls,const struct dlm_message * ms) receive_cancel() argument
4211 receive_grant(struct dlm_ls * ls,const struct dlm_message * ms) receive_grant() argument
4242 receive_bast(struct dlm_ls * ls,const struct dlm_message * ms) receive_bast() argument
4270 receive_lookup(struct dlm_ls * ls,const struct dlm_message * ms) receive_lookup() argument
4290 receive_remove(struct dlm_ls * ls,const struct dlm_message * ms) receive_remove() argument
4385 receive_purge(struct dlm_ls * ls,const struct dlm_message * ms) receive_purge() argument
4390 receive_request_reply(struct dlm_ls * ls,const struct dlm_message * ms) receive_request_reply() argument
4579 receive_convert_reply(struct dlm_ls * ls,const struct dlm_message * ms) receive_convert_reply() argument
4630 receive_unlock_reply(struct dlm_ls * ls,const struct dlm_message * ms) receive_unlock_reply() argument
4682 receive_cancel_reply(struct dlm_ls * ls,const struct dlm_message * ms) receive_cancel_reply() argument
4697 receive_lookup_reply(struct dlm_ls * ls,const struct dlm_message * ms) receive_lookup_reply() argument
4777 _receive_message(struct dlm_ls * ls,const struct dlm_message * ms,uint32_t saved_seq) _receive_message() argument
4913 dlm_receive_message(struct dlm_ls * ls,const struct dlm_message * ms,int nodeid) dlm_receive_message() argument
4948 dlm_receive_message_saved(struct dlm_ls * ls,const struct dlm_message * ms,uint32_t saved_seq) dlm_receive_message_saved() argument
4962 struct dlm_ls *ls; dlm_receive_buffer() local
5014 recover_convert_waiter(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_message * ms_local) recover_convert_waiter() argument
5044 waiter_needs_recovery(struct dlm_ls * ls,struct dlm_lkb * lkb,int dir_nodeid) waiter_needs_recovery() argument
5062 dlm_recover_waiters_pre(struct dlm_ls * ls) dlm_recover_waiters_pre() argument
5168 find_resend_waiter(struct dlm_ls * ls) find_resend_waiter() argument
5212 dlm_recover_waiters_post(struct dlm_ls * ls) dlm_recover_waiters_post() argument
5340 purge_mstcpy_list(struct dlm_ls * ls,struct dlm_rsb * r,struct list_head * list) purge_mstcpy_list() argument
5365 struct dlm_ls *ls = r->res_ls; dlm_purge_mstcpy_locks() local
5372 purge_dead_list(struct dlm_ls * ls,struct dlm_rsb * r,struct list_head * list,int nodeid_gone,unsigned int * count) purge_dead_list() argument
5407 dlm_recover_purge(struct dlm_ls * ls,const struct list_head * root_list) dlm_recover_purge() argument
5446 find_grant_rsb(struct dlm_ls * ls) find_grant_rsb() argument
5483 dlm_recover_grant(struct dlm_ls * ls) dlm_recover_grant() argument
5543 receive_rcom_lock_args(struct dlm_ls * ls,struct dlm_lkb * lkb,struct dlm_rsb * r,const struct dlm_rcom * rc) receive_rcom_lock_args() argument
5595 dlm_recover_master_copy(struct dlm_ls * ls,const struct dlm_rcom * rc,__le32 * rl_remid,__le32 * rl_result) dlm_recover_master_copy() argument
5679 dlm_recover_process_copy(struct dlm_ls * ls,const struct dlm_rcom * rc,uint64_t seq) dlm_recover_process_copy() argument
5748 dlm_user_request(struct dlm_ls * ls,struct dlm_user_args * ua,int mode,uint32_t flags,void * name,unsigned int namelen) dlm_user_request() argument
5817 dlm_user_convert(struct dlm_ls * ls,struct dlm_user_args * ua_tmp,int mode,uint32_t flags,uint32_t lkid,char * lvb_in) dlm_user_convert() argument
5879 dlm_user_adopt_orphan(struct dlm_ls * ls,struct dlm_user_args * ua_tmp,int mode,uint32_t flags,void * name,unsigned int namelen,uint32_t * lkid) dlm_user_adopt_orphan() argument
5944 dlm_user_unlock(struct dlm_ls * ls,struct dlm_user_args * ua_tmp,uint32_t flags,uint32_t lkid,char * lvb_in) dlm_user_unlock() argument
5996 dlm_user_cancel(struct dlm_ls * ls,struct dlm_user_args * ua_tmp,uint32_t flags,uint32_t lkid) dlm_user_cancel() argument
6037 dlm_user_deadlock(struct dlm_ls * ls,uint32_t flags,uint32_t lkid) dlm_user_deadlock() argument
6091 orphan_proc_lock(struct dlm_ls * ls,struct dlm_lkb * lkb) orphan_proc_lock() argument
6114 unlock_proc_lock(struct dlm_ls * ls,struct dlm_lkb * lkb) unlock_proc_lock() argument
6132 del_proc_lock(struct dlm_ls * ls,struct dlm_user_proc * proc) del_proc_lock() argument
6163 dlm_clear_proc_locks(struct dlm_ls * ls,struct dlm_user_proc * proc) dlm_clear_proc_locks() argument
6204 purge_proc_locks(struct dlm_ls * ls,struct dlm_user_proc * proc) purge_proc_locks() argument
6245 do_purge(struct dlm_ls * ls,int nodeid,int pid) do_purge() argument
6260 send_purge(struct dlm_ls * ls,int nodeid,int pid) send_purge() argument
6276 dlm_user_purge(struct dlm_ls * ls,struct dlm_user_proc * proc,int nodeid,int pid) dlm_user_purge() argument
6295 dlm_debug_add_lkb(struct dlm_ls * ls,uint32_t lkb_id,char * name,int len,int lkb_nodeid,unsigned int lkb_dflags,int lkb_status) dlm_debug_add_lkb() argument
6340 dlm_debug_add_lkb_to_waiters(struct dlm_ls * ls,uint32_t lkb_id,int mstype,int to_nodeid) dlm_debug_add_lkb_to_waiters() argument
[all...] |
| H A D | requestqueue.c | 33 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, in dlm_add_requestqueue() argument
46 e->recover_seq = ls->ls_recover_seq & 0xFFFFFFFF; in dlm_add_requestqueue()
51 list_add_tail(&e->list, &ls->ls_requestqueue); in dlm_add_requestqueue()
65 int dlm_process_requestqueue(struct dlm_ls *ls) in dlm_process_requestqueue() argument
71 write_lock_bh(&ls->ls_requestqueue_lock); in dlm_process_requestqueue()
73 if (list_empty(&ls->ls_requestqueue)) { in dlm_process_requestqueue()
74 clear_bit(LSFL_RECV_MSG_BLOCKED, &ls->ls_flags); in dlm_process_requestqueue()
78 e = list_first_entry(&ls->ls_requestqueue, struct rq_entry, list); in dlm_process_requestqueue()
82 log_limit(ls, "dlm_process_requestqueue msg %d from %d " in dlm_process_requestqueue()
90 dlm_receive_message_saved(ls, in dlm_process_requestqueue()
108 purge_request(struct dlm_ls * ls,struct dlm_message * ms,int nodeid) purge_request() argument
133 dlm_purge_requestqueue(struct dlm_ls * ls) dlm_purge_requestqueue() argument
[all...] |
| H A D | lock.h | 15 void dlm_dump_rsb_name(struct dlm_ls *ls, const char *name, int len);
17 void dlm_receive_message_saved(struct dlm_ls *ls, const struct dlm_message *ms,
25 int dlm_lock_recovery_try(struct dlm_ls *ls);
26 void dlm_lock_recovery(struct dlm_ls *ls);
27 void dlm_unlock_recovery(struct dlm_ls *ls);
29 void resume_scan_timer(struct dlm_ls *ls);
31 int dlm_master_lookup(struct dlm_ls *ls, int from_nodeid, const char *name,
37 void dlm_recover_purge(struct dlm_ls *ls, const struct list_head *root_list);
39 void dlm_recover_grant(struct dlm_ls *ls);
40 int dlm_recover_waiters_post(struct dlm_ls *ls);
[all...] |
| H A D | recover.h | 15 int dlm_wait_function(struct dlm_ls *ls, int (*testfn) (struct dlm_ls *ls));
16 uint32_t dlm_recover_status(struct dlm_ls *ls);
17 void dlm_set_recover_status(struct dlm_ls *ls, uint32_t status);
18 int dlm_recover_members_wait(struct dlm_ls *ls, uint64_t seq);
19 int dlm_recover_directory_wait(struct dlm_ls *ls, uint64_t seq);
20 int dlm_recover_locks_wait(struct dlm_ls *ls, uint64_t seq);
21 int dlm_recover_done_wait(struct dlm_ls *ls, uint64_t seq);
22 int dlm_recover_masters(struct dlm_ls *ls, uint64_t seq,
24 int dlm_recover_master_reply(struct dlm_ls *ls, cons
[all...] |
| H A D | member.h | 14 int dlm_ls_stop(struct dlm_ls *ls);
15 int dlm_ls_start(struct dlm_ls *ls);
16 void dlm_clear_members(struct dlm_ls *ls);
17 void dlm_clear_members_gone(struct dlm_ls *ls);
18 int dlm_recover_members(struct dlm_ls *ls, struct dlm_recover *rv,int *neg_out);
19 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
20 int dlm_is_member(struct dlm_ls *ls, int nodeid);
22 void dlm_slot_save(struct dlm_ls *ls, struct dlm_rcom *rc,
24 void dlm_slots_copy_out(struct dlm_ls *ls, struct dlm_rcom *rc);
25 int dlm_slots_copy_in(struct dlm_ls *ls);
[all...] |
| H A D | user.c | 181 struct dlm_ls *ls; in dlm_user_add_ast() local
191 ls = lkb->lkb_resource->res_ls; in dlm_user_add_ast()
192 spin_lock_bh(&ls->ls_clear_proc_locks); in dlm_user_add_ast()
245 spin_unlock_bh(&ls->ls_clear_proc_locks); in dlm_user_add_ast()
251 struct dlm_ls *ls; in device_user_lock() local
256 ls = dlm_find_lockspace_local(proc->lockspace); in device_user_lock()
257 if (!ls) in device_user_lock()
277 error = dlm_user_convert(ls, ua, in device_user_lock()
281 error = dlm_user_adopt_orphan(ls, ua, in device_user_lock()
288 error = dlm_user_request(ls, u in device_user_lock()
302 struct dlm_ls *ls; device_user_unlock() local
331 struct dlm_ls *ls; device_user_deadlock() local
344 dlm_device_register(struct dlm_ls * ls,char * name) dlm_device_register() argument
376 dlm_device_deregister(struct dlm_ls * ls) dlm_device_deregister() argument
392 struct dlm_ls *ls; device_user_purge() local
408 struct dlm_ls *ls; device_create_lockspace() local
438 struct dlm_ls *ls; device_remove_lockspace() local
642 struct dlm_ls *ls; device_open() local
669 struct dlm_ls *ls; device_close() local
[all...] |
| H A D | debug_fs.c | 399 struct dlm_ls *ls = seq->private; in table_seq_start() local
412 list = &ls->ls_slow_inactive; in table_seq_start()
414 list = &ls->ls_slow_active; in table_seq_start()
416 read_lock_bh(&ls->ls_rsbtbl_lock); in table_seq_start()
422 struct dlm_ls *ls = seq->private; in table_seq_next() local
426 list = &ls->ls_slow_inactive; in table_seq_next()
428 list = &ls->ls_slow_active; in table_seq_next()
435 struct dlm_ls *ls = seq->private; in table_seq_stop() local
437 read_unlock_bh(&ls->ls_rsbtbl_lock); in table_seq_stop()
507 struct dlm_ls *ls in table_write2() local
597 struct dlm_ls *ls = file->private_data; waiters_read() local
631 struct dlm_ls *ls = file->private_data; waiters_write() local
665 dlm_delete_debug_file(struct dlm_ls * ls) dlm_delete_debug_file() argument
762 dlm_create_debug_file(struct dlm_ls * ls) dlm_create_debug_file() argument
[all...] |
| H A D | plock.c | 126 struct dlm_ls *ls; in dlm_posix_lock() local
130 ls = dlm_find_lockspace_local(lockspace); in dlm_posix_lock()
131 if (!ls) in dlm_posix_lock()
144 op->info.fsid = ls->ls_global_id; in dlm_posix_lock()
207 log_debug(ls, "%s: wait interrupted %x %llx pid %d", in dlm_posix_lock()
208 __func__, ls->ls_global_id, in dlm_posix_lock()
226 log_error(ls, "dlm_posix_lock: vfs lock error %llx", in dlm_posix_lock()
232 dlm_put_lockspace(ls); in dlm_posix_lock()
291 struct dlm_ls *ls; in dlm_posix_unlock() local
296 ls in dlm_posix_unlock()
364 struct dlm_ls *ls; dlm_posix_cancel() local
425 struct dlm_ls *ls; dlm_posix_get() local
[all...] |
| H A D | dlm_internal.h | 62 #define log_error(ls, fmt, args...) \ argument
63 printk(KERN_ERR "dlm: %s: " fmt "\n", (ls)->ls_name , ##args)
65 #define log_rinfo(ls, fmt, args...) \ argument
69 (ls)->ls_name, ##args); \
72 (ls)->ls_name , ##args); \
75 #define log_debug(ls, fmt, args...) \ argument
79 (ls)->ls_name , ##args); \
82 #define log_limit(ls, fmt, args...) \ argument
86 (ls)->ls_name , ##args); \
104 * Lockspace member (per node in a ls)
724 dlm_locking_stopped(struct dlm_ls * ls) dlm_locking_stopped() argument
729 dlm_recovery_stopped(struct dlm_ls * ls) dlm_recovery_stopped() argument
734 dlm_no_directory(struct dlm_ls * ls) dlm_no_directory() argument
824 dlm_create_debug_file(struct dlm_ls * ls) dlm_create_debug_file() argument
825 dlm_delete_debug_file(struct dlm_ls * ls) dlm_delete_debug_file() argument
[all...] |
| H A D | recoverd.h | 15 void dlm_recoverd_stop(struct dlm_ls *ls);
16 int dlm_recoverd_start(struct dlm_ls *ls);
17 void dlm_recoverd_suspend(struct dlm_ls *ls);
18 void dlm_recoverd_resume(struct dlm_ls *ls);
|
| H A D | requestqueue.h | 14 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid,
16 int dlm_process_requestqueue(struct dlm_ls *ls);
17 void dlm_wait_requestqueue(struct dlm_ls *ls);
18 void dlm_purge_requestqueue(struct dlm_ls *ls);
|
| H A D | dir.h | 16 int dlm_hash2nodeid(struct dlm_ls *ls, uint32_t hash);
17 void dlm_recover_dir_nodeid(struct dlm_ls *ls,
19 int dlm_recover_directory(struct dlm_ls *ls, uint64_t seq);
20 void dlm_copy_master_names(struct dlm_ls *ls, const char *inbuf, int inlen,
|
| /linux/fs/gfs2/ |
| H A D | lock_dlm.c | 296 struct lm_lockstruct *ls = &gl->gl_name.ln_sbd->sd_lockstruct; in gdlm_lock() local
321 error = dlm_lock(ls->ls_dlm, req, &gl->gl_lksb, lkf, strname, in gdlm_lock()
333 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in gdlm_put_lock() local
350 if (test_bit(DFL_UNMOUNT, &ls->ls_recover_flags)) { in gdlm_put_lock()
372 error = dlm_unlock(ls->ls_dlm, gl->gl_lksb.sb_lkid, flags, in gdlm_put_lock()
388 struct lm_lockstruct *ls = &gl->gl_name.ln_sbd->sd_lockstruct; in gdlm_cancel() local
389 dlm_unlock(ls->ls_dlm, gl->gl_lksb.sb_lkid, DLM_LKF_CANCEL, NULL, gl); in gdlm_cancel()
535 static void control_lvb_read(struct lm_lockstruct *ls, uint32_t *lvb_gen, in control_lvb_read() argument
539 memcpy(lvb_bits, ls->ls_control_lvb, GDLM_LVB_SIZE); in control_lvb_read()
544 static void control_lvb_write(struct lm_lockstruct *ls, uint32_ argument
561 struct lm_lockstruct *ls = arg; sync_wait_cb() local
567 struct lm_lockstruct *ls = &sdp->sd_lockstruct; sync_unlock() local
590 struct lm_lockstruct *ls = &sdp->sd_lockstruct; sync_lock() local
620 struct lm_lockstruct *ls = &sdp->sd_lockstruct; mounted_unlock() local
626 struct lm_lockstruct *ls = &sdp->sd_lockstruct; mounted_lock() local
633 struct lm_lockstruct *ls = &sdp->sd_lockstruct; control_unlock() local
639 struct lm_lockstruct *ls = &sdp->sd_lockstruct; control_lock() local
669 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gfs2_control_func() local
853 struct lm_lockstruct *ls = &sdp->sd_lockstruct; control_mount() local
1052 struct lm_lockstruct *ls = &sdp->sd_lockstruct; control_first_done() local
1119 struct lm_lockstruct *ls = &sdp->sd_lockstruct; set_recover_size() local
1164 free_recover_size(struct lm_lockstruct * ls) free_recover_size() argument
1180 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_recover_prep() local
1205 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_recover_slot() local
1235 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_recover_done() local
1266 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_recovery_result() local
1315 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_mount() local
1412 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_first_done() local
1425 struct lm_lockstruct *ls = &sdp->sd_lockstruct; gdlm_unmount() local
[all...] |
| /linux/fs/nfsd/ |
| H A D | nfs4layouts.c | 155 void nfsd4_close_layout(struct nfs4_layout_stateid *ls) in nfsd4_close_layout() argument
159 spin_lock(&ls->ls_stid.sc_file->fi_lock); in nfsd4_close_layout()
160 fl = ls->ls_file; in nfsd4_close_layout()
161 ls->ls_file = NULL; in nfsd4_close_layout()
162 spin_unlock(&ls->ls_stid.sc_file->fi_lock); in nfsd4_close_layout()
165 if (!nfsd4_layout_ops[ls->ls_layout_type]->disable_recalls) in nfsd4_close_layout()
167 (void **)&ls); in nfsd4_close_layout()
175 struct nfs4_layout_stateid *ls = layoutstateid(stid); in nfsd4_free_layout_stateid() local
176 struct nfs4_client *clp = ls->ls_stid.sc_client; in nfsd4_free_layout_stateid()
177 struct nfs4_file *fp = ls in nfsd4_free_layout_stateid()
198 nfsd4_layout_setlease(struct nfs4_layout_stateid * ls) nfsd4_layout_setlease() argument
232 struct nfs4_layout_stateid *ls; nfsd4_alloc_layout_stateid() local
284 struct nfs4_layout_stateid *ls; nfsd4_preprocess_layout_stateid() local
334 nfsd4_recall_file_layout(struct nfs4_layout_stateid * ls) nfsd4_recall_file_layout() argument
399 nfsd4_recall_conflict(struct nfs4_layout_stateid * ls) nfsd4_recall_conflict() argument
418 nfsd4_insert_layout(struct nfsd4_layoutget * lgp,struct nfs4_layout_stateid * ls) nfsd4_insert_layout() argument
509 struct nfs4_layout_stateid *ls; nfsd4_return_file_layouts() local
552 struct nfs4_layout_stateid *ls, *n; nfsd4_return_client_layouts() local
584 nfsd4_return_all_layouts(struct nfs4_layout_stateid * ls,struct list_head * reaplist) nfsd4_return_all_layouts() argument
595 struct nfs4_layout_stateid *ls, *n; nfsd4_return_all_client_layouts() local
609 struct nfs4_layout_stateid *ls, *n; nfsd4_return_all_file_layouts() local
623 nfsd4_cb_layout_fail(struct nfs4_layout_stateid * ls,struct nfsd_file * file) nfsd4_cb_layout_fail() argument
659 struct nfs4_layout_stateid *ls = nfsd4_cb_layout_prepare() local
670 struct nfs4_layout_stateid *ls = nfsd4_cb_layout_done() local
729 struct nfs4_layout_stateid *ls = nfsd4_cb_layout_release() local
[all...] |
| /linux/tools/testing/selftests/media_tests/ |
| H A D | media_dev_allocator.sh | 11 MDEV=$(ls -d *\-*)
15 ADEV=$(ls -d *\-*.1)
23 ls -l /dev/media*
32 ls -l /dev/media*
42 ls -l /dev/media*
48 ls -l /dev/media*
60 ls -l /dev/media*
68 ls -l /dev/media*
74 ls -l /dev/media*
82 ls
[all...] |
| /linux/security/apparmor/ |
| H A D | label.c | 601 struct aa_labelset *ls = labels_set(label); in __label_remove() local
603 AA_BUG(!ls); in __label_remove()
605 lockdep_assert_held_write(&ls->lock); in __label_remove()
614 rb_erase(&label->node, &ls->root); in __label_remove()
637 struct aa_labelset *ls = labels_set(old); in __label_replace() local
639 AA_BUG(!ls); in __label_replace()
642 lockdep_assert_held_write(&ls->lock); in __label_replace()
649 rb_replace_node(&old->node, &new->node, &ls->root); in __label_replace()
661 * @ls: set of labels to insert @l into (NOT NULL)
665 * Requires: @ls
672 __label_insert(struct aa_labelset * ls,struct aa_label * label,bool replace) __label_insert() argument
782 struct aa_labelset *ls = labels_set(label); aa_label_remove() local
818 struct aa_labelset *ls = labels_set(old); aa_label_replace() local
846 struct aa_labelset *ls; vec_find() local
867 struct aa_labelset *ls; vec_create_and_insert_label() local
919 aa_label_insert(struct aa_labelset * ls,struct aa_label * label) aa_label_insert() argument
1045 struct aa_labelset *ls; label_merge_insert() local
1131 __label_find_merge(struct aa_labelset * ls,struct aa_label * a,struct aa_label * b) __label_find_merge() argument
1174 struct aa_labelset *ls; aa_label_find_merge() local
1436 struct aa_labelset *ls; aa_update_label_name() local
1955 aa_labelset_destroy(struct aa_labelset * ls) aa_labelset_destroy() argument
1978 aa_labelset_init(struct aa_labelset * ls) aa_labelset_init() argument
1986 labelset_next_stale(struct aa_labelset * ls) labelset_next_stale() argument
2027 struct aa_labelset *ls; __label_update() local
[all...] |
| /linux/drivers/net/ethernet/mellanox/mlx5/core/en/ |
| H A D | tc_tun_mplsoudp.c | 89 match.mask->ls[0].mpls_label); in parse_tunnel()
92 match.key->ls[0].mpls_label); in parse_tunnel()
96 match.mask->ls[0].mpls_tc); in parse_tunnel()
98 outer_first_mpls_over_udp.mpls_exp, match.key->ls[0].mpls_tc); in parse_tunnel()
102 match.mask->ls[0].mpls_bos); in parse_tunnel()
105 match.key->ls[0].mpls_bos); in parse_tunnel()
109 match.mask->ls[0].mpls_ttl); in parse_tunnel()
112 match.key->ls[0].mpls_ttl); in parse_tunnel()
|
| /linux/tools/perf/ |
| H A D | builtin-lock.c | 234 struct lock_stat *ls) \
236 fprintf(lock_output, "%*llu", key->len, (unsigned long long)ls->member);\
241 struct lock_stat *ls) \
243 lock_stat_key_print_time((unsigned long long)ls->member, key->len); \
253 struct lock_stat *ls) in PRINT_KEY()
255 u64 wait_time = ls->wait_time_min; in PRINT_KEY()
569 struct lock_stat *ls; in report_lock_acquire_event() local
582 ls = lock_stat_findnew(key, name, 0); in report_lock_acquire_event()
583 if (!ls) in report_lock_acquire_event()
601 ls in report_lock_acquire_event()
644 struct lock_stat *ls; report_lock_acquired_event() local
710 struct lock_stat *ls; report_lock_contended_event() local
768 struct lock_stat *ls; report_lock_release_event() local
969 struct lock_stat *ls; report_lock_contention_begin_event() local
1133 struct lock_stat *ls; report_lock_contention_end_event() local
[all...] |
| /linux/arch/m68k/lib/ |
| H A D | memset.c | 34 long *ls = s; in memset() local
37 *ls++ = c; in memset()
58 : "=a" (ls), "=d" (temp), "=&d" (temp1) in memset()
59 : "d" (c), "0" (ls), "1" (temp)); in memset()
61 s = ls; in memset()
|