Home
last modified time | relevance | path

Searched refs:nodeid (Results 1 – 25 of 56) sorted by relevance

123

/linux-6.12.1/fs/dlm/
Dmidcomms.c155 int nodeid; member
274 static struct midcomms_node *__find_node(int nodeid, int r) in __find_node() argument
279 if (node->nodeid == nodeid) in __find_node()
306 pr_debug("flush midcomms send queue of node %d\n", node->nodeid); in dlm_send_queue_flush()
319 pr_debug("reset node %d\n", node->nodeid); in midcomms_node_reset()
332 static struct midcomms_node *nodeid2node(int nodeid) in nodeid2node() argument
334 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
337 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr) in dlm_midcomms_addr() argument
339 int ret, idx, r = nodeid_hash(nodeid); in dlm_midcomms_addr()
342 ret = dlm_lowcomms_addr(nodeid, addr); in dlm_midcomms_addr()
[all …]
Dmember.c52 if (!slot->nodeid) in dlm_slots_copy_out()
54 ro->ro_nodeid = cpu_to_le32(slot->nodeid); in dlm_slots_copy_out()
75 if (!array[i].nodeid) in log_slots()
79 array[i].slot, array[i].nodeid); in log_slots()
127 if (le32_to_cpu(ro->ro_nodeid) != memb->nodeid) in dlm_slots_copy_in()
134 if (memb->nodeid == our_nodeid) { in dlm_slots_copy_in()
148 memb->nodeid); in dlm_slots_copy_in()
175 if (memb->nodeid == our_nodeid) { in dlm_slots_assign()
207 memb->nodeid, memb->slot_prev, memb->slot); in dlm_slots_assign()
232 array[memb->slot - 1].nodeid = memb->nodeid; in dlm_slots_assign()
[all …]
Ddir.c63 int error = -ENOMEM, last_len, nodeid, result; in dlm_recover_directory() local
77 if (memb->nodeid == dlm_our_nodeid()) in dlm_recover_directory()
90 error = dlm_rcom_names(ls, memb->nodeid, in dlm_recover_directory()
132 error = dlm_master_lookup(ls, memb->nodeid, in dlm_recover_directory()
135 &nodeid, &result); in dlm_recover_directory()
148 nodeid != memb->nodeid) { in dlm_recover_directory()
152 result, nodeid, memb->nodeid, in dlm_recover_directory()
163 nodeid == memb->nodeid) { in dlm_recover_directory()
236 static void drop_dir_ctx(struct dlm_ls *ls, int nodeid) in drop_dir_ctx() argument
242 if (dd->nodeid_init == nodeid) { in drop_dir_ctx()
[all …]
Dlowcomms.h27 static inline int nodeid_hash(int nodeid) in nodeid_hash() argument
29 return nodeid & (CONN_HASH_SIZE-1); in nodeid_hash()
37 void dlm_lowcomms_shutdown_node(int nodeid, bool force);
41 int dlm_lowcomms_close(int nodeid);
42 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, char **ppc,
47 int dlm_lowcomms_connect_node(int nodeid);
48 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark);
49 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr);
50 void dlm_midcomms_receive_done(int nodeid);
Dmidcomms.h17 int dlm_validate_incoming_buffer(int nodeid, unsigned char *buf, int len);
18 int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int buflen);
19 struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len, char **ppc);
22 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr);
24 int dlm_midcomms_close(int nodeid);
30 void dlm_midcomms_add_member(int nodeid);
31 void dlm_midcomms_remove_member(int nodeid);
32 void dlm_midcomms_unack_msg_resend(int nodeid);
Drcom.c122 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) in check_rcom_config() argument
128 DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid, in check_rcom_config()
136 ls->ls_lvblen, ls->ls_exflags, nodeid, in check_rcom_config()
171 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags, in dlm_rcom_status() argument
178 ls->ls_recover_nodeid = nodeid; in dlm_rcom_status()
180 if (nodeid == dlm_our_nodeid()) { in dlm_rcom_status()
187 error = create_rcom_stateless(ls, nodeid, DLM_RCOM_STATUS, in dlm_rcom_status()
211 log_debug(ls, "remote node %d not ready", nodeid); in dlm_rcom_status()
215 error = check_rcom_config(ls, rc, nodeid); in dlm_rcom_status()
230 int nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid); in receive_rcom_status() local
[all …]
Dlowcomms.c71 uint32_t nodeid; /* So we know who we are in the list */ member
153 int nodeid; member
269 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
274 if (con->nodeid == nodeid) in __find_con()
281 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
283 con->nodeid = nodeid; in dlm_con_init()
297 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
302 r = nodeid_hash(nodeid); in nodeid2con()
303 con = __find_con(nodeid, r); in nodeid2con()
311 dlm_con_init(con, nodeid); in nodeid2con()
[all …]
Drequestqueue.c22 int nodeid; member
33 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, in dlm_add_requestqueue() argument
47 e->nodeid = nodeid; in dlm_add_requestqueue()
108 static int purge_request(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) in purge_request() argument
116 if (dlm_is_removed(ls, nodeid)) in purge_request()
142 if (purge_request(ls, ms, e->nodeid)) { in dlm_purge_requestqueue()
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,
22 int nodeid);
23 int dlm_send_ls_not_ready(int nodeid, const struct dlm_rcom *rc_in);
Dconfig.c287 int nodeid; member
301 int nodeid; member
531 cm->nodeid = -1; in make_comm()
543 dlm_midcomms_close(cm->nodeid); in drop_comm()
565 nd->nodeid = -1; in make_node()
625 return sprintf(buf, "%d\n", config_item_to_comm(item)->nodeid); in comm_nodeid_show()
631 int rc = kstrtoint(buf, 0, &config_item_to_comm(item)->nodeid); in comm_nodeid_store()
675 rv = dlm_midcomms_addr(cm->nodeid, addr); in comm_addr_store()
750 rc = dlm_lowcomms_nodes_set_mark(comm->nodeid, mark); in comm_mark_store()
758 CONFIGFS_ATTR(comm_, nodeid);
[all …]
Dconfig.h18 int nodeid; member
53 int dlm_comm_seq(int nodeid, uint32_t *seq);
Dmember.h19 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
20 int dlm_is_member(struct dlm_ls *ls, int nodeid);
Dlock.h19 void dlm_receive_buffer(const union dlm_packet *p, int nodeid);
59 int nodeid, int pid);
Drequestqueue.h14 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid,
/linux-6.12.1/arch/x86/mm/
Damdtopology.c61 u32 nodeid, reg; in amd_numa_init() local
87 nodeids[i] = nodeid = limit & 7; in amd_numa_init()
93 if (nodeid >= numnodes) { in amd_numa_init()
94 pr_info("Ignoring excess node %d (%Lx:%Lx)\n", nodeid, in amd_numa_init()
106 nodeid, (base >> 8) & 3, (limit >> 8) & 3); in amd_numa_init()
109 if (node_isset(nodeid, numa_nodes_parsed)) { in amd_numa_init()
111 nodeid); in amd_numa_init()
132 pr_err("Empty node %d\n", nodeid); in amd_numa_init()
137 nodeid, base, limit); in amd_numa_init()
149 nodeid, base, limit); in amd_numa_init()
[all …]
/linux-6.12.1/fs/fuse/
Dinode.c99 fi->nodeid = 0; in fuse_alloc_inode()
147 fuse_queue_forget(fc, sl->forget, sl->nodeid, 1); in fuse_cleanup_submount_lookup()
167 fuse_queue_forget(fc, fi->forget, fi->nodeid, in fuse_evict_inode()
376 u64 nodeid) in fuse_init_submount_lookup() argument
378 sl->nodeid = nodeid; in fuse_init_submount_lookup()
413 u64 nodeid = *(u64 *) _nodeidp; in fuse_inode_eq() local
414 if (get_node_id(inode) == nodeid) in fuse_inode_eq()
422 u64 nodeid = *(u64 *) _nodeidp; in fuse_inode_set() local
423 get_fuse_inode(inode)->nodeid = nodeid; in fuse_inode_set()
427 struct inode *fuse_iget(struct super_block *sb, u64 nodeid, in fuse_iget() argument
[all …]
Dfuse_i.h73 u64 nodeid; member
96 u64 nodeid; member
233 u64 nodeid; member
295 uint64_t nodeid; member
968 return get_fuse_inode(inode)->nodeid; in get_node_id()
971 static inline int invalid_nodeid(u64 nodeid) in invalid_nodeid() argument
973 return !nodeid || nodeid == FUSE_ROOT_ID; in invalid_nodeid()
1038 struct inode *fuse_iget(struct super_block *sb, u64 nodeid,
1042 int fuse_lookup_name(struct super_block *sb, u64 nodeid, const struct qstr *name,
1049 u64 nodeid, u64 nlookup);
[all …]
Ddir.c172 u64 nodeid, const struct qstr *name, in fuse_lookup_init() argument
177 args->nodeid = nodeid; in fuse_lookup_init()
236 if (!ret && !outarg.nodeid) in fuse_dentry_revalidate()
240 if (outarg.nodeid != get_node_id(inode) || in fuse_dentry_revalidate()
243 outarg.nodeid, 1); in fuse_dentry_revalidate()
363 int fuse_lookup_name(struct super_block *sb, u64 nodeid, const struct qstr *name, in fuse_lookup_name() argument
385 fuse_lookup_init(fm->fc, &args, nodeid, name, outarg); in fuse_lookup_name()
388 if (err || !outarg->nodeid) in fuse_lookup_name()
394 if (outarg->nodeid == FUSE_ROOT_ID && outarg->generation != 0) { in fuse_lookup_name()
399 *inode = fuse_iget(sb, outarg->nodeid, outarg->generation, in fuse_lookup_name()
[all …]
Dreaddir.c165 if (!o->nodeid) { in fuse_direntplus_link()
187 if (invalid_nodeid(o->nodeid)) in fuse_direntplus_link()
205 if (inode && get_node_id(inode) != o->nodeid) in fuse_direntplus_link()
234 inode = fuse_iget(dir->i_sb, o->nodeid, o->generation, in fuse_direntplus_link()
265 static void fuse_force_forget(struct file *file, u64 nodeid) in fuse_force_forget() argument
275 args.nodeid = nodeid; in fuse_force_forget()
324 fuse_force_forget(file, direntplus->entry_out.nodeid); in parse_dirplusfile()
Dxattr.c31 args.nodeid = get_node_id(inode); in fuse_setxattr()
66 args.nodeid = get_node_id(inode); in fuse_getxattr()
130 args.nodeid = get_node_id(inode); in fuse_listxattr()
166 args.nodeid = get_node_id(inode); in fuse_removexattr()
Dfile.c25 static int fuse_send_open(struct fuse_mount *fm, u64 nodeid, in fuse_send_open() argument
43 args.nodeid = nodeid; in fuse_send_open()
126 struct fuse_file *fuse_file_open(struct fuse_mount *fm, u64 nodeid, in fuse_file_open() argument
146 err = fuse_send_open(fm, nodeid, open_flags, opcode, outargp); in fuse_file_open()
167 ff->nodeid = nodeid; in fuse_file_open()
172 int fuse_do_open(struct fuse_mount *fm, u64 nodeid, struct file *file, in fuse_do_open() argument
175 struct fuse_file *ff = fuse_file_open(fm, nodeid, file->f_flags, isdir); in fuse_do_open()
324 ra->args.nodeid = ff->nodeid; in fuse_prepare_release()
536 args.nodeid = get_node_id(inode); in fuse_flush()
571 args.nodeid = get_node_id(inode); in fuse_fsync_common()
[all …]
Ddev.c320 u64 nodeid, u64 nlookup) in fuse_queue_forget() argument
324 forget->forget_one.nodeid = nodeid; in fuse_queue_forget()
534 req->in.h.nodeid = args->nodeid; in fuse_args_to_req()
1161 .nodeid = forget->forget_one.nodeid, in fuse_read_single_forget()
1616 u64 nodeid; in fuse_notify_store() local
1636 nodeid = outarg.nodeid; in fuse_notify_store()
1641 inode = fuse_ilookup(fc, nodeid, NULL); in fuse_notify_store()
1750 args->nodeid = outarg->nodeid; in fuse_retrieve()
1796 u64 nodeid; in fuse_notify_retrieve() local
1811 nodeid = outarg.nodeid; in fuse_notify_retrieve()
[all …]
/linux-6.12.1/include/trace/events/
Ddlm.h593 __field(int32_t, nodeid)
608 __entry->nodeid = info->nodeid;
620 __entry->flags, __entry->pid, __entry->nodeid,
633 TP_PROTO(int nodeid, int ret),
635 TP_ARGS(nodeid, ret),
638 __field(int, nodeid)
643 __entry->nodeid = nodeid;
647 TP_printk("nodeid=%d ret=%d", __entry->nodeid, __entry->ret)
653 TP_PROTO(int nodeid, int ret),
655 TP_ARGS(nodeid, ret),
[all …]
/linux-6.12.1/drivers/nvdimm/
Dnd_perf.c133 int nodeid; in nvdimm_pmu_cpu_offline() local
156 nodeid = cpu_to_node(cpu); in nvdimm_pmu_cpu_offline()
157 cpumask = cpumask_of_node(nodeid); in nvdimm_pmu_cpu_offline()
219 int nodeid, rc; in nvdimm_pmu_cpu_hotplug_init() local
232 nodeid = dev_to_node(nd_pmu->dev); in nvdimm_pmu_cpu_hotplug_init()
233 cpumask = cpumask_of_node(nodeid); in nvdimm_pmu_cpu_hotplug_init()
/linux-6.12.1/include/uapi/linux/
Dfuse.h667 uint64_t nodeid; /* Inode ID */ member
682 uint64_t nodeid; member
1011 uint64_t nodeid; member
1072 uint64_t nodeid; member
1080 uint64_t nodeid; member

123