block_manager.cpp

Go to the documentation of this file.

/***************************************************************************
 *  lib/mng/block_manager.cpp
 *
 *  Part of the STXXL. See http://stxxl.sourceforge.net
 *
 *  Copyright (C) 2002-2004 Roman Dementiev <[email protected]>
 *  Copyright (C) 2008, 2010 Andreas Beckmann <[email protected]>
 *  Copyright (C) 2013 Timo Bingmann <[email protected]>
 *
 *  Distributed under the Boost Software License, Version 1.0.
 *  (See accompanying file LICENSE_1_0.txt or copy at
 *  http://www.boost.org/LICENSE_1_0.txt)
 **************************************************************************/

#include <stxxl/bits/common/types.h>
#include <stxxl/bits/io/create_file.h>
#include <stxxl/bits/io/file.h>
#include <stxxl/bits/mng/block_manager.h>
#include <stxxl/bits/mng/config.h>
#include <stxxl/bits/mng/disk_allocator.h>
#include <stxxl/bits/namespace.h>
#include <stxxl/bits/verbose.h>

#include <cstddef>
#include <fstream>
#include <string>

STXXL_BEGIN_NAMESPACE

class io_error;

block_manager::block_manager()
{
    config* config = config::get_instance();

    // initialize config (may read config files now)
    config->check_initialized();

    // allocate disk_allocators
    ndisks = config->disks_number();
    disk_allocators = new disk_allocator*[ndisks];
    disk_files = new file*[ndisks];

    uint64 total_size = 0;

    for (unsigned i = 0; i < ndisks; ++i)
    {
        disk_config& cfg = config->disk(i);

        // assign queues in order of disks.
        if (cfg.queue == file::DEFAULT_QUEUE)
            cfg.queue = i;

        try
        {
            disk_files[i] = create_file(cfg, file::CREAT | file::RDWR, i);

            STXXL_MSG("Disk '" << cfg.path << "' is allocated, space: " <<
                      (cfg.size) / (1024 * 1024) <<
                      " MiB, I/O implementation: " << cfg.fileio_string());
        }
        catch (io_error&)
        {
            STXXL_MSG("Error allocating disk '" << cfg.path << "', space: " <<
                      (cfg.size) / (1024 * 1024) <<
                      " MiB, I/O implementation: " << cfg.fileio_string());
            throw;
        }

        total_size += cfg.size;

        disk_allocators[i] = new disk_allocator(disk_files[i], cfg);
    }

    if (ndisks > 1)
    {
        STXXL_MSG("In total " << ndisks << " disks are allocated, space: " <<
                  (total_size / (1024 * 1024)) <<
                  " MiB");
    }

#if STXXL_MNG_COUNT_ALLOCATION
    m_current_allocation = 0;
    m_total_allocation = 0;
    m_maximum_allocation = 0;
#endif // STXXL_MNG_COUNT_ALLOCATION
}

block_manager::~block_manager()
{
    STXXL_VERBOSE1("Block manager destructor");
    for (size_t i = ndisks; i > 0; )
    {
        --i;
        delete disk_allocators[i];
        delete disk_files[i];
    }
    delete[] disk_allocators;
    delete[] disk_files;
}

uint64 block_manager::get_total_bytes() const
{
    uint64 total = 0;

    for (unsigned i = 0; i < ndisks; ++i)
        total += disk_allocators[i]->get_total_bytes();

    return total;
}

uint64 block_manager::get_free_bytes() const
{
    uint64 total = 0;

    for (unsigned i = 0; i < ndisks; ++i)
        total += disk_allocators[i]->get_free_bytes();

    return total;
}

STXXL_END_NAMESPACE
// vim: et:ts=4:sw=4