Archipelago » qemu

static int qcow2_write(BlockDriverState *bs, int64_t sector_num,

                     const uint8_t *buf, int nb_sectors)

{

    BDRVQcowState *s = bs->opaque;

    int ret, index_in_cluster, n;

    uint64_t cluster_offset;

    int n_end;

    QCowL2Meta l2meta;

    while (nb_sectors > 0) {

        memset(&l2meta, 0, sizeof(l2meta));

        index_in_cluster = sector_num & (s->cluster_sectors - 1);

        n_end = index_in_cluster + nb_sectors;

        if (s->crypt_method &&

            n_end > QCOW_MAX_CRYPT_CLUSTERS * s->cluster_sectors)

            n_end = QCOW_MAX_CRYPT_CLUSTERS * s->cluster_sectors;

        cluster_offset = qcow2_alloc_cluster_offset(bs, sector_num << 9,

                                              index_in_cluster,

                                              n_end, &n, &l2meta);

        if (!cluster_offset)

            return -1;

        if (s->crypt_method) {

            qcow2_encrypt_sectors(s, sector_num, s->cluster_data, buf, n, 1,

                            &s->aes_encrypt_key);

            ret = bdrv_pwrite(s->hd, cluster_offset + index_in_cluster * 512,

                              s->cluster_data, n * 512);

        } else {

            ret = bdrv_pwrite(s->hd, cluster_offset + index_in_cluster * 512, buf, n * 512);

        }

        if (ret != n * 512 || qcow2_alloc_cluster_link_l2(bs, cluster_offset, &l2meta) < 0) {

            qcow2_free_any_clusters(bs, cluster_offset, l2meta.nb_clusters);

            return -1;

        }

        nb_sectors -= n;

        sector_num += n;

        buf += n * 512;

        if (l2meta.nb_clusters != 0) {

            QLIST_REMOVE(&l2meta, next_in_flight);

        }

    }

    s->cluster_cache_offset = -1; /* disable compressed cache */

    return 0;

}

    .bdrv_read          = qcow2_read,

    .bdrv_write         = qcow2_write,

    .bdrv_aio_readv     = qcow_aio_readv,

    .bdrv_aio_writev    = qcow_aio_writev,