ValidateRawChecksums.cxx

Go to the documentation of this file.

// $Id: ValidateRawChecksums.cxx,v 1.3 2004/09/02 21:03:46 rhatcher Exp $
#include "DataUtil/ValidateRawChecksums.h"

#include "RawData/RawRecord.h"
#include "RawData/RawDataBlock.h"
#include "JobControl/JobCModuleRegistry.h"
#include "MinosObjectMap/MomNavigator.h"
#include "MessageService/MsgService.h"
//#include "Util/UtilString.h"

CVSID("$Id: ValidateRawChecksums.cxx,v 1.3 2004/09/02 21:03:46 rhatcher Exp $");
JOBMODULE(ValidateRawChecksums, 
          "ValidateRawChecksums", "Filter for bad raw block xsums.");

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

ValidateRawChecksums::ValidateRawChecksums()
  : fDumpLevel(1)
  , fMaxDumps(-1)
  , fRawBlockList("")
{}

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

ValidateRawChecksums::~ValidateRawChecksums() {}

//......................................................................
  
JobCResult ValidateRawChecksums::Ana(const MomNavigator* mom)
{
   JobCResult result = JobCResult::kPassed;

   // Get any and all raw records attached to the data record pointed 
   // to by "mom".  The dynamic cast from TObject is ugly but necessary
   TObject   *tobj   = 0;
   TIter reciter = const_cast<MomNavigator*>(mom)->FragmentIter();
   while ( (tobj = reciter() ) ) {
      RawRecord *rawrec = dynamic_cast<RawRecord *>(tobj);
      JobCResult one_res = FilterRawRecord(rawrec);
      if (one_res.Failed()) result.SetFailed();
   }

   return result;
}

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

const Registry& ValidateRawChecksums::DefaultConfig() const 
{
//======================================================================
// The default configuration for this module
//======================================================================
  static Registry r;
  
  std::string name = this->GetName();
  name += ".config.default";
  r.SetName(name.c_str());
  
  r.UnLockValues();
  r.Set("DumpLevel",        1);
  r.Set("MaxDumps",        -1);   // no limit
  r.Set("RawBlockList",     "");
  r.LockValues();

  return r;
}

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

void ValidateRawChecksums::Config(const Registry& r) 
{
//======================================================================
// Configure the module using the registry r
//======================================================================
  int  tmpi;
  const char* tmpcs = 0;

  if (r.Get("DumpLevel",tmpi))        fDumpLevel    = tmpi;
  if (r.Get("MaxDumps", tmpi))        fMaxDumps     = tmpi;
  if (r.Get("RawBlockList",tmpcs))    fRawBlockList = tmpcs;

}

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

JobCResult ValidateRawChecksums::FilterRawRecord(const RawRecord* rawrec)
{
//======================================================================
// For this raw record object check if all th
//======================================================================
   JobCResult result = JobCResult::kPassed;

   bool checklist = (fRawBlockList != "");

   TIter itr = rawrec->GetRawBlockIter();
   RawDataBlock* rdb = 0;
   // the dynamic cast from TObject is ugly but necessary
   // Careful! the itr() advances the iterator as a side effect!
   while (( rdb = dynamic_cast<RawDataBlock*>(itr()))) {
     bool testit = true;
     if (checklist) {
       std::string blkname = rdb->GetName();
       if (fRawBlockList.find(blkname) == string::npos) testit = false;
     }
     if (testit) {
       bool mismatch = rdb->TestChecksum();
       if (mismatch) {
         result = JobCResult::kFailed; // set final result for record
         if ( fDumpLevel > 0 && fMaxDumps != 0 ) {
           MSG("Validate",Msg::kInfo)
             << "RawRecord contained raw block \""
             << rdb->GetName() 
             << "\" which failed checksum test." << endl;
           --fMaxDumps;
           switch (fDumpLevel) {
           case 3:  rdb->FormatToOStream(cout,"x"); break; 
           case 2:  rdb->FormatToOStream(cout,"");  break; 
           default:
             // no additional info printed
             break;
           }
         }
       }
     }
   }

  return result;
}

---