/fs/ocfs2/dlm/ |
H A D | dlmdomain.h | 31 int dlm_joined(struct dlm_ctxt *dlm); 32 int dlm_shutting_down(struct dlm_ctxt *dlm); 33 void dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm,
|
H A D | dlmdebug.h | 47 int dlm_debug_init(struct dlm_ctxt *dlm); 48 void dlm_debug_shutdown(struct dlm_ctxt *dlm); 50 int dlm_create_debugfs_subroot(struct dlm_ctxt *dlm); 51 void dlm_destroy_debugfs_subroot(struct dlm_ctxt *dlm); 58 static inline int dlm_debug_init(struct dlm_ctxt *dlm) argument 62 static inline void dlm_debug_shutdown(struct dlm_ctxt *dlm) argument 65 static inline int dlm_create_debugfs_subroot(struct dlm_ctxt *dlm) argument 69 static inline void dlm_destroy_debugfs_subroot(struct dlm_ctxt *dlm) argument
|
H A D | dlmdomain.c | 156 static void dlm_unregister_domain_handlers(struct dlm_ctxt *dlm); 158 void __dlm_unhash_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 163 mlog(0, "%s: Unhash res %.*s\n", dlm->name, res->lockname.len, 169 void __dlm_insert_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 174 assert_spin_locked(&dlm->spinlock); 177 bucket = dlm_lockres_hash(dlm, q->hash); 184 mlog(0, "%s: Hash res %.*s\n", dlm->name, res->lockname.len, 188 struct dlm_lock_resource * __dlm_lookup_lockres_full(struct dlm_ctxt *dlm, argument 198 assert_spin_locked(&dlm->spinlock); 200 bucket = dlm_lockres_hash(dlm, has 221 __dlm_lookup_lockres(struct dlm_ctxt *dlm, const char *name, unsigned int len, unsigned int hash) argument 246 dlm_lookup_lockres(struct dlm_ctxt *dlm, const char *name, unsigned int len) argument 305 dlm_free_ctxt_mem(struct dlm_ctxt *dlm) argument 324 struct dlm_ctxt *dlm; local 345 dlm_put(struct dlm_ctxt *dlm) argument 352 __dlm_get(struct dlm_ctxt *dlm) argument 360 dlm_grab(struct dlm_ctxt *dlm) argument 380 dlm_domain_fully_joined(struct dlm_ctxt *dlm) argument 392 dlm_destroy_dlm_worker(struct dlm_ctxt *dlm) argument 401 dlm_complete_dlm_shutdown(struct dlm_ctxt *dlm) argument 420 dlm_migrate_all_locks(struct dlm_ctxt *dlm) argument 477 dlm_no_joining_node(struct dlm_ctxt *dlm) argument 491 struct dlm_ctxt *dlm = data; local 510 dlm_mark_domain_leaving(struct dlm_ctxt *dlm) argument 533 __dlm_print_nodes(struct dlm_ctxt *dlm) argument 551 struct dlm_ctxt *dlm = data; local 578 dlm_send_one_domain_exit(struct dlm_ctxt *dlm, u32 msg_type, unsigned int node) argument 600 dlm_begin_exit_domain(struct dlm_ctxt *dlm) argument 629 dlm_leave_domain(struct dlm_ctxt *dlm) argument 677 dlm_joined(struct dlm_ctxt *dlm) argument 691 dlm_shutting_down(struct dlm_ctxt *dlm) argument 705 dlm_unregister_domain(struct dlm_ctxt *dlm) argument 828 struct dlm_ctxt *dlm = NULL; local 945 struct dlm_ctxt *dlm = NULL; local 988 dlm_match_regions(struct dlm_ctxt *dlm, struct dlm_query_region *qr, char *local, int locallen) argument 1074 dlm_send_regions(struct dlm_ctxt *dlm, unsigned long *node_map) argument 1131 struct dlm_ctxt *dlm = NULL; local 1186 dlm_match_nodes(struct dlm_ctxt *dlm, struct dlm_query_nodeinfo *qn) argument 1246 dlm_send_nodeinfo(struct dlm_ctxt *dlm, unsigned long *node_map) argument 1308 struct dlm_ctxt *dlm = NULL; local 1357 struct dlm_ctxt *dlm = NULL; local 1382 dlm_send_one_join_cancel(struct dlm_ctxt *dlm, unsigned int node) argument 1408 dlm_send_join_cancels(struct dlm_ctxt *dlm, unsigned long *node_map, unsigned int map_size) argument 1444 dlm_request_join(struct dlm_ctxt *dlm, int node, enum dlm_query_join_response_code *response) argument 1524 dlm_send_one_join_assert(struct dlm_ctxt *dlm, unsigned int node) argument 1551 dlm_send_join_asserts(struct dlm_ctxt *dlm, unsigned long *node_map) argument 1590 dlm_should_restart_join(struct dlm_ctxt *dlm, struct domain_join_ctxt *ctxt, enum dlm_query_join_response_code response) argument 1614 dlm_try_to_join_domain(struct dlm_ctxt *dlm) argument 1727 dlm_unregister_domain_handlers(struct dlm_ctxt *dlm) argument 1734 dlm_register_domain_handlers(struct dlm_ctxt *dlm) argument 1872 dlm_join_domain(struct dlm_ctxt *dlm) argument 1974 struct dlm_ctxt *dlm = NULL; local 2128 struct dlm_ctxt *dlm = NULL; local 2294 dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm, int node_num) argument 2316 dlm_register_eviction_cb(struct dlm_ctxt *dlm, struct dlm_eviction_cb *cb) argument [all...] |
H A D | dlmrecovery.c | 55 static void dlm_do_local_recovery_cleanup(struct dlm_ctxt *dlm, u8 dead_node); 58 static int dlm_do_recovery(struct dlm_ctxt *dlm); 60 static int dlm_pick_recovery_master(struct dlm_ctxt *dlm); 61 static int dlm_remaster_locks(struct dlm_ctxt *dlm, u8 dead_node); 62 static int dlm_init_recovery_area(struct dlm_ctxt *dlm, u8 dead_node); 63 static int dlm_request_all_locks(struct dlm_ctxt *dlm, 65 static void dlm_destroy_recovery_area(struct dlm_ctxt *dlm, u8 dead_node); 72 static int dlm_send_mig_lockres_msg(struct dlm_ctxt *dlm, 77 static int dlm_process_recovery_data(struct dlm_ctxt *dlm, 80 static int dlm_send_finalize_reco_message(struct dlm_ctxt *dlm); 117 dlm_set_reco_dead_node(struct dlm_ctxt *dlm, u8 dead_node) argument 127 dlm_set_reco_master(struct dlm_ctxt *dlm, u8 master) argument 136 __dlm_reset_recovery(struct dlm_ctxt *dlm) argument 144 dlm_reset_recovery(struct dlm_ctxt *dlm) argument 154 struct dlm_ctxt *dlm = local 191 dlm_kick_recovery_thread(struct dlm_ctxt *dlm) argument 203 dlm_launch_recovery_thread(struct dlm_ctxt *dlm) argument 218 dlm_complete_recovery_thread(struct dlm_ctxt *dlm) argument 252 dlm_print_reco_node_status(struct dlm_ctxt *dlm) argument 304 struct dlm_ctxt *dlm = data; local 330 dlm_reco_master_ready(struct dlm_ctxt *dlm) argument 341 dlm_is_node_dead(struct dlm_ctxt *dlm, u8 node) argument 352 dlm_is_node_recovered(struct dlm_ctxt *dlm, u8 node) argument 362 dlm_wait_for_node_death(struct dlm_ctxt *dlm, u8 node, int timeout) argument 379 dlm_wait_for_node_recovery(struct dlm_ctxt *dlm, u8 node, int timeout) argument 402 dlm_in_recovery(struct dlm_ctxt *dlm) argument 412 dlm_wait_for_recovery(struct dlm_ctxt *dlm) argument 424 dlm_begin_recovery(struct dlm_ctxt *dlm) argument 434 dlm_end_recovery(struct dlm_ctxt *dlm) argument 444 dlm_print_recovery_master(struct dlm_ctxt *dlm) argument 452 dlm_do_recovery(struct dlm_ctxt *dlm) argument 551 dlm_remaster_locks(struct dlm_ctxt *dlm, u8 dead_node) argument 747 dlm_init_recovery_area(struct dlm_ctxt *dlm, u8 dead_node) argument 781 dlm_destroy_recovery_area(struct dlm_ctxt *dlm, u8 dead_node) argument 796 dlm_request_all_locks(struct dlm_ctxt *dlm, u8 request_from, u8 dead_node) argument 833 struct dlm_ctxt *dlm = data; local 884 struct dlm_ctxt *dlm; local 959 dlm_send_all_done_msg(struct dlm_ctxt *dlm, u8 dead_node, u8 send_to) argument 989 struct dlm_ctxt *dlm = data; local 1051 dlm_move_reco_locks_to_list(struct dlm_ctxt *dlm, struct list_head *list, u8 dead_node) argument 1109 dlm_send_mig_lockres_msg(struct dlm_ctxt *dlm, struct dlm_migratable_lockres *mres, u8 send_to, struct dlm_lock_resource *res, int total_locks) argument 1247 dlm_add_dummy_lock(struct dlm_ctxt *dlm, struct dlm_migratable_lockres *mres) argument 1261 dlm_is_dummy_lock(struct dlm_ctxt *dlm, struct dlm_migratable_lock *ml, u8 *nodenum) argument 1276 dlm_send_one_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_migratable_lockres *mres, u8 send_to, u8 flags) argument 1364 struct dlm_ctxt *dlm = data; local 1523 struct dlm_ctxt *dlm; local 1589 dlm_lockres_master_requery(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 *real_master) argument 1647 dlm_do_master_requery(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 nodenum, u8 *real_master) argument 1684 struct dlm_ctxt *dlm = data; local 1763 dlm_process_recovery_data(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_migratable_lockres *mres) argument 2027 dlm_move_lockres_to_recovery_list(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2112 dlm_finish_local_lockres_recovery(struct dlm_ctxt *dlm, u8 dead_node, u8 new_master) argument 2186 dlm_revalidate_lvb(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 dead_node) argument 2229 dlm_free_dead_locks(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 dead_node) argument 2303 dlm_do_local_recovery_cleanup(struct dlm_ctxt *dlm, u8 dead_node) argument 2381 __dlm_hb_node_down(struct dlm_ctxt *dlm, int idx) argument 2446 struct dlm_ctxt *dlm = data; local 2467 struct dlm_ctxt *dlm = data; local 2483 struct dlm_ctxt *dlm = astdata; local 2489 struct dlm_ctxt *dlm = astdata; local 2510 dlm_pick_recovery_master(struct dlm_ctxt *dlm) argument 2634 dlm_send_begin_reco_message(struct dlm_ctxt *dlm, u8 dead_node) argument 2724 struct dlm_ctxt *dlm = data; local 2797 dlm_send_finalize_reco_message(struct dlm_ctxt *dlm) argument 2856 struct dlm_ctxt *dlm = data; local [all...] |
H A D | dlmthread.c | 55 static void dlm_flush_asts(struct dlm_ctxt *dlm); 57 #define dlm_lock_is_remote(dlm, lock) ((lock)->ml.node != (dlm)->node_num) 124 void __dlm_lockres_calc_usage(struct dlm_ctxt *dlm, argument 127 assert_spin_locked(&dlm->spinlock); 133 dlm->name, res->lockname.len, res->lockname.name); 137 list_add_tail(&res->purge, &dlm->purge_list); 138 dlm->purge_count++; 142 dlm->name, res->lockname.len, res->lockname.name); 146 dlm 150 dlm_lockres_calc_usage(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 162 dlm_purge_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 224 dlm_run_purge_list(struct dlm_ctxt *dlm, int purge_now) argument 288 dlm_shuffle_lists(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 445 dlm_kick_thread(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 457 __dlm_dirty_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 482 dlm_launch_thread(struct dlm_ctxt *dlm) argument 496 dlm_complete_thread(struct dlm_ctxt *dlm) argument 505 dlm_dirty_list_empty(struct dlm_ctxt *dlm) argument 516 dlm_flush_asts(struct dlm_ctxt *dlm) argument 631 struct dlm_ctxt *dlm = data; local [all...] |
H A D | dlmconvert.h | 28 enum dlm_status dlmconvert_master(struct dlm_ctxt *dlm, 31 enum dlm_status dlmconvert_remote(struct dlm_ctxt *dlm,
|
H A D | dlmmaster.c | 55 static void dlm_mle_node_down(struct dlm_ctxt *dlm, 59 static void dlm_mle_node_up(struct dlm_ctxt *dlm, 65 static int dlm_do_assert_master(struct dlm_ctxt *dlm, 70 static inline int dlm_mle_equal(struct dlm_ctxt *dlm, argument 75 if (dlm != mle->dlm) 92 struct dlm_ctxt *dlm, 98 static int dlm_find_mle(struct dlm_ctxt *dlm, 106 static int dlm_wait_for_lock_mastery(struct dlm_ctxt *dlm, 110 static int dlm_restart_lock_mastery(struct dlm_ctxt *dlm, 178 __dlm_mle_attach_hb_events(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 187 __dlm_mle_detach_hb_events(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 195 dlm_mle_detach_hb_events(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 205 struct dlm_ctxt *dlm; local 216 struct dlm_ctxt *dlm; local 231 struct dlm_ctxt *dlm; local 250 struct dlm_ctxt *dlm; local 265 dlm_init_mle(struct dlm_master_list_entry *mle, enum dlm_mle_type type, struct dlm_ctxt *dlm, struct dlm_lock_resource *res, const char *name, unsigned int namelen) argument 319 __dlm_unlink_mle(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 328 __dlm_insert_mle(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 339 dlm_find_mle(struct dlm_ctxt *dlm, struct dlm_master_list_entry **mle, char *name, unsigned int namelen) argument 361 dlm_hb_event_notify_attached(struct dlm_ctxt *dlm, int idx, int node_up) argument 375 dlm_mle_node_down(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle, struct o2nm_node *node, int idx) argument 389 dlm_mle_node_up(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle, struct o2nm_node *node, int idx) argument 424 struct dlm_ctxt *dlm; local 489 struct dlm_ctxt *dlm; local 555 dlm_init_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, const char *name, unsigned int namelen) argument 610 dlm_new_lockres(struct dlm_ctxt *dlm, const char *name, unsigned int namelen) argument 633 dlm_lockres_set_refmap_bit(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, int bit) argument 644 dlm_lockres_clear_refmap_bit(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, int bit) argument 655 __dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 665 dlm_lockres_grab_inflight_ref(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 672 dlm_lockres_drop_inflight_ref(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 688 __dlm_lockres_grab_inflight_worker(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 698 dlm_lockres_grab_inflight_worker(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 706 __dlm_lockres_drop_inflight_worker(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 717 dlm_lockres_drop_inflight_worker(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 741 dlm_get_lock_resource(struct dlm_ctxt *dlm, const char *lockid, int namelen, int flags) argument 1018 dlm_wait_for_lock_mastery(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_master_list_entry *mle, int *blocked) argument 1230 dlm_restart_lock_mastery(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_master_list_entry *mle, int blocked) argument 1333 struct dlm_ctxt *dlm = mle->dlm; local 1428 struct dlm_ctxt *dlm = data; local 1664 dlm_do_assert_master(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, void *nodemap, u32 flags) argument 1776 struct dlm_ctxt *dlm = data; local 2063 dlm_dispatch_assert_master(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, int ignore_higher, u8 request_from, u32 flags) argument 2096 struct dlm_ctxt *dlm = data; local 2180 dlm_pre_master_reco_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2230 dlm_drop_lockres_ref(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2264 struct dlm_ctxt *dlm = data; local 2357 struct dlm_ctxt *dlm; local 2396 dlm_is_lockres_migrateable(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2453 dlm_migrate_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 target) argument 2680 dlm_empty_lockres(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2709 dlm_lock_basts_flushed(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 2720 dlm_migration_can_proceed(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 mig_target) argument 2738 dlm_lockres_is_dirty(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2749 dlm_mark_lockres_migrating(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 target) argument 2839 dlm_remove_nonlocal_locks(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2893 dlm_pick_migration_target(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 2939 dlm_do_migrate_request(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 master, u8 new_master, struct dlm_node_iter *iter) argument 3019 struct dlm_ctxt *dlm = data; local 3093 dlm_add_migration_mle(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_master_list_entry *mle, struct dlm_master_list_entry **oldmle, const char *name, unsigned int namelen, u8 new_master, u8 master) argument 3168 dlm_reset_mleres_owner(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 3198 dlm_clean_migration_mle(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle) argument 3211 dlm_clean_block_mle(struct dlm_ctxt *dlm, struct dlm_master_list_entry *mle, u8 dead_node) argument 3240 dlm_clean_master_list(struct dlm_ctxt *dlm, u8 dead_node) argument 3315 dlm_finish_migration(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 old_master) argument 3413 dlm_lockres_release_ast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res) argument 3432 dlm_force_free_mles(struct dlm_ctxt *dlm) argument [all...] |
H A D | dlmast.c | 51 static void dlm_update_lvb(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, 53 static int dlm_should_cancel_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock); 64 static int dlm_should_cancel_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 66 assert_spin_locked(&dlm->ast_lock); 91 void __dlm_queue_ast(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 95 BUG_ON(!dlm); 100 assert_spin_locked(&dlm->ast_lock); 105 dlm->name, res->lockname.len, res->lockname.name, 113 dlm->name, res->lockname.len, res->lockname.name, 122 if (dlm_should_cancel_bast(dlm, loc 146 dlm_queue_ast(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 157 __dlm_queue_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 183 dlm_queue_bast(struct dlm_ctxt *dlm, struct dlm_lock *lock) argument 193 dlm_update_lvb(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock) argument 223 dlm_do_local_ast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock) argument 243 dlm_do_remote_ast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock) argument 267 dlm_do_local_bast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int blocked_type) argument 290 struct dlm_ctxt *dlm = data; local 446 dlm_send_proxy_ast_msg(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int msg_type, int blocked_type, int flags) argument [all...] |
H A D | dlmdebug.c | 6 * debug functionality for the dlm 246 * of the format of the lockname that should be outside the purview of the dlm. 247 * We are adding only to make dlm debugging slightly easier. 385 static int debug_purgelist_print(struct dlm_ctxt *dlm, char *buf, int len) argument 392 "Dumping Purgelist for Domain: %s\n", dlm->name); 394 spin_lock(&dlm->spinlock); 395 list_for_each_entry(res, &dlm->purge_list, purge) { 407 spin_unlock(&dlm->spinlock); 416 struct dlm_ctxt *dlm = inode->i_private; local 423 i_size_write(inode, debug_purgelist_print(dlm, bu 441 debug_mle_print(struct dlm_ctxt *dlm, char *buf, int len) argument 473 struct dlm_ctxt *dlm = inode->i_private; local 579 struct dlm_ctxt *dlm = dl->dl_ctxt; local 649 struct dlm_ctxt *dlm = inode->i_private; local 697 debug_state_print(struct dlm_ctxt *dlm, char *buf, int len) argument 864 struct dlm_ctxt *dlm = inode->i_private; local 889 dlm_debug_init(struct dlm_ctxt *dlm) argument 943 dlm_debug_shutdown(struct dlm_ctxt *dlm) argument 957 dlm_create_debugfs_subroot(struct dlm_ctxt *dlm) argument 980 dlm_destroy_debugfs_subroot(struct dlm_ctxt *dlm) argument [all...] |
H A D | dlmcommon.h | 62 struct dlm_ctxt *dlm; member in struct:dlm_master_list_entry 186 /* This is the inter-dlm communication version */ 190 static inline struct hlist_head *dlm_lockres_hash(struct dlm_ctxt *dlm, unsigned i) argument 192 return dlm->lockres_hash[(i / DLM_BUCKETS_PER_PAGE) % DLM_HASH_PAGES] + (i % DLM_BUCKETS_PER_PAGE); 195 static inline struct hlist_head *dlm_master_hash(struct dlm_ctxt *dlm, argument 198 return dlm->master_hash[(i / DLM_BUCKETS_PER_PAGE) % DLM_HASH_PAGES] + 244 struct dlm_ctxt *dlm; member in struct:dlm_work_item 254 static inline void dlm_init_work_item(struct dlm_ctxt *dlm, argument 262 i->dlm = dlm; /* mus 267 __dlm_set_joining_node(struct dlm_ctxt *dlm, u8 node) argument 324 struct dlm_ctxt *dlm; member in struct:dlm_lock_resource 936 dlm_send_proxy_bast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int blocked_type) argument 945 dlm_send_proxy_ast(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int flags) argument 1131 dlm_set_lockres_owner(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 owner) argument 1140 dlm_change_lockres_owner(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, u8 owner) argument [all...] |
H A D | dlmlock.c | 60 static enum dlm_status dlm_send_remote_lock_request(struct dlm_ctxt *dlm, 119 static enum dlm_status dlmlock_master(struct dlm_ctxt *dlm, argument 133 lock->ml.node != dlm->node_num) { 161 "node %u for reco lock\n", dlm->name, 172 "node %u for reco lock\n", dlm->name, 188 dlm_queue_ast(dlm, lock); 190 dlm_lockres_release_ast(dlm, res); 192 dlm_lockres_calc_usage(dlm, res); 194 dlm_kick_thread(dlm, res); 215 static enum dlm_status dlmlock_remote(struct dlm_ctxt *dlm, argument 301 dlm_send_remote_lock_request(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int flags) argument 461 struct dlm_ctxt *dlm = data; local 558 dlmlock(struct dlm_ctxt *dlm, int mode, struct dlm_lockstatus *lksb, int flags, const char *name, int namelen, dlm_astlockfunc_t *ast, void *data, dlm_bastlockfunc_t *bast) argument [all...] |
H A D | dlmunlock.c | 58 static enum dlm_status dlm_get_cancel_actions(struct dlm_ctxt *dlm, 63 static enum dlm_status dlm_get_unlock_actions(struct dlm_ctxt *dlm, 69 static enum dlm_status dlm_send_remote_unlock_request(struct dlm_ctxt *dlm, 98 static enum dlm_status dlmunlock_common(struct dlm_ctxt *dlm, argument 114 BUG_ON(res->owner != dlm->node_num); 116 BUG_ON(res->owner == dlm->node_num); 118 spin_lock(&dlm->ast_lock); 122 spin_unlock(&dlm->ast_lock); 156 status = dlm_get_cancel_actions(dlm, res, lock, lksb, &actions); 158 status = dlm_get_unlock_actions(dlm, re 283 dlmunlock_master(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, struct dlm_lockstatus *lksb, int flags, int *call_ast) argument 293 dlmunlock_remote(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, struct dlm_lockstatus *lksb, int flags, int *call_ast) argument 309 dlm_send_remote_unlock_request(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, struct dlm_lockstatus *lksb, int flags, u8 owner) argument 394 struct dlm_ctxt *dlm = data; local 528 dlm_get_cancel_actions(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, struct dlm_lockstatus *lksb, int *actions) argument 560 dlm_get_unlock_actions(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, struct dlm_lockstatus *lksb, int *actions) argument 587 dlmunlock(struct dlm_ctxt *dlm, struct dlm_lockstatus *lksb, int flags, dlm_astunlockfunc_t *unlockast, void *data) argument [all...] |
H A D | dlmconvert.c | 58 static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm, 63 static enum dlm_status dlm_send_remote_convert_request(struct dlm_ctxt *dlm, 76 enum dlm_status dlmconvert_master(struct dlm_ctxt *dlm, argument 89 status = __dlmconvert_master(dlm, res, lock, flags, type, 100 dlm_queue_ast(dlm, lock); 102 dlm_lockres_release_ast(dlm, res); 105 dlm_kick_thread(dlm, res); 119 static enum dlm_status __dlmconvert_master(struct dlm_ctxt *dlm, argument 209 if (lock->ml.node == dlm->node_num) 260 enum dlm_status dlmconvert_remote(struct dlm_ctxt *dlm, argument 342 dlm_send_remote_convert_request(struct dlm_ctxt *dlm, struct dlm_lock_resource *res, struct dlm_lock *lock, int flags, int type) argument 421 struct dlm_ctxt *dlm = data; local [all...] |
H A D | dlmapi.h | 6 * externally exported dlm interfaces 88 * meantime this lets us track dlm errors as they bubble up. When we 95 mlog(ML_ERROR, "dlm status = %s\n", dlm_errname((st))); \ 130 * reserved: flags used by the "real" dlm 131 * only a few are supported by this dlm 132 * (U) = unsupported by ocfs2 dlm */ 180 enum dlm_status dlmlock(struct dlm_ctxt *dlm, 190 enum dlm_status dlmunlock(struct dlm_ctxt *dlm, 203 void dlm_unregister_domain(struct dlm_ctxt *dlm); 216 void dlm_register_eviction_cb(struct dlm_ctxt *dlm, [all...] |
/fs/dlm/ |
H A D | Makefile | 1 obj-$(CONFIG_DLM) += dlm.o 2 dlm-y := ast.o \ 20 dlm-$(CONFIG_DLM_DEBUG) += debug_fs.o
|
H A D | netlink.c | 10 #include <linux/dlm.h>
|
H A D | dlm_internal.h | 44 #include <linux/dlm.h> 65 printk(KERN_ERR "dlm: "fmt"\n" , ##args) 67 printk(KERN_ERR "dlm: %s: " fmt "\n", (ls)->ls_name , ##args) 69 printk(KERN_INFO "dlm: %s: " fmt "\n", (ls)->ls_name , ##args); 74 printk(KERN_DEBUG "dlm: %s: " fmt "\n", \ 81 printk_ratelimited(KERN_DEBUG "dlm: %s: " fmt "\n", \ 164 * dlm_unlock. The dlm does not modify these or use any private flags in 165 * this field; it only contains DLM_LKF_ flags from dlm.h. These flags 168 * lkb_flags: internal dlm flags (DLM_IFL_ prefix) from dlm_internal.h. 177 * ast. All defined in dlm [all...] |
H A D | plock.c | 12 #include <linux/dlm.h>
|
H A D | user.c | 18 #include <linux/dlm.h> 29 static const char name_prefix[] = "dlm"; 455 printk(KERN_DEBUG "dlm: process %s (%d) version mismatch " 962 .name = "dlm-control", 975 .name = "dlm-monitor",
|
/fs/ocfs2/ |
H A D | stack_o2cb.c | 240 * o2dlm aways has a "valid" LVB. If the dlm loses track of the LVB 315 * Called from the dlm when it's about to evict a node. This is how the 332 struct dlm_ctxt *dlm; local 359 /* used by the dlm code to make message headers unique, each 365 dlm = dlm_register_domain(conn->cc_name, dlm_key, &fs_version); 366 if (IS_ERR(dlm)) { 367 rc = PTR_ERR(dlm); 374 conn->cc_lockspace = dlm; 376 dlm_register_eviction_cb(dlm, &priv->op_eviction_cb); 388 struct dlm_ctxt *dlm local [all...] |
H A D | Makefile | 53 obj-$(CONFIG_OCFS2_FS_O2CB) += dlm/
|
H A D | stackglue.h | 28 #include "dlm/dlmapi.h" 29 #include <linux/dlm.h> 43 * This shadows DLM_LOCKSPACE_LEN in fs/dlm/dlm_internal.h. That probably 164 * Call the underlying dlm lock function. The ->dlm_lock() 181 * Call the underlying dlm unlock function. The ->dlm_unlock()
|
/fs/ |
H A D | Makefile | 60 obj-$(CONFIG_DLM) += dlm/
|
/fs/gfs2/ |
H A D | incore.h | 16 #include <linux/dlm.h> 156 * Internally, we prefix things with gdlm_ and GDLM_ (for gfs-dlm) since a 166 * DFL_BLOCK_LOCKS: dlm is in recovery and will grant locks that had been 169 * This is set by the dlm recover_prep callback and cleared by the 175 * DFL_NO_DLM_OPS: dlm lockspace ops/callbacks are not being used. 190 * DFL_DLM_RECOVERY: set while dlm is in recovery, between recover_prep() 236 GFS2_LKS_DCOUNT = 6, /* Count of dlm requests */ 337 gl_req:2, /* State in last dlm request */ 338 gl_reply:8; /* Last reply from the dlm */
|
H A D | file.c | 26 #include <linux/dlm.h>
|