t_byte_filer.cpp

Go to the documentation of this file.

/*****************************************************************************\
*                                                                             *
*  Name   : test_byte_filer                                                   *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 1991-$now By Author.  This program is free software; you can  *
* redistribute it and/or modify it under the terms of the GNU General Public  *
* License as published by the Free Software Foundation; either version 2 of   *
* the License or (at your option) any later version.  This is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include <basis/byte_array.h>
#include <basis/chaos.h>
#include <basis/function.h>
#include <basis/guards.h>
#include <basis/istring.h>
#include <basis/portable.h>
#include <basis/string_array.h>
#include <opsystem/application_shell.h>
#include <opsystem/byte_filer.h>
#include <loggers/console_logger.h>
#include <loggers/file_logger.h>
#include <opsystem/directory.h>
#include <opsystem/filename.h>
#include <data_struct/static_memory_gremlin.h>

#define LOG(s) CLASS_EMERGENCY_LOG(program_wide_logger(), s)

class test_byte_filer : public application_shell
{
public:
  test_byte_filer() : application_shell(class_name()) {}
  IMPLEMENT_CLASS_NAME("test_byte_filer");
  int run_simple_test();
  int run_file_scan();
  virtual int execute();
};

const istring TEST_FILE_BASE = "garbage.txt";

const istring TEST_FILE = portable::env_string("TMP") + "/" + TEST_FILE_BASE;

int test_byte_filer::run_simple_test()
{
  FUNCDEF("run_simple_test");
#ifdef DEBUG
  LOG("ahoy, beginning file test...");
#endif
  chaos randomizer;

//hmmm: move to t_filename.
  // test filename's exist operation.
  byte_filer garbage(TEST_FILE.s(), "wb");
  garbage.write("oy.\n");
  garbage.close();
  filename test1(TEST_FILE);
  if (!test1.exists())
    deadly_error(class_name(), "exists test", "file didn't exist when should!");
  filename test2("c:\this_file_shouldNt_exist_ever.txt");
  if (test2.exists())
    deadly_error(class_name(), "exists test", "file existed when shouldn't!");
  // test again to make sure it didn't create it.
  if (test2.exists())
    deadly_error(class_name(), "exists test", "file existed when shouldn't!");
  test1.unlink();

  int block_size = randomizer.inclusive(3000, 30000);
#ifdef DEBUG
  LOG(isprintf("block size=%d", block_size));
#endif
  byte *original_block = new byte[block_size];
  for (int i = 0; i < block_size; i++)
    original_block[i] = byte(randomizer.inclusive(32, 126));
  unsigned int original_checksum
      = utility::bizarre_checksum((byte *)original_block, block_size);
  if (original_checksum) {} // compiler quieting.
#ifdef DEBUG
  LOG(isprintf("random block checksum=%d", original_checksum));
#endif
  {
    byte_array to_stuff_in_file(block_size, original_block);
    delete [] original_block;
    byte_filer fred(TEST_FILE, "w+");
    fred.write(to_stuff_in_file);
  }
#ifdef DEBUG
  LOG(istring("about to compare file to checksum"));
#endif
  {
    byte *temp_array = new byte[21309];
    byte_array to_fake_stuff(21309, temp_array);
    delete [] temp_array;
    byte_filer fred(TEST_FILE, "r");
#ifdef DEBUG
    LOG(istring("about to try writing to file"));
#endif
    int should_be_failure = fred.write(to_fake_stuff);
    if (should_be_failure != 0)
      deadly_error(class_name(), "write on read only",
          istring(istring::SPRINTF, "write supposedly succeeded (len = %d)!",
              should_be_failure));

}//temp

//hmmm: uhhh, why is the below all disabled?


/*
#ifdef DEBUG
    LOG(isprintf("about to try reading from file %d bytes", fredsize));
#endif
    byte_array file_contents = fred.next();
    unsigned int check_2
      = utility::bizarre_checksum((byte *)file_contents.access(), file_contents.length());
    if (check_2 != original_checksum)
      deadly_error(class_name(), "file comparison", "next() read different contents!");
  }

#define FACTOR 1354

  {
    int numpacs = number_of_packets(block_size, FACTOR);
    file fred(TEST_FILE, file::READ_ONLY);
    fred.chunk_factor(FACTOR);
    int whole_size = 0;
    for (int i = 0; i < numpacs; i++) {
      byte_array blob_i = fred[i];
      whole_size += blob_i.length();
    }
    if (whole_size != fred.size())
      deadly_error(class_name(), "chunking comparison", "sizes are different");
  }

// test writing out a copy and comparing them... there's no == on files!

  remove(TEST_FILE);
*/

  // it seems everything worked during our tests.
  return 0;
}

int test_byte_filer::run_file_scan()
{
  FUNCDEF("run_file_scan");
  chaos randomizer;

  string_array files(__argc, (const char **)__argv);
  files.zap(0, 0);  // toss the first element since that's our app filename.

  if (!files.length()) {
    // pretend they gave us the list of files in the TMP directory.  some of
    // these might fail if they're locked up.
//    istring tmpdir = portable::env_string("TMP");
    istring tmpdir = portable::current_directory();
    directory dir(tmpdir);
    for (int i = 0; i < dir.files().length(); i++) {
      // skip text files since we use those right here.
      if ( (dir.files()[i].ends(".txt")) || (dir.files()[i].ends(".txt")) )
        continue;
      istring chewed_string = tmpdir + "/" + dir.files()[i];
      files += chewed_string;
    }
LOG(istring("added files since no cmd args: ") + files.text_form());
  }

  byte_array data_found;
  for (int i = 0; i < files.length(); i++) {
    istring curr = files[i];
    LOG(isprintf("file %d: ", i) + curr);
    byte_filer test(curr, "rb");
    if (!test.good()) {
      LOG(istring("good check: ") + curr + " cannot be opened.  is this bad?");
      continue;
    }

    // check that we get the expected position report from scooting to the
    // end of a file.
    test.seek(0, byte_filer::FROM_END);
    if (test.tell() != test.length())
      deadly_error(class_name(), "seek check",
          isprintf("seek to end, posn at %d bytes but should be at %d",
              test.tell(), test.length()));
    test.seek(0, byte_filer::FROM_START);

    size_t len = test.length();
//log(isprintf("file len is %.0f", double(len)));
    size_t posn = 0;
    while ( (posn < len) && !test.eof() ) {
      size_t readlen = randomizer.inclusive(1, 256 * KILOBYTE);
//log(isprintf("read %u bytes, posn now %d bytes", readlen, posn));
      int bytes_read = int(test.read(data_found, int(readlen)));
      if (bytes_read < 0) {
        deadly_error(class_name(), "reading", curr + " failed to be read.");
      } else {
        posn += bytes_read;
      }
    }
    if (!test.eof())
      deadly_error(class_name(), "eof check", curr + " not at eof.");
    if (posn != len)
      deadly_error(class_name(), "eof check", curr + " is at wrong position: "
          + isprintf("want %.0f, got %.0f", double(len), double(posn)));
    log(istring("successfully read ") + curr);
  }

  return 0;
}

int test_byte_filer::execute()
{
  FUNCDEF("execute");
  SET_DEFAULT_COMBO_LOGGER;
  int ret = run_simple_test();
  if (ret) return ret;  // failed.
  ret = run_file_scan();
  if (ret) return ret;  // failed here.

  guards::alert_message("byte_filer:: works for those functions tested.\n");
  return 0;
}

HOOPLE_MAIN(test_byte_filer, )

---