Commit 8bf86fd9 authored by John L. Hammond's avatar John L. Hammond Committed by Greg Kroah-Hartman

staging/lustre/llite: change it_data to it_request

Change the void *it_data member of struct lookup_intent to struct
ptlrpc_request *it_request.
Signed-off-by: default avatarJohn L. Hammond <john.hammond@intel.com>
Reviewed-on: http://review.whamcloud.com/17070
Intel-bug-id: https://jira.hpdd.intel.com/browse/LU-7403Reviewed-by: default avatarAndreas Dilger <andreas.dilger@intel.com>
Reviewed-by: default avatarJames Simmons <uja.ornl@yahoo.com>
Signed-off-by: default avatarOleg Drokin <green@linuxhacker.ru>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 51b39f1d
...@@ -46,7 +46,7 @@ struct lookup_intent { ...@@ -46,7 +46,7 @@ struct lookup_intent {
int it_lock_mode; int it_lock_mode;
int it_remote_lock_mode; int it_remote_lock_mode;
__u64 it_remote_lock_handle; __u64 it_remote_lock_handle;
void *it_data; struct ptlrpc_request *it_request;
unsigned int it_lock_set:1; unsigned int it_lock_set:1;
}; };
......
...@@ -233,13 +233,13 @@ void ll_intent_release(struct lookup_intent *it) ...@@ -233,13 +233,13 @@ void ll_intent_release(struct lookup_intent *it)
ll_intent_drop_lock(it); ll_intent_drop_lock(it);
/* We are still holding extra reference on a request, need to free it */ /* We are still holding extra reference on a request, need to free it */
if (it_disposition(it, DISP_ENQ_OPEN_REF)) if (it_disposition(it, DISP_ENQ_OPEN_REF))
ptlrpc_req_finished(it->it_data); /* ll_file_open */ ptlrpc_req_finished(it->it_request); /* ll_file_open */
if (it_disposition(it, DISP_ENQ_CREATE_REF)) /* create rec */ if (it_disposition(it, DISP_ENQ_CREATE_REF)) /* create rec */
ptlrpc_req_finished(it->it_data); ptlrpc_req_finished(it->it_request);
it->it_disposition = 0; it->it_disposition = 0;
it->it_data = NULL; it->it_request = NULL;
} }
void ll_invalidate_aliases(struct inode *inode) void ll_invalidate_aliases(struct inode *inode)
......
...@@ -362,7 +362,7 @@ struct page *ll_get_dir_page(struct inode *dir, __u64 hash, ...@@ -362,7 +362,7 @@ struct page *ll_get_dir_page(struct inode *dir, __u64 hash,
ll_finish_md_op_data(op_data); ll_finish_md_op_data(op_data);
request = (struct ptlrpc_request *)it.it_data; request = (struct ptlrpc_request *)it.it_request;
if (request) if (request)
ptlrpc_req_finished(request); ptlrpc_req_finished(request);
if (rc < 0) { if (rc < 0) {
......
...@@ -464,10 +464,9 @@ void ll_ioepoch_open(struct ll_inode_info *lli, __u64 ioepoch) ...@@ -464,10 +464,9 @@ void ll_ioepoch_open(struct ll_inode_info *lli, __u64 ioepoch)
static int ll_och_fill(struct obd_export *md_exp, struct lookup_intent *it, static int ll_och_fill(struct obd_export *md_exp, struct lookup_intent *it,
struct obd_client_handle *och) struct obd_client_handle *och)
{ {
struct ptlrpc_request *req = it->it_data;
struct mdt_body *body; struct mdt_body *body;
body = req_capsule_server_get(&req->rq_pill, &RMF_MDT_BODY); body = req_capsule_server_get(&it->it_request->rq_pill, &RMF_MDT_BODY);
och->och_fh = body->handle; och->och_fh = body->handle;
och->och_fid = body->fid1; och->och_fid = body->fid1;
och->och_lease_handle.cookie = it->it_lock_handle; och->och_lease_handle.cookie = it->it_lock_handle;
...@@ -488,7 +487,6 @@ static int ll_local_open(struct file *file, struct lookup_intent *it, ...@@ -488,7 +487,6 @@ static int ll_local_open(struct file *file, struct lookup_intent *it,
LASSERT(fd); LASSERT(fd);
if (och) { if (och) {
struct ptlrpc_request *req = it->it_data;
struct mdt_body *body; struct mdt_body *body;
int rc; int rc;
...@@ -496,7 +494,8 @@ static int ll_local_open(struct file *file, struct lookup_intent *it, ...@@ -496,7 +494,8 @@ static int ll_local_open(struct file *file, struct lookup_intent *it,
if (rc != 0) if (rc != 0)
return rc; return rc;
body = req_capsule_server_get(&req->rq_pill, &RMF_MDT_BODY); body = req_capsule_server_get(&it->it_request->rq_pill,
&RMF_MDT_BODY);
ll_ioepoch_open(lli, body->ioepoch); ll_ioepoch_open(lli, body->ioepoch);
} }
...@@ -713,7 +712,7 @@ int ll_file_open(struct inode *inode, struct file *file) ...@@ -713,7 +712,7 @@ int ll_file_open(struct inode *inode, struct file *file)
} }
if (it && it_disposition(it, DISP_ENQ_OPEN_REF)) { if (it && it_disposition(it, DISP_ENQ_OPEN_REF)) {
ptlrpc_req_finished(it->it_data); ptlrpc_req_finished(it->it_request);
it_clear_disposition(it, DISP_ENQ_OPEN_REF); it_clear_disposition(it, DISP_ENQ_OPEN_REF);
} }
...@@ -1401,7 +1400,7 @@ int ll_lov_setstripe_ea_info(struct inode *inode, struct dentry *dentry, ...@@ -1401,7 +1400,7 @@ int ll_lov_setstripe_ea_info(struct inode *inode, struct dentry *dentry,
out: out:
return rc; return rc;
out_req_free: out_req_free:
ptlrpc_req_finished((struct ptlrpc_request *)oit.it_data); ptlrpc_req_finished((struct ptlrpc_request *)oit.it_request);
goto out; goto out;
} }
...@@ -1689,7 +1688,7 @@ int ll_release_openhandle(struct inode *inode, struct lookup_intent *it) ...@@ -1689,7 +1688,7 @@ int ll_release_openhandle(struct inode *inode, struct lookup_intent *it)
out: out:
/* this one is in place of ll_file_open */ /* this one is in place of ll_file_open */
if (it_disposition(it, DISP_ENQ_OPEN_REF)) { if (it_disposition(it, DISP_ENQ_OPEN_REF)) {
ptlrpc_req_finished(it->it_data); ptlrpc_req_finished(it->it_request);
it_clear_disposition(it, DISP_ENQ_OPEN_REF); it_clear_disposition(it, DISP_ENQ_OPEN_REF);
} }
return rc; return rc;
...@@ -3595,8 +3594,8 @@ int ll_layout_refresh(struct inode *inode, __u32 *gen) ...@@ -3595,8 +3594,8 @@ int ll_layout_refresh(struct inode *inode, __u32 *gen)
rc = md_enqueue(sbi->ll_md_exp, &einfo, &it, op_data, &lockh, rc = md_enqueue(sbi->ll_md_exp, &einfo, &it, op_data, &lockh,
NULL, 0, NULL, 0); NULL, 0, NULL, 0);
ptlrpc_req_finished(it.it_data); ptlrpc_req_finished(it.it_request);
it.it_data = NULL; it.it_request = NULL;
ll_finish_md_op_data(op_data); ll_finish_md_op_data(op_data);
......
...@@ -659,7 +659,7 @@ static struct inode *ll_create_node(struct inode *dir, struct lookup_intent *it) ...@@ -659,7 +659,7 @@ static struct inode *ll_create_node(struct inode *dir, struct lookup_intent *it)
LASSERT(it && it->it_disposition); LASSERT(it && it->it_disposition);
LASSERT(it_disposition(it, DISP_ENQ_CREATE_REF)); LASSERT(it_disposition(it, DISP_ENQ_CREATE_REF));
request = it->it_data; request = it->it_request;
it_clear_disposition(it, DISP_ENQ_CREATE_REF); it_clear_disposition(it, DISP_ENQ_CREATE_REF);
rc = ll_prep_inode(&inode, request, dir->i_sb, it); rc = ll_prep_inode(&inode, request, dir->i_sb, it);
if (rc) { if (rc) {
......
...@@ -315,7 +315,7 @@ static int ll_xattr_find_get_lock(struct inode *inode, ...@@ -315,7 +315,7 @@ static int ll_xattr_find_get_lock(struct inode *inode,
return rc; return rc;
} }
*req = (struct ptlrpc_request *)oit->it_data; *req = oit->it_request;
out: out:
down_write(&lli->lli_xattrs_list_rwsem); down_write(&lli->lli_xattrs_list_rwsem);
mutex_unlock(&lli->lli_xattrs_enq_lock); mutex_unlock(&lli->lli_xattrs_enq_lock);
......
...@@ -84,7 +84,7 @@ static int lmv_intent_remote(struct obd_export *exp, void *lmm, ...@@ -84,7 +84,7 @@ static int lmv_intent_remote(struct obd_export *exp, void *lmm,
if (pmode) { if (pmode) {
plock.cookie = it->it_lock_handle; plock.cookie = it->it_lock_handle;
it->it_lock_mode = 0; it->it_lock_mode = 0;
it->it_data = NULL; it->it_request = NULL;
} }
LASSERT(fid_is_sane(&body->fid1)); LASSERT(fid_is_sane(&body->fid1));
......
...@@ -1679,7 +1679,7 @@ lmv_enqueue_remote(struct obd_export *exp, struct ldlm_enqueue_info *einfo, ...@@ -1679,7 +1679,7 @@ lmv_enqueue_remote(struct obd_export *exp, struct ldlm_enqueue_info *einfo,
struct lustre_handle *lockh, void *lmm, int lmmsize, struct lustre_handle *lockh, void *lmm, int lmmsize,
__u64 extra_lock_flags) __u64 extra_lock_flags)
{ {
struct ptlrpc_request *req = it->it_data; struct ptlrpc_request *req = it->it_request;
struct obd_device *obd = exp->exp_obd; struct obd_device *obd = exp->exp_obd;
struct lmv_obd *lmv = &obd->u.lmv; struct lmv_obd *lmv = &obd->u.lmv;
struct lustre_handle plock; struct lustre_handle plock;
...@@ -1705,7 +1705,7 @@ lmv_enqueue_remote(struct obd_export *exp, struct ldlm_enqueue_info *einfo, ...@@ -1705,7 +1705,7 @@ lmv_enqueue_remote(struct obd_export *exp, struct ldlm_enqueue_info *einfo,
LASSERT(pmode != 0); LASSERT(pmode != 0);
memcpy(&plock, lockh, sizeof(plock)); memcpy(&plock, lockh, sizeof(plock));
it->it_lock_mode = 0; it->it_lock_mode = 0;
it->it_data = NULL; it->it_request = NULL;
fid1 = body->fid1; fid1 = body->fid1;
ptlrpc_req_finished(req); ptlrpc_req_finished(req);
......
...@@ -561,7 +561,7 @@ static int mdc_finish_enqueue(struct obd_export *exp, ...@@ -561,7 +561,7 @@ static int mdc_finish_enqueue(struct obd_export *exp,
it->it_status = (int)lockrep->lock_policy_res2; it->it_status = (int)lockrep->lock_policy_res2;
it->it_lock_mode = einfo->ei_mode; it->it_lock_mode = einfo->ei_mode;
it->it_lock_handle = lockh->cookie; it->it_lock_handle = lockh->cookie;
it->it_data = req; it->it_request = req;
/* Technically speaking rq_transno must already be zero if /* Technically speaking rq_transno must already be zero if
* it_status is in error, so the check is a bit redundant * it_status is in error, so the check is a bit redundant
...@@ -883,7 +883,7 @@ int mdc_enqueue(struct obd_export *exp, struct ldlm_enqueue_info *einfo, ...@@ -883,7 +883,7 @@ int mdc_enqueue(struct obd_export *exp, struct ldlm_enqueue_info *einfo,
it->it_lock_handle = 0; it->it_lock_handle = 0;
it->it_lock_mode = 0; it->it_lock_mode = 0;
it->it_data = NULL; it->it_request = NULL;
} }
return rc; return rc;
...@@ -1146,7 +1146,7 @@ int mdc_intent_lock(struct obd_export *exp, struct md_op_data *op_data, ...@@ -1146,7 +1146,7 @@ int mdc_intent_lock(struct obd_export *exp, struct md_op_data *op_data,
if (rc < 0) if (rc < 0)
return rc; return rc;
*reqp = it->it_data; *reqp = it->it_request;
rc = mdc_finish_intent_lock(exp, *reqp, op_data, it, &lockh); rc = mdc_finish_intent_lock(exp, *reqp, op_data, it, &lockh);
return rc; return rc;
} }
......
...@@ -637,7 +637,7 @@ int mdc_set_open_replay_data(struct obd_export *exp, ...@@ -637,7 +637,7 @@ int mdc_set_open_replay_data(struct obd_export *exp,
struct md_open_data *mod; struct md_open_data *mod;
struct mdt_rec_create *rec; struct mdt_rec_create *rec;
struct mdt_body *body; struct mdt_body *body;
struct ptlrpc_request *open_req = it->it_data; struct ptlrpc_request *open_req = it->it_request;
struct obd_import *imp = open_req->rq_import; struct obd_import *imp = open_req->rq_import;
if (!open_req->rq_replay) if (!open_req->rq_replay)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment