source: mainline/uspace/app/bithenge/block.c@ 1923501

/*
 * Copyright (c) 2012 Sean Bartell
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/** @addtogroup bithenge
 * @{
 */
/**
 * @file
 * Access block devices as blobs.
 * @todo Provide more information about the block device (block size).
 */

#include <assert.h>
#include <errno.h>
#include <libblock.h>
#include <loc.h>
#include <macros.h>
#include <stdlib.h>
#include "blob.h"
#include "block.h"

typedef struct {
        bithenge_blob_t base;
        service_id_t service_id;
        aoff64_t size;
} block_blob_t;

static inline block_blob_t *block_from_blob(bithenge_blob_t *base)
{
        return (block_blob_t *)base;
}

static inline bithenge_blob_t *blob_from_block(block_blob_t *blob)
{
        return &blob->base;
}

static int block_size(bithenge_blob_t *base, aoff64_t *size)
{
        block_blob_t *blob = block_from_blob(base);
        *size = blob->size;
        return EOK;
}

static int block_read(bithenge_blob_t *base, aoff64_t offset, char *buffer,
    aoff64_t *size)
{
        block_blob_t *blob = block_from_blob(base);
        if (offset > blob->size)
                return ELIMIT;
        *size = min(*size, blob->size - offset);
        return block_read_bytes_direct(blob->service_id, offset, *size, buffer);
}

static int block_destroy(bithenge_blob_t *base)
{
        block_blob_t *blob = block_from_blob(base);
        block_fini(blob->service_id);
        free(blob);
        return EOK;
}

static const bithenge_random_access_blob_ops_t block_ops = {
        .size = block_size,
        .read = block_read,
        .destroy = block_destroy,
};

/** Create a blob for a block device. The blob must be freed with
 * @a bithenge_blob_t::bithenge_blob_destroy after it is used.
 * @param out[out] Place to store the blob.
 * @param service_id The service ID of the block device.
 * @return EOK on success or an error code from errno.h. */
int bithenge_new_block_blob(bithenge_blob_t **out, service_id_t service_id)
{
        assert(out);

        // Initialize libblock
        int rc;
        rc = block_init(EXCHANGE_SERIALIZE, service_id, 2048);
        if (rc != EOK)
                return rc;

        // Calculate total device size
        size_t bsize;
        aoff64_t nblocks;
        aoff64_t size;
        rc = block_get_bsize(service_id, &bsize);
        if (rc != EOK)
                return rc;
        rc = block_get_nblocks(service_id, &nblocks);
        if (rc != EOK)
                return rc;
        size = bsize * nblocks;

        // Create blob
        block_blob_t *blob = malloc(sizeof(*blob));
        if (!blob)
                return ENOMEM;
        rc = bithenge_new_random_access_blob(blob_from_block(blob),
            &block_ops);
        if (rc != EOK) {
                free(blob);
                return rc;
        }
        blob->service_id = service_id;
        blob->size = size;
        *out = &blob->base;

        return EOK;
}

/** @}
 */