fwlite::Record Class Reference

#include <Record.h>

Classes
class	TypeID

Public Member Functions
const IOVSyncValue &	endSyncValue () const
template<typename HANDLE >
bool	get (HANDLE &, const char *iLabel="") const
const std::string &	name () const
	Record (const char *iName, TTree *)
const IOVSyncValue &	startSyncValue () const
void	syncTo (const edm::EventID &, const edm::Timestamp &)
std::vector< std::pair < std::string, std::string > >	typeAndLabelOfAvailableData () const
virtual	~Record ()

Private Member Functions
cms::Exception *	get (const TypeID &, const char *iLabel, const void *&) const
const Record &	operator= (const Record &)
	Record (const Record &)
void	resetCaches ()

Private Attributes
std::map< std::pair< TypeID, std::string >, std::pair < TBranch *, void * > >	m_branches
IOVSyncValue	m_end
long	m_entry
std::string	m_name
IOVSyncValue	m_start
std::map< IOVSyncValue, unsigned int >	m_startIOVtoEntry
TTree *	m_tree

Detailed Description

Definition at line 47 of file Record.h.

Constructor & Destructor Documentation

Record::Record	(	const char *	iName,
		TTree *	iTree
	)

Definition at line 36 of file Record.cc.

References printConversionInfo::aux, edm::ESRecordAuxiliary::eventID(), getHLTprescales::index, edm::Timestamp::invalidTimestamp(), m_startIOVtoEntry, m_tree, edm::EventID::run(), groupFilesInBlocks::temp, and edm::ESRecordAuxiliary::timestamp().

                                             :
m_name(iName), m_tree(iTree), m_entry(-1),
m_start(IOVSyncValue::invalidIOVSyncValue()),
m_end(IOVSyncValue::invalidIOVSyncValue())
{
   //read the start iovs and get them in order
   edm::ESRecordAuxiliary aux;
   edm::ESRecordAuxiliary* pAux=&aux;
   TBranch* auxBranch = m_tree->FindBranch("ESRecordAuxiliary");
   auxBranch->SetAddress(&pAux);
   IOVSyncValue temp;
   for(unsigned int index=0; index < m_tree->GetEntries();++index){
      auxBranch->GetEntry(index);
      if(aux.timestamp() != edm::Timestamp::invalidTimestamp()){
         if(aux.eventID().run() != 0) {
            temp = IOVSyncValue(aux.eventID(),aux.timestamp());
         } else {
            temp = IOVSyncValue(aux.timestamp());
         }
      } else {
         temp=IOVSyncValue(aux.eventID());
         assert(aux.eventID().run()!=0);
      }
      
      m_startIOVtoEntry[temp]=index;
   }
}

Record::~Record ( )

virtual

Definition at line 69 of file Record.cc.

References resetCaches().

{
  resetCaches();
}

fwlite::Record::Record ( const Record &  )

private

Member Function Documentation

const IOVSyncValue & Record::endSyncValue

(

)

const

Definition at line 170 of file Record.cc.

References m_end.

Referenced by FWLiteESSource::setIntervalFor().

{
   return m_end;
}

template<typename HANDLE >

bool Record::get	(	HANDLE &	iHandle,
		const char *	iLabel = ""
	)		const

Definition at line 94 of file Record.h.

References alignCSCRings::e, and relativeConstraints::value.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), and main().

   {
      const void* value = 0;
      cms::Exception* e = get(TypeID(iHandle.typeInfo()),iLabel,value);
      if(0==e){
         iHandle = HANDLE(value);
      } else {
         iHandle = HANDLE(e);
      }
      return 0==e;
   }

cms::Exception * Record::get ( const TypeID &  iType, const char *  iLabel, const void *&  iData  ) const

private

Definition at line 177 of file Record.cc.

