RawBlockRegistry.cxx

Go to the documentation of this file.

// $Id: RawBlockRegistry.cxx,v 1.9 2009/02/28 21:46:16 gmieg Exp $
//
// A place for the available RawBlocks to register themselves
//
// Initial    JobCModuleRegistry  by messier@huhepl.harvard.edu
// Adapted to RawBlockRegistry    by rhatcher@fnal.gov (2001-04-13)
//
#include <cstring>

#include "RawData/RawBlockRegistry.h"
#include "MessageService/MsgService.h"
CVSID("$Id: RawBlockRegistry.cxx,v 1.9 2009/02/28 21:46:16 gmieg Exp $");

RawBlockRegistry* RawBlockRegistry::fInstance = 0;

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

std::ostream& operator<<(std::ostream& os, const RawBlockRegistry& rbr) 
{
   std::list<RawBlockProxy*>::const_iterator itrRawBlockProxyTable;
   os << "Registered Raw Blocks:\n";
   for (itrRawBlockProxyTable  = rbr.fRawBlockProxyTable.begin();
        itrRawBlockProxyTable != rbr.fRawBlockProxyTable.end();
        ++itrRawBlockProxyTable) {
      os << " " << (*(*itrRawBlockProxyTable)) << endl;
  }
  return os;
}

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

RawBlockRegistry::~RawBlockRegistry()
{
   // dtor is NOT responsible for destroying elements of the list;
   // they are created statically and are thus automagically
   // destroyed when the process ends
}

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

void RawBlockRegistry::Register(RawBlockProxy *proxy)
{
  const char* blockName    = proxy->GetName();
  bool        isDCS        = proxy->IsDCS();
  int         blockMajorId = proxy->GetMajorId();
  // Add the raw block to the table
  if (this->LookUp(blockName)) {
    MSG("RawData", Msg::kWarning) 
      << "A raw block named " << blockName << " is already registered!\n"
      << "Duplicate block names are not allowed!\n";
    return;
  }
  else {
    // Do insertions in alphabetical order
    std::list<RawBlockProxy*>::iterator itrRawBlockProxyTable;
    for (itrRawBlockProxyTable  = fRawBlockProxyTable.begin();
         itrRawBlockProxyTable != fRawBlockProxyTable.end();
         ++itrRawBlockProxyTable) {
      if (strcmp(blockName,(*itrRawBlockProxyTable)->GetName())<0) {
        break;
      }
    }
    fRawBlockProxyTable.insert(itrRawBlockProxyTable,proxy);

    const char* isDCSstring = (isDCS) ? "DCS" : "DAQ";
    MSG("RawData", Msg::kDebug) 
      << "Registered block " << blockName << " "
      << isDCSstring << " "
      << blockMajorId << " proxy @ "
      << proxy << "." << endl;
  }
}

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

RawBlockProxy* RawBlockRegistry::LookUp(const char *name)
{
  // Check if its in table
  std::list<RawBlockProxy*>::iterator itrRawBlockProxyTable;
  for (itrRawBlockProxyTable  = fRawBlockProxyTable.begin();
       itrRawBlockProxyTable != fRawBlockProxyTable.end();
       ++itrRawBlockProxyTable) {
    if (strcmp(name,(*itrRawBlockProxyTable)->GetName())==0) {
      return (*itrRawBlockProxyTable);
    }
  }
  return 0;
}

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

RawBlockProxy* RawBlockRegistry::LookUp(bool isDCS, int majorId)
{
  // Check if its in table
  std::list<RawBlockProxy*>::iterator itrRawBlockProxyTable;
  for (itrRawBlockProxyTable  = fRawBlockProxyTable.begin();
       itrRawBlockProxyTable != fRawBlockProxyTable.end();
       ++itrRawBlockProxyTable) {
    if ((*itrRawBlockProxyTable)->IsDCS()      == isDCS &&
        (*itrRawBlockProxyTable)->GetMajorId() == majorId  ) {
      return (*itrRawBlockProxyTable);
    }
  }
  return 0;
}

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

RawBlockRegistry::RawBlockRegistry()
{
//#define DEBUG_RAWDATA
#ifdef DEBUG_RAWDATA
#include <MessageService/MsgStream.h>
  // Setting this debug level at run time is too late in this case...
  MsgService::Instance()->GetStream("RawData")->SetLogLevel(Msg::kVerbose);
#endif
}

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

RawBlockRegistry& RawBlockRegistry::Instance() 
{
  if (fInstance==0) {
     static RawBlockRegistry::Cleaner c; // end-of-run clean up
     c.ClassIsUsed();

     fInstance = new RawBlockRegistry;
  }
  return *fInstance;
}

---