| /fs/ocfs2/ |
| D | stack_o2cb.c | 265 u8 node_num; in o2cb_cluster_check() local
270 node_num = o2nm_this_node(); in o2cb_cluster_check()
271 if (node_num == O2NM_MAX_NODES) { in o2cb_cluster_check()
287 if (!test_bit(node_num, hbmap)) { in o2cb_cluster_check()
295 set_bit(node_num, netmap); in o2cb_cluster_check()
318 static void o2dlm_eviction_cb(int node_num, void *data) in o2dlm_eviction_cb() argument
323 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
325 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
404 int node_num; in o2cb_cluster_this_node() local
406 node_num = o2nm_this_node(); in o2cb_cluster_this_node()
[all …]
|
| D | journal.c | 63 int node_num, int slot_num);
122 int i, node_num; in ocfs2_compute_replay_slots() local
143 if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT) in ocfs2_compute_replay_slots()
241 unsigned int node_num) in __ocfs2_recovery_map_test() argument
249 if (rm->rm_entries[i] == node_num) in __ocfs2_recovery_map_test()
258 unsigned int node_num) in ocfs2_recovery_map_set() argument
263 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_recovery_map_set()
271 rm->rm_entries[rm->rm_used] = node_num; in ocfs2_recovery_map_set()
279 unsigned int node_num) in ocfs2_recovery_map_clear() argument
287 if (rm->rm_entries[i] == node_num) in ocfs2_recovery_map_clear()
[all …]
|
| D | heartbeat.c | 63 void ocfs2_do_node_down(int node_num, void *data) in ocfs2_do_node_down() argument
67 BUG_ON(osb->node_num == node_num); in ocfs2_do_node_down()
69 trace_ocfs2_do_node_down(node_num); in ocfs2_do_node_down()
81 ocfs2_recovery_thread(osb, node_num); in ocfs2_do_node_down()
|
| D | slot_map.c | 63 unsigned int node_num);
73 int slot_num, unsigned int node_num) in ocfs2_set_slot() argument
78 si->si_slots[slot_num].sl_node_num = node_num; in ocfs2_set_slot()
252 unsigned int node_num) in __ocfs2_node_num_to_slot() argument
258 (node_num == si->si_slots[i].sl_node_num)) { in __ocfs2_node_num_to_slot()
289 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num) in ocfs2_node_num_to_slot() argument
295 slot = __ocfs2_node_num_to_slot(si, node_num); in ocfs2_node_num_to_slot()
302 unsigned int *node_num) in ocfs2_slot_to_node_num_locked() argument
314 *node_num = si->si_slots[slot_num].sl_node_num; in ocfs2_slot_to_node_num_locked()
484 slot = __ocfs2_node_num_to_slot(si, osb->node_num); in ocfs2_find_slot()
[all …]
|
| D | stackglue.h | 109 void (*cc_recovery_handler)(int node_num, void *recovery_data);
253 void (*recovery_handler)(int node_num,
264 void (*recovery_handler)(int node_num,
|
| D | slot_map.h | 38 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num);
40 unsigned int *node_num);
|
| D | heartbeat.h | 31 void ocfs2_do_node_down(int node_num, void *data);
|
| D | super.h | 32 int node_num);
|
| D | localalloc.h | 37 int node_num,
|
| D | stackglue.c | 317 void (*recovery_handler)(int node_num, in ocfs2_cluster_connect() argument
386 void (*recovery_handler)(int node_num, in ocfs2_cluster_connect_agnostic() argument
|
| /fs/ocfs2/dlm/ |
| D | dlmrecovery.c | 291 dlm->name, ndata->node_num, st); in dlm_print_reco_node_status()
448 (dlm->node_num == dlm->reco.new_master ? "me" : "he"), in dlm_print_recovery_master()
499 if (dlm->reco.new_master == dlm->node_num) in dlm_do_recovery()
539 dlm->name, dlm->reco.dead_node, dlm->node_num); in dlm_do_recovery()
577 ndata->node_num); in dlm_remaster_locks()
579 if (ndata->node_num == dlm->node_num) { in dlm_remaster_locks()
585 status = dlm_request_all_locks(dlm, ndata->node_num, in dlm_remaster_locks()
597 ndata->node_num), in dlm_remaster_locks()
600 "dead? %s\n", ndata->node_num, in dlm_remaster_locks()
601 dlm_is_node_dead(dlm, ndata->node_num) ? in dlm_remaster_locks()
[all …]
|
| D | dlmlock.c | 133 lock->ml.node != dlm->node_num) { in dlmlock_master()
232 if (res->owner == dlm->node_num) { in dlmlock_remote()
281 dlm->name, dlm->node_num, res->owner); in dlmlock_remote()
310 create.node_idx = dlm->node_num; in dlm_send_remote_lock_request()
542 static inline void dlm_get_next_cookie(u8 node_num, u64 *cookie) in dlm_get_next_cookie() argument
544 u64 tmpnode = node_num; in dlm_get_next_cookie()
637 if (res->owner == dlm->node_num) in dlmlock()
668 dlm_get_next_cookie(dlm->node_num, &tmpcookie); in dlmlock()
669 lock = dlm_new_lock(mode, dlm->node_num, tmpcookie, lksb); in dlmlock()
708 if (res->owner == dlm->node_num) in dlmlock()
|
| D | dlmmaster.c | 312 clear_bit(dlm->node_num, mle->vote_map); in dlm_init_mle()
313 clear_bit(dlm->node_num, mle->node_map); in dlm_init_mle()
793 BUG_ON(tmpres->owner == dlm->node_num); in dlm_get_lock_resource()
831 dlm_change_lockres_owner(dlm, res, dlm->node_num); in dlm_get_lock_resource()
861 BUG_ON(mig && mle->master == dlm->node_num); in dlm_get_lock_resource()
887 set_bit(dlm->node_num, mle->maybe_map); in dlm_get_lock_resource()
1053 if (res->owner != dlm->node_num) { in dlm_wait_for_lock_mastery()
1113 if (dlm->node_num <= bit) { in dlm_wait_for_lock_mastery()
1117 mle->master = dlm->node_num; in dlm_wait_for_lock_mastery()
1156 m = dlm->node_num; in dlm_wait_for_lock_mastery()
[all …]
|
| D | dlmdomain.c | 588 leave_msg.node_idx = dlm->node_num; in dlm_send_one_domain_exit()
619 if (node == dlm->node_num) in dlm_begin_exit_domain()
640 clear_bit(dlm->node_num, dlm->domain_map); in dlm_leave_domain()
1001 qr->qr_domain, qr->qr_node, dlm->node_num); in dlm_match_regions()
1010 qr->qr_domain, dlm->node_num, qr->qr_node); in dlm_match_regions()
1041 dlm->node_num, qr->qr_node); in dlm_match_regions()
1064 qr->qr_node, dlm->node_num); in dlm_match_regions()
1090 qr->qr_node = dlm->node_num; in dlm_send_regions()
1105 if (i == dlm->node_num) in dlm_send_regions()
1228 qn->qn_nodenum, dlm->node_num); in dlm_match_nodes()
[all …]
|
| D | dlmast.c | 201 if (res->owner == dlm->node_num) { in dlm_update_lvb()
205 lock->ml.node == dlm->node_num ? "master" : in dlm_update_lvb()
236 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_ast()
256 BUG_ON(lock->ml.node == dlm->node_num); in dlm_do_remote_ast()
272 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_bast()
357 BUG_ON(res->owner == dlm->node_num); in dlm_proxy_ast_handler()
461 past.node_idx = dlm->node_num; in dlm_send_proxy_ast_msg()
|
| D | dlmunlock.c | 114 BUG_ON(res->owner != dlm->node_num); in dlmunlock_common()
116 BUG_ON(res->owner == dlm->node_num); in dlmunlock_common()
325 if (owner == dlm->node_num) { in dlm_send_remote_unlock_request()
336 unlock.node_idx = dlm->node_num; in dlm_send_remote_unlock_request()
458 if (res->owner != dlm->node_num) { in dlm_unlock_lock_handler()
628 is_master = (res->owner == dlm->node_num); in dlmunlock()
|
| D | dlmthread.c | 57 #define dlm_lock_is_remote(dlm, lock) ((lock)->ml.node != (dlm)->node_num)
171 master = (res->owner == dlm->node_num); in dlm_purge_lockres()
463 if ((res->owner == dlm->node_num)) { in __dlm_dirty_lockres()
544 if (lock->ml.node != dlm->node_num) { in dlm_flush_asts()
596 if (lock->ml.node != dlm->node_num) { in dlm_flush_asts()
676 if (res->owner != dlm->node_num) { in dlm_thread()
685 BUG_ON(res->owner != dlm->node_num); in dlm_thread()
|
| D | dlmdomain.h | 34 int node_num);
|
| D | dlmconvert.c | 209 if (lock->ml.node == dlm->node_num) in __dlmconvert_master()
378 convert.node_idx = dlm->node_num; in dlm_send_remote_convert_request()
|
| /fs/ocfs2/cluster/ |
| D | heartbeat.h | 82 int o2hb_check_node_heartbeating(u8 node_num);
83 int o2hb_check_node_heartbeating_no_sem(u8 node_num);
84 int o2hb_check_node_heartbeating_from_callback(u8 node_num);
|
| D | heartbeat.c | 590 int node_num; in o2hb_prepare_block() local
595 node_num = o2nm_this_node(); in o2hb_prepare_block()
596 slot = ®->hr_slots[node_num]; in o2hb_prepare_block()
606 hb_block->hb_node = node_num; in o2hb_prepare_block()
674 int node_num) in o2hb_queue_node_event() argument
682 event->hn_node_num = node_num; in o2hb_queue_node_event()
685 type == O2HB_NODE_UP_CB ? "UP" : "DOWN", node_num); in o2hb_queue_node_event()
2559 int o2hb_check_node_heartbeating(u8 node_num) in o2hb_check_node_heartbeating() argument
2564 if (!test_bit(node_num, testing_map)) { in o2hb_check_node_heartbeating()
2567 node_num); in o2hb_check_node_heartbeating()
[all …]
|
| D | nodemanager.c | 43 struct o2nm_node *o2nm_get_node_by_num(u8 node_num) in o2nm_get_node_by_num() argument
47 if (node_num >= O2NM_MAX_NODES || o2nm_single_cluster == NULL) in o2nm_get_node_by_num()
51 node = o2nm_single_cluster->cl_nodes[node_num]; in o2nm_get_node_by_num()
145 u8 node_num = O2NM_MAX_NODES; in o2nm_this_node() local
148 node_num = o2nm_single_cluster->cl_local_node; in o2nm_this_node()
150 return node_num; in o2nm_this_node()
|
| D | tcp.c | 291 static struct o2net_node * o2net_nn_from_num(u8 node_num) in o2net_nn_from_num() argument
293 BUG_ON(node_num >= ARRAY_SIZE(o2net_nodes)); in o2net_nn_from_num()
294 return &o2net_nodes[node_num]; in o2net_nn_from_num()
1772 static void o2net_hb_node_down_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_down_cb() argument
1775 o2quo_hb_down(node_num); in o2net_hb_node_down_cb()
1780 if (node_num != o2nm_this_node()) in o2net_hb_node_down_cb()
1786 static void o2net_hb_node_up_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_up_cb() argument
1789 struct o2net_node *nn = o2net_nn_from_num(node_num); in o2net_hb_node_up_cb()
1791 o2quo_hb_up(node_num); in o2net_hb_node_up_cb()
1799 if (node_num != o2nm_this_node()) { in o2net_hb_node_up_cb()
|
| D | nodemanager.h | 78 struct o2nm_node *o2nm_get_node_by_num(u8 node_num);
|
| /fs/ubifs/ |
| D | lpt_commit.c | 903 static int make_nnode_dirty(struct ubifs_info *c, int node_num, int lnum, in make_nnode_dirty() argument
908 nnode = nnode_lookup(c, node_num); in make_nnode_dirty()
952 static int make_pnode_dirty(struct ubifs_info *c, int node_num, int lnum, in make_pnode_dirty() argument
958 pnode = pnode_lookup(c, node_num); in make_pnode_dirty()
1034 static int make_node_dirty(struct ubifs_info *c, int node_type, int node_num, in make_node_dirty() argument
1039 return make_nnode_dirty(c, node_num, lnum, offs); in make_node_dirty()
1041 return make_pnode_dirty(c, node_num, lnum, offs); in make_node_dirty()
1094 int *node_num) in get_lpt_node_type() argument
1100 *node_num = ubifs_unpack_bits(&addr, &pos, c->pcnt_bits); in get_lpt_node_type()
1150 int err, len = c->leb_size, node_type, node_num, node_len, offs; in lpt_gc_lnum() local
[all …]
|