References dt, edm::hlt::Exception, fwlite::format_type_to_mangled(), m_branches, m_entry, m_tree, name(), lumiQTWidget::t, and edm::TypeIDBase::typeInfo().

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), and betterConfigParser.BetterConfigParser::getResultingSection().

{
   cms::Exception* returnValue = 0;
   
   std::pair<TBranch*,void*>& branch = m_branches[std::make_pair(iType,iLabel)];
   if(0==branch.first){
      branch.second=0;
      using namespace ROOT::Reflex;
      Type t = Type::ByTypeInfo(iType.typeInfo());
      if(t == Type()){
         returnValue = new cms::Exception("UnknownType");
         (*returnValue)<<"The type "
         <<iType.typeInfo().name()<<" was requested from Record "<<name()
         <<" but the type has no known dictionary";
         return returnValue;
      }
      //build branch name
      std::string branchName = fwlite::format_type_to_mangled(t.Name(ROOT::Reflex::SCOPED|ROOT::Reflex::FINAL))+"__"+iLabel;
      branch.first = m_tree->FindBranch(branchName.c_str());
      
      if(0==branch.first){
         returnValue = new cms::Exception("NoDataAvailable");
         (*returnValue)<<"The data of type "
                       <<t.Name(ROOT::Reflex::SCOPED|ROOT::Reflex::FINAL)
                       <<" with label '"<<iLabel<<"' for Record "<<name()<<" is not in this file.";
         return returnValue;
      }
      //We need GetExpectedType to work in order to delete objects
      TClass* cls;
      EDataType dt;
      if(0!=branch.first->GetExpectedType(cls,dt)) {
        returnValue = new cms::Exception("UnknownType");
        (*returnValue)<<"The type "
        <<iType.typeInfo().name()<<" was requested from Record "<<name()
        <<" but the TBranch does not know what Type it holds.";
        return returnValue;
      }

      branch.first->SetAutoDelete(kFALSE);
   }
   if(m_entry<0) {
      returnValue = new cms::Exception("NoValidIOV");
      (*returnValue) <<" The Record "
         <<name()<<" was asked to get data for a 'time' for which it has no data";
      return returnValue;
   }
   if(0!=branch.second) {
     iData=branch.second;
     return nullptr;
   }

   assert(0==branch.second);
   branch.first->SetAddress(&branch.second);
   iData = branch.second;
   branch.first->GetEntry(m_entry);
   return returnValue;
}

const std::string & Record::name

(

)

const

Definition at line 160 of file Record.cc.

References m_name.

Referenced by get(), typeAndLabelOfAvailableData(), and Vispa.Views.PropertyView.Property::valueChanged().

{
   return m_name;
}

const Record& fwlite::Record::operator= ( const Record &  )

private

void Record::resetCaches ( )

private

Definition at line 139 of file Record.cc.

References b, dt, m_branches, and or.

Referenced by syncTo(), and ~Record().

{
  for(auto&b : m_branches){
    TClass* cls=0;
    EDataType dt;
    if(0==b.second.first or 0==b.second.second) continue;
    if(0==b.second.first->GetExpectedType(cls,dt)) {
      cls->Destructor(b.second.second);
      b.second.second=0;
    }
  }
  for(auto&b : m_branches){
    if(0==b.second.first) continue;
    assert(b.second.second==0);
  }
}

const IOVSyncValue & Record::startSyncValue

(

)

const

Definition at line 166 of file Record.cc.

References m_start.

Referenced by main(), and FWLiteESSource::setIntervalFor().

                             {
   return m_start;
}

void Record::syncTo	(	const edm::EventID &	iEvent,
		const edm::Timestamp &	iTime
	)

Definition at line 90 of file Record.cc.

References fwlite::IOVSyncValue::invalidIOVSyncValue(), edm::Timestamp::invalidTimestamp(), m_end, m_entry, m_start, m_startIOVtoEntry, resetCaches(), edm::EventID::run(), and groupFilesInBlocks::temp.

