d/numam-spdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

bdev/virtio: handle missed eventq I/O

Browse Source 
If the host fails to send some events,
the next event it succeeds to send
might have an EVENTS_MISSED flag set.
Once virtio receives such event, it will
schedule a full bus rescan to manually
detect any changes.

Change-Id: Ifa66536f8e2980ad31ee68769f042f08100da54e
Signed-off-by: Dariusz Stojaczyk <dariuszx.stojaczyk@intel.com>
Reviewed-on: https://review.gerrithub.io/392780
Tested-by: SPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: Daniel Verkamp <daniel.verkamp@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
This commit is contained in:
Dariusz Stojaczyk 2017-12-22 12:58:30 +01:00 committed by Ben Walker
parent 166f6e9cb8
commit 7f4ff3d922
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/bdev/virtio/bdev_virtio.c
View File

@ -363,6 +363,8 @@ virtio_scsi_dev_get_disk_by_id(struct virtio_scsi_dev *svdev, uint8_t target_id)
return NULL;
}
static int virtio_scsi_dev_scan(struct virtio_scsi_dev *svdev,
bdev_virtio_create_cb cb_fn, void *cb_arg);
static int send_scan_io(struct virtio_scsi_scan_base *base);
static void _virtio_scsi_dev_scan_tgt(struct virtio_scsi_scan_base *base, uint8_t target);
static int _virtio_scsi_dev_scan_next(struct virtio_scsi_scan_base *base);
@ -778,7 +780,15 @@ bdev_virtio_eventq_io_cpl(struct virtio_scsi_dev *svdev, struct virtio_scsi_even
goto out;
}
if (ev->event == VIRTIO_SCSI_T_TRANSPORT_RESET) {
if (ev->event & VIRTIO_SCSI_T_EVENTS_MISSED) {
ev->event &= ~VIRTIO_SCSI_T_EVENTS_MISSED;
virtio_scsi_dev_scan(svdev, NULL, NULL);
}
switch (ev->event) {
case VIRTIO_SCSI_T_NO_EVENT:
break;
case VIRTIO_SCSI_T_TRANSPORT_RESET:
switch (ev->reason) {
case VIRTIO_SCSI_EVT_RESET_RESCAN:
virtio_scsi_dev_scan_tgt(svdev, ev->lun[1]);
@ -792,6 +802,9 @@ bdev_virtio_eventq_io_cpl(struct virtio_scsi_dev *svdev, struct virtio_scsi_even
default:
break;
}
break;
default:
break;
}
out: