virtio-scsi: introduce virtio_scsi_acquire/release
These will be used more as soon as the acquire/release is pushed down to the ioeventfd handlers. Reviewed-by: Fam Zheng <famz@redhat.com> Reviewed-by: Stefan Hajnoczi <stefanha@redhat.com> Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
This commit is contained in:
parent
c17a18ef30
commit
e7a9f35321
|
@ -420,6 +420,20 @@ static void virtio_scsi_handle_ctrl_req(VirtIOSCSI *s, VirtIOSCSIReq *req)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static inline void virtio_scsi_acquire(VirtIOSCSI *s)
|
||||||
|
{
|
||||||
|
if (s->ctx) {
|
||||||
|
aio_context_acquire(s->ctx);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static inline void virtio_scsi_release(VirtIOSCSI *s)
|
||||||
|
{
|
||||||
|
if (s->ctx) {
|
||||||
|
aio_context_release(s->ctx);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void virtio_scsi_handle_ctrl_vq(VirtIOSCSI *s, VirtQueue *vq)
|
void virtio_scsi_handle_ctrl_vq(VirtIOSCSI *s, VirtQueue *vq)
|
||||||
{
|
{
|
||||||
VirtIOSCSIReq *req;
|
VirtIOSCSIReq *req;
|
||||||
|
@ -691,10 +705,7 @@ void virtio_scsi_push_event(VirtIOSCSI *s, SCSIDevice *dev,
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (s->dataplane_started) {
|
virtio_scsi_acquire(s);
|
||||||
assert(s->ctx);
|
|
||||||
aio_context_acquire(s->ctx);
|
|
||||||
}
|
|
||||||
|
|
||||||
req = virtio_scsi_pop_req(s, vs->event_vq);
|
req = virtio_scsi_pop_req(s, vs->event_vq);
|
||||||
if (!req) {
|
if (!req) {
|
||||||
|
@ -730,9 +741,7 @@ void virtio_scsi_push_event(VirtIOSCSI *s, SCSIDevice *dev,
|
||||||
}
|
}
|
||||||
virtio_scsi_complete_req(req);
|
virtio_scsi_complete_req(req);
|
||||||
out:
|
out:
|
||||||
if (s->dataplane_started) {
|
virtio_scsi_release(s);
|
||||||
aio_context_release(s->ctx);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void virtio_scsi_handle_event_vq(VirtIOSCSI *s, VirtQueue *vq)
|
void virtio_scsi_handle_event_vq(VirtIOSCSI *s, VirtQueue *vq)
|
||||||
|
@ -778,9 +787,9 @@ static void virtio_scsi_hotplug(HotplugHandler *hotplug_dev, DeviceState *dev,
|
||||||
if (blk_op_is_blocked(sd->conf.blk, BLOCK_OP_TYPE_DATAPLANE, errp)) {
|
if (blk_op_is_blocked(sd->conf.blk, BLOCK_OP_TYPE_DATAPLANE, errp)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
aio_context_acquire(s->ctx);
|
virtio_scsi_acquire(s);
|
||||||
blk_set_aio_context(sd->conf.blk, s->ctx);
|
blk_set_aio_context(sd->conf.blk, s->ctx);
|
||||||
aio_context_release(s->ctx);
|
virtio_scsi_release(s);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue