Home
last modified time | relevance | path

Searched refs:node_num (Results 1 - 25 of 78) sorted by relevance

1234

/kernel/linux/linux-5.10/fs/ocfs2/
H A Dstack_o2cb.c257 u8 node_num; in o2cb_cluster_check() local
262 node_num = o2nm_this_node(); in o2cb_cluster_check()
263 if (node_num == O2NM_MAX_NODES) { in o2cb_cluster_check()
279 if (!test_bit(node_num, hbmap)) { in o2cb_cluster_check()
287 set_bit(node_num, netmap); in o2cb_cluster_check()
310 static void o2dlm_eviction_cb(int node_num, void *data) in o2dlm_eviction_cb() argument
315 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
317 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
396 int node_num; in o2cb_cluster_this_node() local
398 node_num in o2cb_cluster_this_node()
[all...]
H A Dheartbeat.c49 void ocfs2_do_node_down(int node_num, void *data) in ocfs2_do_node_down() argument
53 BUG_ON(osb->node_num == node_num); in ocfs2_do_node_down()
55 trace_ocfs2_do_node_down(node_num); in ocfs2_do_node_down()
67 ocfs2_recovery_thread(osb, node_num); in ocfs2_do_node_down()
H A Dslot_map.c47 unsigned int node_num);
57 int slot_num, unsigned int node_num) in ocfs2_set_slot()
62 si->si_slots[slot_num].sl_node_num = node_num; in ocfs2_set_slot()
236 unsigned int node_num) in __ocfs2_node_num_to_slot()
242 (node_num == si->si_slots[i].sl_node_num)) { in __ocfs2_node_num_to_slot()
273 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num) in ocfs2_node_num_to_slot() argument
279 slot = __ocfs2_node_num_to_slot(si, node_num); in ocfs2_node_num_to_slot()
286 unsigned int *node_num) in ocfs2_slot_to_node_num_locked()
298 *node_num = si->si_slots[slot_num].sl_node_num; in ocfs2_slot_to_node_num_locked()
463 slot = __ocfs2_node_num_to_slot(si, osb->node_num); in ocfs2_find_slot()
56 ocfs2_set_slot(struct ocfs2_slot_info *si, int slot_num, unsigned int node_num) ocfs2_set_slot() argument
235 __ocfs2_node_num_to_slot(struct ocfs2_slot_info *si, unsigned int node_num) __ocfs2_node_num_to_slot() argument
285 ocfs2_slot_to_node_num_locked(struct ocfs2_super *osb, int slot_num, unsigned int *node_num) ocfs2_slot_to_node_num_locked() argument
[all...]
H A Djournal.c51 int node_num, int slot_num);
112 int i, node_num; in ocfs2_compute_replay_slots() local
133 if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT) in ocfs2_compute_replay_slots()
234 unsigned int node_num) in __ocfs2_recovery_map_test()
242 if (rm->rm_entries[i] == node_num) in __ocfs2_recovery_map_test()
251 unsigned int node_num) in ocfs2_recovery_map_set()
256 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_recovery_map_set()
264 rm->rm_entries[rm->rm_used] = node_num; in ocfs2_recovery_map_set()
272 unsigned int node_num) in ocfs2_recovery_map_clear()
280 if (rm->rm_entries[i] == node_num) in ocfs2_recovery_map_clear()
233 __ocfs2_recovery_map_test(struct ocfs2_super *osb, unsigned int node_num) __ocfs2_recovery_map_test() argument
250 ocfs2_recovery_map_set(struct ocfs2_super *osb, unsigned int node_num) ocfs2_recovery_map_set() argument
271 ocfs2_recovery_map_clear(struct ocfs2_super *osb, unsigned int node_num) ocfs2_recovery_map_clear() argument
1371 int status, node_num, slot_num; __ocfs2_recovery_thread() local
1508 ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num) ocfs2_recovery_thread() argument
1573 ocfs2_replay_journal(struct ocfs2_super *osb, int node_num, int slot_num) ocfs2_replay_journal() argument
1722 ocfs2_recover_node(struct ocfs2_super *osb, int node_num, int slot_num) ocfs2_recover_node() argument
1820 unsigned int node_num; ocfs2_mark_dead_nodes() local
[all...]
H A Dslot_map.h24 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num);
26 unsigned int *node_num);
H A Dstackglue.h101 void (*cc_recovery_handler)(int node_num, void *recovery_data);
245 void (*recovery_handler)(int node_num,
256 void (*recovery_handler)(int node_num,
/kernel/linux/linux-6.6/fs/ocfs2/
H A Dstack_o2cb.c255 u8 node_num; in o2cb_cluster_check() local
260 node_num = o2nm_this_node(); in o2cb_cluster_check()
261 if (node_num == O2NM_MAX_NODES) { in o2cb_cluster_check()
277 if (!test_bit(node_num, hbmap)) { in o2cb_cluster_check()
285 set_bit(node_num, netmap); in o2cb_cluster_check()
308 static void o2dlm_eviction_cb(int node_num, void *data) in o2dlm_eviction_cb() argument
313 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
315 conn->cc_recovery_handler(node_num, conn->cc_recovery_data); in o2dlm_eviction_cb()
394 int node_num; in o2cb_cluster_this_node() local
396 node_num in o2cb_cluster_this_node()
[all...]
H A Dheartbeat.c42 void ocfs2_do_node_down(int node_num, void *data) in ocfs2_do_node_down() argument
46 BUG_ON(osb->node_num == node_num); in ocfs2_do_node_down()
48 trace_ocfs2_do_node_down(node_num); in ocfs2_do_node_down()
60 ocfs2_recovery_thread(osb, node_num); in ocfs2_do_node_down()
H A Dslot_map.c45 unsigned int node_num);
55 int slot_num, unsigned int node_num) in ocfs2_set_slot()
60 si->si_slots[slot_num].sl_node_num = node_num; in ocfs2_set_slot()
234 unsigned int node_num) in __ocfs2_node_num_to_slot()
240 (node_num == si->si_slots[i].sl_node_num)) { in __ocfs2_node_num_to_slot()
271 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num) in ocfs2_node_num_to_slot() argument
277 slot = __ocfs2_node_num_to_slot(si, node_num); in ocfs2_node_num_to_slot()
284 unsigned int *node_num) in ocfs2_slot_to_node_num_locked()
296 *node_num = si->si_slots[slot_num].sl_node_num; in ocfs2_slot_to_node_num_locked()
461 slot = __ocfs2_node_num_to_slot(si, osb->node_num); in ocfs2_find_slot()
54 ocfs2_set_slot(struct ocfs2_slot_info *si, int slot_num, unsigned int node_num) ocfs2_set_slot() argument
233 __ocfs2_node_num_to_slot(struct ocfs2_slot_info *si, unsigned int node_num) __ocfs2_node_num_to_slot() argument
283 ocfs2_slot_to_node_num_locked(struct ocfs2_super *osb, int slot_num, unsigned int *node_num) ocfs2_slot_to_node_num_locked() argument
[all...]
H A Djournal.c50 int node_num, int slot_num);
111 int i, node_num; in ocfs2_compute_replay_slots() local
132 if (ocfs2_slot_to_node_num_locked(osb, i, &node_num) == -ENOENT) in ocfs2_compute_replay_slots()
230 unsigned int node_num) in __ocfs2_recovery_map_test()
238 if (rm->rm_entries[i] == node_num) in __ocfs2_recovery_map_test()
247 unsigned int node_num) in ocfs2_recovery_map_set()
252 if (__ocfs2_recovery_map_test(osb, node_num)) { in ocfs2_recovery_map_set()
260 rm->rm_entries[rm->rm_used] = node_num; in ocfs2_recovery_map_set()
268 unsigned int node_num) in ocfs2_recovery_map_clear()
276 if (rm->rm_entries[i] == node_num) in ocfs2_recovery_map_clear()
229 __ocfs2_recovery_map_test(struct ocfs2_super *osb, unsigned int node_num) __ocfs2_recovery_map_test() argument
246 ocfs2_recovery_map_set(struct ocfs2_super *osb, unsigned int node_num) ocfs2_recovery_map_set() argument
267 ocfs2_recovery_map_clear(struct ocfs2_super *osb, unsigned int node_num) ocfs2_recovery_map_clear() argument
1409 int status, node_num, slot_num; __ocfs2_recovery_thread() local
1543 ocfs2_recovery_thread(struct ocfs2_super *osb, int node_num) ocfs2_recovery_thread() argument
1608 ocfs2_replay_journal(struct ocfs2_super *osb, int node_num, int slot_num) ocfs2_replay_journal() argument
1755 ocfs2_recover_node(struct ocfs2_super *osb, int node_num, int slot_num) ocfs2_recover_node() argument
1853 unsigned int node_num; ocfs2_mark_dead_nodes() local
[all...]
H A Dslot_map.h22 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num);
24 unsigned int *node_num);
H A Dstackglue.h99 void (*cc_recovery_handler)(int node_num, void *recovery_data);
243 void (*recovery_handler)(int node_num,
254 void (*recovery_handler)(int node_num,
/kernel/linux/linux-5.10/fs/ocfs2/dlm/
H A Ddlmrecovery.c276 dlm->name, ndata->node_num, st); in dlm_print_reco_node_status()
432 (dlm->node_num == dlm->reco.new_master ? "me" : "he"), in dlm_print_recovery_master()
491 if (dlm->reco.new_master == dlm->node_num) in dlm_do_recovery()
531 dlm->name, dlm->reco.dead_node, dlm->node_num); in dlm_do_recovery()
569 ndata->node_num); in dlm_remaster_locks()
571 if (ndata->node_num == dlm->node_num) { in dlm_remaster_locks()
577 status = dlm_request_all_locks(dlm, ndata->node_num, in dlm_remaster_locks()
589 ndata->node_num), in dlm_remaster_locks()
592 "dead? %s\n", ndata->node_num, in dlm_remaster_locks()
[all...]
H A Ddlmlock.c117 lock->ml.node != dlm->node_num) { in dlmlock_master()
216 if (res->owner == dlm->node_num) { in dlmlock_remote()
265 dlm->name, dlm->node_num, res->owner); in dlmlock_remote()
294 create.node_idx = dlm->node_num; in dlm_send_remote_lock_request()
526 static inline void dlm_get_next_cookie(u8 node_num, u64 *cookie) in dlm_get_next_cookie() argument
528 u64 tmpnode = node_num; in dlm_get_next_cookie()
621 if (res->owner == dlm->node_num) in dlmlock()
652 dlm_get_next_cookie(dlm->node_num, &tmpcookie); in dlmlock()
653 lock = dlm_new_lock(mode, dlm->node_num, tmpcookie, lksb); in dlmlock()
692 if (res->owner == dlm->node_num) in dlmlock()
[all...]
H A Ddlmdomain.c586 leave_msg.node_idx = dlm->node_num; in dlm_send_one_domain_exit()
617 if (node == dlm->node_num) in dlm_begin_exit_domain()
638 clear_bit(dlm->node_num, dlm->domain_map); in dlm_leave_domain()
971 qr->qr_domain, qr->qr_node, dlm->node_num); in dlm_match_regions()
980 qr->qr_domain, dlm->node_num, qr->qr_node); in dlm_match_regions()
1011 dlm->node_num, qr->qr_node); in dlm_match_regions()
1034 qr->qr_node, dlm->node_num); in dlm_match_regions()
1060 qr->qr_node = dlm->node_num; in dlm_send_regions()
1075 if (i == dlm->node_num) in dlm_send_regions()
1198 qn->qn_nodenum, dlm->node_num); in dlm_match_nodes()
2274 dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm, int node_num) dlm_fire_domain_eviction_callbacks() argument
[all...]
H A Ddlmast.c186 if (res->owner == dlm->node_num) { in dlm_update_lvb()
190 lock->ml.node == dlm->node_num ? "master" : in dlm_update_lvb()
219 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_ast()
239 BUG_ON(lock->ml.node == dlm->node_num); in dlm_do_remote_ast()
255 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_bast()
340 BUG_ON(res->owner == dlm->node_num); in dlm_proxy_ast_handler()
448 past.node_idx = dlm->node_num; in dlm_send_proxy_ast_msg()
H A Ddlmmaster.c297 clear_bit(dlm->node_num, mle->vote_map); in dlm_init_mle()
298 clear_bit(dlm->node_num, mle->node_map); in dlm_init_mle()
755 BUG_ON(tmpres->owner == dlm->node_num); in dlm_get_lock_resource()
803 dlm_change_lockres_owner(dlm, res, dlm->node_num); in dlm_get_lock_resource()
833 BUG_ON(mig && mle->master == dlm->node_num); in dlm_get_lock_resource()
859 set_bit(dlm->node_num, mle->maybe_map); in dlm_get_lock_resource()
1025 if (res->owner != dlm->node_num) { in dlm_wait_for_lock_mastery()
1085 if (dlm->node_num <= bit) { in dlm_wait_for_lock_mastery()
1089 mle->master = dlm->node_num; in dlm_wait_for_lock_mastery()
1121 m = dlm->node_num; in dlm_wait_for_lock_mastery()
[all...]
H A Ddlmunlock.c100 BUG_ON(res->owner != dlm->node_num); in dlmunlock_common()
102 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()
/kernel/linux/linux-6.6/fs/ocfs2/dlm/
H A Ddlmrecovery.c267 dlm->name, ndata->node_num, st); in dlm_print_reco_node_status()
423 (dlm->node_num == dlm->reco.new_master ? "me" : "he"), in dlm_print_recovery_master()
482 if (dlm->reco.new_master == dlm->node_num) in dlm_do_recovery()
522 dlm->name, dlm->reco.dead_node, dlm->node_num); in dlm_do_recovery()
560 ndata->node_num); in dlm_remaster_locks()
562 if (ndata->node_num == dlm->node_num) { in dlm_remaster_locks()
568 status = dlm_request_all_locks(dlm, ndata->node_num, in dlm_remaster_locks()
580 ndata->node_num), in dlm_remaster_locks()
583 "dead? %s\n", ndata->node_num, in dlm_remaster_locks()
[all...]
H A Ddlmlock.c115 lock->ml.node != dlm->node_num) { in dlmlock_master()
214 if (res->owner == dlm->node_num) { in dlmlock_remote()
263 dlm->name, dlm->node_num, res->owner); in dlmlock_remote()
292 create.node_idx = dlm->node_num; in dlm_send_remote_lock_request()
524 static inline void dlm_get_next_cookie(u8 node_num, u64 *cookie) in dlm_get_next_cookie() argument
526 u64 tmpnode = node_num; in dlm_get_next_cookie()
619 if (res->owner == dlm->node_num) in dlmlock()
650 dlm_get_next_cookie(dlm->node_num, &tmpcookie); in dlmlock()
651 lock = dlm_new_lock(mode, dlm->node_num, tmpcookie, lksb); in dlmlock()
690 if (res->owner == dlm->node_num) in dlmlock()
[all...]
H A Ddlmdomain.c584 leave_msg.node_idx = dlm->node_num; in dlm_send_one_domain_exit()
615 if (node == dlm->node_num) in dlm_begin_exit_domain()
636 clear_bit(dlm->node_num, dlm->domain_map); in dlm_leave_domain()
969 qr->qr_domain, qr->qr_node, dlm->node_num); in dlm_match_regions()
978 qr->qr_domain, dlm->node_num, qr->qr_node); in dlm_match_regions()
1009 dlm->node_num, qr->qr_node); in dlm_match_regions()
1032 qr->qr_node, dlm->node_num); in dlm_match_regions()
1058 qr->qr_node = dlm->node_num; in dlm_send_regions()
1073 if (i == dlm->node_num) in dlm_send_regions()
1196 qn->qn_nodenum, dlm->node_num); in dlm_match_nodes()
2269 dlm_fire_domain_eviction_callbacks(struct dlm_ctxt *dlm, int node_num) dlm_fire_domain_eviction_callbacks() argument
[all...]
H A Ddlmast.c174 if (res->owner == dlm->node_num) { in dlm_update_lvb()
178 lock->ml.node == dlm->node_num ? "master" : in dlm_update_lvb()
207 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_ast()
227 BUG_ON(lock->ml.node == dlm->node_num); in dlm_do_remote_ast()
243 BUG_ON(lock->ml.node != dlm->node_num); in dlm_do_local_bast()
328 BUG_ON(res->owner == dlm->node_num); in dlm_proxy_ast_handler()
436 past.node_idx = dlm->node_num; in dlm_send_proxy_ast_msg()
H A Ddlmmaster.c295 clear_bit(dlm->node_num, mle->vote_map); in dlm_init_mle()
296 clear_bit(dlm->node_num, mle->node_map); in dlm_init_mle()
753 BUG_ON(tmpres->owner == dlm->node_num); in dlm_get_lock_resource()
801 dlm_change_lockres_owner(dlm, res, dlm->node_num); in dlm_get_lock_resource()
831 BUG_ON(mig && mle->master == dlm->node_num); in dlm_get_lock_resource()
857 set_bit(dlm->node_num, mle->maybe_map); in dlm_get_lock_resource()
1023 if (res->owner != dlm->node_num) { in dlm_wait_for_lock_mastery()
1083 if (dlm->node_num <= bit) { in dlm_wait_for_lock_mastery()
1087 mle->master = dlm->node_num; in dlm_wait_for_lock_mastery()
1119 m = dlm->node_num; in dlm_wait_for_lock_mastery()
[all...]
/kernel/linux/linux-5.10/fs/ocfs2/cluster/
H A Dheartbeat.h67 int o2hb_check_node_heartbeating_no_sem(u8 node_num);
68 int o2hb_check_node_heartbeating_from_callback(u8 node_num);
/kernel/linux/linux-6.6/fs/ocfs2/cluster/
H A Dheartbeat.h65 int o2hb_check_node_heartbeating_no_sem(u8 node_num);
66 int o2hb_check_node_heartbeating_from_callback(u8 node_num);

Completed in 23 milliseconds

1234