提交 efb9ee02 编写于 作者: H Hannes Reinecke 提交者: Paolo Bonzini

scsi-disk: add data direction checking

scsi_req_parse() already provides for a data direction setting,
so we should be using it to check for correct direction.
And we should return the sense code 'INVALID FIELD IN CDB'
in these cases.
Signed-off-by: NHannes Reinecke <hare@suse.de>
Signed-off-by: NPaolo Bonzini <pbonzini@redhat.com>
Reviewed-by: NChristoph Hellwig <hch@lst.de>
上级 74382217
...@@ -51,8 +51,6 @@ typedef struct SCSIDiskState SCSIDiskState; ...@@ -51,8 +51,6 @@ typedef struct SCSIDiskState SCSIDiskState;
typedef struct SCSIDiskReq { typedef struct SCSIDiskReq {
SCSIRequest req; SCSIRequest req;
/* ??? We should probably keep track of whether the data transfer is
a read or a write. Currently we rely on the host getting it right. */
/* Both sector and sector_count are in terms of qemu 512 byte blocks. */ /* Both sector and sector_count are in terms of qemu 512 byte blocks. */
uint64_t sector; uint64_t sector;
uint32_t sector_count; uint32_t sector_count;
...@@ -180,6 +178,12 @@ static void scsi_read_data(SCSIRequest *req) ...@@ -180,6 +178,12 @@ static void scsi_read_data(SCSIRequest *req)
/* No data transfer may already be in progress */ /* No data transfer may already be in progress */
assert(r->req.aiocb == NULL); assert(r->req.aiocb == NULL);
if (r->req.cmd.mode == SCSI_XFER_TO_DEV) {
DPRINTF("Data transfer direction invalid\n");
scsi_read_complete(r, -EINVAL);
return;
}
n = r->sector_count; n = r->sector_count;
if (n > SCSI_DMA_BUF_SIZE / 512) if (n > SCSI_DMA_BUF_SIZE / 512)
n = SCSI_DMA_BUF_SIZE / 512; n = SCSI_DMA_BUF_SIZE / 512;
...@@ -216,16 +220,22 @@ static int scsi_handle_rw_error(SCSIDiskReq *r, int error, int type) ...@@ -216,16 +220,22 @@ static int scsi_handle_rw_error(SCSIDiskReq *r, int error, int type)
if (type == SCSI_REQ_STATUS_RETRY_READ) { if (type == SCSI_REQ_STATUS_RETRY_READ) {
scsi_req_data(&r->req, 0); scsi_req_data(&r->req, 0);
} }
if (error == ENOMEM) { switch (error) {
case ENOMEM:
scsi_command_complete(r, CHECK_CONDITION, scsi_command_complete(r, CHECK_CONDITION,
SENSE_CODE(TARGET_FAILURE)); SENSE_CODE(TARGET_FAILURE));
} else { break;
case EINVAL:
scsi_command_complete(r, CHECK_CONDITION,
SENSE_CODE(INVALID_FIELD));
break;
default:
scsi_command_complete(r, CHECK_CONDITION, scsi_command_complete(r, CHECK_CONDITION,
SENSE_CODE(IO_ERROR)); SENSE_CODE(IO_ERROR));
break;
} }
bdrv_mon_event(s->bs, BDRV_ACTION_REPORT, is_read); bdrv_mon_event(s->bs, BDRV_ACTION_REPORT, is_read);
} }
return 1; return 1;
} }
...@@ -268,6 +278,12 @@ static int scsi_write_data(SCSIRequest *req) ...@@ -268,6 +278,12 @@ static int scsi_write_data(SCSIRequest *req)
/* No data transfer may already be in progress */ /* No data transfer may already be in progress */
assert(r->req.aiocb == NULL); assert(r->req.aiocb == NULL);
if (r->req.cmd.mode != SCSI_XFER_TO_DEV) {
DPRINTF("Data transfer direction invalid\n");
scsi_write_complete(r, -EINVAL);
return 0;
}
n = r->iov.iov_len / 512; n = r->iov.iov_len / 512;
if (n) { if (n) {
qemu_iovec_init_external(&r->qiov, &r->iov, 1); qemu_iovec_init_external(&r->qiov, &r->iov, 1);
...@@ -987,14 +1003,12 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf) ...@@ -987,14 +1003,12 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf)
SCSIDiskReq *r = DO_UPCAST(SCSIDiskReq, req, req); SCSIDiskReq *r = DO_UPCAST(SCSIDiskReq, req, req);
SCSIDiskState *s = DO_UPCAST(SCSIDiskState, qdev, req->dev); SCSIDiskState *s = DO_UPCAST(SCSIDiskState, qdev, req->dev);
int32_t len; int32_t len;
int is_write;
uint8_t command; uint8_t command;
uint8_t *outbuf; uint8_t *outbuf;
int rc; int rc;
command = buf[0]; command = buf[0];
outbuf = (uint8_t *)r->iov.iov_base; outbuf = (uint8_t *)r->iov.iov_base;
is_write = 0;
DPRINTF("Command: lun=%d tag=0x%x data=0x%02x", lun, tag, buf[0]); DPRINTF("Command: lun=%d tag=0x%x data=0x%02x", lun, tag, buf[0]);
if (scsi_req_parse(&r->req, buf) != 0) { if (scsi_req_parse(&r->req, buf) != 0) {
...@@ -1074,7 +1088,6 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf) ...@@ -1074,7 +1088,6 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf)
goto illegal_lba; goto illegal_lba;
r->sector = r->req.cmd.lba * s->cluster_size; r->sector = r->req.cmd.lba * s->cluster_size;
r->sector_count = len * s->cluster_size; r->sector_count = len * s->cluster_size;
is_write = 1;
break; break;
case MODE_SELECT: case MODE_SELECT:
DPRINTF("Mode Select(6) (len %lu)\n", (long)r->req.cmd.xfer); DPRINTF("Mode Select(6) (len %lu)\n", (long)r->req.cmd.xfer);
...@@ -1140,13 +1153,13 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf) ...@@ -1140,13 +1153,13 @@ static int32_t scsi_send_command(SCSIRequest *req, uint8_t *buf)
scsi_command_complete(r, GOOD, SENSE_CODE(NO_SENSE)); scsi_command_complete(r, GOOD, SENSE_CODE(NO_SENSE));
} }
len = r->sector_count * 512 + r->iov.iov_len; len = r->sector_count * 512 + r->iov.iov_len;
if (is_write) { if (r->req.cmd.mode == SCSI_XFER_TO_DEV) {
len = -len; return -len;
} else { } else {
if (!r->sector_count) if (!r->sector_count)
r->sector_count = -1; r->sector_count = -1;
return len;
} }
return len;
} }
static void scsi_disk_reset(DeviceState *dev) static void scsi_disk_reset(DeviceState *dev)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册