Referenced by fwlite::EventSetup::syncTo().

{
   
   IOVSyncValue temp;
   if(iTime != edm::Timestamp::invalidTimestamp()){
      if(iEvent.run() != 0) {
         temp = IOVSyncValue(iEvent,iTime);
      } else {
         temp = IOVSyncValue(iTime);
      }
   } else {
      temp=IOVSyncValue(iEvent);
      assert(iEvent.run()!=0);
   }

   //already synched
   if( (m_start != IOVSyncValue::invalidIOVSyncValue()) && 
       (m_start <=temp ) && 
       ( (m_end == IOVSyncValue::invalidIOVSyncValue()) ||
         (temp <m_end))) {
      return;
   }
   std::pair<StartIOVtoEntryMap::iterator, StartIOVtoEntryMap::iterator> range =
      m_startIOVtoEntry.equal_range(temp);
   if(range.first!=range.second){
      //happens to be the start of the IOV
      m_start = range.first->first;
      m_entry = range.first->second;
   } else {
      if(range.first!=m_startIOVtoEntry.begin()){
         //we have overshot
         --range.first;
         m_start = range.first->first;
         m_entry = range.first->second;
      } else {
         //off the beginning
         m_start=IOVSyncValue::invalidIOVSyncValue();
         m_entry = -1;
      }
   }
   if(range.second==m_startIOVtoEntry.end()){
      m_end = IOVSyncValue::invalidIOVSyncValue();
   } else {
      m_end = range.second->first;
   }
   resetCaches();
}

std::vector< std::pair< std::string, std::string > > Record::typeAndLabelOfAvailableData

(

)

const

Definition at line 238 of file Record.cc.

References diffTwoXMLs::label, m_tree, name(), GetRecoTauVFromDQM_MC_cff::next, getGTfromDQMFile::obj, and fwlite::unformat_mangled_to_type().

Referenced by FWLiteESSource::registerProxies().

{
   std::vector<std::pair<std::string,std::string> > returnValue;
   
   TObjArray* branches = m_tree->GetListOfBranches();
   TIter next( branches );
   while (TObject* obj = next()) {
      TBranch* branch = static_cast<TBranch*> (obj);
      const char* name = branch->GetName();
      if (0!=strcmp(name, "ESRecordAuxiliary") ) {
         //The type and label are separated by a double underscore so we need to find that
         size_t len = strlen(name);
         const char* cIndex = name+len;
         std::string label;
         while (name != --cIndex) {
            if(*cIndex == '_') {
               if( *(cIndex-1)=='_') {
                  label = std::string(cIndex+1);
                  break;
               }
            }
         }
         std::string type(name, cIndex-name-1);
         type = fwlite::unformat_mangled_to_type(type);
         returnValue.push_back(std::make_pair(type,label));
      }
   }
   return returnValue;
}

Member Data Documentation

std::map<std::pair<TypeID,std::string>, std::pair<TBranch*,void*> > fwlite::Record::m_branches

mutableprivate

Definition at line 89 of file Record.h.

Referenced by get(), and resetCaches().

IOVSyncValue fwlite::Record::m_end

private

Definition at line 87 of file Record.h.

Referenced by endSyncValue(), and syncTo().

long fwlite::Record::m_entry

private

Definition at line 85 of file Record.h.

Referenced by get(), and syncTo().

std::string fwlite::Record::m_name

private

Definition at line 82 of file Record.h.

Referenced by name().

IOVSyncValue fwlite::Record::m_start

private

Definition at line 86 of file Record.h.

Referenced by startSyncValue(), and syncTo().

std::map<IOVSyncValue,unsigned int> fwlite::Record::m_startIOVtoEntry

private

Definition at line 84 of file Record.h.

Referenced by Record(), and syncTo().

TTree* fwlite::Record::m_tree

private

Definition at line 83 of file Record.h.

Referenced by get(), Record(), and typeAndLabelOfAvailableData().