Home
last modified time | relevance | path

Searched refs:node_num (Results 1 – 25 of 33) sorted by relevance

12

/fs/ocfs2/
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()
313 node_num, conn->cc_namelen, conn->cc_name); in o2dlm_eviction_cb()
394 int node_num; in o2cb_cluster_this_node() local
396 node_num = o2nm_this_node(); in o2cb_cluster_this_node()
397 if (node_num == O2NM_INVALID_NODE_NUM) in o2cb_cluster_this_node()
400 if (node_num >= O2NM_MAX_NODES) in o2cb_cluster_this_node()
[all …]
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()
A Djournal.c50 int node_num, int slot_num);
111 int i, node_num; in ocfs2_compute_replay_slots() local
252 unsigned int node_num) in __ocfs2_recovery_map_test() argument
269 unsigned int node_num) in ocfs2_recovery_map_set() argument
290 unsigned int node_num) in ocfs2_recovery_map_clear() argument
1558 status, node_num, in __ocfs2_recovery_thread()
1625 trace_ocfs2_recovery_thread(node_num, osb->node_num, in ocfs2_recovery_thread()
1685 int node_num, in ocfs2_replay_journal() argument
1838 trace_ocfs2_recover_node(node_num, slot_num, osb->node_num); in ocfs2_recover_node()
1842 BUG_ON(osb->node_num == node_num); in ocfs2_recover_node()
[all …]
A Dslot_map.c45 unsigned int node_num);
55 int slot_num, unsigned int node_num) in ocfs2_set_slot() argument
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() argument
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() argument
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()
[all …]
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,
A Dslot_map.h22 int ocfs2_node_num_to_slot(struct ocfs2_super *osb, unsigned int node_num);
24 unsigned int *node_num);
A Dheartbeat.h15 void ocfs2_do_node_down(int node_num, void *data);
A Dlocalalloc.h21 int node_num,
A Dstackglue.c307 void (*recovery_handler)(int node_num, in ocfs2_cluster_connect() argument
376 void (*recovery_handler)(int node_num, in ocfs2_cluster_connect_agnostic() argument
A Docfs2_trace.h2627 TP_PROTO(int node_num, int osb_node_num, int disable,
2629 TP_ARGS(node_num, osb_node_num, disable, recovery_thread, map_set),
2631 __field(int, node_num)
2638 __entry->node_num = node_num;
2644 TP_printk("%d %d %d %p %d", __entry->node_num,
/fs/ocfs2/dlm/
A Ddlmrecovery.c560 ndata->node_num); in dlm_remaster_locks()
562 if (ndata->node_num == dlm->node_num) { in dlm_remaster_locks()
580 ndata->node_num), in dlm_remaster_locks()
643 ndata->node_num); in dlm_remaster_locks()
701 dlm->node_num); in dlm_remaster_locks()
752 ndata->node_num = num; in dlm_init_recovery_area()
792 lr.node_idx = dlm->node_num; in dlm_request_all_locks()
1011 ndata->node_num); in dlm_reco_data_done_handler()
1666 req.node_idx = dlm->node_num; in dlm_do_master_requery()
2685 br.node_idx = dlm->node_num; in dlm_send_begin_reco_message()
[all …]
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()
A Ddlmmaster.c1083 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()
2106 bit = dlm->node_num; in dlm_assert_master_worker()
2179 if (nodenum == dlm->node_num) in dlm_pre_master_reco_lockres()
2227 deref.node_idx = dlm->node_num; in dlm_drop_lockres_ref()
2421 deref.node_idx = dlm->node_num; in dlm_drop_lockres_ref_done()
2502 if (res->owner != dlm->node_num) in dlm_is_lockres_migratable()
2961 if (bit != dlm->node_num) { in dlm_remove_nonlocal_locks()
3008 if (noderef == dlm->node_num) in dlm_pick_migration_target()
[all …]
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()
1058 qr->qr_node = dlm->node_num; in dlm_send_regions()
1073 if (i == dlm->node_num) in dlm_send_regions()
1243 qn->qn_nodenum = dlm->node_num; in dlm_send_nodeinfo()
1251 if (i == dlm->node_num) in dlm_send_nodeinfo()
1394 if (node == dlm->node_num) in dlm_send_join_cancels()
1533 if (node == dlm->node_num) in dlm_send_join_asserts()
1615 if (node == dlm->node_num) in dlm_try_to_join_domain()
1984 dlm->node_num = o2nm_this_node(); in dlm_alloc_ctxt()
[all …]
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()
A Ddlmunlock.c98 BUG_ON(res->owner != dlm->node_num); in dlmunlock_common()
100 BUG_ON(res->owner == dlm->node_num); in dlmunlock_common()
323 if (owner == dlm->node_num) { in dlm_send_remote_unlock_request()
334 unlock.node_idx = dlm->node_num; in dlm_send_remote_unlock_request()
455 if (res->owner != dlm->node_num) { in dlm_unlock_lock_handler()
625 is_master = (res->owner == dlm->node_num); in dlmunlock()
A Ddlmthread.c199 master = (res->owner == dlm->node_num); in dlm_purge_lockres()
515 if (res->owner == dlm->node_num) { in __dlm_dirty_lockres()
597 if (lock->ml.node != dlm->node_num) { in dlm_flush_asts()
649 if (lock->ml.node != dlm->node_num) { in dlm_flush_asts()
728 if (res->owner != dlm->node_num) { in dlm_thread()
737 BUG_ON(res->owner != dlm->node_num); in dlm_thread()
A Ddlmdomain.h39 int node_num);
A Ddlmconvert.c192 if (lock->ml.node == dlm->node_num) in __dlmconvert_master()
367 convert.node_idx = dlm->node_num; in dlm_send_remote_convert_request()
/fs/ubifs/
A Dlpt_commit.c865 nnode = nnode_lookup(c, node_num); in make_nnode_dirty()
915 pnode = ubifs_pnode_lookup(c, node_num); in make_pnode_dirty()
996 return make_nnode_dirty(c, node_num, lnum, offs); in make_node_dirty()
998 return make_pnode_dirty(c, node_num, lnum, offs); in make_node_dirty()
1051 int *node_num) in get_lpt_node_type() argument
1128 node_type = get_lpt_node_type(c, buf, &node_num); in lpt_gc_lnum()
1133 err = make_node_dirty(c, node_type, node_num, lnum, offs); in lpt_gc_lnum()
1640 node_type = get_lpt_node_type(c, p, &node_num); in dbg_check_ltab_lnum()
1876 node_type = get_lpt_node_type(c, p, &node_num); in dump_lpt_leb()
1883 lnum, offs, node_num); in dump_lpt_leb()
[all …]
/fs/ocfs2/cluster/
A Dheartbeat.h65 int o2hb_check_node_heartbeating_no_sem(u8 node_num);
66 int o2hb_check_node_heartbeating_from_callback(u8 node_num);
A Dheartbeat.c284 u8 node_num; member
358 msg.node_num = o2nm_this_node(); in o2hb_send_nego_msg()
448 if (nego_msg->node_num < O2NM_MAX_NODES) in o2hb_nego_timeout_handler()
710 int node_num; in o2hb_prepare_block() local
715 node_num = o2nm_this_node(); in o2hb_prepare_block()
716 slot = &reg->hr_slots[node_num]; in o2hb_prepare_block()
726 hb_block->hb_node = node_num; in o2hb_prepare_block()
794 int node_num) in o2hb_queue_node_event() argument
802 event->hn_node_num = node_num; in o2hb_queue_node_event()
2476 node_num); in o2hb_check_node_heartbeating_no_sem()
[all …]
A Dnodemanager.c30 struct o2nm_node *o2nm_get_node_by_num(u8 node_num) in o2nm_get_node_by_num() argument
34 if (node_num >= O2NM_MAX_NODES || o2nm_single_cluster == NULL) in o2nm_get_node_by_num()
38 node = o2nm_single_cluster->cl_nodes[node_num]; in o2nm_get_node_by_num()
132 u8 node_num = O2NM_MAX_NODES; in o2nm_this_node() local
135 node_num = o2nm_single_cluster->cl_local_node; in o2nm_this_node()
137 return node_num; in o2nm_this_node()
A Dtcp.c277 static struct o2net_node * o2net_nn_from_num(u8 node_num) in o2net_nn_from_num() argument
279 BUG_ON(node_num >= ARRAY_SIZE(o2net_nodes)); in o2net_nn_from_num()
280 return &o2net_nodes[node_num]; in o2net_nn_from_num()
1713 static void o2net_hb_node_down_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_down_cb() argument
1716 o2quo_hb_down(node_num); in o2net_hb_node_down_cb()
1721 if (node_num != o2nm_this_node()) in o2net_hb_node_down_cb()
1727 static void o2net_hb_node_up_cb(struct o2nm_node *node, int node_num, in o2net_hb_node_up_cb() argument
1730 struct o2net_node *nn = o2net_nn_from_num(node_num); in o2net_hb_node_up_cb()
1732 o2quo_hb_up(node_num); in o2net_hb_node_up_cb()
1740 if (node_num != o2nm_this_node()) { in o2net_hb_node_up_cb()
A Dnodemanager.h61 struct o2nm_node *o2nm_get_node_by_num(u8 node_num);

Completed in 61 milliseconds

12