Skip to content

Commit

Permalink
block: Split change_cb() into change_media_cb(), resize_cb()
Browse files Browse the repository at this point in the history
Multiplexing callbacks complicates matters needlessly.

Signed-off-by: Markus Armbruster <armbru@redhat.com>
Signed-off-by: Kevin Wolf <kwolf@redhat.com>
  • Loading branch information
Markus Armbruster authored and kevmw committed Sep 6, 2011
1 parent 0e49de5 commit 145feb1
Show file tree
Hide file tree
Showing 6 changed files with 33 additions and 29 deletions.
23 changes: 15 additions & 8 deletions block.c
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@
#include <windows.h>
#endif

static void bdrv_dev_change_cb(BlockDriverState *bs, int reason);
static void bdrv_dev_change_media_cb(BlockDriverState *bs);
static BlockDriverAIOCB *bdrv_aio_readv_em(BlockDriverState *bs,
int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
BlockDriverCompletionFunc *cb, void *opaque);
Expand Down Expand Up @@ -690,7 +690,7 @@ int bdrv_open(BlockDriverState *bs, const char *filename, int flags,

if (!bdrv_key_required(bs)) {
bs->media_changed = 1;
bdrv_dev_change_cb(bs, CHANGE_MEDIA);
bdrv_dev_change_media_cb(bs);
}

return 0;
Expand Down Expand Up @@ -727,7 +727,7 @@ void bdrv_close(BlockDriverState *bs)
}

bs->media_changed = 1;
bdrv_dev_change_cb(bs, CHANGE_MEDIA);
bdrv_dev_change_media_cb(bs);
}
}

Expand Down Expand Up @@ -806,10 +806,17 @@ void bdrv_set_dev_ops(BlockDriverState *bs, const BlockDevOps *ops,
bs->dev_opaque = opaque;
}

static void bdrv_dev_change_cb(BlockDriverState *bs, int reason)
static void bdrv_dev_change_media_cb(BlockDriverState *bs)
{
if (bs->dev_ops && bs->dev_ops->change_cb) {
bs->dev_ops->change_cb(bs->dev_opaque, reason);
if (bs->dev_ops && bs->dev_ops->change_media_cb) {
bs->dev_ops->change_media_cb(bs->dev_opaque);
}
}

static void bdrv_dev_resize_cb(BlockDriverState *bs)
{
if (bs->dev_ops && bs->dev_ops->resize_cb) {
bs->dev_ops->resize_cb(bs->dev_opaque);
}
}

Expand Down Expand Up @@ -1283,7 +1290,7 @@ int bdrv_truncate(BlockDriverState *bs, int64_t offset)
ret = drv->bdrv_truncate(bs, offset);
if (ret == 0) {
ret = refresh_total_sectors(bs, offset >> BDRV_SECTOR_BITS);
bdrv_dev_change_cb(bs, CHANGE_SIZE);
bdrv_dev_resize_cb(bs);
}
return ret;
}
Expand Down Expand Up @@ -1659,7 +1666,7 @@ int bdrv_set_key(BlockDriverState *bs, const char *key)
bs->valid_key = 1;
/* call the change callback now, we skipped it on open */
bs->media_changed = 1;
bdrv_dev_change_cb(bs, CHANGE_MEDIA);
bdrv_dev_change_media_cb(bs);
}
return ret;
}
Expand Down
12 changes: 11 additions & 1 deletion block.h
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,18 @@ typedef struct QEMUSnapshotInfo {
uint64_t vm_clock_nsec; /* VM clock relative to boot */
} QEMUSnapshotInfo;

/* Callbacks for block device models */
typedef struct BlockDevOps {
void (*change_cb)(void *opaque, int reason);
/*
* Runs when virtual media changed (monitor commands eject, change)
* Beware: doesn't run when a host device's physical media
* changes. Sure would be useful if it did.
*/
void (*change_media_cb)(void *opaque);
/*
* Runs when the size changed (e.g. monitor command block_resize)
*/
void (*resize_cb)(void *opaque);
} BlockDevOps;

#define BDRV_O_RDWR 0x0002
Expand Down
3 changes: 0 additions & 3 deletions block_int.h
Original file line number Diff line number Diff line change
Expand Up @@ -211,9 +211,6 @@ struct BlockDriverState {
void *private;
};

#define CHANGE_MEDIA 0x01
#define CHANGE_SIZE 0x02

struct BlockDriverAIOCB {
AIOPool *pool;
BlockDriverState *bs;
Expand Down
8 changes: 2 additions & 6 deletions hw/ide/core.c
Original file line number Diff line number Diff line change
Expand Up @@ -783,15 +783,11 @@ static void ide_cfata_metadata_write(IDEState *s)
}

/* called when the inserted state of the media has changed */
static void cdrom_change_cb(void *opaque, int reason)
static void ide_cd_change_cb(void *opaque)
{
IDEState *s = opaque;
uint64_t nb_sectors;

if (!(reason & CHANGE_MEDIA)) {
return;
}

bdrv_get_geometry(s->bs, &nb_sectors);
s->nb_sectors = nb_sectors;

Expand Down Expand Up @@ -1743,7 +1739,7 @@ void ide_bus_reset(IDEBus *bus)
}

static const BlockDevOps ide_cd_block_ops = {
.change_cb = cdrom_change_cb,
.change_media_cb = ide_cd_change_cb,
};

int ide_init_drive(IDEState *s, BlockDriverState *bs, IDEDriveKind kind,
Expand Down
8 changes: 2 additions & 6 deletions hw/sd.c
Original file line number Diff line number Diff line change
Expand Up @@ -420,14 +420,10 @@ static void sd_reset(SDState *sd, BlockDriverState *bdrv)
sd->pwd_len = 0;
}

static void sd_cardchange(void *opaque, int reason)
static void sd_cardchange(void *opaque)
{
SDState *sd = opaque;

if (!(reason & CHANGE_MEDIA)) {
return;
}

qemu_set_irq(sd->inserted_cb, bdrv_is_inserted(sd->bdrv));
if (bdrv_is_inserted(sd->bdrv)) {
sd_reset(sd, sd->bdrv);
Expand All @@ -436,7 +432,7 @@ static void sd_cardchange(void *opaque, int reason)
}

static const BlockDevOps sd_block_ops = {
.change_cb = sd_cardchange,
.change_media_cb = sd_cardchange,
};

/* We do not model the chip select pin, so allow the board to select
Expand Down
8 changes: 3 additions & 5 deletions hw/virtio-blk.c
Original file line number Diff line number Diff line change
Expand Up @@ -543,17 +543,15 @@ static int virtio_blk_load(QEMUFile *f, void *opaque, int version_id)
return 0;
}

static void virtio_blk_change_cb(void *opaque, int reason)
static void virtio_blk_resize(void *opaque)
{
VirtIOBlock *s = opaque;

if (reason & CHANGE_SIZE) {
virtio_notify_config(&s->vdev);
}
virtio_notify_config(&s->vdev);
}

static const BlockDevOps virtio_block_ops = {
.change_cb = virtio_blk_change_cb,
.resize_cb = virtio_blk_resize,
};

VirtIODevice *virtio_blk_init(DeviceState *dev, BlockConf *conf,
Expand Down

0 comments on commit 145feb1

Please sign in to comment.