block: cleanup rq->data_len usages

With recent unification of fields, it's now guaranteed that
rq->data_len always equals blk_rq_bytes().  Convert all non-IDE direct
users to accessors.  IDE will be converted in a separate patch.

Boaz: spotted incorrect data_len/resid_len conversion in osd.

[ Impact: convert direct rq->data_len usages to blk_rq_bytes() ]

Signed-off-by: Tejun Heo <tj@kernel.org>
Acked-by: Sergei Shtylyov <sshtylyov@ru.mvista.com>
Cc: Pete Zaitcev <zaitcev@redhat.com>
Cc: Eric Moore <Eric.Moore@lsi.com>
Cc: Markus Lidel <Markus.Lidel@shadowconnect.com>
Cc: Darrick J. Wong <djwong@us.ibm.com>
Cc: James Bottomley <James.Bottomley@HansenPartnership.com>
Cc: Eric Moore <Eric.Moore@lsi.com>
Cc: Boaz Harrosh <bharrosh@panasas.com>
Cc: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
This commit is contained in:
Tejun Heo 2009-05-07 22:24:42 +09:00 committed by Jens Axboe
parent 2e46e8b27a
commit b079041030
10 changed files with 49 additions and 49 deletions

View file

@ -1084,7 +1084,7 @@ static int atapi_drain_needed(struct request *rq)
if (likely(!blk_pc_request(rq))) if (likely(!blk_pc_request(rq)))
return 0; return 0;
if (!rq->data_len || (rq->cmd_flags & REQ_RW)) if (!blk_rq_bytes(rq) || (rq->cmd_flags & REQ_RW))
return 0; return 0;
return atapi_cmd_type(rq->cmd[0]) == ATAPI_MISC; return atapi_cmd_type(rq->cmd[0]) == ATAPI_MISC;

View file

