InputreaderTester.hpp

Go to the documentation of this file.

#ifndef InputreaderTester_HPP
#define InputreaderTester_HPP

#include "common.hpp"
#include "common/log.h"
#include "io/input/transaction_reader/TransactionReader.hpp"
#include "io/input/transaction_reader/LBufferedTransactionReader.hpp"
#include "io/input/transaction_reader/brBufferedTransactionReader.hpp"
#include "io/FileReprBase.hpp"
#include <vector>

#if DEBUG_LEVEL >= LEVEL_DBG
#include <iterator>
#endif

class InputreaderTester
{
   public:
      void usageSimpleInput();


      void doTest( int argc, char *argv[]  );
   private:
      template <class F_R> void selectReader(
         char* reader, char* file_name, unsigned int nr_of_scan,
         std::streamsize lowlevel_buffer_size);

      template <class T_R> void readDatabase(
         char* file_name, unsigned int nr_of_scan, 
         std::streamsize lowlevel_buffer_size);
};
template <class F_R> void InputreaderTester::selectReader(
   char* reader, char* file_name, unsigned int nr_of_scan, 
   std::streamsize lowlevel_buffer_size)
{
   if( strcmp(reader, "lars") == 0 )
   {
      log_info(0,"Lars' buffered transaction reader is selected for test.");
      readDatabase< LBufferedTransactionReader< TransactionReader<F_R> > >(
         file_name, nr_of_scan, lowlevel_buffer_size);
   }
   else if( strcmp(reader, "bracz") == 0 )
   {
      log_info(0,"Bracz' buffered transaction reader is selected for test.");
      readDatabase< brBufferedTransactionReader< TransactionReader<F_R> > >(
         file_name, nr_of_scan, lowlevel_buffer_size);
   }
   else
      usageSimpleInput();   
}

template <class T_R> void InputreaderTester::readDatabase(
   char* file_name, unsigned int nr_of_scan, 
   std::streamsize lowlevel_buffer_size)
{
   typename T_R::params_t par;
   par.file_name = file_name;
   par.mode = FileReprBase::READ;
   par.file_buffer_size = lowlevel_buffer_size;

   try
   {
      T_R t_r(&par);
      std::vector<item_t> transaction;
      while(nr_of_scan)
      {
         --nr_of_scan;
         t_r.rewind();
         log_info(0,"New scan started.");
         while( t_r.nextTransactionBIS(transaction) )
         {
#if DEBUG_LEVEL >= LEVEL_DBG
            std::copy( transaction.begin(), transaction.end(), 
                       std::ostream_iterator<item_t>(std::cout, " "));
            std::cout<<std::endl;
#endif
         }
      }
   }
   catch (std::ios_base::failure e)
   {
      log_err(0,"Exiting the program due to IO exception");
      exit(1);
   }
}

#endif

---