/fs/dlm/ |
H A D | lowcomms.h | 20 int dlm_lowcomms_close(int nodeid); 21 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc); 23 int dlm_lowcomms_connect_node(int nodeid); 24 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len);
|
H A D | midcomms.h | 17 int dlm_process_incoming_buffer(int nodeid, const void *base, unsigned offset,
|
H A D | rcom.h | 17 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags); 18 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name,int last_len); 22 void dlm_receive_rcom(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid); 23 int dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in);
|
H A D | requestqueue.h | 16 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, struct dlm_message *ms);
|
H A D | config.h | 18 int nodeid; member in struct:dlm_config_node 48 int dlm_comm_seq(int nodeid, uint32_t *seq);
|
H A D | member.c | 53 if (!slot->nodeid) 55 ro->ro_nodeid = cpu_to_le32(slot->nodeid); 76 if (!array[i].nodeid) 80 array[i].slot, array[i].nodeid); 133 if (ro->ro_nodeid != memb->nodeid) 140 if (memb->nodeid == our_nodeid) { 153 log_error(ls, "dlm_slots_copy_in nodeid %d no slot", 154 memb->nodeid); 181 if (memb->nodeid == our_nodeid) { 212 log_error(ls, "nodeid 340 find_memb(struct list_head *head, int nodeid) argument 351 dlm_is_member(struct dlm_ls *ls, int nodeid) argument 358 dlm_is_removed(struct dlm_ls *ls, int nodeid) argument 517 find_config_node(struct dlm_recover *rv, int nodeid) argument [all...] |
H A D | dir.h | 22 char *outbuf, int outlen, int nodeid);
|
H A D | requestqueue.c | 23 int nodeid; member in struct:rq_entry 34 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, struct dlm_message *ms) argument 46 e->nodeid = nodeid; 130 static int purge_request(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) argument 138 if (dlm_is_removed(ls, nodeid)) 164 if (purge_request(ls, ms, e->nodeid)) {
|
H A D | dir.c | 32 * offset into the sorted list of nodeid's to give the particular nodeid. 67 int error = -ENOMEM, last_len, nodeid, result; local 81 if (memb->nodeid == dlm_our_nodeid()) 93 error = dlm_rcom_names(ls, memb->nodeid, 135 error = dlm_master_lookup(ls, memb->nodeid, 138 &nodeid, &result); 146 * master nodeid is different from 147 * memb->nodeid which says it is the master. 151 nodeid ! 236 dlm_copy_master_names(struct dlm_ls *ls, char *inbuf, int inlen, char *outbuf, int outlen, int nodeid) argument [all...] |
H A D | member.h | 21 int dlm_is_removed(struct dlm_ls *ls, int nodeid); 22 int dlm_is_member(struct dlm_ls *ls, int nodeid);
|
H A D | rcom.c | 95 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) argument 100 log_error(ls, "version mismatch: %x nodeid %d: %x", 101 DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid, 108 log_error(ls, "config mismatch: %d,%x nodeid %d: %d,%x", 109 ls->ls_lvblen, ls->ls_exflags, nodeid, 134 * low nodeid gathers one slot value at a time from each node. 138 * other nodes gather all slot values at once from the low nodeid. 144 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags) argument 150 ls->ls_recover_nodeid = nodeid; 152 if (nodeid 197 int nodeid = rc_in->rc_header.h_nodeid; local 271 dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name, int last_len) argument 299 int error, inlen, outlen, nodeid; local 358 int error, ret_nodeid, nodeid = rc_in->rc_header.h_nodeid; local 446 int error, nodeid = rc_in->rc_header.h_nodeid; local 468 dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in) argument 548 dlm_receive_rcom(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) argument [all...] |
H A D | lowcomms.c | 105 uint32_t nodeid; /* So we know who we are in the list */ member in struct:connection 145 int nodeid; member in struct:dlm_node_addr 173 static inline int nodeid_hash(int nodeid) argument 175 return nodeid & (CONN_HASH_SIZE-1); 178 static struct connection *__find_con(int nodeid) argument 183 r = nodeid_hash(nodeid); 186 if (con->nodeid == nodeid) 196 static struct connection *__nodeid2con(int nodeid, gfp_t alloc) argument 201 con = __find_con(nodeid); 244 nodeid2con(int nodeid, gfp_t allocation) argument 275 find_node_addr(int nodeid) argument 313 nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, struct sockaddr *sa_out, bool try_new_addr) argument 361 addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid) argument 385 dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) argument 466 dlm_lowcomms_connect_node(int nodeid) argument 617 int nodeid = sn_send_failed->ssf_info.sinfo_ppid; local 670 int nodeid; local 912 int nodeid; local 1490 dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc) argument 1639 dlm_lowcomms_close(int nodeid) argument [all...] |
H A D | midcomms.c | 58 int dlm_process_incoming_buffer(int nodeid, const void *base, argument 97 msglen, nodeid, len); 129 dlm_receive_buffer(p, nodeid);
|
H A D | lock.h | 21 void dlm_receive_buffer(union dlm_packet *p, int nodeid); 32 int dlm_master_lookup(struct dlm_ls *ls, int nodeid, char *name, int len, 57 int nodeid, int pid);
|
H A D | config.c | 28 * /config/dlm/<cluster>/spaces/<space>/nodes/<node>/nodeid 30 * /config/dlm/<cluster>/comms/<comm>/nodeid 235 .ca_name = "nodeid", 284 .ca_name = "nodeid", 326 int nodeid; member in struct:dlm_comm 339 int nodeid; member in struct:dlm_node 342 int comm_seq; /* copy of cm->seq when nd->nodeid is set */ 599 cm->nodeid = -1; 610 dlm_lowcomms_close(cm->nodeid); 632 nd->nodeid 904 get_comm(int nodeid) argument 984 dlm_comm_seq(int nodeid, uint32_t *seq) argument [all...] |
H A D | netlink.c | 101 data->nodeid = lkb->lkb_nodeid;
|
H A D | recover.c | 66 * status. The node with the lowest nodeid polls all the others for their 69 * status flag X, then status flag X_ALL will be set on the low nodeid. 108 error = dlm_rcom_status(ls, memb->nodeid, 0); 130 int error = 0, delay = 0, nodeid = ls->ls_low_nodeid; local 138 error = dlm_rcom_status(ls, nodeid, status_flags); 227 * master nodeid. As replies are returned from the resource directories the 396 * when setting the new nodeid. 399 static void set_lock_master(struct list_head *queue, int nodeid) argument 405 lkb->lkb_nodeid = nodeid; 419 * Propagate the new master nodeid t [all...] |
H A D | lock.c | 91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid); 164 printk(KERN_ERR "lkb: nodeid %d id %x remid %x exflags %x flags %x " 174 printk(KERN_ERR "rsb: nodeid %d master %d dir %d flags %lx first %x " 701 /* When we are the dir nodeid, we can set the master 867 /* our rsb is not master, but the dir nodeid has sent us a 885 * master nodeid. During normal operation (non recovery) this is only 1380 static int nodeid_warned(int nodeid, int num_nodes, int *warned) argument 1386 warned[i] = nodeid; 1389 if (warned[i] == nodeid) 2617 log_print("grant_pending_locks r nodeid 3844 int error, nodeid = ms_in->m_header.h_nodeid; local 4984 dlm_receive_message(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) argument 5018 dlm_receive_buffer(union dlm_packet *p, int nodeid) argument 5544 search_remid_list(struct list_head *head, int nodeid, uint32_t remid) argument 5556 search_remid(struct dlm_rsb *r, int nodeid, uint32_t remid) argument 6184 do_purge(struct dlm_ls *ls, int nodeid, int pid) argument 6199 send_purge(struct dlm_ls *ls, int nodeid, int pid) argument 6215 dlm_user_purge(struct dlm_ls *ls, struct dlm_user_proc *proc, int nodeid, int pid) argument [all...] |
H A D | user.c | 103 kb->i.purge.nodeid = kb32->i.purge.nodeid; 380 error = dlm_user_purge(ls, proc, params->nodeid, params->pid);
|
/fs/fuse/ |
H A D | inode.c | 90 fi->nodeid = 0; 131 fuse_queue_forget(fc, fi->forget, fi->nodeid, fi->nlookup); 279 u64 nodeid = *(u64 *) _nodeidp; local 280 if (get_node_id(inode) == nodeid) 288 u64 nodeid = *(u64 *) _nodeidp; local 289 get_fuse_inode(inode)->nodeid = nodeid; 293 struct inode *fuse_iget(struct super_block *sb, u64 nodeid, argument 302 inode = iget5_locked(sb, nodeid, fuse_inode_eq, fuse_inode_set, &nodeid); 330 fuse_reverse_inval_inode(struct super_block *sb, u64 nodeid, loff_t offset, loff_t len) argument 651 u64 nodeid; member in struct:fuse_inode_handle 708 u64 nodeid; local [all...] |
H A D | fuse_i.h | 73 u64 nodeid; member in struct:fuse_inode 141 u64 nodeid; member in struct:fuse_file 620 return get_fuse_inode(inode)->nodeid; 629 * Inode to nodeid comparison. 636 struct inode *fuse_iget(struct super_block *sb, u64 nodeid, 640 int fuse_lookup_name(struct super_block *sb, u64 nodeid, struct qstr *name, 647 u64 nodeid, u64 nlookup); 652 void fuse_force_forget(struct file *file, u64 nodeid); 854 int fuse_reverse_inval_inode(struct super_block *sb, u64 nodeid, 870 int fuse_do_open(struct fuse_conn *fc, u64 nodeid, struc [all...] |
H A D | dir.c | 149 u64 nodeid, struct qstr *name, 154 req->in.h.nodeid = nodeid; 239 /* Zero nodeid is same as -ENOENT */ 240 if (!err && !outarg.nodeid) 244 if (outarg.nodeid != get_node_id(inode)) { 245 fuse_queue_forget(fc, forget, outarg.nodeid, 1); 280 static int invalid_nodeid(u64 nodeid) argument 282 return !nodeid || nodeid 148 fuse_lookup_init(struct fuse_conn *fc, struct fuse_req *req, u64 nodeid, struct qstr *name, struct fuse_entry_out *outarg) argument 295 fuse_lookup_name(struct super_block *sb, u64 nodeid, struct qstr *name, struct fuse_entry_out *outarg, struct inode **inode) argument [all...] |
H A D | dev.c | 328 u64 nodeid, u64 nlookup) 330 forget->forget_one.nodeid = nodeid; 582 void fuse_force_forget(struct file *file, u64 nodeid) argument 593 req->in.h.nodeid = nodeid; 1109 .nodeid = forget->forget_one.nodeid, 1534 u64 nodeid; local 1554 nodeid 327 fuse_queue_forget(struct fuse_conn *fc, struct fuse_forget_link *forget, u64 nodeid, u64 nlookup) argument 1708 u64 nodeid = outarg.nodeid; local [all...] |
H A D | file.c | 23 static int fuse_send_open(struct fuse_conn *fc, u64 nodeid, struct file *file, argument 39 req->in.h.nodeid = nodeid; 152 int fuse_do_open(struct fuse_conn *fc, u64 nodeid, struct file *file, argument 168 err = fuse_send_open(fc, nodeid, file, opcode, &outarg); 184 ff->nodeid = nodeid; 276 req->in.h.nodeid = ff->nodeid; 462 req->in.h.nodeid [all...] |
/fs/ocfs2/ |
H A D | stack_user.c | 959 slot->nodeid, slot->slot); 960 conn->cc_recovery_handler(slot->nodeid, conn->cc_recovery_data); 974 atomic_set(&lc->oc_this_node, slots[i].nodeid);
|