Home
last modified time | relevance | path

Searched refs:ls (Results 1 – 25 of 40) sorted by relevance

12

/fs/dlm/
A Drecoverd.c110 resume_scan_timer(ls); in enable_locking()
132 dlm_callback_suspend(ls); in ls_recover()
134 dlm_clear_inactive(ls); in ls_recover()
294 dlm_purge_requestqueue(ls); in ls_recover()
306 dlm_callback_resume(ls); in ls_recover()
326 dlm_recover_grant(ls); in ls_recover()
353 rv = ls->ls_recover_args; in do_ls_recovery()
392 struct dlm_ls *ls; in dlm_recoverd() local
395 if (!ls) { in dlm_recoverd()
430 do_ls_recovery(ls); in dlm_recoverd()
[all …]
A Dlockspace.c41 ls = dlm_find_lockspace_local(ls); in dlm_control_store()
42 if (!ls) in dlm_control_store()
253 ls = NULL; in dlm_find_lockspace_global()
256 return ls; in dlm_find_lockspace_global()
264 return ls; in dlm_find_lockspace_local()
278 ls = NULL; in dlm_find_lockspace_device()
281 return ls; in dlm_find_lockspace_device()
425 ls = kzalloc(sizeof(*ls), GFP_NOFS); in new_lockspace()
426 if (!ls) in new_lockspace()
473 ls->ls_local_rsb.res_ls = ls; in new_lockspace()
[all …]
A Dmember.c135 if (ls->ls_slot && ls->ls_slot != memb->slot) { in dlm_slots_copy_in()
142 if (!ls->ls_slot) in dlm_slots_copy_in()
345 ls->ls_num_nodes++; in dlm_add_member()
476 if (!ls->ls_ops || !ls->ls_ops->recover_prep) in dlm_lsop_recover_prep()
478 ls->ls_ops->recover_prep(ls->ls_ops_arg); in dlm_lsop_recover_prep()
487 if (!ls->ls_ops || !ls->ls_ops->recover_slot) in dlm_lsop_recover_slot()
504 ls->ls_ops->recover_slot(ls->ls_ops_arg, &slot); in dlm_lsop_recover_slot()
513 if (!ls->ls_ops || !ls->ls_ops->recover_done) in dlm_lsop_recover_done()
532 ls->ls_ops->recover_done(ls->ls_ops_arg, slots, num, in dlm_lsop_recover_done()
533 ls->ls_slot, ls->ls_generation); in dlm_lsop_recover_done()
[all …]
A Drecover.c42 int dlm_wait_function(struct dlm_ls *ls, int (*testfn) (struct dlm_ls *ls)) in dlm_wait_function() argument
49 testfn(ls) || dlm_recovery_stopped(ls), in dlm_wait_function()
195 ls->ls_slots = slots; in dlm_recover_members_wait()
196 ls->ls_generation = gen; in dlm_recover_members_wait()
207 dlm_slots_copy_in(ls); in dlm_recover_members_wait()
270 ls->ls_recover_list_count--; in recover_list_del()
328 ls->ls_recover_list_count++; in recover_xa_add()
343 ls->ls_recover_list_count--; in recover_xa_del()
563 recover_xa_clear(ls); in dlm_recover_masters()
593 if (recover_xa_empty(ls)) in dlm_recover_master_reply()
[all …]
A Drcom.c136 ls->ls_lvblen, ls->ls_exflags, nodeid, in check_rcom_config()
181 rc = ls->ls_recover_buf; in dlm_rcom_status()
201 disallow_sync_reply(ls); in dlm_rcom_status()
207 rc = ls->ls_recover_buf; in dlm_rcom_status()
250 num_slots = ls->ls_num_slots; in receive_rcom_status()
279 dlm_slots_copy_out(ls, rc); in receive_rcom_status()
329 disallow_sync_reply(ls); in dlm_rcom_names()
456 len += ls->ls_lvblen; in dlm_send_rcom_lock()
619 seq = ls->ls_recover_seq; in dlm_receive_rcom()
654 receive_sync_reply(ls, rc); in dlm_receive_rcom()
[all …]
A Ddir.c37 if (ls->ls_num_nodes == 1) in dlm_hash2nodeid()
41 return ls->ls_node_array[node]; in dlm_hash2nodeid()
69 if (dlm_no_directory(ls)) in dlm_recover_directory()
85 if (dlm_recovery_stopped(ls)) { in dlm_recover_directory()
101 b = ls->ls_recover_buf->rc_buf; in dlm_recover_directory()
203 read_lock_bh(&ls->ls_rsbtbl_lock); in find_rsb_root()
272 dd = lookup_dir_dump(ls, nodeid); in init_dir_dump()
276 drop_dir_ctx(ls, nodeid); in init_dir_dump()
283 dd->seq_init = ls->ls_recover_seq; in init_dir_dump()
334 dd = init_dir_dump(ls, nodeid); in dlm_copy_master_names()
[all …]
A Dlock.c512 struct dlm_ls *ls = timer_container_of(ls, timer, ls_scan_timer); in dlm_rsb_scan() local
607 r->res_ls = ls; in get_rsb_struct()
834 del_scan(ls, r); in find_rsb_dir()
997 del_scan(ls, r); in find_rsb_nodir()
1459 add_scan(ls, r); in deactivate_rsb()
3389 if (!ls) in dlm_lock()
3441 if (!ls) in dlm_unlock()
4063 send_request_reply(&ls->ls_local_rsb, &ls->ls_local_lkb, error); in receive_request()
4171 send_unlock_reply(&ls->ls_local_rsb, &ls->ls_local_lkb, error); in receive_unlock()
4207 send_cancel_reply(&ls->ls_local_rsb, &ls->ls_local_lkb, error); in receive_cancel()
[all …]
A Dast.c61 struct dlm_ls *ls = rsb->res_ls; in dlm_may_skip_callback() local
126 struct dlm_ls *ls = rsb->res_ls; in dlm_get_cb() local
134 (*cb)->ls_id = ls->ls_global_id; in dlm_get_cb()
169 struct dlm_ls *ls = rsb->res_ls; in dlm_add_cb() local
181 spin_lock_bh(&ls->ls_cb_lock); in dlm_add_cb()
199 spin_unlock_bh(&ls->ls_cb_lock); in dlm_add_cb()
210 if (!ls->ls_callback_wq) { in dlm_callback_start()
219 if (ls->ls_callback_wq) in dlm_callback_stop()
228 spin_lock_bh(&ls->ls_cb_lock); in dlm_callback_suspend()
232 if (ls->ls_callback_wq) in dlm_callback_suspend()
[all …]
A Drequestqueue.c71 write_lock_bh(&ls->ls_requestqueue_lock); in dlm_process_requestqueue()
73 if (list_empty(&ls->ls_requestqueue)) { in dlm_process_requestqueue()
94 if (dlm_locking_stopped(ls)) { in dlm_process_requestqueue()
101 write_lock_bh(&ls->ls_requestqueue_lock); in dlm_process_requestqueue()
103 write_unlock_bh(&ls->ls_requestqueue_lock); in dlm_process_requestqueue()
113 if (!atomic_read(&ls->ls_count)) in purge_request()
116 if (dlm_is_removed(ls, nodeid)) in purge_request()
127 if (!dlm_no_directory(ls)) in purge_request()
138 write_lock_bh(&ls->ls_requestqueue_lock); in dlm_purge_requestqueue()
142 if (purge_request(ls, ms, e->nodeid)) { in dlm_purge_requestqueue()
[all …]
A Dlock.h15 void dlm_dump_rsb_name(struct dlm_ls *ls, const char *name, int len);
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);
39 void dlm_recover_grant(struct dlm_ls *ls);
40 int dlm_recover_waiters_post(struct dlm_ls *ls);
41 void dlm_recover_waiters_pre(struct dlm_ls *ls);
54 int dlm_user_unlock(struct dlm_ls *ls, struct dlm_user_args *ua_tmp,
58 int dlm_user_purge(struct dlm_ls *ls, struct dlm_user_proc *proc,
[all …]
A Duser.c181 struct dlm_ls *ls; in dlm_user_add_ast() local
251 struct dlm_ls *ls; in device_user_lock() local
257 if (!ls) in device_user_lock()
307 if (!ls) in device_user_unlock()
335 if (!ls) in device_user_deadlock()
396 if (!ls) in device_user_purge()
421 if (!ls) in device_create_lockspace()
445 if (!ls) in device_remove_lockspace()
451 lockspace = ls; in device_remove_lockspace()
645 if (!ls) in device_open()
[all …]
A Drecover.h15 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, const struct dlm_rcom *rc);
25 int dlm_recover_locks(struct dlm_ls *ls, uint64_t seq,
[all …]
A Dmember.h14 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);
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);
26 int dlm_slots_assign(struct dlm_ls *ls, int *num_slots, int *slots_size,
[all …]
A Ddebug_fs.c412 list = &ls->ls_slow_inactive; in table_seq_start()
414 list = &ls->ls_slow_active; in table_seq_start()
428 list = &ls->ls_slow_active; in table_seq_next()
620 dlm_unlock_recovery(ls); in waiters_read()
650 dlm_unlock_recovery(ls); in waiters_write()
769 ls->ls_debug_rsb_dentry = debugfs_create_file(ls->ls_name, in dlm_create_debug_file()
772 ls, in dlm_create_debug_file()
782 ls, in dlm_create_debug_file()
792 ls, in dlm_create_debug_file()
802 ls, in dlm_create_debug_file()
[all …]
A Dplock.c126 struct dlm_ls *ls; in dlm_posix_lock() local
131 if (!ls) in dlm_posix_lock()
232 dlm_put_lockspace(ls); in dlm_posix_lock()
291 struct dlm_ls *ls; in dlm_posix_unlock() local
297 if (!ls) in dlm_posix_unlock()
347 dlm_put_lockspace(ls); in dlm_posix_unlock()
364 struct dlm_ls *ls; in dlm_posix_cancel() local
374 if (!ls) in dlm_posix_cancel()
381 dlm_put_lockspace(ls); in dlm_posix_cancel()
425 struct dlm_ls *ls; in dlm_posix_get() local
[all …]
A Ddlm_internal.h62 #define log_error(ls, fmt, args...) \ argument
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); \
736 return test_bit(LSFL_NODIR, &ls->ls_flags); in dlm_no_directory()
817 void dlm_create_debug_file(struct dlm_ls *ls);
[all …]
A Drecoverd.h15 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);
A Drequestqueue.h14 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);
A Ddir.h16 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,
A Dast.h22 int dlm_callback_start(struct dlm_ls *ls);
23 void dlm_callback_stop(struct dlm_ls *ls);
24 void dlm_callback_suspend(struct dlm_ls *ls);
25 void dlm_callback_resume(struct dlm_ls *ls);
A Drcom.h15 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags,
17 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name,
21 void dlm_receive_rcom(struct dlm_ls *ls, const struct dlm_rcom *rc,
/fs/gfs2/
A Dlock_dlm.c570 error = dlm_unlock(ls->ls_dlm, lksb->sb_lkid, 0, lksb, ls); in sync_unlock()
730 control_lvb_read(ls, &lvb_gen, ls->ls_lvb_bits); in gfs2_control_func()
801 control_lvb_write(ls, start_gen, ls->ls_lvb_bits); in gfs2_control_func()
862 ls->ls_control_lksb.sb_lvbptr = ls->ls_control_lvb; in control_mount()
959 control_lvb_read(ls, &lvb_gen, ls->ls_lvb_bits); in control_mount()
1095 control_lvb_write(ls, start_gen, ls->ls_lvb_bits); in control_first_done()
1187 ls->ls_recover_block = ls->ls_recover_start; in gdlm_recover_prep()
1216 jid, ls->ls_recover_block, ls->ls_recover_size); in gdlm_recover_slot()
1223 jid, ls->ls_recover_block, ls->ls_recover_submit[jid]); in gdlm_recover_slot()
1225 ls->ls_recover_submit[jid] = ls->ls_recover_block; in gdlm_recover_slot()
[all …]
A Dsys.c405 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in block_show() local
409 if (test_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags)) in block_show()
417 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in block_store() local
425 set_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags); in block_store()
427 clear_bit(DFL_BLOCK_LOCKS, &ls->ls_recover_flags); in block_store()
461 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in lkfirst_show() local
462 return sprintf(buf, "%d\n", ls->ls_first); in lkfirst_show()
494 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in first_done_show() local
552 struct lm_lockstruct *ls = &sdp->sd_lockstruct; in recover_done_show() local
553 return sprintf(buf, "%d\n", ls->ls_recover_jid_done); in recover_done_show()
[all …]
/fs/nfsd/
A Dnfs4layouts.c160 fl = ls->ls_file; in nfsd4_close_layout()
161 ls->ls_file = NULL; in nfsd4_close_layout()
167 (void **)&ls); in nfsd4_close_layout()
191 if (ls->ls_recalled) in nfsd4_free_layout_stateid()
276 return ls; in nfsd4_alloc_layout_stateid()
308 if (!ls) in nfsd4_preprocess_layout_stateid()
322 *lsp = ls; in nfsd4_preprocess_layout_stateid()
408 if (l != ls) { in nfsd4_recall_conflict()
441 new->lo_state = ls; in nfsd4_insert_layout()
517 &ls); in nfsd4_return_file_layouts()
[all …]
A Dpnfs.h40 void (*fence_client)(struct nfs4_layout_stateid *ls,
59 struct nfs4_layout_stateid *ls);
76 void nfsd4_close_layout(struct nfs4_layout_stateid *ls);
95 static inline void nfsd4_close_layout(struct nfs4_layout_stateid *ls) in nfsd4_close_layout() argument

Completed in 86 milliseconds

12