@ -747,7 +747,7 @@ static void ub_cmd_build_packet(struct ub_dev *sc, struct ub_lun *lun,
{ {
struct request *rq = urq->rq; struct request *rq = urq->rq;
if (rq->data_len == 0) { if (blk_rq_bytes(rq) == 0) {
cmd->dir = UB_DIR_NONE; cmd->dir = UB_DIR_NONE;
} else { } else {
if (rq_data_dir(rq) == WRITE) if (rq_data_dir(rq) == WRITE)
@ -762,7 +762,7 @@ static void ub_cmd_build_packet(struct ub_dev *sc, struct ub_lun *lun,
memcpy(&cmd->cdb, rq->cmd, rq->cmd_len); memcpy(&cmd->cdb, rq->cmd, rq->cmd_len);
cmd->cdb_len = rq->cmd_len; cmd->cdb_len = rq->cmd_len;
cmd->len = rq->data_len; cmd->len = blk_rq_bytes(rq);
/* /*
* To reapply this to every URB is not as incorrect as it looks. * To reapply this to every URB is not as incorrect as it looks.
@ -783,8 +783,8 @@ static void ub_rw_cmd_done(struct ub_dev *sc, struct ub_scsi_cmd *cmd)
if (cmd->error == 0) { if (cmd->error == 0) {
if (blk_pc_request(rq)) { if (blk_pc_request(rq)) {
if (cmd->act_len < rq->data_len) if (cmd->act_len < blk_rq_bytes(rq))
rq->resid_len = rq->data_len - cmd->act_len; rq->resid_len = blk_rq_bytes(rq) - cmd->act_len;
scsi_status = 0; scsi_status = 0;
} else { } else {
if (cmd->act_len != cmd->len) { if (cmd->act_len != cmd->len) {

View file

@ -1277,8 +1277,8 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
/* do we need to support multiple segments? */ /* do we need to support multiple segments? */
if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) { if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) {
printk(MYIOC_s_ERR_FMT "%s: multiple segments req %u %u, rsp %u %u\n", printk(MYIOC_s_ERR_FMT "%s: multiple segments req %u %u, rsp %u %u\n",
ioc->name, __func__, req->bio->bi_vcnt, req->data_len, ioc->name, __func__, req->bio->bi_vcnt, blk_rq_bytes(req),
rsp->bio->bi_vcnt, rsp->data_len); rsp->bio->bi_vcnt, blk_rq_bytes(rsp));
return -EINVAL; return -EINVAL;
} }
@ -1295,7 +1295,7 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
smpreq = (SmpPassthroughRequest_t *)mf; smpreq = (SmpPassthroughRequest_t *)mf;
memset(smpreq, 0, sizeof(*smpreq)); memset(smpreq, 0, sizeof(*smpreq));
smpreq->RequestDataLength = cpu_to_le16(req->data_len - 4); smpreq->RequestDataLength = cpu_to_le16(blk_rq_bytes(req) - 4);
smpreq->Function = MPI_FUNCTION_SMP_PASSTHROUGH; smpreq->Function = MPI_FUNCTION_SMP_PASSTHROUGH;
if (rphy) if (rphy)
@ -1321,10 +1321,10 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
MPI_SGE_FLAGS_END_OF_BUFFER | MPI_SGE_FLAGS_END_OF_BUFFER |
MPI_SGE_FLAGS_DIRECTION | MPI_SGE_FLAGS_DIRECTION |
mpt_addr_size()) << MPI_SGE_FLAGS_SHIFT; mpt_addr_size()) << MPI_SGE_FLAGS_SHIFT;
flagsLength |= (req->data_len - 4); flagsLength |= (blk_rq_bytes(req) - 4);
dma_addr_out = pci_map_single(ioc->pcidev, bio_data(req->bio), dma_addr_out = pci_map_single(ioc->pcidev, bio_data(req->bio),
req->data_len, PCI_DMA_BIDIRECTIONAL); blk_rq_bytes(req), PCI_DMA_BIDIRECTIONAL);
if (!dma_addr_out) if (!dma_addr_out)
goto put_mf; goto put_mf;
mpt_add_sge(psge, flagsLength, dma_addr_out); mpt_add_sge(psge, flagsLength, dma_addr_out);
@ -1332,9 +1332,9 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
/* response */ /* response */
flagsLength = MPT_SGE_FLAGS_SSIMPLE_READ; flagsLength = MPT_SGE_FLAGS_SSIMPLE_READ;
flagsLength |= rsp->data_len + 4; flagsLength |= blk_rq_bytes(rsp) + 4;
dma_addr_in = pci_map_single(ioc->pcidev, bio_data(rsp->bio), dma_addr_in = pci_map_single(ioc->pcidev, bio_data(rsp->bio),
rsp->data_len, PCI_DMA_BIDIRECTIONAL); blk_rq_bytes(rsp), PCI_DMA_BIDIRECTIONAL);
if (!dma_addr_in) if (!dma_addr_in)
goto unmap; goto unmap;
mpt_add_sge(psge, flagsLength, dma_addr_in); mpt_add_sge(psge, flagsLength, dma_addr_in);
@ -1357,7 +1357,7 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
smprep = (SmpPassthroughReply_t *)ioc->sas_mgmt.reply; smprep = (SmpPassthroughReply_t *)ioc->sas_mgmt.reply;
memcpy(req->sense, smprep, sizeof(*smprep)); memcpy(req->sense, smprep, sizeof(*smprep));
req->sense_len = sizeof(*smprep); req->sense_len = sizeof(*smprep);
rsp->resid_len = rsp->data_len - smprep->ResponseDataLength; rsp->resid_len = blk_rq_bytes(rsp) - smprep->ResponseDataLength;
} else { } else {
printk(MYIOC_s_ERR_FMT "%s: smp passthru reply failed to be returned\n", printk(MYIOC_s_ERR_FMT "%s: smp passthru reply failed to be returned\n",
ioc->name, __func__); ioc->name, __func__);
@ -1365,10 +1365,10 @@ static int mptsas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
} }
unmap: unmap:
if (dma_addr_out) if (dma_addr_out)
pci_unmap_single(ioc->pcidev, dma_addr_out, req->data_len, pci_unmap_single(ioc->pcidev, dma_addr_out, blk_rq_bytes(req),
PCI_DMA_BIDIRECTIONAL); PCI_DMA_BIDIRECTIONAL);
if (dma_addr_in) if (dma_addr_in)
pci_unmap_single(ioc->pcidev, dma_addr_in, rsp->data_len, pci_unmap_single(ioc->pcidev, dma_addr_in, blk_rq_bytes(rsp),
PCI_DMA_BIDIRECTIONAL); PCI_DMA_BIDIRECTIONAL);
put_mf: put_mf:
if (mf) if (mf)

