}
memset(request, 0, sizeof(*request));
- spin_lock_init(&request->rq_lock);
+ //spin_lock_init(&request->rq_lock);
spin_lock(&cl->cli_lock);
request->rq_xid = cl->cli_xid++;
{
int rc = 0;
- spin_lock(&req->rq_lock);
+ //spin_lock(&req->rq_lock);
if (req->rq_repbuf != NULL) {
req->rq_flags = PTL_RPC_REPLY;
EXIT;
}
out:
- spin_unlock(&req->rq_lock);
+ //spin_unlock(&req->rq_lock);
return rc;
}
{
/* First remove the MD for the reply; in theory, this means
* that we can tear down the buffer safely. */
- spin_lock(&request->rq_lock);
+ //spin_lock(&request->rq_lock);
PtlMEUnlink(request->rq_reply_me_h);
PtlMDUnlink(request->rq_reply_md_h);
OBD_FREE(request->rq_repbuf, request->rq_replen);
request->rq_repbuf = NULL;
request->rq_replen = 0;
- spin_unlock(&request->rq_lock);
+ //spin_unlock(&request->rq_lock);
return 0;
}
CDEBUG(D_OTHER, "-- sleeping\n");
wait_event_interruptible(req->rq_wait_for_rep, ptlrpc_check_reply(req));
CDEBUG(D_OTHER, "-- done\n");
- spin_lock(&req->rq_lock);
+ //spin_lock(&req->rq_lock);
if (req->rq_flags == PTL_RPC_INTR) {
/* Clean up the dangling reply buffers */
ptlrpc_abort(req);
EXIT;
out:
- spin_unlock(&req->rq_lock);
+ //spin_unlock(&req->rq_lock);
return rc;
}