PFID(rootfid), lustre_msg_get_last_committed(req->rq_repmsg));
EXIT;
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
goto again;
}
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
} else {
*request = req;
}
goto again;
}
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
} else {
*request = req;
}
ptlrpc_put_mod_rpc_slot(req);
if (rc)
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
else
*request = req;
RETURN(rc);
GOTO(out, rc = body->mbo_eadatasize);
out:
if (rc < 0) {
- ptlrpc_req_finished(*req);
+ ptlrpc_req_put(*req);
*req = NULL;
}
MDS_BULK_PORTAL,
&ptlrpc_bulk_kiov_pin_ops);
if (desc == NULL) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(-ENOMEM);
}
ptlrpc_request_set_replen(req);
rc = ptlrpc_queue_wait(req);
if (rc) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
if (rc != -ETIMEDOUT)
RETURN(rc);
rc = sptlrpc_cli_unwrap_bulk_read(req, req->rq_bulk,
req->rq_bulk->bd_nob_transferred);
if (rc < 0) {
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(rc);
}
CERROR("%s: unexpected bytes transferred: %d (%ld expected)\n",
exp->exp_obd->obd_name, req->rq_bulk->bd_nob_transferred,
PAGE_SIZE * npages);
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(-EPROTO);
}
}
unlock_page(page0);
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
CDEBUG(D_CACHE, "read %d/%d pages\n", rd_pgs, npages);
for (i = 1; i < npages; i++) {
unsigned long offset;
rc = mdc_intent_lock(exp, op_data, &it, &enq_req,
mrinfo->mr_blocking_ast, 0);
if (enq_req != NULL)
- ptlrpc_req_finished(enq_req);
+ ptlrpc_req_put(enq_req);
if (rc < 0) {
CERROR("%s: "DFID" lock enqueue fails: rc = %d\n",
*osfs = *msfs;
EXIT;
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
output:
class_import_put(imp);
return rc;
GOTO(out, rc);
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
rc = mdc_queue_wait(req);
GOTO(out, rc);
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
EXIT;
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
rc = mdc_queue_wait(req);
GOTO(out, rc);
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
EXIT;
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
GOTO(out, rc);
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
GOTO(out, rc);
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
exp->exp_obd->obd_name, rc);
}
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(rc);
}
EXIT;
out:
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
return rc;
}
lustre_swab_fid2path(val);
}
}
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
RETURN(rc);
}
rc = ptlrpc_queue_wait(req);
if (rc)
- ptlrpc_req_finished(req);
+ ptlrpc_req_put(req);
else
*request = req;
RETURN(rc);