View file

@ -430,7 +430,7 @@ static void i2o_block_end_request(struct request *req, int error,
int leftover = (blk_rq_sectors(req) << KERNEL_SECTOR_SHIFT); int leftover = (blk_rq_sectors(req) << KERNEL_SECTOR_SHIFT);
if (blk_pc_request(req)) if (blk_pc_request(req))
leftover = req->data_len; leftover = blk_rq_bytes(req);
if (error) if (error)
blk_end_request(req, -EIO, leftover); blk_end_request(req, -EIO, leftover);

View file

@ -1927,13 +1927,13 @@ int sas_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
/* do we need to support multiple segments? */ /* do we need to support multiple segments? */
if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) { if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) {
printk("%s: multiple segments req %u %u, rsp %u %u\n", printk("%s: multiple segments req %u %u, rsp %u %u\n",
__func__, req->bio->bi_vcnt, req->data_len, __func__, req->bio->bi_vcnt, blk_rq_bytes(req),
rsp->bio->bi_vcnt, rsp->data_len); rsp->bio->bi_vcnt, blk_rq_bytes(rsp));
return -EINVAL; return -EINVAL;
} }
ret = smp_execute_task(dev, bio_data(req->bio), req->data_len, ret = smp_execute_task(dev, bio_data(req->bio), blk_rq_bytes(req),
bio_data(rsp->bio), rsp->data_len); bio_data(rsp->bio), blk_rq_bytes(rsp));
if (ret > 0) { if (ret > 0) {
/* positive number is the untransferred residual */ /* positive number is the untransferred residual */
rsp->resid_len = ret; rsp->resid_len = ret;

View file

@ -137,21 +137,21 @@ int sas_smp_host_handler(struct Scsi_Host *shost, struct request *req,
int error = -EINVAL; int error = -EINVAL;
/* eight is the minimum size for request and response frames */ /* eight is the minimum size for request and response frames */
if (req->data_len < 8 || rsp->data_len < 8) if (blk_rq_bytes(req) < 8 || blk_rq_bytes(rsp) < 8)
goto out; goto out;
if (bio_offset(req->bio) + req->data_len > PAGE_SIZE || if (bio_offset(req->bio) + blk_rq_bytes(req) > PAGE_SIZE ||
bio_offset(rsp->bio) + rsp->data_len > PAGE_SIZE) { bio_offset(rsp->bio) + blk_rq_bytes(rsp) > PAGE_SIZE) {
shost_printk(KERN_ERR, shost, shost_printk(KERN_ERR, shost,
"SMP request/response frame crosses page boundary"); "SMP request/response frame crosses page boundary");
goto out; goto out;
} }
req_data = kzalloc(req->data_len, GFP_KERNEL); req_data = kzalloc(blk_rq_bytes(req), GFP_KERNEL);
/* make sure frame can always be built ... we copy /* make sure frame can always be built ... we copy
* back only the requested length */ * back only the requested length */
resp_data = kzalloc(max(rsp->data_len, 128U), GFP_KERNEL); resp_data = kzalloc(max(blk_rq_bytes(rsp), 128U), GFP_KERNEL);
if (!req_data || !resp_data) { if (!req_data || !resp_data) {
error = -ENOMEM; error = -ENOMEM;
@ -160,7 +160,7 @@ int sas_smp_host_handler(struct Scsi_Host *shost, struct request *req,
local_irq_disable(); local_irq_disable();
buf = kmap_atomic(bio_page(req->bio), KM_USER0) + bio_offset(req->bio); buf = kmap_atomic(bio_page(req->bio), KM_USER0) + bio_offset(req->bio);
memcpy(req_data, buf, req->data_len); memcpy(req_data, buf, blk_rq_bytes(req));
kunmap_atomic(buf - bio_offset(req->bio), KM_USER0); kunmap_atomic(buf - bio_offset(req->bio), KM_USER0);
local_irq_enable(); local_irq_enable();
@ -176,8 +176,8 @@ int sas_smp_host_handler(struct Scsi_Host *shost, struct request *req,
resp_data[1] = req_data[1]; resp_data[1] = req_data[1];
resp_data[2] = SMP_RESP_FUNC_UNK; resp_data[2] = SMP_RESP_FUNC_UNK;
req->resid_len = req->data_len; req->resid_len = blk_rq_bytes(req);
rsp->resid_len = rsp->data_len; rsp->resid_len = blk_rq_bytes(rsp);
switch (req_data[1]) { switch (req_data[1]) {
case SMP_REPORT_GENERAL: case SMP_REPORT_GENERAL:
@ -264,7 +264,7 @@ int sas_smp_host_handler(struct Scsi_Host *shost, struct request *req,
local_irq_disable(); local_irq_disable();
buf = kmap_atomic(bio_page(rsp->bio), KM_USER0) + bio_offset(rsp->bio); buf = kmap_atomic(bio_page(rsp->bio), KM_USER0) + bio_offset(rsp->bio);
memcpy(buf, resp_data, rsp->data_len); memcpy(buf, resp_data, blk_rq_bytes(rsp));
flush_kernel_dcache_page(bio_page(rsp->bio)); flush_kernel_dcache_page(bio_page(rsp->bio));
kunmap_atomic(buf - bio_offset(rsp->bio), KM_USER0); kunmap_atomic(buf - bio_offset(rsp->bio), KM_USER0);
local_irq_enable(); local_irq_enable();

View file

@ -1041,7 +1041,7 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) { if (req->bio->bi_vcnt > 1 || rsp->bio->bi_vcnt > 1) {
printk(MPT2SAS_ERR_FMT "%s: multiple segments req %u %u, " printk(MPT2SAS_ERR_FMT "%s: multiple segments req %u %u, "
"rsp %u %u\n", ioc->name, __func__, req->bio->bi_vcnt, "rsp %u %u\n", ioc->name, __func__, req->bio->bi_vcnt,
req->data_len, rsp->bio->bi_vcnt, rsp->data_len); blk_rq_bytes(req), rsp->bio->bi_vcnt, blk_rq_bytes(rsp));
return -EINVAL; return -EINVAL;
} }
@ -1104,7 +1104,7 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
*((u64 *)&mpi_request->SASAddress) = (rphy) ? *((u64 *)&mpi_request->SASAddress) = (rphy) ?
cpu_to_le64(rphy->identify.sas_address) : cpu_to_le64(rphy->identify.sas_address) :
cpu_to_le64(ioc->sas_hba.sas_address); cpu_to_le64(ioc->sas_hba.sas_address);
mpi_request->RequestDataLength = cpu_to_le16(req->data_len - 4); mpi_request->RequestDataLength = cpu_to_le16(blk_rq_bytes(req) - 4);
psge = &mpi_request->SGL; psge = &mpi_request->SGL;
/* WRITE sgel first */ /* WRITE sgel first */
@ -1112,13 +1112,13 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
MPI2_SGE_FLAGS_END_OF_BUFFER | MPI2_SGE_FLAGS_HOST_TO_IOC); MPI2_SGE_FLAGS_END_OF_BUFFER | MPI2_SGE_FLAGS_HOST_TO_IOC);
sgl_flags = sgl_flags << MPI2_SGE_FLAGS_SHIFT; sgl_flags = sgl_flags << MPI2_SGE_FLAGS_SHIFT;
dma_addr_out = pci_map_single(ioc->pdev, bio_data(req->bio), dma_addr_out = pci_map_single(ioc->pdev, bio_data(req->bio),
req->data_len, PCI_DMA_BIDIRECTIONAL); blk_rq_bytes(req), PCI_DMA_BIDIRECTIONAL);
if (!dma_addr_out) { if (!dma_addr_out) {
mpt2sas_base_free_smid(ioc, le16_to_cpu(smid)); mpt2sas_base_free_smid(ioc, le16_to_cpu(smid));
goto unmap; goto unmap;
} }
ioc->base_add_sg_single(psge, sgl_flags | (req->data_len - 4), ioc->base_add_sg_single(psge, sgl_flags | (blk_rq_bytes(req) - 4),
dma_addr_out); dma_addr_out);
/* incr sgel */ /* incr sgel */
@ -1129,14 +1129,14 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
MPI2_SGE_FLAGS_LAST_ELEMENT | MPI2_SGE_FLAGS_END_OF_BUFFER | MPI2_SGE_FLAGS_LAST_ELEMENT | MPI2_SGE_FLAGS_END_OF_BUFFER |
MPI2_SGE_FLAGS_END_OF_LIST); MPI2_SGE_FLAGS_END_OF_LIST);
sgl_flags = sgl_flags << MPI2_SGE_FLAGS_SHIFT; sgl_flags = sgl_flags << MPI2_SGE_FLAGS_SHIFT;
dma_addr_in = pci_map_single(ioc->pdev, bio_data(rsp->bio), dma_addr_in = pci_map_single(ioc->pdev, bio_data(rsp->bio),
rsp->data_len, PCI_DMA_BIDIRECTIONAL); blk_rq_bytes(rsp), PCI_DMA_BIDIRECTIONAL);
if (!dma_addr_in) { if (!dma_addr_in) {
mpt2sas_base_free_smid(ioc, le16_to_cpu(smid)); mpt2sas_base_free_smid(ioc, le16_to_cpu(smid));
goto unmap; goto unmap;
} }
ioc->base_add_sg_single(psge, sgl_flags | (rsp->data_len + 4), ioc->base_add_sg_single(psge, sgl_flags | (blk_rq_bytes(rsp) + 4),
dma_addr_in); dma_addr_in);
dtransportprintk(ioc, printk(MPT2SAS_DEBUG_FMT "%s - " dtransportprintk(ioc, printk(MPT2SAS_DEBUG_FMT "%s - "
@ -1170,7 +1170,8 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
memcpy(req->sense, mpi_reply, sizeof(*mpi_reply)); memcpy(req->sense, mpi_reply, sizeof(*mpi_reply));
req->sense_len = sizeof(*mpi_reply); req->sense_len = sizeof(*mpi_reply);
rsp->resid_len = rsp->data_len - mpi_reply->ResponseDataLength; rsp->resid_len = blk_rq_bytes(rsp) -
mpi_reply->ResponseDataLength;
} else { } else {
dtransportprintk(ioc, printk(MPT2SAS_DEBUG_FMT dtransportprintk(ioc, printk(MPT2SAS_DEBUG_FMT
"%s - no reply\n", ioc->name, __func__)); "%s - no reply\n", ioc->name, __func__));
@ -1186,10 +1187,10 @@ transport_smp_handler(struct Scsi_Host *shost, struct sas_rphy *rphy,
unmap: unmap:
if (dma_addr_out) if (dma_addr_out)
pci_unmap_single(ioc->pdev, dma_addr_out, req->data_len, pci_unmap_single(ioc->pdev, dma_addr_out, blk_rq_bytes(req),
PCI_DMA_BIDIRECTIONAL); PCI_DMA_BIDIRECTIONAL);
if (dma_addr_in) if (dma_addr_in)
pci_unmap_single(ioc->pdev, dma_addr_in, rsp->data_len, pci_unmap_single(ioc->pdev, dma_addr_in, blk_rq_bytes(rsp),
PCI_DMA_BIDIRECTIONAL); PCI_DMA_BIDIRECTIONAL);
out: out:

View file

@ -1299,7 +1299,7 @@ int osd_finalize_request(struct osd_request *or,
return ret; return ret;
} }
OSD_DEBUG("out bytes=%llu (bytes_req=%u)\n", OSD_DEBUG("out bytes=%llu (bytes_req=%u)\n",
_LLU(or->out.total_bytes), or->out.req->data_len); _LLU(or->out.total_bytes), blk_rq_bytes(or->out.req));
} }
if (or->in.bio) { if (or->in.bio) {
ret = blk_rq_append_bio(or->request->q, or->in.req, or->in.bio); ret = blk_rq_append_bio(or->request->q, or->in.req, or->in.bio);
@ -1308,7 +1308,7 @@ int osd_finalize_request(struct osd_request *or,
return ret; return ret;
} }
OSD_DEBUG("in bytes=%llu (bytes_req=%u)\n", OSD_DEBUG("in bytes=%llu (bytes_req=%u)\n",
_LLU(or->in.total_bytes), or->in.req->data_len); _LLU(or->in.total_bytes), blk_rq_bytes(or->in.req));
} }
or->out.pad_buff = sg_out_pad_buffer; or->out.pad_buff = sg_out_pad_buffer;

View file

@ -682,14 +682,13 @@ EXPORT_SYMBOL(scsi_release_buffers);
static void scsi_end_bidi_request(struct scsi_cmnd *cmd) static void scsi_end_bidi_request(struct scsi_cmnd *cmd)
{ {
struct request *req = cmd->request; struct request *req = cmd->request;
unsigned int dlen = req->data_len;
unsigned int next_dlen = req->next_rq->data_len;
req->resid_len = scsi_out(cmd)->resid; req->resid_len = scsi_out(cmd)->resid;
req->next_rq->resid_len = scsi_in(cmd)->resid; req->next_rq->resid_len = scsi_in(cmd)->resid;
/* The req and req->next_rq have not been completed */ /* The req and req->next_rq have not been completed */
BUG_ON(blk_end_bidi_request(req, 0, dlen, next_dlen)); BUG_ON(blk_end_bidi_request(req, 0, blk_rq_bytes(req),
blk_rq_bytes(req->next_rq)));
scsi_release_buffers(cmd); scsi_release_buffers(cmd);
@ -966,7 +965,7 @@ static int scsi_init_sgtable(struct request *req, struct scsi_data_buffer *sdb,
BUG_ON(count > sdb->table.nents); BUG_ON(count > sdb->table.nents);
sdb->table.nents = count; sdb->table.nents = count;
if (blk_pc_request(req)) if (blk_pc_request(req))
sdb->length = req->data_len; sdb->length = blk_rq_bytes(req);
else else
sdb->length = blk_rq_sectors(req) << 9; sdb->length = blk_rq_sectors(req) << 9;
return BLKPREP_OK; return BLKPREP_OK;
@ -1087,21 +1086,21 @@ int scsi_setup_blk_pc_cmnd(struct scsi_device *sdev, struct request *req)
if (unlikely(ret)) if (unlikely(ret))
return ret; return ret;
} else { } else {
BUG_ON(req->data_len); BUG_ON(blk_rq_bytes(req));
memset(&cmd->sdb, 0, sizeof(cmd->sdb)); memset(&cmd->sdb, 0, sizeof(cmd->sdb));
req->buffer = NULL; req->buffer = NULL;
} }
cmd->cmd_len = req->cmd_len; cmd->cmd_len = req->cmd_len;
if (!req->data_len) if (!blk_rq_bytes(req))
cmd->sc_data_direction = DMA_NONE; cmd->sc_data_direction = DMA_NONE;
else if (rq_data_dir(req) == WRITE) else if (rq_data_dir(req) == WRITE)
cmd->sc_data_direction = DMA_TO_DEVICE; cmd->sc_data_direction = DMA_TO_DEVICE;
else else
cmd->sc_data_direction = DMA_FROM_DEVICE; cmd->sc_data_direction = DMA_FROM_DEVICE;
cmd->transfersize = req->data_len; cmd->transfersize = blk_rq_bytes(req);
cmd->allowed = req->retries; cmd->allowed = req->retries;
return BLKPREP_OK; return BLKPREP_OK;
} }

View file

@ -387,7 +387,7 @@ static int scsi_map_user_pages(struct scsi_tgt_cmd *tcmd, struct scsi_cmnd *cmd,
* we use REQ_TYPE_BLOCK_PC so scsi_init_io doesn't set the * we use REQ_TYPE_BLOCK_PC so scsi_init_io doesn't set the
* length for us. * length for us.
*/ */
cmd->sdb.length = rq->data_len; cmd->sdb.length = blk_rq_bytes(rq);
return 0; return 0;