IoInputModuleValidate.cxx

Go to the documentation of this file.

// $Id: IoInputModuleValidate.cxx,v 1.4 2006/06/28 04:30:23 rhatcher Exp $
#include "IoModules/test/IoInputModuleValidate.h"
#include "MessageService/MsgService.h"
#include "MessageService/MsgFormat.h"
#include "MinosObjectMap/MomNavigator.h"
#include "JobControl/JobCommand.h"
#include "Persistency/Per.h"

using std::endl;

CVSID("$Id: IoInputModuleValidate.cxx,v 1.4 2006/06/28 04:30:23 rhatcher Exp $");

//......................................................................

IoInputModuleValidate::IoInputModuleValidate(int nfiles, 
                                             const char* const* files) :
  fNfiles(nfiles),fFileName(files)
{
//======================================================================
// Purpose: Create the validation class using several test files
//
// nfiles - number of files to use in test
// files  - list of file names
//======================================================================
  MsgService::Instance() -> GetStream("Io") -> SetLogLevel(Msg::kVerbose);
  MsgService::Instance() -> GetStream("Per") -> SetLogLevel(Msg::kVerbose);
  fIoModule.Config(fIoModule.DefaultConfig());
  cout << "nfiles = " << fNfiles << endl;

}

//......................................................................

IoInputModuleValidate::~IoInputModuleValidate() {}

//......................................................................

bool IoInputModuleValidate::TestAdd() 
{
//======================================================================
// Purpose: Test the "Add" command to add a file to the list of input
// files
//======================================================================
  MSG("Io",Msg::kDebug) << "TestAdd -- \n";
  MSG("Io",Msg::kDebug) << " Before:" << endl;
  
  fIoModule.List();
  for (int i=0; i<fNfiles; ++i) {
    string s(fFileName[i]);
    fIoModule.AddFile(s.c_str());
  }
  MSG("Io",Msg::kDebug) << " After:" << endl;
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestRemove() 
{
  MSG("Io",Msg::kDebug) << "TestRemove every other file -- \n";
  MSG("Io",Msg::kDebug) << " Before:" << endl;
  fIoModule.List();
  for (int i=1; i<fNfiles; i += 2) {
    string s(fFileName[i]);
    fIoModule.RemoveFile(s.c_str());
  }
  MSG("Io",Msg::kDebug) << " After:" << endl;
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestNextFile() 
{
  MSG("Io",Msg::kDebug) << "Test NextFile by 3" << endl;
  fIoModule.NextFile(3);
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestPrevFile() 
{
  MSG("Io",Msg::kDebug) << "Test PrevFile by 2" << endl;
  fIoModule.PrevFile(2);
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestGoToFile() 
{
  MSG("Io",Msg::kDebug) << "Test GoToFile 2" << endl;
  fIoModule.GoToFile(2);
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestNext() 
{
  MSG("Io",Msg::kDebug) << "Test Next by 10" << endl;
  fIoModule.Next(10);
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestPrev() 
{
  MSG("Io",Msg::kDebug) << "Test Prev by 10" << endl;
  fIoModule.Prev(10);
  return true;
}


//......................................................................

bool IoInputModuleValidate::TestStreams() 
{
  MSG("Io",Msg::kDebug) << "Test Streams" << endl;
  fIoModule.Set("Streams=DaqSnarl,LightInjection");
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestGoToEOF() 
{
  MSG("Io",Msg::kDebug) << "Test GoToEOF" << endl;
  fIoModule.GoTo(Per::GetVldEnd());
  fIoModule.List();
  return true;
}

//......................................................................

bool IoInputModuleValidate::TestSetFormat() 
{
  return true;
}

bool IoInputModuleValidate::TestGet() 
{
  MSG("Io",Msg::kDebug) << "Test Get" << endl;
  int i;
  MomNavigator mom;
  MsgFormat fmt("%4d");
  JobCResult r;
  for (i=0; r.EndOfInputStream() == false; ++i) {
    fIoModule.Get();
    
    MSG("Io",Msg::kInfo) << fmt(i);
    if (i%15 == 14) MSG("Io",Msg::kInfo) << endl;
    
    r = fIoModule.Next();
  }
  MSG("Io",Msg::kInfo) << endl;
  MSG("Io",Msg::kInfo) << "Read " << i << " events from file list" << endl;
  return true;
}

//......................................................................

bool IoInputModuleValidate::RunAllTests()
{
  bool passed;
  MomNavigator* mom = new MomNavigator();
  fIoModule.SetMom(mom);
  passed  = this->TestAdd();
  passed &= this->TestRemove();
  passed &= this->TestNextFile();
  passed &= this->TestPrevFile();
  passed &= this->TestGoToFile();
  passed &= this->TestStreams();
  passed &= this->TestNext();
  passed &= this->TestGoToEOF();
  passed &= this->TestPrev();
  passed &= this->TestGet();
  mom = fIoModule.GetMom();
  if ( mom ) delete mom; mom = 0;
 
  return passed;
}

---