TestSetvbuffer.cc

Go to the documentation of this file.

/*
 * (C) Copyright 1996-2012 ECMWF.
 * 
 * This software is licensed under the terms of the Apache Licence Version 2.0
 * which can be obtained at http://www.apache.org/licenses/LICENSE-2.0. 
 * In applying this licence, ECMWF does not waive the privileges and immunities 
 * granted to it by virtue of its status as an intergovernmental organisation nor
 * does it submit to any jurisdiction.
 */
 
/// \file TestSetvbuffer.h
///
/// @author Piotr Kuchta, ECMWF, Feb 2009
 
#include <sys/wait.h>
 
#include "eckit/log/Timer.h"
#include "odc/ODBAPISettings.h"
 
#include "odc/Writer.h"
#include "TestCase.h"
 
using namespace std;
using namespace eckit;
using namespace odc;
 
 
 
static void setUp() { }
 
 
static void createFile(size_t numberOfColumns, long long numberOfRows, size_t setvbufferSize)
{
 
    ODBAPISettings::instance().setvbufferSize(setvbufferSize);
 
    odc::Writer<> oda("TestSetvbuffer.odb");
    odc::Writer<>::iterator row = oda.begin();
 
    row->setNumberOfColumns(numberOfColumns);
 
    for (size_t i = 0; i < numberOfColumns; ++i)
    {
        stringstream name;
        name << "Column" << i;
        row->setColumn(i, name.str().c_str(), odc::api::REAL);
    }
    row->writeHeader();
 
    for (long long i = 1; i <= numberOfRows; ++i, ++row)
        for (size_t c = 0; c < numberOfColumns; ++c)
            (*row)[c] = c;
}
 
static void tearDown()
{
    int catStatus = system("ls -l TestSetvbuffer.odb");
    ASSERT(WEXITSTATUS(catStatus) == 0);
}
 
 
static void test()
{
    size_t cols = 400;
    long long rows = 1000;
    size_t buffSize = 8 * 1024 * 1024;
 
    for (size_t i = 0; i < 10; ++i)
    {
        stringstream s;
        s << "setUp(): createFile(" << cols << ", " << rows << ", " << buffSize << ")" << std::endl;
        Timer t(s.str());
        createFile(cols, rows, buffSize);
    }
}
 
 
 
SIMPLE_TEST(Setvbuffer)