fmwk/Config/Table.cxx

Go to the documentation of this file.

// $Id: Table.cxx,v 1.1 2007/02/09 05:38:27 fmwk Exp $
//
//
// messier@indiana.edu
#include "Config/Table.h"
#include "Config/Config.h"

cfg::Table* cfg::Table::fInstance = 0;

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

cfg::Table& cfg::Table::Instance() 
{
//======================================================================
// Return the sole instance of this class
//======================================================================
  if (fInstance == 0) fInstance = new cfg::Table;
  return (*fInstance);
}

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

cfg::Config* cfg::Table::GetConfig(const char* name, 
                                   const char* version) const 
{
//======================================================================
// Find and return the configuration that matches the requested name
// and version
//======================================================================
  std::string n(name);
  std::string v(version);
  
  // Loop over configurations looking for one that matches
  ConfigList::iterator itr   (fConfigList.begin());
  ConfigList::iterator itrEnd(fConfigList.end());
  for (; itr!=itrEnd; ++itr) {
    cfg::Config* cfg = *itr;
    if (n == cfg->GetName() && v == cfg->GetVersion()) return cfg;
  }

  // Not found
  return 0;
}

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

void cfg::Table::GetObservers(const char*          name, 
                              const char*          version,
                              cfg::Table::ObsList& obslist) const
{
//======================================================================
// Unpack the observers of configuration "name.version" to the list
// obslist
//======================================================================
  ObsTable::iterator otItr   (fObsTable.begin());
  ObsTable::iterator otItrEnd(fObsTable.end());
  for (; otItr!=otItrEnd; ++otItr) {
    cfg::Observer* obs    = otItr->first;
    NVPairList&  nvlist = otItr->second;
    
    NVPairList::iterator nvItr(nvlist.begin());
    NVPairList::iterator nvItrEnd(nvlist.end());
    for (; nvItr != nvItrEnd; ++nvItr) {
      std::string& n = nvItr->first;
      std::string& v = nvItr->second;
      
      if (n == name && v == version) obslist.push_back(obs);
      
    } // Loop on configuration name/version pairs
  } // Loop on all observers
}

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

void cfg::Table::Print(std::ostream& os) const 
{
//======================================================================
// Print all the configurations and their watchers
//======================================================================
  ConfigList::const_iterator itr(fConfigList.begin());
  ConfigList::const_iterator itrEnd(fConfigList.end());
  for (; itr!=itrEnd; ++itr) {
    cfg::Config* c = *itr;
    os << c->GetName() << "." << c->GetVersion() << "\t";

    os << "obs={ ";
    ObsList obslist;
    this->GetObservers(c->GetName(), c->GetVersion(), obslist);
    ObsList::const_iterator itr2(obslist.begin());
    ObsList::const_iterator itrEnd2(obslist.end());
    for (; itr2!=itrEnd2; ++itr2) {
      os << *itr2 << " ";
    }
    os << "}" << std::endl;
  }
}

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

void cfg::Table::AdoptConfig(cfg::Config* cfg) 
{
//======================================================================
// Place the configuration into the list
//======================================================================
  std::string n(cfg->GetName());
  std::string v(cfg->GetVersion());
  
  // Check if a configuration matching this name and version exists.
  // If yes, replace it
  ConfigList::iterator itr   (fConfigList.begin());
  ConfigList::iterator itrEnd(fConfigList.end());
  for (; itr!=itrEnd; ++itr) {
    cfg::Config* inlist = *itr;
    if (n == inlist->GetName() && v == inlist->GetVersion()) {
      // replace existing config with new
      delete inlist;
      *itr = cfg;
      return;
    }
  }
  
  // Insert the configuration into the list
  fConfigList.push_back(cfg);
}

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

void cfg::Table::SetWatch(const char*    config, 
                          const char*    version, 
                          cfg::Observer* obs) 
{
//======================================================================
// Set a watch from observer obs to configuration with name
// config.version
//======================================================================
  NVPairList& nvlist = fObsTable[obs];
  
  NVPairList::iterator itr   (nvlist.begin());
  NVPairList::iterator itrEnd(nvlist.end());
  
  // Look if there is already a watch for this configuration. If yes,
  // update the version watched
  for (; itr!=itrEnd; ++itr) {
    if (itr->first == config) {
      itr->second = version;
      return;
    }
  }
  // Reach here if no watch was set for this config
  nvlist.push_back(NVPair(config,version));
}

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

void cfg::Table::RemoveWatch(const char* config, cfg::Observer* obs)
{
//======================================================================
// Drop the watch set by observer obs to the configuration named
// "config"
//======================================================================
  // Get the list of configuration name/version pairs
  NVPairList& nvlist = fObsTable[obs];
  
  // Erase each entry which matches the config name
  NVPairList::iterator    itr(nvlist.begin());
  NVPairList::iterator itrEnd(nvlist.end());
  for (; itr!=itrEnd; ++itr) {
    if (itr->first == config) {
      nvlist.erase(itr);
      return;
    }
  }
}

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

void cfg::Table::RemoveAllWatches(cfg::Observer* obs) 
{
  // Erase the configuration list for this observer
  NVPairList& nvplist = fObsTable[obs];
  nvplist.clear();
  
  fObsTable.erase(obs);
}

---