Lines Matching refs:rc_in
171 static void receive_rcom_status(struct dlm_ls *ls, struct dlm_rcom *rc_in)
175 int error, nodeid = rc_in->rc_header.h_nodeid;
181 rc->rc_id = rc_in->rc_id;
182 rc->rc_seq_reply = rc_in->rc_seq;
189 static void receive_sync_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in)
193 rc_in->rc_id != ls->ls_rcom_seq) {
195 rc_in->rc_type, rc_in->rc_header.h_nodeid,
196 (unsigned long long)rc_in->rc_id,
200 memcpy(ls->ls_recover_buf, rc_in, rc_in->rc_header.h_length);
242 static void receive_rcom_names(struct dlm_ls *ls, struct dlm_rcom *rc_in)
248 nodeid = rc_in->rc_header.h_nodeid;
249 inlen = rc_in->rc_header.h_length - sizeof(struct dlm_rcom);
255 rc->rc_id = rc_in->rc_id;
256 rc->rc_seq_reply = rc_in->rc_seq;
258 dlm_copy_master_names(ls, rc_in->rc_buf, inlen, rc->rc_buf, outlen,
282 static void receive_rcom_lookup(struct dlm_ls *ls, struct dlm_rcom *rc_in)
286 int error, ret_nodeid, nodeid = rc_in->rc_header.h_nodeid;
287 int len = rc_in->rc_header.h_length - sizeof(struct dlm_rcom);
293 error = dlm_dir_lookup(ls, nodeid, rc_in->rc_buf, len, &ret_nodeid);
297 rc->rc_id = rc_in->rc_id;
298 rc->rc_seq_reply = rc_in->rc_seq;
303 static void receive_rcom_lookup_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in)
305 dlm_recover_master_reply(ls, rc_in);
361 static void receive_rcom_lock(struct dlm_ls *ls, struct dlm_rcom *rc_in)
365 int error, nodeid = rc_in->rc_header.h_nodeid;
367 dlm_recover_master_copy(ls, rc_in);
377 memcpy(rc->rc_buf, rc_in->rc_buf, sizeof(struct rcom_lock));
378 rc->rc_id = rc_in->rc_id;
379 rc->rc_seq_reply = rc_in->rc_seq;
387 int dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in)
403 rc->rc_header.h_lockspace = rc_in->rc_header.h_lockspace;
409 rc->rc_id = rc_in->rc_id;
410 rc->rc_seq_reply = rc_in->rc_seq;