TDbiEpochRollback.cxx

Go to the documentation of this file.

///////////////////////////////////////////////////////////////////////
// $Id: TDbiEpochRollback.cxx,v 1.1 2011/01/18 05:49:19 finch Exp $
//
// TDbiEpochRollback

#include <cstring>
#include <sstream>

#include "TString.h"

#include "TDbi.hxx"
#include "TDbiEpochRollback.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>
using std::endl;
#include "TDbiRegistry.hxx"
#include "UtilString.hxx"
#include "TVldTimeStamp.hxx"

ClassImp(TDbiEpochRollback)

//   Definition of static data members
//   *********************************


// Definition of member functions (alphabetical order)
// ***************************************************


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

TDbiEpochRollback::TDbiEpochRollback()
{
//
//
//  Purpose:  Default constructor
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create TDbiEpochRollback.


//  Program Notes:-
//  =============

//  None.


    SK_DBI_Trace( "Creating TDbiEpochRollback" << "  ");
}
//.....................................................................

TDbiEpochRollback::~TDbiEpochRollback() {
//
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Destroy TDbiEpochRollback.



  SK_DBI_Trace( "Destroying TDbiEpochRollback" << "  ");

}
//.....................................................................

const std::string& TDbiEpochRollback::GetEpochCondition(const std::string& tableName) const {
//
//
//  Purpose:  Return epoch rollback condition  associated with named table.
//            - returns an empty string if there is no associated condition
//
//  Contact:   N. West

//  Program Notes:-
//  =============

//  Search in reverse order so that specific entries are processed
//  before generic (i.e. ones that end in wildcard *).

  static std::string condition;

  condition = "";

  name_map_t::const_reverse_iterator itr    = fTableToEpoch.rbegin();
  name_map_t::const_reverse_iterator itrEnd = fTableToEpoch.rend();

  for (; itr != itrEnd; ++itr) {
    if ( ! UtilString::cmp_wildcard(tableName,itr->first) ) {
      ostringstream condition_stream;
      condition_stream << "EPOCH <= ";
      condition_stream << itr->second;
      condition = condition_stream.str();
      return condition;
    }
  }
  return condition;
}

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

void TDbiEpochRollback::Set(TDbiRegistry& reg) {
//
//
//  Purpose:  Extract epoch Rollback from TDbiRegistry.
//
//  Arguments:
//    reg          in    TDbiRegistry containing "EpochRollback:"
//                 out   Updated TDbiRegistry with this key removed.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Extract epoch Rollback from TDbiRegistry.

  TDbiRegistry::TDbiRegistryKey keyItr(&reg);

  Bool_t  hasChanged = kFALSE;

  const char* key = keyItr();
  while ( key ) {

    const char* nextKey =  keyItr();

    // Process EpochRollback keys

    if ( ! strncmp("EpochRollback:",key,14) ) {
      std::string tableName = key+14;
      Int_t epoch;
      bool  ok = reg.Get(key,epoch);
      if ( ok ) {
        fTableToEpoch[tableName] = epoch;
        hasChanged = kTRUE;

      }
      else SK_DBI_Warn(  "Illegal EpochRollback registry item: " << key
        << " = " <<  reg.GetValueAsString(key) << "  ");
      reg.RemoveKey(key);
    }
    key = nextKey;
  }

  if ( hasChanged ) this->Show();
}
//.....................................................................

void TDbiEpochRollback::Show() const {

}