Searched refs:nodeid (Results 1 - 25 of 26) sorted by relevance

12

/fs/dlm/
H A Dlowcomms.h20 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 Dmidcomms.h17 int dlm_process_incoming_buffer(int nodeid, const void *base, unsigned offset,
H A Drcom.h17 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 Drequestqueue.h16 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, struct dlm_message *ms);
H A Dconfig.h18 int nodeid; member in struct:dlm_config_node
48 int dlm_comm_seq(int nodeid, uint32_t *seq);
H A Dmember.c53 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 Ddir.h22 char *outbuf, int outlen, int nodeid);
H A Drequestqueue.c23 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 Ddir.c32 * 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 Dmember.h21 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
22 int dlm_is_member(struct dlm_ls *ls, int nodeid);
H A Drcom.c95 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 Dlowcomms.c105 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 Dmidcomms.c58 int dlm_process_incoming_buffer(int nodeid, const void *base, argument
97 msglen, nodeid, len);
129 dlm_receive_buffer(p, nodeid);
H A Dlock.h21 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 Dconfig.c28 * /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 Dnetlink.c101 data->nodeid = lkb->lkb_nodeid;
H A Drecover.c66 * 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 Dlock.c91 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 Duser.c103 kb->i.purge.nodeid = kb32->i.purge.nodeid;
380 error = dlm_user_purge(ls, proc, params->nodeid, params->pid);
/fs/fuse/
H A Dinode.c90 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 Dfuse_i.h73 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 Ddir.c149 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 Ddev.c328 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 Dfile.c23 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 Dstack_user.c959 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);

Completed in 5902 milliseconds

12