Lines Matching defs:rc_in
192 static void receive_rcom_status(struct dlm_ls *ls, struct dlm_rcom *rc_in)
198 int nodeid = rc_in->rc_header.h_nodeid;
203 if (!dlm_slots_version(&rc_in->rc_header)) {
208 rs = (struct rcom_status *)rc_in->rc_buf;
227 rc->rc_id = rc_in->rc_id;
228 rc->rc_seq_reply = rc_in->rc_seq;
253 static void receive_sync_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in)
257 rc_in->rc_id != ls->ls_rcom_seq) {
259 rc_in->rc_type, rc_in->rc_header.h_nodeid,
260 (unsigned long long)rc_in->rc_id,
264 memcpy(ls->ls_recover_buf, rc_in, rc_in->rc_header.h_length);
299 static void receive_rcom_names(struct dlm_ls *ls, struct dlm_rcom *rc_in)
305 nodeid = rc_in->rc_header.h_nodeid;
306 inlen = rc_in->rc_header.h_length - sizeof(struct dlm_rcom);
312 rc->rc_id = rc_in->rc_id;
313 rc->rc_seq_reply = rc_in->rc_seq;
315 dlm_copy_master_names(ls, rc_in->rc_buf, inlen, rc->rc_buf, outlen,
339 static void receive_rcom_lookup(struct dlm_ls *ls, struct dlm_rcom *rc_in)
343 int error, ret_nodeid, nodeid = rc_in->rc_header.h_nodeid;
344 int len = rc_in->rc_header.h_length - sizeof(struct dlm_rcom);
351 if (rc_in->rc_id == 0xFFFFFFFF) {
353 dlm_dump_rsb_name(ls, rc_in->rc_buf, len);
357 error = dlm_master_lookup(ls, nodeid, rc_in->rc_buf, len,
362 rc->rc_id = rc_in->rc_id;
363 rc->rc_seq_reply = rc_in->rc_seq;
368 static void receive_rcom_lookup_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in)
370 dlm_recover_master_reply(ls, rc_in);
428 static void receive_rcom_lock(struct dlm_ls *ls, struct dlm_rcom *rc_in)
432 int error, nodeid = rc_in->rc_header.h_nodeid;
434 dlm_recover_master_copy(ls, rc_in);
444 memcpy(rc->rc_buf, rc_in->rc_buf, sizeof(struct rcom_lock));
445 rc->rc_id = rc_in->rc_id;
446 rc->rc_seq_reply = rc_in->rc_seq;
454 int dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in)
470 rc->rc_header.h_lockspace = rc_in->rc_header.h_lockspace;
476 rc->rc_id = rc_in->rc_id;
477 rc->rc_seq_reply = rc_in->rc_seq;