|
Packit |
a4aae4 |
// -*- mode: c++; c-basic-offset:4 -*-
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// This file is part of libdap, A C++ implementation of the OPeNDAP Data
|
|
Packit |
a4aae4 |
// Access Protocol.
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// Copyright (c) 2013 OPeNDAP, Inc.
|
|
Packit |
a4aae4 |
// Author: James Gallagher <jgallagher@opendap.org>
|
|
Packit |
a4aae4 |
//
|
|
Packit |
a4aae4 |
// This library is free software; you can redistribute it and/or
|
|
Packit |
a4aae4 |
// modify it under the terms of the GNU Lesser General Public
|
|
Packit |
a4aae4 |
// License as published by the Free Software Foundation; either
|
|
Packit |
a4aae4 |
// version 2.1 of the License, or (at your option) any later version.
|
|
Packit |
a4aae4 |
//
|
|
Packit |
a4aae4 |
// This library is distributed in the hope that it will be useful,
|
|
Packit |
a4aae4 |
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
a4aae4 |
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
a4aae4 |
// Lesser General Public License for more details.
|
|
Packit |
a4aae4 |
//
|
|
Packit |
a4aae4 |
// You should have received a copy of the GNU Lesser General Public
|
|
Packit |
a4aae4 |
// License along with this library; if not, write to the Free Software
|
|
Packit |
a4aae4 |
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
|
Packit |
a4aae4 |
//
|
|
Packit |
a4aae4 |
// You can contact OPeNDAP, Inc. at PO Box 112, Saunderstown, RI. 02874-0112.
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include <cppunit/TextTestRunner.h>
|
|
Packit |
a4aae4 |
#include <cppunit/extensions/TestFactoryRegistry.h>
|
|
Packit |
a4aae4 |
#include <cppunit/extensions/HelperMacros.h>
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include <fcntl.h>
|
|
Packit |
a4aae4 |
#include <stdio.h>
|
|
Packit |
a4aae4 |
#include <stdlib.h>
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include <iostream>
|
|
Packit |
a4aae4 |
#include <fstream>
|
|
Packit |
a4aae4 |
#include <string>
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include "GetOpt.h"
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include "chunked_ostream.h"
|
|
Packit |
a4aae4 |
#include "chunked_istream.h"
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#include "InternalErr.h"
|
|
Packit |
a4aae4 |
#include "test_config.h"
|
|
Packit |
a4aae4 |
#include "debug.h"
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
static bool debug = false;
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
const string path = (string) TEST_SRC_DIR + "/chunked-io";
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
#undef DBG
|
|
Packit |
a4aae4 |
#define DBG(x) do { if (debug) (x); } while(false);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
using namespace std;
|
|
Packit |
a4aae4 |
using namespace CppUnit;
|
|
Packit |
a4aae4 |
using namespace libdap;
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
/**
|
|
Packit |
a4aae4 |
* The intent is to test writing to and reading from a chunked iostream,
|
|
Packit |
a4aae4 |
* using various combinations of chunk/buffer sizes and character red/write
|
|
Packit |
a4aae4 |
* sizes. There are three write functions and three read functions and
|
|
Packit |
a4aae4 |
* all combinations are tested.
|
|
Packit |
a4aae4 |
*/
|
|
Packit |
a4aae4 |
class chunked_iostream_test: public TestFixture {
|
|
Packit |
a4aae4 |
private:
|
|
Packit |
a4aae4 |
// This should be big enough to do meaningful timing tests
|
|
Packit |
a4aae4 |
string big_file, big_file_2, big_file_3;
|
|
Packit |
a4aae4 |
// This should be smaller than a single buffer
|
|
Packit |
a4aae4 |
string small_file;
|
|
Packit |
a4aae4 |
// A modest sized text file - makes looking at the results easier
|
|
Packit |
a4aae4 |
string text_file;
|
|
Packit |
a4aae4 |
public:
|
|
Packit |
a4aae4 |
chunked_iostream_test()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
~chunked_iostream_test()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void setUp()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
big_file = path + "/test_big_binary_file.bin";
|
|
Packit |
a4aae4 |
big_file_2 = path + "/test_big_binary_file_2.bin";
|
|
Packit |
a4aae4 |
big_file_3 = path + "/test_big_binary_file_3.bin"; // not used yet
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
small_file = path + "/test_small_text_file.txt";
|
|
Packit |
a4aae4 |
text_file = path + "/test_text_file.txt";
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void tearDown()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void single_char_write(const string &file, int buf_size)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
fstream infile(file.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
DBG(cerr << "infile: " << file << endl);
|
|
Packit |
a4aae4 |
if (!infile.good()) CPPUNIT_FAIL("File not open or eof");
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
string out = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
chunked_ostream chunked_outfile(outfile, buf_size);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
char c;
|
|
Packit |
a4aae4 |
infile.read(&c, 1);
|
|
Packit |
a4aae4 |
int num = infile.gcount();
|
|
Packit |
a4aae4 |
while (num > 0 && !infile.eof()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(&c, num);
|
|
Packit |
a4aae4 |
infile.read(&c, 1);
|
|
Packit |
a4aae4 |
num = infile.gcount();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !infile.bad()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(&c, num);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
chunked_outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void write_128char_data(const string &file, int buf_size)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
fstream infile(file.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
if (!infile.good()) CPPUNIT_FAIL("File not open or eof");
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
string out = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
chunked_ostream chunked_outfile(outfile, buf_size);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
char str[128];
|
|
Packit |
a4aae4 |
infile.read(str, 128);
|
|
Packit |
a4aae4 |
int num = infile.gcount();
|
|
Packit |
a4aae4 |
while (num > 0 && !infile.eof()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
infile.read(str, 128);
|
|
Packit |
a4aae4 |
num = infile.gcount();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !infile.bad()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
chunked_outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// This will not work with the small text file. This code assume that
|
|
Packit |
a4aae4 |
// the file to be written has at least 24 bytes for the first chunk,
|
|
Packit |
a4aae4 |
// which is deliberately sent using flush before the buffer is full and
|
|
Packit |
a4aae4 |
// then has at least 48 more bytes (but ideally 49, because this code
|
|
Packit |
a4aae4 |
// tries to send an End chunk with one or more bytes as opposed to
|
|
Packit |
a4aae4 |
// sending the last data chunk with fewer than buf_size and then sending a
|
|
Packit |
a4aae4 |
// zero length END chunk).
|
|
Packit |
a4aae4 |
void write_24char_data_with_error_option(const string &file, int buf_size, bool error = false)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
fstream infile(file.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
if (!infile.good()) CPPUNIT_FAIL("File not open or eof");
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
string out = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
chunked_ostream chunked_outfile(outfile, buf_size);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
try {
|
|
Packit |
a4aae4 |
char str[24];
|
|
Packit |
a4aae4 |
infile.read(str, 24);
|
|
Packit |
a4aae4 |
int num = infile.gcount();
|
|
Packit |
a4aae4 |
if (num > 0 && !infile.eof()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
chunked_outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
infile.read(str, 24);
|
|
Packit |
a4aae4 |
num = infile.gcount();
|
|
Packit |
a4aae4 |
if (num > 0 && !infile.eof()) chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// Send an error chunk; the 24 bytes read here are lost...
|
|
Packit |
a4aae4 |
if (error) throw Error("Testing error transmission");
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
infile.read(str, 24);
|
|
Packit |
a4aae4 |
num = infile.gcount();
|
|
Packit |
a4aae4 |
while (num == 24 && !infile.eof()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
infile.read(str, 24);
|
|
Packit |
a4aae4 |
num = infile.gcount();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !infile.bad()) {
|
|
Packit |
a4aae4 |
chunked_outfile.write(str, num);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// flush() calls sync() which forces a DATA chunk to be sent, regardless of
|
|
Packit |
a4aae4 |
// the amount of data in the buffer. When the stream is destroyed, end_chunk()
|
|
Packit |
a4aae4 |
// is sent with the remain chars, so removing flush() here ensures that we test
|
|
Packit |
a4aae4 |
// a non-empty END chunk.
|
|
Packit |
a4aae4 |
// chunked_outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
catch (Error &e) {
|
|
Packit |
a4aae4 |
chunked_outfile.write_err_chunk(e.get_error_message());
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void single_char_read(const string &file, int buf_size)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
string in = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream infile(in.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
if (!infile.good()) CPPUNIT_FAIL("File not open or eof");
|
|
Packit |
a4aae4 |
#if BYTE_ORDER_PREFIX
|
|
Packit |
a4aae4 |
chunked_istream chunked_infile(infile, buf_size, 0x00);
|
|
Packit |
a4aae4 |
#else
|
|
Packit |
a4aae4 |
chunked_istream chunked_infile(infile, buf_size);
|
|
Packit |
a4aae4 |
#endif
|
|
Packit |
a4aae4 |
string out = file + ".plain";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
char c;
|
|
Packit |
a4aae4 |
int count = 1;
|
|
Packit |
a4aae4 |
chunked_infile.read(&c, 1);
|
|
Packit |
a4aae4 |
int num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
DBG(cerr << "num: " << num << ", " << count++ << endl);
|
|
Packit |
a4aae4 |
while (num > 0 && !chunked_infile.eof()) {
|
|
Packit |
a4aae4 |
outfile.write(&c, num);
|
|
Packit |
a4aae4 |
chunked_infile.read(&c, 1);
|
|
Packit |
a4aae4 |
num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
DBG(cerr << "num: " << num << ", " << count++ << ", eof: " << chunked_infile.eof() << endl);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
DBG(cerr << "eof is :" << chunked_infile.eof() << ", num: " << num << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !chunked_infile.bad()) outfile.write(&c, num);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void read_128char_data(const string &file, int buf_size)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
string in = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream infile(in.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
if (!infile.good()) cerr << "File not open or eof" << endl;
|
|
Packit |
a4aae4 |
chunked_istream chunked_infile(infile, buf_size);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
string out = file + ".plain";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
char str[128];
|
|
Packit |
a4aae4 |
int count = 1;
|
|
Packit |
a4aae4 |
chunked_infile.read(str, 128);
|
|
Packit |
a4aae4 |
int num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
DBG(cerr << "num: " << num << ", " << count++ << endl);
|
|
Packit |
a4aae4 |
while (num > 0 && !chunked_infile.eof()) {
|
|
Packit |
a4aae4 |
outfile.write(str, num);
|
|
Packit |
a4aae4 |
chunked_infile.read(str, 128);
|
|
Packit |
a4aae4 |
num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
DBG(cerr << "num: " << num << ", " << count++ << ", eof: " << chunked_infile.eof() << endl);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !chunked_infile.bad()) {
|
|
Packit |
a4aae4 |
outfile.write(str, num);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void read_24char_data_with_error_option(const string &file, int buf_size)
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
string in = file + ".chunked";
|
|
Packit |
a4aae4 |
fstream infile(in.c_str(), ios::in | ios::binary);
|
|
Packit |
a4aae4 |
if (!infile.good()) cerr << "File not open or eof" << endl;
|
|
Packit |
a4aae4 |
chunked_istream chunked_infile(infile, buf_size);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
string out = file + ".plain";
|
|
Packit |
a4aae4 |
fstream outfile(out.c_str(), ios::out | ios::binary);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
try {
|
|
Packit |
a4aae4 |
#if 0
|
|
Packit |
a4aae4 |
chunked_infile.read(str, 24);
|
|
Packit |
a4aae4 |
int num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
if (num > 0 && !chunked_infile.eof()) {
|
|
Packit |
a4aae4 |
outfile.write(str, num);
|
|
Packit |
a4aae4 |
outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
#endif
|
|
Packit |
a4aae4 |
char str[24];
|
|
Packit |
a4aae4 |
chunked_infile.read(str, 24);
|
|
Packit |
a4aae4 |
int num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
while (num > 0 && !chunked_infile.eof()) {
|
|
Packit |
a4aae4 |
outfile.write(str, num);
|
|
Packit |
a4aae4 |
chunked_infile.read(str, 24);
|
|
Packit |
a4aae4 |
num = chunked_infile.gcount();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// The chunked_istream uses a chunked_inbuf and that signals error
|
|
Packit |
a4aae4 |
// using EOF. The error message is stored in the buffer and can be
|
|
Packit |
a4aae4 |
// detected and accessed using the error() error_message() methods
|
|
Packit |
a4aae4 |
// that both the buffer and istream classes have.
|
|
Packit |
a4aae4 |
if (chunked_infile.error()) throw Error("Found an error in the stream");
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
if (num > 0 && !chunked_infile.bad()) {
|
|
Packit |
a4aae4 |
outfile.write(str, num);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
outfile.flush();
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
catch (Error &e) {
|
|
Packit |
a4aae4 |
DBG(cerr << "Error chunk found: " << e.get_error_message() << endl);
|
|
Packit |
a4aae4 |
throw;
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// these are the tests
|
|
Packit |
a4aae4 |
void test_write_1_read_1_small_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(small_file, 32);
|
|
Packit |
a4aae4 |
single_char_read(small_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + small_file + " " + small_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_1_read_1_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(text_file, 32);
|
|
Packit |
a4aae4 |
single_char_read(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_1_read_1_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(big_file, 28);
|
|
Packit |
a4aae4 |
single_char_read(big_file, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
void test_write_1_read_1_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(big_file_2, 28);
|
|
Packit |
a4aae4 |
single_char_read(big_file_2, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// these are the tests
|
|
Packit |
a4aae4 |
void test_write_1_read_128_small_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(small_file, 32);
|
|
Packit |
a4aae4 |
read_128char_data(small_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + small_file + " " + small_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_1_read_128_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(text_file, 32);
|
|
Packit |
a4aae4 |
read_128char_data(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_1_read_128_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(big_file, 28);
|
|
Packit |
a4aae4 |
read_128char_data(big_file, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_1_read_128_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
single_char_write(big_file_2, 28);
|
|
Packit |
a4aae4 |
read_128char_data(big_file_2, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// 24 char write units
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_1_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(text_file, 32);
|
|
Packit |
a4aae4 |
single_char_read(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_1_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(big_file, 1024);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
single_char_read(big_file, 1024);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_1_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(big_file_2, 1024);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
single_char_read(big_file_2, 1024);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_128_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(text_file, 32);
|
|
Packit |
a4aae4 |
read_128char_data(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_128_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(big_file, 28);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
read_128char_data(big_file, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_128_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(big_file_2, 28);
|
|
Packit |
a4aae4 |
read_128char_data(big_file_2, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// 128 char writes
|
|
Packit |
a4aae4 |
void test_write_128_read_1_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(text_file, 32);
|
|
Packit |
a4aae4 |
single_char_read(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_128_read_1_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(big_file, 32);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
single_char_read(big_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_128_read_1_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(big_file_2, 32);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
single_char_read(big_file_2, 1024);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_128_read_128_text_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(text_file, 32);
|
|
Packit |
a4aae4 |
read_128char_data(text_file, 32);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + text_file + " " + text_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_128_read_128_big_file()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(big_file, 28);
|
|
Packit |
a4aae4 |
DBG(cerr << "Wrote the file" << endl);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
read_128char_data(big_file, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file + " " + big_file + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_128_read_128_big_file_2()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_128char_data(big_file_2, 28);
|
|
Packit |
a4aae4 |
read_128char_data(big_file_2, 28);
|
|
Packit |
a4aae4 |
string cmp = "cmp " + big_file_2 + " " + big_file_2 + ".plain";
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(system(cmp.c_str()) == 0);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
// Send an error
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
void test_write_24_read_24_big_file_2_error()
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
write_24char_data_with_error_option(big_file_2, 2048, true /*error*/);
|
|
Packit |
a4aae4 |
try {
|
|
Packit |
a4aae4 |
read_24char_data_with_error_option(big_file_2, 2048);
|
|
Packit |
a4aae4 |
CPPUNIT_FAIL("Should have caught an error message");
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
catch (Error &e) {
|
|
Packit |
a4aae4 |
CPPUNIT_ASSERT(!e.get_error_message().empty());
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST_SUITE (chunked_iostream_test);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_1_small_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_1_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_1_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_1_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_128_small_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_128_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_128_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_1_read_128_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_1_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_1_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_1_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_128_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_128_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_128_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_1_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_1_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_1_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_128_text_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_128_big_file);
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_128_read_128_big_file_2);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST (test_write_24_read_24_big_file_2_error);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST_SUITE_END();
|
|
Packit |
a4aae4 |
};
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CPPUNIT_TEST_SUITE_REGISTRATION (chunked_iostream_test);
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
int main(int argc, char *argv[])
|
|
Packit |
a4aae4 |
{
|
|
Packit |
a4aae4 |
GetOpt getopt(argc, argv, "dh");
|
|
Packit |
a4aae4 |
int option_char;
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
while ((option_char = getopt()) != -1)
|
|
Packit |
a4aae4 |
switch (option_char) {
|
|
Packit |
a4aae4 |
case 'd':
|
|
Packit |
a4aae4 |
debug = 1; // debug is a static global
|
|
Packit |
a4aae4 |
break;
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
case 'h': { // help - show test names
|
|
Packit |
a4aae4 |
cerr << "Usage: chunked_iostream_test has the following tests:" << endl;
|
|
Packit |
a4aae4 |
const std::vector<Test*> &tests = chunked_iostream_test::suite()->getTests();
|
|
Packit |
a4aae4 |
unsigned int prefix_len = chunked_iostream_test::suite()->getName().append("::").length();
|
|
Packit |
a4aae4 |
for (std::vector<Test*>::const_iterator i = tests.begin(), e = tests.end(); i != e; ++i) {
|
|
Packit |
a4aae4 |
cerr << (*i)->getName().replace(0, prefix_len, "") << endl;
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
break;
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
default:
|
|
Packit |
a4aae4 |
break;
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
CppUnit::TextTestRunner runner;
|
|
Packit |
a4aae4 |
runner.addTest(CppUnit::TestFactoryRegistry::getRegistry().makeTest());
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
bool wasSuccessful = true;
|
|
Packit |
a4aae4 |
string test = "";
|
|
Packit |
a4aae4 |
int i = getopt.optind;
|
|
Packit |
a4aae4 |
if (i == argc) {
|
|
Packit |
a4aae4 |
// run them all
|
|
Packit |
a4aae4 |
wasSuccessful = runner.run("");
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
else {
|
|
Packit |
a4aae4 |
for (; i < argc; ++i) {
|
|
Packit |
a4aae4 |
if (debug) cerr << "Running " << argv[i] << endl;
|
|
Packit |
a4aae4 |
test = chunked_iostream_test::suite()->getName().append("::").append(argv[i]);
|
|
Packit |
a4aae4 |
wasSuccessful = wasSuccessful && runner.run(test);
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
}
|
|
Packit |
a4aae4 |
|
|
Packit |
a4aae4 |
return wasSuccessful ? 0 : 1;
|
|
Packit |
a4aae4 |
}
|