mds_pack_req_body(req);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
if (!rc) {
body = lustre_msg_buf(req->rq_repmsg, 0);
req->rq_replen = lustre_msg_size(2, size);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
out:
RETURN(rc);
mds_pack_req_body(req);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
if (!rc) {
body = lustre_msg_buf(req->rq_repmsg, 0);
struct mds_rec_create *rec = lustre_msg_buf(req->rq_reqmsg, reqoff);
struct mds_body *body = lustre_msg_buf(req->rq_repmsg, repoff);
+ DEBUG_REQ(D_HA, req, "storing generation %x for ino "LPD64,
+ body->fid1.generation, body->fid1.id);
memcpy(&rec->cr_replayfid, &body->fid1, sizeof rec->cr_replayfid);
}
req->rq_replen = lustre_msg_size(1, size);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
if (!rc) {
body = lustre_msg_buf(req->rq_repmsg, 0);
mds_unpack_body(body);
req->rq_replen = lustre_msg_size(0, NULL);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
EXIT;
out:
req->rq_replen = lustre_msg_size(1, &size);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
if (rc) {
ptlrpc_abort_bulk(desc);
GOTO(out2, rc);
req->rq_replen = lustre_msg_size(1, &size);
rc = ptlrpc_queue_wait(req);
- rc = ptlrpc_check_status(req, rc);
if (rc)
GOTO(out, rc);