/***************************************************************************
 *  mng/unittest.cpp
 *
 *  Part of the STXXL. See http://stxxl.sourceforge.net
 *
 *  Copyright (C) 2007 Roman Dementiev <dementiev@ira.uka.de>
 *  Copyright (C) 2009 Andreas Beckmann <beckmann@cs.uni-frankfurt.de>
 *
 *  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 <iostream>
#include <stxxl.h>

#include <cppunit/extensions/TestFactoryRegistry.h>
#include <cppunit/extensions/HelperMacros.h>
#include <cppunit/ui/text/TestRunner.h>


#define BLOCK_SIZE (1024 * 512)

struct MyType
{
    int integer;
    char chars[5];
};

struct my_handler
{
    void operator () (stxxl::request * req)
    {
        STXXL_MSG(req << " done, type=" << req->io_type());
    }
};

typedef stxxl::typed_block<BLOCK_SIZE, MyType> block_type;

class BMLayerTest : public CppUnit::TestCase
{
    CPPUNIT_TEST_SUITE(BMLayerTest);
    CPPUNIT_TEST(testIO);
    CPPUNIT_TEST(testIO2);
    CPPUNIT_TEST(testPrefetchPool);
    CPPUNIT_TEST(testWritePool);
    CPPUNIT_TEST(testStreams);
    CPPUNIT_TEST_SUITE_END();

public:
    BMLayerTest(std::string name) : CppUnit::TestCase(name) { }
    BMLayerTest() { }

    void testIO()
    {
        const unsigned nblocks = 2;
        stxxl::BIDArray<BLOCK_SIZE> bids(nblocks);
        std::vector<int> disks(nblocks, 2);
        stxxl::request_ptr * reqs = new stxxl::request_ptr[nblocks];
        stxxl::block_manager * bm = stxxl::block_manager::get_instance();
        bm->new_blocks(stxxl::striping(), bids.begin(), bids.end());

        block_type * block = new block_type;
        STXXL_MSG(std::hex);
        STXXL_MSG("Allocated block address    : " << long(block));
        STXXL_MSG("Allocated block address + 1: " << long(block + 1));
        STXXL_MSG(std::dec);
        unsigned i = 0;
        for (i = 0; i < block_type::size; ++i)
        {
            block->elem[i].integer = i;
            //memcpy (block->elem[i].chars, "STXXL", 4);
        }
        for (i = 0; i < nblocks; ++i)
            reqs[i] = block->write(bids[i], my_handler());


        std::cout << "Waiting " << std::endl;
        stxxl::wait_all(reqs, nblocks);

        for (i = 0; i < nblocks; ++i)
        {
            reqs[i] = block->read(bids[i], my_handler());
            reqs[i]->wait();
            for (int j = 0; j < block_type::size; ++j)
            {
                CPPUNIT_ASSERT(j == block->elem[j].integer);
            }
        }

        bm->delete_blocks(bids.begin(), bids.end());

        delete[] reqs;
        delete block;
    }

    void testIO2()
    {
        typedef stxxl::typed_block<128 * 1024, double> block_type;
        std::vector<block_type::bid_type> bids;
        std::vector<stxxl::request_ptr> requests;
        stxxl::block_manager * bm = stxxl::block_manager::get_instance();
        bm->new_blocks<block_type>(32, stxxl::striping(), std::back_inserter(bids));
        block_type * blocks = new block_type[32];
        int vIndex;
        for (vIndex = 0; vIndex < 32; ++vIndex) {
            for (int vIndex2 = 0; vIndex2 < block_type::size; ++vIndex2) {
                blocks[vIndex][vIndex2] = vIndex2;
            }
        }
        for (vIndex = 0; vIndex < 32; ++vIndex) {
            requests.push_back(blocks[vIndex].write(bids[vIndex]));
        }
        stxxl::wait_all(requests.begin(), requests.end());
        bm->delete_blocks(bids.begin(), bids.end());
        delete[] blocks;
    }


    void testPrefetchPool()
    {
        stxxl::prefetch_pool<block_type> pool(2);
        pool.resize(10);
        pool.resize(5);
        block_type * blk = new block_type;
        block_type::bid_type bid;
        stxxl::block_manager::get_instance()->new_block(stxxl::single_disk(), bid);
        pool.hint(bid);
        pool.read(blk, bid)->wait();
        delete blk;
    }

    void testWritePool()
    {
        stxxl::write_pool<block_type> pool(100);
        pool.resize(10);
        pool.resize(5);
        block_type * blk = new block_type;
        block_type::bid_type bid;
        stxxl::block_manager::get_instance()->new_block(stxxl::single_disk(), bid);
        pool.write(blk, bid);
    }

    typedef stxxl::typed_block<BLOCK_SIZE, int> block_type1;
    typedef stxxl::buf_ostream<block_type1, stxxl::BIDArray<BLOCK_SIZE>::iterator> buf_ostream_type;
    typedef stxxl::buf_istream<block_type1, stxxl::BIDArray<BLOCK_SIZE>::iterator> buf_istream_type;

    void testStreams()
    {
        const unsigned nblocks = 64;
        const unsigned nelements = nblocks * block_type1::size;
        stxxl::BIDArray<BLOCK_SIZE> bids(nblocks);

        stxxl::block_manager * bm = stxxl::block_manager::get_instance();
        bm->new_blocks(stxxl::striping(), bids.begin(), bids.end());
        {
            buf_ostream_type out(bids.begin(), 2);
            for (unsigned i = 0; i < nelements; i++)
                out << i;
        }
        {
            buf_istream_type in(bids.begin(), bids.end(), 2);
            for (unsigned i = 0; i < nelements; i++)
            {
                int value;
                in >> value;
                CPPUNIT_ASSERT(value == int(i));
            }
        }
        bm->delete_blocks(bids.begin(), bids.end());
    }
};

CPPUNIT_TEST_SUITE_REGISTRATION(BMLayerTest);

int main()
{
    CppUnit::TextUi::TestRunner runner;
    CppUnit::TestFactoryRegistry & registry = CppUnit::TestFactoryRegistry::getRegistry();
    runner.addTest(registry.makeTest());
    bool wasSuccessful = runner.run("", false);
    return wasSuccessful ? 0 : 1;
}