Home
last modified time | relevance | path

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

12

/linux/fs/dlm/
H A Dmidcomms.c155 int nodeid; member
274 static struct midcomms_node *__find_node(int nodeid, int r) in __find_node() argument
280 if (node->nodeid == nodeid) in __find_node()
307 pr_debug("flush midcomms send queue of node %d\n", node->nodeid); in dlm_send_queue_flush()
320 pr_debug("reset node %d\n", node->nodeid); in midcomms_node_reset()
333 static struct midcomms_node *nodeid2node(int nodeid) in nodeid2node()
335 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
338 int dlm_midcomms_addr(int nodeid, struc in dlm_midcomms_addr()
332 nodeid2node(int nodeid) nodeid2node() argument
337 dlm_midcomms_addr(int nodeid,struct sockaddr_storage * addr) dlm_midcomms_addr() argument
375 dlm_send_ack(int nodeid,uint32_t seq) dlm_send_ack() argument
608 dlm_opts_check_msglen(const union dlm_packet * p,uint16_t msglen,int nodeid) dlm_opts_check_msglen() argument
657 dlm_midcomms_receive_buffer_3_2(const union dlm_packet * p,int nodeid) dlm_midcomms_receive_buffer_3_2() argument
785 dlm_midcomms_receive_buffer_3_1(const union dlm_packet * p,int nodeid) dlm_midcomms_receive_buffer_3_1() argument
836 dlm_validate_incoming_buffer(int nodeid,unsigned char * buf,int len) dlm_validate_incoming_buffer() argument
883 dlm_process_incoming_buffer(int nodeid,unsigned char * buf,int len) dlm_process_incoming_buffer() argument
918 dlm_midcomms_unack_msg_resend(int nodeid) dlm_midcomms_unack_msg_resend() argument
977 dlm_midcomms_get_msg_3_2(struct dlm_mhandle * mh,int nodeid,int len,char ** ppc) dlm_midcomms_get_msg_3_2() argument
1003 dlm_midcomms_get_mhandle(int nodeid,int len,char ** ppc) dlm_midcomms_get_mhandle() argument
1214 dlm_midcomms_add_member(int nodeid) dlm_midcomms_add_member() argument
1259 dlm_midcomms_remove_member(int nodeid) dlm_midcomms_remove_member() argument
1415 dlm_midcomms_close(int nodeid) dlm_midcomms_close() argument
[all...]
H A 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 …]
H A 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()
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()
252 static struct dlm_dir_dump *lookup_dir_dump(struct dlm_ls *ls, int nodeid) in lookup_dir_dump() argument
[all …]
H A 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);
H A 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);
H A Dconfig.c299 int nodeid; member
313 int nodeid; member
321 int nodeid; member
527 unsigned int nodeid; in make_comm() local
530 rv = kstrtouint(name, 0, &nodeid); in make_comm()
544 cm->nodeid = nodeid; in make_comm()
556 dlm_midcomms_close(cm->nodeid); in drop_comm()
571 unsigned int nodeid; in make_node() local
576 rv = kstrtouint(name, 0, &nodeid); in make_node()
585 nd->nodeid = nodeid; in make_node()
[all …]
H A 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 …]
H A Dlowcomms.c71 uint32_t nodeid; /* So we know who we are in the list */ member
153 int nodeid; member
270 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
276 if (con->nodeid == nodeid) in __find_con()
283 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init()
285 con->nodeid = nodeid; in dlm_con_init()
299 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con()
304 r = nodeid_hash(nodeid); in nodeid2con()
282 dlm_con_init(struct connection * con,int nodeid) dlm_con_init() argument
298 nodeid2con(int nodeid,gfp_t alloc) nodeid2con() argument
362 nodeid_to_addr(int nodeid,struct sockaddr_storage * sas_out,struct sockaddr * sa_out,bool try_new_addr,unsigned int * mark) nodeid_to_addr() argument
421 addr_to_nodeid(struct sockaddr_storage * addr,int * nodeid,unsigned int * mark) addr_to_nodeid() argument
463 dlm_lowcomms_addr(int nodeid,struct sockaddr_storage * addr) dlm_lowcomms_addr() argument
548 dlm_lowcomms_connect_node(int nodeid) dlm_lowcomms_connect_node() argument
573 dlm_lowcomms_nodes_set_mark(int nodeid,unsigned int mark) dlm_lowcomms_nodes_set_mark() argument
836 new_processqueue_entry(int nodeid,int buflen) new_processqueue_entry() argument
985 int len, idx, result, nodeid; accept_from_sock() local
1260 dlm_lowcomms_new_msg(int nodeid,int len,char ** ppc,void (* cb)(void * data),void * data) dlm_lowcomms_new_msg() argument
1444 dlm_lowcomms_close(int nodeid) dlm_lowcomms_close() argument
[all...]
H A 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()
H A 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);
H A Dconfig.h18 int nodeid; member
55 int dlm_comm_seq(int nodeid, uint32_t *seq, bool locked);
H A Dmember.h19 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
20 int dlm_is_member(struct dlm_ls *ls, int nodeid);
H A Dlock.h19 void dlm_receive_buffer(const union dlm_packet *p, int nodeid);
59 int nodeid, int pid);
H A Dlock.c91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid);
3808 int error, nodeid = le32_to_cpu(ms_in->m_header.h_nodeid); in send_lookup_reply() local
3810 error = create_message(r, NULL, nodeid, DLM_MSG_LOOKUP_REPLY, &ms, &mh); in send_lookup_reply()
4915 int nodeid) in dlm_receive_message() argument
4926 le32_to_cpu(ms->m_type), nodeid); in dlm_receive_message()
4938 dlm_add_requestqueue(ls, nodeid, ms); in dlm_receive_message()
4960 void dlm_receive_buffer(const union dlm_packet *p, int nodeid) in dlm_receive_buffer() argument
4974 log_print("invalid h_cmd %d from %u", hd->h_cmd, nodeid); in dlm_receive_buffer()
4978 if (le32_to_cpu(hd->h_nodeid) != nodeid) { in dlm_receive_buffer()
4980 le32_to_cpu(hd->h_nodeid), nodeid, in dlm_receive_buffer()
[all …]
H A Drequestqueue.h14 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid,
H A Drecover.c110 error = dlm_rcom_status(ls, memb->nodeid, 0, seq); in wait_status_all()
132 int error = 0, delay = 0, nodeid = ls->ls_low_nodeid; in wait_status_low() local
140 error = dlm_rcom_status(ls, nodeid, status_flags, seq); in wait_status_low()
405 static void set_lock_master(struct list_head *queue, int nodeid) in set_lock_master() argument
411 lkb->lkb_nodeid = nodeid; in set_lock_master()
H A Ddir.h21 char *outbuf, int outlen, int nodeid);
/linux/fs/fuse/
H A Dinode.c139 fuse_chan_queue_forget(fc->chan, sl->forget, sl->nodeid, 1); in fuse_free_inode()
162 fuse_chan_queue_forget(fc->chan, fi->forget, fi->nodeid, in fuse_evict_inode()
400 u64 nodeid) in fuse_change_attributes_i()
402 sl->nodeid = nodeid; in fuse_change_attributes_i()
437 u64 nodeid = *(u64 *) _nodeidp; in fuse_init_inode()
438 if (get_node_id(inode) == nodeid) in fuse_init_inode()
446 u64 nodeid = *(u64 *) _nodeidp; in fuse_init_inode()
447 get_fuse_inode(inode)->nodeid = nodeid; in fuse_init_inode()
414 fuse_init_submount_lookup(struct fuse_submount_lookup * sl,u64 nodeid) fuse_init_submount_lookup() argument
451 u64 nodeid = *(u64 *) _nodeidp; fuse_inode_eq() local
460 u64 nodeid = *(u64 *) _nodeidp; fuse_inode_set() local
465 fuse_iget(struct super_block * sb,u64 nodeid,int generation,struct fuse_attr * attr,u64 attr_valid,u64 attr_version,u64 evict_ctr) fuse_iget() argument
537 fuse_ilookup(struct fuse_conn * fc,u64 nodeid,struct fuse_mount ** fm) fuse_ilookup() argument
559 fuse_reverse_inval_inode(struct fuse_conn * fc,u64 nodeid,loff_t offset,loff_t len) fuse_reverse_inval_inode() argument
591 fuse_try_prune_one_inode(struct fuse_conn * fc,u64 nodeid) fuse_try_prune_one_inode() argument
1098 u64 nodeid; global() member
1153 u64 nodeid; fuse_encode_fh() local
[all...]
H A Dfile.c25 static int fuse_send_open(struct fuse_mount *fm, u64 nodeid,
43 args.nodeid = nodeid; in fuse_send_open()
133 struct fuse_file *fuse_file_open(struct fuse_mount *fm, u64 nodeid, in fuse_file_put()
162 err = fuse_send_open(fm, nodeid, open_flags, opcode, outargp); in fuse_file_open()
184 ff->nodeid = nodeid; in fuse_file_open()
189 int fuse_do_open(struct fuse_mount *fm, u64 nodeid, struct file *file, in fuse_file_open()
192 struct fuse_file *ff = fuse_file_open(fm, nodeid, file->f_flags, isdir); in fuse_do_open()
341 ra->args.nodeid in fuse_prepare_release()
26 fuse_send_open(struct fuse_mount * fm,u64 nodeid,unsigned int open_flags,int opcode,struct fuse_open_out * outargp) fuse_send_open() argument
135 fuse_file_open(struct fuse_mount * fm,u64 nodeid,unsigned int open_flags,bool isdir) fuse_file_open() argument
191 fuse_do_open(struct fuse_mount * fm,u64 nodeid,struct file * file,bool isdir) fuse_do_open() argument
[all...]
H A Ddev.c572 u64 nodeid, u64 nlookup) in request_wait_answer()
576 forget->forget_one.nodeid = nodeid; in request_wait_answer()
798 req->in.h.nodeid = args->nodeid; in fuse_simple_notify_reply()
1433 .nodeid = forget->forget_one.nodeid, in fuse_dev_do_read()
425 fuse_queue_forget(struct fuse_conn * fc,struct fuse_forget_link * forget,u64 nodeid,u64 nlookup) fuse_queue_forget() argument
1766 u64 nodeid; fuse_notify_store() local
1956 u64 nodeid; fuse_notify_retrieve() local
H A Dioctl.c319 ap.args.nodeid = ff->nodeid; in fuse_do_ioctl()
464 args.nodeid = ff->nodeid; in fuse_priv_ioctl()
/linux/include/trace/events/
H A 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/drivers/nvdimm/
H A 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/include/uapi/linux/
H A Dfuse.h693 uint64_t nodeid; /* Inode ID */ member
708 uint64_t nodeid; member
1038 uint64_t nodeid; member
1099 uint64_t nodeid; member
1107 uint64_t nodeid; member
/linux/tools/testing/selftests/net/
H A Dsrv6_end_next_csid_l3vpn_test.sh531 local nodeid="$1"
533 printf "${LCNODEFUNC_FMT}" "${nodeid}"
538 local nodeid="$1"
543 lcnodefunc="$(build_csid "${nodeid}")"

12