Home
last modified time | relevance | path

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

12

/fs/dlm/
A Dmidcomms.c155 int nodeid; member
279 if (node->nodeid == nodeid) in __find_node()
334 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
358 node->nodeid = nodeid; in dlm_midcomms_addr()
608 int nodeid) in dlm_opts_check_msglen() argument
627 len, nodeid); in dlm_opts_check_msglen()
635 msglen, nodeid); in dlm_opts_check_msglen()
643 len, nodeid); in dlm_opts_check_msglen()
674 node->nodeid); in dlm_midcomms_receive_buffer_3_2()
803 node->nodeid); in dlm_midcomms_receive_buffer_3_1()
[all …]
A Dmember.c52 if (!slot->nodeid) in dlm_slots_copy_out()
232 array[memb->slot - 1].nodeid = memb->nodeid; in dlm_slots_assign()
249 array[i].nodeid = memb->nodeid; in dlm_slots_assign()
295 if (new->nodeid < memb->nodeid) in add_ordered_member()
334 memb->nodeid = node->nodeid; in dlm_add_member()
354 if (memb->nodeid == nodeid) in find_memb()
369 WARN_ON_ONCE(!nodeid || nodeid == -1); in dlm_is_removed()
501 slot.nodeid = memb->nodeid; in dlm_lsop_recover_slot()
527 slots[i].nodeid = memb->nodeid; in dlm_lsop_recover_done()
539 int nodeid) in find_config_node() argument
[all …]
A Ddir.c135 &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()
242 if (dd->nodeid_init == nodeid) { in drop_dir_ctx()
275 nodeid); in init_dir_dump()
276 drop_dir_ctx(ls, nodeid); in init_dir_dump()
284 dd->nodeid_init = nodeid; in init_dir_dump()
312 nodeid); in dlm_copy_master_names()
334 dd = init_dir_dump(ls, nodeid); in dlm_copy_master_names()
[all …]
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);
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);
A Drcom.c128 DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid, in check_rcom_config()
136 ls->ls_lvblen, ls->ls_exflags, nodeid, in check_rcom_config()
178 ls->ls_recover_nodeid = nodeid; in dlm_rcom_status()
180 if (nodeid == dlm_our_nodeid()) { in dlm_rcom_status()
215 error = check_rcom_config(ls, rc, nodeid); in dlm_rcom_status()
314 ls->ls_recover_nodeid = nodeid; in dlm_rcom_names()
341 int error, inlen, outlen, nodeid; in receive_rcom_names() local
343 nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid); in receive_rcom_names()
356 nodeid); in receive_rcom_names()
681 nodeid, in dlm_receive_rcom()
[all …]
A Dconfig.c295 int nodeid; member
309 int nodeid; member
514 unsigned int nodeid; in make_comm() local
531 cm->nodeid = nodeid; in make_comm()
558 unsigned int nodeid; in make_node() local
572 nd->nodeid = nodeid; in make_node()
634 unsigned int nodeid; in comm_nodeid_show() local
787 unsigned int nodeid; in node_nodeid_show() local
864 if (cm->nodeid != nodeid) in get_comm()
911 node->nodeid = nd->nodeid; in dlm_config_nodes()
[all …]
A Dlowcomms.c153 int nodeid; member
275 if (con->nodeid == nodeid) in __find_con()
284 con->nodeid = nodeid; in dlm_con_init()
303 r = nodeid_hash(nodeid); in nodeid2con()
304 con = __find_con(nodeid, r); in nodeid2con()
312 dlm_con_init(con, nodeid); in nodeid2con()
321 tmp = __find_con(nodeid, r); in nodeid2con()
374 con = nodeid2con(nodeid, 0); in nodeid_to_addr()
435 *nodeid = con->nodeid; in addr_to_nodeid()
554 con = nodeid2con(nodeid, 0); in dlm_lowcomms_connect_node()
[all …]
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()
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);
A Dconfig.h18 int nodeid; member
53 int dlm_comm_seq(int nodeid, uint32_t *seq, bool locked);
A Dmember.h19 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
20 int dlm_is_member(struct dlm_ls *ls, int nodeid);
A Dlock.h19 void dlm_receive_buffer(const union dlm_packet *p, int nodeid);
59 int nodeid, int pid);
A Dlock.c4914 int nodeid) in dlm_receive_message() argument
4925 le32_to_cpu(ms->m_type), nodeid); in dlm_receive_message()
4937 dlm_add_requestqueue(ls, nodeid, ms); in dlm_receive_message()
4979 le32_to_cpu(hd->h_nodeid), nodeid, in dlm_receive_buffer()
5005 dlm_receive_rcom(ls, &p->rcom, nodeid); in dlm_receive_buffer()
5420 nodeid_gone = memb->nodeid; in dlm_recover_purge()
6270 ms->m_nodeid = cpu_to_le32(nodeid); in send_purge()
6277 int nodeid, int pid) in dlm_user_purge() argument
6281 if (nodeid && (nodeid != dlm_our_nodeid())) { in dlm_user_purge()
6282 error = send_purge(ls, nodeid, pid); in dlm_user_purge()
[all …]
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()
A Drequestqueue.h14 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid,
A Ddir.h21 char *outbuf, int outlen, int nodeid);
/fs/fuse/
A Dinode.c106 fi->nodeid = 0; in fuse_alloc_inode()
410 u64 nodeid) in fuse_init_submount_lookup() argument
412 sl->nodeid = nodeid; in fuse_init_submount_lookup()
457 get_fuse_inode(inode)->nodeid = nodeid; in fuse_inode_set()
487 fi->nodeid = nodeid; in fuse_iget()
541 inode = ilookup5(fm_iter->sb, nodeid, fuse_inode_eq, &nodeid); in fuse_ilookup()
1051 u64 nodeid; member
1066 inode = ilookup5(sb, handle->nodeid, fuse_inode_eq, &handle->nodeid); in fuse_get_dentry()
1106 u64 nodeid; in fuse_encode_fh() local
1114 nodeid = get_fuse_inode(inode)->nodeid; in fuse_encode_fh()
[all …]
A Dfuse_i.h93 u64 nodeid; member
116 u64 nodeid; member
250 u64 nodeid; member
312 uint64_t nodeid; member
1036 return get_fuse_inode(inode)->nodeid; in get_node_id()
1039 static inline int invalid_nodeid(u64 nodeid) in invalid_nodeid() argument
1041 return !nodeid || nodeid == FUSE_ROOT_ID; in invalid_nodeid()
1110 struct inode *fuse_iget(struct super_block *sb, u64 nodeid,
1122 u64 nodeid, u64 nlookup);
1374 struct inode *fuse_ilookup(struct fuse_conn *fc, u64 nodeid,
[all …]
A Ddir.c177 args->nodeid = nodeid; in fuse_lookup_init()
242 if (!ret && !outarg.nodeid) in fuse_dentry_revalidate()
249 outarg.nodeid, 1); in fuse_dentry_revalidate()
383 if (err || !outarg->nodeid) in fuse_lookup_name()
664 args.nodeid = get_node_id(dir); in fuse_create_open()
693 ff->nodeid = outentry.nodeid; in fuse_create_open()
806 args->nodeid = get_node_id(dir); in create_new_entry()
1016 args.nodeid = get_node_id(dir); in fuse_unlink()
1040 args.nodeid = get_node_id(dir); in fuse_rmdir()
1252 args.nodeid = get_node_id(inode); in fuse_do_statx()
[all …]
A Dreaddir.c166 if (!o->nodeid) { in fuse_direntplus_link()
188 if (invalid_nodeid(o->nodeid)) in fuse_direntplus_link()
207 if (inode && get_node_id(inode) != o->nodeid) in fuse_direntplus_link()
236 inode = fuse_iget(dir->i_sb, o->nodeid, o->generation, in fuse_direntplus_link()
268 static void fuse_force_forget(struct file *file, u64 nodeid) in fuse_force_forget() argument
278 args.nodeid = nodeid; in fuse_force_forget()
328 fuse_force_forget(file, direntplus->entry_out.nodeid); in parse_dirplusfile()
A 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()
A Dfile.c44 args.nodeid = nodeid; in fuse_send_open()
168 ff->nodeid = nodeid; in fuse_file_open()
325 ra->args.nodeid = ff->nodeid; in fuse_prepare_release()
470 args.nodeid = get_node_id(inode); in fuse_flush()
573 args->nodeid = ff->nodeid; in fuse_read_args_fill()
1042 args->nodeid = ff->nodeid; in fuse_write_args_fill()
2550 args.nodeid = ff->nodeid; in fuse_lseek()
2683 args.nodeid = ff->nodeid; in fuse_file_poll()
2908 args.nodeid = ff->nodeid; in fuse_file_fallocate()
2960 .nodeid_out = ff_out->nodeid, in __fuse_copy_file_range()
[all …]
A Ddev.c405 u64 nodeid, u64 nlookup) in fuse_queue_forget() argument
409 forget->forget_one.nodeid = nodeid; in fuse_queue_forget()
635 req->in.h.nodeid = args->nodeid; in fuse_args_to_req()
1292 .nodeid = forget->forget_one.nodeid, in fuse_read_single_forget()
1749 u64 nodeid; in fuse_notify_store() local
1769 nodeid = outarg.nodeid; in fuse_notify_store()
1774 inode = fuse_ilookup(fc, nodeid, NULL); in fuse_notify_store()
1888 args->nodeid = outarg->nodeid; in fuse_retrieve()
1940 u64 nodeid; in fuse_notify_retrieve() local
1955 nodeid = outarg.nodeid; in fuse_notify_retrieve()
[all …]
A Dioctl.c318 ap.args.nodeid = ff->nodeid; in fuse_do_ioctl()
463 args.nodeid = ff->nodeid; in fuse_priv_ioctl()

Completed in 73 milliseconds

12