| /fs/dlm/ |
| D | midcomms.c | 155 int nodeid; member
275 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() argument
335 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
338 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) in dlm_midcomms_addr() argument
340 int ret, idx, r = nodeid_hash(nodeid); in dlm_midcomms_addr()
343 ret = dlm_lowcomms_addr(nodeid, addr, len); in dlm_midcomms_addr()
[all …]
|
| D | member.c | 52 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 …]
|
| D | lowcomms.h | 27 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, gfp_t allocation,
48 int dlm_lowcomms_connect_node(int nodeid);
49 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark);
50 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len);
51 void dlm_midcomms_receive_done(int nodeid);
|
| D | midcomms.h | 17 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,
23 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr, int len);
25 int dlm_midcomms_close(int nodeid);
31 void dlm_midcomms_add_member(int nodeid);
32 void dlm_midcomms_remove_member(int nodeid);
33 void dlm_midcomms_unack_msg_resend(int nodeid);
|
| D | rcom.c | 123 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) in check_rcom_config() argument
129 DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid, in check_rcom_config()
137 ls->ls_lvblen, ls->ls_exflags, nodeid, in check_rcom_config()
172 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags, in dlm_rcom_status() argument
179 ls->ls_recover_nodeid = nodeid; in dlm_rcom_status()
181 if (nodeid == dlm_our_nodeid()) { in dlm_rcom_status()
188 error = create_rcom_stateless(ls, nodeid, DLM_RCOM_STATUS, in dlm_rcom_status()
212 log_debug(ls, "remote node %d not ready", nodeid); in dlm_rcom_status()
216 error = check_rcom_config(ls, rc, nodeid); in dlm_rcom_status()
231 int nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid); in receive_rcom_status() local
[all …]
|
| D | dir.c | 65 int error = -ENOMEM, last_len, nodeid, result; in dlm_recover_directory() local
79 if (memb->nodeid == dlm_our_nodeid()) in dlm_recover_directory()
92 error = dlm_rcom_names(ls, memb->nodeid, in dlm_recover_directory()
134 error = dlm_master_lookup(ls, memb->nodeid, in dlm_recover_directory()
137 &nodeid, &result); in dlm_recover_directory()
150 nodeid != memb->nodeid) { in dlm_recover_directory()
154 result, nodeid, memb->nodeid, in dlm_recover_directory()
165 nodeid == memb->nodeid) { in dlm_recover_directory()
237 char *outbuf, int outlen, int nodeid) in dlm_copy_master_names() argument
250 nodeid, inlen, inlen, inbuf); in dlm_copy_master_names()
[all …]
|
| D | lowcomms.c | 70 uint32_t nodeid; /* So we know who we are in the list */ member
152 int nodeid; member
267 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
272 if (con->nodeid == nodeid) in __find_con()
279 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
281 con->nodeid = nodeid; in dlm_con_init()
295 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
300 r = nodeid_hash(nodeid); in nodeid2con()
301 con = __find_con(nodeid, r); in nodeid2con()
309 dlm_con_init(con, nodeid); in nodeid2con()
[all …]
|
| D | requestqueue.c | 22 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()
131 static int purge_request(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) in purge_request() argument
139 if (dlm_is_removed(ls, nodeid)) in purge_request()
165 if (purge_request(ls, ms, e->nodeid)) { in dlm_purge_requestqueue()
|
| D | config.c | 279 int nodeid; member
293 int nodeid; member
523 cm->nodeid = -1; in make_comm()
535 dlm_midcomms_close(cm->nodeid); in drop_comm()
557 nd->nodeid = -1; in make_node()
617 return sprintf(buf, "%d\n", config_item_to_comm(item)->nodeid); in comm_nodeid_show()
623 int rc = kstrtoint(buf, 0, &config_item_to_comm(item)->nodeid); in comm_nodeid_store()
667 rv = dlm_midcomms_addr(cm->nodeid, addr, len); in comm_addr_store()
742 rc = dlm_lowcomms_nodes_set_mark(comm->nodeid, mark); in comm_mark_store()
750 CONFIGFS_ATTR(comm_, nodeid);
[all …]
|
| D | rcom.h | 15 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);
|
| D | config.h | 18 int nodeid; member
51 int dlm_comm_seq(int nodeid, uint32_t *seq);
|
| D | member.h | 19 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
20 int dlm_is_member(struct dlm_ls *ls, int nodeid);
|
| D | lock.h | 19 void dlm_receive_buffer(const union dlm_packet *p, int nodeid);
56 int nodeid, int pid);
|
| D | recover.c | 110 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()
402 static void set_lock_master(struct list_head *queue, int nodeid) in set_lock_master() argument
408 lkb->lkb_nodeid = nodeid; in set_lock_master()
|
| D | lock.c | 91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid);
3651 int error, nodeid = le32_to_cpu(ms_in->m_header.h_nodeid); in send_lookup_reply() local
3653 error = create_message(r, NULL, nodeid, DLM_MSG_LOOKUP_REPLY, &ms, &mh, in send_lookup_reply()
4755 int nodeid) in dlm_receive_message() argument
4763 le32_to_cpu(ms->m_type), nodeid); in dlm_receive_message()
4767 dlm_add_requestqueue(ls, nodeid, ms); in dlm_receive_message()
4788 void dlm_receive_buffer(const union dlm_packet *p, int nodeid) in dlm_receive_buffer() argument
4802 log_print("invalid h_cmd %d from %u", hd->h_cmd, nodeid); in dlm_receive_buffer()
4806 if (le32_to_cpu(hd->h_nodeid) != nodeid) { in dlm_receive_buffer()
4808 le32_to_cpu(hd->h_nodeid), nodeid, in dlm_receive_buffer()
[all …]
|
| D | requestqueue.h | 14 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid,
|
| /fs/fuse/ |
| D | inode.c | 105 fi->nodeid = 0; in fuse_alloc_inode()
151 fuse_queue_forget(fc, sl->forget, sl->nodeid, 1); in fuse_cleanup_submount_lookup()
170 fuse_queue_forget(fc, fi->forget, fi->nodeid, in fuse_evict_inode()
413 u64 nodeid) in fuse_init_submount_lookup() argument
415 sl->nodeid = nodeid; in fuse_init_submount_lookup()
449 u64 nodeid; member
459 return fii->nodeid == fi->nodeid; in fuse_inode_eq()
468 return fii->nodeid == fi->nodeid in fuse_inode_backing_eq()
481 fi->nodeid = fii->nodeid; in fuse_inode_set()
492 fi->nodeid = fii->nodeid; in fuse_inode_backing_set()
[all …]
|
| D | backing.c | 64 .nodeid = get_fuse_inode(inode)->nodeid, in fuse_open_initialize()
141 ff->nodeid = get_fuse_inode(inode)->nodeid; in fuse_open_finalize()
160 .nodeid = get_node_id(dir), in fuse_create_open_initialize()
257 target_nodeid = get_fuse_inode(d_inode)->nodeid; in fuse_create_open_backing()
298 fi->nodeid = feo->nodeid; in fuse_create_open_finalize()
317 .nodeid = get_fuse_inode(inode)->nodeid, in fuse_release_initialize()
350 .nodeid = get_node_id(file->f_inode), in fuse_flush_initialize()
388 .nodeid = get_node_id(file->f_inode), in fuse_lseek_initialize()
450 .nodeid_out = fuse_file_out->nodeid, in fuse_copy_file_range_initialize()
458 .nodeid = get_node_id(file_in->f_inode), in fuse_copy_file_range_initialize()
[all …]
|
| D | dir.c | 162 u64 nodeid, const struct qstr *name, in fuse_lookup_init() argument
168 args->nodeid = nodeid; in fuse_lookup_init()
300 if (!ret && !outarg.nodeid) in fuse_dentry_revalidate()
304 if (outarg.nodeid != get_node_id(inode) || in fuse_dentry_revalidate()
311 outarg.nodeid, 1); in fuse_dentry_revalidate()
439 args.nodeid = get_node_id(inode); in fuse_dentry_canonical_path()
494 int fuse_lookup_name(struct super_block *sb, u64 nodeid, const struct qstr *name, in fuse_lookup_name() argument
518 fuse_lookup_init(fm->fc, &args, nodeid, name, outarg, &bpf_arg.out); in fuse_lookup_name()
542 *inode = fuse_iget_backing(sb, outarg->nodeid, backing_inode); in fuse_lookup_name()
561 if (err || !outarg->nodeid) in fuse_lookup_name()
[all …]
|
| D | readdir.c | 23 if (fi->nodeid == 0) in fuse_use_readdirplus()
167 if (!o->nodeid) { in fuse_direntplus_link()
189 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()
267 static void fuse_force_forget(struct file *file, u64 nodeid) in fuse_force_forget() argument
277 args.nodeid = nodeid; in fuse_force_forget()
326 fuse_force_forget(file, direntplus->entry_out.nodeid); in parse_dirplusfile()
|
| D | fuse_i.h | 80 u64 nodeid; member
145 u64 nodeid; member
281 u64 nodeid; member
351 uint64_t nodeid; member
1019 return get_fuse_inode(inode)->nodeid; in get_node_id()
1022 static inline int invalid_nodeid(u64 nodeid) in invalid_nodeid() argument
1024 return !nodeid || nodeid == FUSE_ROOT_ID; in invalid_nodeid()
1090 u64 nodeid,
1092 struct inode *fuse_iget(struct super_block *sb, u64 nodeid,
1096 int fuse_lookup_name(struct super_block *sb, u64 nodeid, const struct qstr *name,
[all …]
|
| D | xattr.c | 31 args.nodeid = get_node_id(inode); in fuse_setxattr()
66 args.nodeid = get_node_id(inode); in fuse_getxattr()
141 args.nodeid = get_node_id(inode); in fuse_listxattr()
177 args.nodeid = get_node_id(inode); in fuse_removexattr()
|
| D | file.c | 25 static int fuse_send_open(struct fuse_mount *fm, u64 nodeid, in fuse_send_open() argument
43 args.nodeid = nodeid; in fuse_send_open()
144 struct fuse_file *fuse_file_open(struct fuse_mount *fm, u64 nodeid, in fuse_file_open() argument
162 err = fuse_send_open(fm, nodeid, open_flags, opcode, &outarg); in fuse_file_open()
181 ff->nodeid = nodeid; in fuse_file_open()
186 int fuse_do_open(struct fuse_mount *fm, u64 nodeid, struct file *file, in fuse_do_open() argument
189 struct fuse_file *ff = fuse_file_open(fm, nodeid, file->f_flags, isdir); in fuse_do_open()
330 ra->args.nodeid = ff->nodeid; in fuse_prepare_release()
559 args.nodeid = get_node_id(inode); in fuse_flush()
594 args.nodeid = get_node_id(inode); in fuse_fsync_common()
[all …]
|
| D | dev.c | 244 u64 nodeid, u64 nlookup) in fuse_queue_forget() argument
248 if (nodeid == 0) { in fuse_queue_forget()
253 forget->forget_one.nodeid = nodeid; in fuse_queue_forget()
490 req->in.h.nodeid = args->nodeid; in fuse_args_to_req()
1128 .nodeid = forget->forget_one.nodeid, in fuse_read_single_forget()
1583 u64 nodeid; in fuse_notify_store() local
1603 nodeid = outarg.nodeid; in fuse_notify_store()
1608 inode = fuse_ilookup(fc, nodeid, NULL); in fuse_notify_store()
1717 args->nodeid = outarg->nodeid; in fuse_retrieve()
1763 u64 nodeid; in fuse_notify_retrieve() local
[all …]
|
| D | ioctl.c | 257 ap.args.nodeid = ff->nodeid; in fuse_do_ioctl()
411 args.nodeid = ff->nodeid; in fuse_priv_ioctl()
|