fs/dlm/rcom.c

123 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid)
128 		log_error(ls, "version mismatch: %x nodeid %d: %x",
129 			  DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid,
136 		log_error(ls, "config mismatch: %d,%x nodeid %d: %d,%x",
137 			  ls->ls_lvblen, ls->ls_exflags, nodeid,
162  * low nodeid gathers one slot value at a time from each node.
166  * other nodes gather all slot values at once from the low nodeid.
172 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags,
179 	ls->ls_recover_nodeid = nodeid;
181 	if (nodeid == dlm_our_nodeid()) {
188 	error = create_rcom_stateless(ls, nodeid, DLM_RCOM_STATUS,
212 		log_debug(ls, "remote node %d not ready", nodeid);
216 		error = check_rcom_config(ls, rc, nodeid);
231 	int nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid);
256 	error = create_rcom_stateless(ls, nodeid, DLM_RCOM_STATUS_REPLY,
308 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name,
315 	ls->ls_recover_nodeid = nodeid;
318 	error = create_rcom(ls, nodeid, DLM_RCOM_NAMES, last_len,
342 	int error, inlen, outlen, nodeid;
344 	nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid);
349 	error = create_rcom(ls, nodeid, DLM_RCOM_NAMES_REPLY, outlen,
357 			      nodeid);
385 	int error, ret_nodeid, nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid);
391 		log_error(ls, "receive_rcom_lookup dump from %d", nodeid);
396 	error = create_rcom(ls, nodeid, DLM_RCOM_LOOKUP_REPLY, 0, &rc, &mh,
401 	error = dlm_master_lookup(ls, nodeid, rc_in->rc_buf, len,
481 	int error, nodeid = le32_to_cpu(rc_in->rc_header.h_nodeid);
485 	error = create_rcom(ls, nodeid, DLM_RCOM_LOCK_REPLY,
505 int dlm_send_ls_not_ready(int nodeid, const struct dlm_rcom *rc_in)
513 	mh = dlm_midcomms_get_mhandle(nodeid, mb_len, GFP_NOFS, &mb);
583 void dlm_receive_rcom(struct dlm_ls *ls, const struct dlm_rcom *rc, int nodeid)
682 		   nodeid,
690 		  le32_to_cpu(rc->rc_type), nodeid);