#include <SiteLocalConfigService.h>

Inheritance diagram for edm::service::SiteLocalConfigService:

Public Member Functions
std::string const	dataCatalog (void) const override

unsigned int	debugLevel () const override

bool	enablePrefetching () const override

std::string const	fallbackDataCatalog (void) const override

std::string const	lookupCalibConnect (std::string const &input) const override

std::string const	rfioType (void) const override

	SiteLocalConfigService (ParameterSet const &pset)

std::string const &	siteName () const override

std::string const *	sourceCacheHint () const override

double const *	sourceCacheMinFree () const override

std::string const *	sourceCacheTempDir () const override

std::string const *	sourceCloneCacheHint () const override

std::vector< std::string > const *	sourceNativeProtocols () const override

std::string const *	sourceReadHint () const override

unsigned int const *	sourceTimeout () const override

unsigned int const *	sourceTTreeCacheSize () const override

struct addrinfo const *	statisticsDestination () const override

std::set< std::string > const *	statisticsInfo () const override

	~SiteLocalConfigService ()

Public Member Functions inherited from edm::SiteLocalConfig
	SiteLocalConfig ()

virtual	~SiteLocalConfig ()

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Private Member Functions
void	computeStatisticsDestination ()

std::string const	frontierConnect (std::string const &servlet) const

void	parse (std::string const &url)

Private Attributes
std::string	m_cacheHint

std::string const *	m_cacheHintPtr

double	m_cacheMinFree

double const *	m_cacheMinFreePtr

std::string	m_cacheTempDir

std::string const *	m_cacheTempDirPtr

std::string	m_cloneCacheHint

std::string const *	m_cloneCacheHintPtr

bool	m_connected

std::string	m_dataCatalog

unsigned int	m_debugLevel

bool	m_enablePrefetching

bool const *	m_enablePrefetchingPtr

std::string	m_fallbackDataCatalog

std::string	m_frontierConnect

std::vector< std::string >	m_nativeProtocols

std::vector< std::string > const *	m_nativeProtocolsPtr

std::string	m_readHint

std::string const *	m_readHintPtr

std::string	m_rfioType

std::string	m_siteName

edm::propagate_const< struct addrinfo * >	m_statisticsAddrInfo

std::string	m_statisticsDestination

std::set< std::string >	m_statisticsInfo

bool	m_statisticsInfoAvail

unsigned int	m_timeout

unsigned int const *	m_timeoutPtr

unsigned int	m_ttreeCacheSize

unsigned int const *	m_ttreeCacheSizePtr

std::string	m_url

Static Private Attributes
static const std::string	m_statisticsDefaultPort = "3334"

Detailed Description

Definition at line 24 of file SiteLocalConfigService.h.

Constructor & Destructor Documentation

edm::service::SiteLocalConfigService::SiteLocalConfigService ( ParameterSet const & pset )

explicit

Definition at line 79 of file SiteLocalConfigService.cc.

References computeStatisticsDestination(), mps_splice::entry, edm::ParameterSet::exists(), edm::ParameterSet::getUntrackedParameter(), m_cacheHint, m_cacheHintPtr, m_cacheMinFree, m_cacheMinFreePtr, m_cacheTempDir, m_cacheTempDirPtr, m_cloneCacheHint, m_cloneCacheHintPtr, m_debugLevel, m_enablePrefetching, m_enablePrefetchingPtr, m_nativeProtocols, m_nativeProtocolsPtr, m_readHint, m_readHintPtr, m_statisticsDestination, m_statisticsInfo, m_statisticsInfoAvail, m_timeout, m_timeoutPtr, m_ttreeCacheSize, m_ttreeCacheSizePtr, m_url, eostools::move(), parse(), AlCaHLTBitMon_QueryRunRegistry::string, and tmp.

                                                                            :
           m_url("/SITECONF/local/JobConfig/site-local-config.xml"),
           m_dataCatalog(),
           m_fallbackDataCatalog(),
           m_frontierConnect(),
           m_rfioType("castor"),
           m_connected(false),
           m_cacheTempDir(),
           m_cacheTempDirPtr(nullptr),
           m_cacheMinFree(),
           m_cacheMinFreePtr(nullptr),
           m_cacheHint(),
           m_cacheHintPtr(nullptr),
           m_cloneCacheHint(),
           m_cloneCacheHintPtr(nullptr),
           m_readHint(),
           m_readHintPtr(nullptr),
           m_ttreeCacheSize(0U),
           m_ttreeCacheSizePtr(nullptr),
           m_timeout(0U),
           m_timeoutPtr(nullptr),
           m_debugLevel(0U),
           m_enablePrefetching(false),
           m_enablePrefetchingPtr(nullptr),
           m_nativeProtocols(),
           m_nativeProtocolsPtr(nullptr),
           m_statisticsDestination(),
           m_statisticsAddrInfo(nullptr),
           m_statisticsInfoAvail(false),
           m_siteName()
     {
         char* tmp = getenv("CMS_PATH");
 
         if (tmp) {
           m_url = tmp + m_url;
         }
 
         this->parse(m_url);
 
         //apply overrides
         overrideFromPSet("overrideSourceCacheTempDir", pset, m_cacheTempDir, m_cacheTempDirPtr);
         overrideFromPSet("overrideSourceCacheMinFree", pset, m_cacheMinFree, m_cacheMinFreePtr);
         overrideFromPSet("overrideSourceCacheHintDir", pset, m_cacheHint, m_cacheHintPtr);
         overrideFromPSet("overrideSourceCloneCacheHintDir", pset, m_cloneCacheHint, m_cloneCacheHintPtr);
         overrideFromPSet("overrideSourceReadHint", pset, m_readHint, m_readHintPtr);
         overrideFromPSet("overrideSourceNativeProtocols", pset, m_nativeProtocols, m_nativeProtocolsPtr);
         overrideFromPSet("overrideSourceTTreeCacheSize", pset, m_ttreeCacheSize, m_ttreeCacheSizePtr);
         overrideFromPSet("overrideSourceTimeout", pset, m_timeout, m_timeoutPtr);
         overrideFromPSet("overridePrefetching", pset, m_enablePrefetching, m_enablePrefetchingPtr);
         const std::string * tmpStringPtr = nullptr;
         overrideFromPSet("overrideStatisticsDestination", pset, m_statisticsDestination, tmpStringPtr);
         this->computeStatisticsDestination();
         std::vector<std::string> tmpStatisticsInfo; std::vector<std::string> const *tmpStatisticsInfoPtr = nullptr;
         overrideFromPSet("overrideStatisticsInfo", pset, tmpStatisticsInfo, tmpStatisticsInfoPtr);
         if (tmpStatisticsInfoPtr) {
           m_statisticsInfoAvail = true;
           m_statisticsInfo.clear();
           for (auto &entry : tmpStatisticsInfo) {m_statisticsInfo.insert(std::move(entry));}
         }
 
        if(pset.exists("debugLevel")) {
             m_debugLevel = pset.getUntrackedParameter<unsigned int>("debugLevel");
        }
 
     }

edm::service::SiteLocalConfigService::~SiteLocalConfigService ( )

Definition at line 145 of file SiteLocalConfigService.cc.

References m_statisticsAddrInfo, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                     {
       if (m_statisticsAddrInfo) {
         freeaddrinfo(m_statisticsAddrInfo);
         m_statisticsAddrInfo = nullptr;
       }
     }

Member Function Documentation

void edm::service::SiteLocalConfigService::computeStatisticsDestination ( )

private

Definition at line 528 of file SiteLocalConfigService.cc.

References MillePedeFileConverter_cfg::e, query::host, m_statisticsAddrInfo, m_statisticsDefaultPort, m_statisticsDestination, query::port, split, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by SiteLocalConfigService().

                                                          {
       std::vector<std::string> inputStrings;
       boost::split(inputStrings, m_statisticsDestination, boost::is_any_of(":"));
       const std::string &host=inputStrings[0];
       const std::string &port = (inputStrings.size() > 1) ? inputStrings[1] : m_statisticsDefaultPort;
       struct addrinfo *res;
       struct addrinfo hints;
       memset(&hints, '\0', sizeof(hints));
       hints.ai_socktype = SOCK_DGRAM;
       hints.ai_flags = AI_ADDRCONFIG;
       hints.ai_family = AF_UNSPEC;
       int e = getaddrinfo(host.c_str(), port.c_str(), &hints, &res);
       if (e != 0) {
         // Silent failure - there's no way to report non-fatal failures from here.
         return;
       }
       m_statisticsAddrInfo = res;
     }

std::string const edm::service::SiteLocalConfigService::dataCatalog ( void ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 153 of file SiteLocalConfigService.cc.

References Exception, m_connected, m_dataCatalog, m_url, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                   {
         if (!m_connected) {
             //throw cms::Exception("Incomplete configuration")
             //    << "Valid site-local-config not found at " << m_url;
             // Return PoolFileCatalog.xml for now
             return "file:PoolFileCatalog.xml";
         }
 
         if (m_dataCatalog == "") {
           throw cms::Exception("Incomplete configuration")
             << "Did not find catalog in event-data section in " << m_url;
         }
 
         return m_dataCatalog;
     }

unsigned int edm::service::SiteLocalConfigService::debugLevel ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 298 of file SiteLocalConfigService.cc.

References m_debugLevel.

                                              {
        return m_debugLevel;
     }

bool edm::service::SiteLocalConfigService::enablePrefetching ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 293 of file SiteLocalConfigService.cc.

References m_enablePrefetchingPtr.

                                                     {
        return m_enablePrefetchingPtr ? *m_enablePrefetchingPtr : false;
     }

std::string const edm::service::SiteLocalConfigService::fallbackDataCatalog ( void ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 170 of file SiteLocalConfigService.cc.

References m_connected, m_fallbackDataCatalog, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                           {
         if (!m_connected) {
             //throw cms::Exception("Incomplete configuration")
             //    << "Valid site-local-config not found at " << m_url;
             // Return PoolFileCatalog.xml for now
             return "file:PoolFileCatalog.xml";
         }
 
         // Note: Unlike the dataCatalog, the fallbackDataCatalog may be empty!
         return  m_fallbackDataCatalog;
     }

void edm::service::SiteLocalConfigService::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 548 of file SiteLocalConfigService.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addOptionalUntracked(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                     {
       ParameterSetDescription desc;
       desc.setComment("Service to translate logical file names to physical file names.");
 
       desc.addOptionalUntracked<std::string>("overrideSourceCacheTempDir");
       desc.addOptionalUntracked<double>("overrideSourceCacheMinFree");
       desc.addOptionalUntracked<std::string>("overrideSourceCacheHintDir");
       desc.addOptionalUntracked<std::string>("overrideSourceCloneCacheHintDir")
         ->setComment("Provide an alternate cache hint for fast cloning.");
       desc.addOptionalUntracked<std::string>("overrideSourceReadHint");
       desc.addOptionalUntracked<std::vector<std::string> >("overrideSourceNativeProtocols");
       desc.addOptionalUntracked<unsigned int>("overrideSourceTTreeCacheSize");
       desc.addOptionalUntracked<unsigned int>("overrideSourceTimeout");
       desc.addOptionalUntracked<unsigned int>("debugLevel");
       desc.addOptionalUntracked<bool>("overridePrefetching")
         ->setComment("Request ROOT to asynchronously prefetch I/O during computation.");
       desc.addOptionalUntracked<std::string>("overrideStatisticsDestination")
         ->setComment("Provide an alternate network destination for I/O statistics (must be in the form of host:port).");
       desc.addOptionalUntracked<std::vector<std::string> >("overrideStatisticsInfo")
         ->setComment("Provide an alternate listing of statistics to send (comma separated list; current options are 'dn' or 'nodn').  If left blank, all information is snet (including DNs).");
 
       descriptions.add("SiteLocalConfigService", desc);
     }

std::string const edm::service::SiteLocalConfigService::frontierConnect ( std::string const & servlet ) const

private

Definition at line 183 of file SiteLocalConfigService.cc.

References Exception, m_connected, m_frontierConnect, m_url, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by lookupCalibConnect(), and parse().

                                                                           {
         if (!m_connected) {
           throw cms::Exception("Incomplete configuration")
             << "Valid site-local-config not found at " << m_url;
         }
 
         if (m_frontierConnect == "") {
           throw cms::Exception("Incomplete configuration")
             << "Did not find frontier-connect in calib-data section in " << m_url;
         }
 
         if (servlet == "") {
           return m_frontierConnect;
         }
 
         // Replace the last component of every "serverurl=" piece (up to the
         //   next close-paren) with the servlet
         std::string::size_type nextparen = 0;
         std::string::size_type serverurl, lastslash;
         std::string complexstr = "";
         while ((serverurl = m_frontierConnect.find("(serverurl=", nextparen)) != std::string::npos) {
           complexstr.append(m_frontierConnect, nextparen, serverurl - nextparen);
           nextparen = m_frontierConnect.find(')', serverurl);
           lastslash = m_frontierConnect.rfind('/', nextparen);
           complexstr.append(m_frontierConnect, serverurl, lastslash - serverurl + 1);
           complexstr.append(servlet);
         }
         complexstr.append(m_frontierConnect, nextparen, m_frontierConnect.length()-nextparen);
 
         return complexstr;
     }

std::string const edm::service::SiteLocalConfigService::lookupCalibConnect ( std::string const & input ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 216 of file SiteLocalConfigService.cc.

References frontierConnect(), input, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                            {
         static std::string const proto = "frontier://";
 
         if (input.substr(0,proto.length()) == proto) {
           // Replace the part after the frontier:// and before either an open-
           //  parentheses (which indicates user-supplied options) or the last
           //  slash (which indicates start of the schema) with the complex
           //  parenthesized string returned from frontierConnect() (which
           //  contains all the information needed to connect to frontier),
           //  if that part is a simple servlet name (non-empty and not
           //  containing special characters)
           // Example connect strings where servlet is replaced:
           //  frontier://cms_conditions_data/CMS_COND_ECAL
           //  frontier://FrontierInt/CMS_COND_ECAL
           //  frontier://FrontierInt(retrieve-ziplevel=0)/CMS_COND_ECAL
           // Example connect strings left untouched:
           //  frontier://cmsfrontier.cern.ch:8000/FrontierInt/CMS_COND_ECAL
           //  frontier://(serverurl=cmsfrontier.cern.ch:8000/FrontierInt)/CMS_COND_ECAL
           std::string::size_type startservlet = proto.length();
           // if user supplied extra parenthesized options, stop servlet there
           std::string::size_type endservlet = input.find("(", startservlet);
           if (endservlet == std::string::npos) {
               endservlet = input.rfind('/', input.length());
           }
           std::string servlet = input.substr(startservlet, endservlet - startservlet);
           if ((servlet != "") && (servlet.find_first_of(":/)[]") == std::string::npos)) {
               if (servlet == "cms_conditions_data") {
                 // use the default servlet from site-local-config.xml
                 servlet = "";
               }
               return proto + frontierConnect(servlet) + input.substr(endservlet);
           }
         }
         return input;
     }

void edm::service::SiteLocalConfigService::parse ( std::string const & url )

private

Definition at line 323 of file SiteLocalConfigService.cc.

References getEcalConditions_orcoffint2r_cff::catalog, MillePedeFileConverter_cfg::e, frontierConnect(), mps_fire::i, m_cacheHint, m_cacheHintPtr, m_cacheMinFree, m_cacheMinFreePtr, m_cacheTempDir, m_cacheTempDirPtr, m_cloneCacheHint, m_cloneCacheHintPtr, m_connected, m_dataCatalog, m_enablePrefetching, m_enablePrefetchingPtr, m_fallbackDataCatalog, m_frontierConnect, m_nativeProtocols, m_nativeProtocolsPtr, m_readHint, m_readHintPtr, m_rfioType, m_siteName, m_statisticsDestination, m_statisticsInfo, m_statisticsInfoAvail, m_timeout, m_timeoutPtr, m_ttreeCacheSize, m_ttreeCacheSizePtr, createfilelist::parser, split, AlCaHLTBitMon_QueryRunRegistry::string, cms::xerces::toBool(), cms::xerces::toDouble(), toolbox::toString(), cms::xerces::toUInt(), cms::xerces::uStr(), cms::concurrency::xercesInitialize(), and cms::concurrency::xercesTerminate().

Referenced by SiteLocalConfigService().

                                                       {
       cms::concurrency::xercesInitialize();
       {
     auto parser = std::make_unique<XercesDOMParser>();
     try {
       parser->setValidationScheme(XercesDOMParser::Val_Auto);
       parser->setDoNamespaces(false);
 
       parser->parse(url.c_str());
       DOMDocument* doc = parser->getDocument();
       if (!doc) {
         return;
       }
 
       // The Site Config has the following format
       // <site-local-config>
       // <site name="FNAL">
       //   <event-data>
       //     <catalog url="trivialcatalog_file:/x/y/z.xml"/>
       //     <rfiotype value="castor"/>
       //   </event-data>
       //   <calib-data>
       //     <catalog url="trivialcatalog_file:/x/y/z.xml"/>
       //     <frontier-connect>
       //       ... frontier-interpreted server/proxy xml ...
       //     </frontier-connect>
       //   </calib-data>
       //   <source-config>
       //     <cache-temp-dir name="/a/b/c"/>
             //     <cache-hint value="..."/>
             //     <read-hint value="..."/>
             //     <ttree-cache-size value="0"/>
             //     <native-protocols>
             //        <protocol  prefix="dcache"/>
             //        <protocol prefix="file"/>
             //     </native-protocols>
             //   </source-config>
       // </site>
       // </site-local-config>
       
       // FIXME: should probably use the parser for validating the XML.
 
       DOMNodeList *sites = doc->getElementsByTagName(uStr("site").ptr());
       XMLSize_t numSites = sites->getLength();
       for (XMLSize_t i = 0; i < numSites; ++i) {
         DOMElement *site = static_cast<DOMElement *>(sites->item(i));
         
         // Parse the site name
         m_siteName = toString(site->getAttribute(uStr("name").ptr()));
         
         // Parsing of the event data section
         {
           DOMNodeList *eventDataList = site->getElementsByTagName(uStr("event-data").ptr());
           if (eventDataList->getLength() > 0) {
         DOMElement *eventData = static_cast<DOMElement *>(eventDataList->item(0));
         
         DOMNodeList *catalogs = eventData->getElementsByTagName(uStr("catalog").ptr());
         
         if (catalogs->getLength() > 0) {
           DOMElement * catalog = static_cast<DOMElement *>(catalogs->item(0));
           m_dataCatalog = toString(catalog->getAttribute(uStr("url").ptr()));
         }
         
         if (catalogs->getLength() > 1) {
           DOMElement * catalog = static_cast<DOMElement *>(catalogs->item(1));
           m_fallbackDataCatalog = toString(catalog->getAttribute(uStr("url").ptr()));
         }
         
         DOMNodeList* rfiotypes = eventData->getElementsByTagName(uStr("rfiotype").ptr());
         
         if (rfiotypes->getLength() > 0) {
           DOMElement* rfiotype = static_cast<DOMElement *>(rfiotypes->item(0));
           m_rfioType = toString(rfiotype->getAttribute(uStr("value").ptr()));
         }
           }
         }
         
         // Parsing of the calib-data section
         {
           DOMNodeList *calibDataList = site->getElementsByTagName(uStr("calib-data").ptr());
           
           if (calibDataList->getLength() > 0) {
         DOMElement *calibData = static_cast<DOMElement *>(calibDataList->item(0));
         DOMNodeList *frontierConnectList = calibData->getElementsByTagName(uStr("frontier-connect").ptr());
         
         if (frontierConnectList->getLength() > 0) {
           DOMElement *frontierConnect = static_cast<DOMElement *>(frontierConnectList->item(0));
           m_frontierConnect = _toParenString(*frontierConnect);
         }
           }
         }
         // Parsing of the source config section
         {
           DOMNodeList *sourceConfigList = site->getElementsByTagName(uStr("source-config").ptr());
           
           if (sourceConfigList->getLength() > 0) {
         DOMElement *sourceConfig = static_cast<DOMElement *>(sourceConfigList->item(0));
         DOMNodeList *cacheTempDirList = sourceConfig->getElementsByTagName(uStr("cache-temp-dir").ptr());
         
         if (cacheTempDirList->getLength() > 0) {
           DOMElement *cacheTempDir = static_cast<DOMElement *>(cacheTempDirList->item(0));
           m_cacheTempDir = toString(cacheTempDir->getAttribute(uStr("name").ptr()));
           m_cacheTempDirPtr = &m_cacheTempDir;
         }
         
         DOMNodeList *cacheMinFreeList = sourceConfig->getElementsByTagName(uStr("cache-min-free").ptr());
         
         if (cacheMinFreeList->getLength() > 0) {
           DOMElement *cacheMinFree = static_cast<DOMElement *>(cacheMinFreeList->item(0));
           m_cacheMinFree = toDouble(cacheMinFree->getAttribute(uStr("value").ptr()));
           m_cacheMinFreePtr = &m_cacheMinFree;
         }
         
         DOMNodeList *cacheHintList = sourceConfig->getElementsByTagName(uStr("cache-hint").ptr());
         
         if (cacheHintList->getLength() > 0) {
           DOMElement *cacheHint = static_cast<DOMElement *>(cacheHintList->item(0));
           m_cacheHint = toString(cacheHint->getAttribute(uStr("value").ptr()));
           m_cacheHintPtr = &m_cacheHint;
         }
         
         DOMNodeList *cloneCacheHintList = sourceConfig->getElementsByTagName(uStr("clone-cache-hint").ptr());
         
         if (cloneCacheHintList->getLength() > 0) {
           DOMElement *cloneCacheHint = static_cast<DOMElement *>(cloneCacheHintList->item(0));
           m_cloneCacheHint = toString(cloneCacheHint->getAttribute(uStr("value").ptr()));
           m_cloneCacheHintPtr = &m_cloneCacheHint;
         }
         
         DOMNodeList *readHintList = sourceConfig->getElementsByTagName(uStr("read-hint").ptr());
         
         if (readHintList->getLength() > 0) {
           DOMElement *readHint = static_cast<DOMElement *>(readHintList->item(0));
           m_readHint = toString(readHint->getAttribute(uStr("value").ptr()));
           m_readHintPtr = &m_readHint;
         }
         
         DOMNodeList *ttreeCacheSizeList = sourceConfig->getElementsByTagName(uStr("ttree-cache-size").ptr());
         
         if (ttreeCacheSizeList->getLength() > 0) {
           DOMElement *ttreeCacheSize = static_cast<DOMElement *>(ttreeCacheSizeList->item(0));
           m_ttreeCacheSize = toUInt(ttreeCacheSize->getAttribute(uStr("value").ptr()));
           m_ttreeCacheSizePtr = &m_ttreeCacheSize;
         }
         
         DOMNodeList *timeoutList = sourceConfig->getElementsByTagName(uStr("timeout-in-seconds").ptr());
         
         if (timeoutList->getLength() > 0) {
           DOMElement *timeout = static_cast<DOMElement *>(timeoutList->item(0));
           m_timeout = toUInt(timeout->getAttribute(uStr("value").ptr()));
           m_timeoutPtr = &m_timeout;
         }
         
         DOMNodeList *statsDestList = sourceConfig->getElementsByTagName(uStr("statistics-destination").ptr());
         
         if (statsDestList->getLength() > 0) {
           DOMElement *statsDest = static_cast<DOMElement *>(statsDestList->item(0));
           m_statisticsDestination = toString(statsDest->getAttribute(uStr("endpoint").ptr()));
           if (!m_statisticsDestination.size()) {
             m_statisticsDestination = toString(statsDest->getAttribute(uStr("name").ptr()));
           }
           std::string tmpStatisticsInfo = toString(statsDest->getAttribute(uStr("info").ptr()));
           boost::split(m_statisticsInfo, tmpStatisticsInfo, boost::is_any_of("\t ,"));
           m_statisticsInfoAvail = !tmpStatisticsInfo.empty();
         }
         
         DOMNodeList *prefetchingList = sourceConfig->getElementsByTagName(uStr("prefetching").ptr());
         
         if (prefetchingList->getLength() > 0) {
           DOMElement *prefetching = static_cast<DOMElement *>(prefetchingList->item(0));
           m_enablePrefetching = toBool(prefetching->getAttribute(uStr("value").ptr()));
           m_enablePrefetchingPtr = &m_enablePrefetching;
         }
         
         DOMNodeList *nativeProtocolsList = sourceConfig->getElementsByTagName(uStr("native-protocols").ptr());
         
         if (nativeProtocolsList->getLength() > 0) {
           DOMElement *nativeProtocol = static_cast<DOMElement *>(nativeProtocolsList->item(0));
           DOMNodeList *childList = nativeProtocol->getChildNodes();
           
           XMLSize_t numNodes = childList->getLength();
           for (XMLSize_t i = 0; i < numNodes; ++i) {
             DOMNode *childNode = childList->item(i);
             if (childNode->getNodeType() != DOMNode::ELEMENT_NODE) {
               continue;
             }
             DOMElement *child = static_cast<DOMElement *>(childNode);
             m_nativeProtocols.push_back(toString(child->getAttribute(uStr("prefix").ptr())));
           }
           m_nativeProtocolsPtr = &m_nativeProtocols;
         }
           }
         }
       }
       m_connected = true;
     }
     catch (xercesc::DOMException const& e) {
     }
       } // The extra pair of braces ensures that
         // all implicit destructors are called
         // *before* terminating Xerces-C++.
       cms::concurrency::xercesTerminate();
     }

std::string const edm::service::SiteLocalConfigService::rfioType ( void ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 253 of file SiteLocalConfigService.cc.

References m_rfioType, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                {
         return m_rfioType;
     }

std::string const & edm::service::SiteLocalConfigService::siteName ( void ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 318 of file SiteLocalConfigService.cc.

References m_siteName.

                                            {
        return m_siteName;
     }

std::string const * edm::service::SiteLocalConfigService::sourceCacheHint ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 268 of file SiteLocalConfigService.cc.

References m_cacheHintPtr, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                   {
        return m_cacheHintPtr;
     }

double const * edm::service::SiteLocalConfigService::sourceCacheMinFree ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 263 of file SiteLocalConfigService.cc.

References m_cacheMinFreePtr, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                      {
        return m_cacheMinFreePtr;
     }

std::string const * edm::service::SiteLocalConfigService::sourceCacheTempDir ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 258 of file SiteLocalConfigService.cc.

References m_cacheTempDirPtr.

                                                      {
        return m_cacheTempDirPtr;
     }

std::string const * edm::service::SiteLocalConfigService::sourceCloneCacheHint ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 273 of file SiteLocalConfigService.cc.

References m_cloneCacheHintPtr, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                        {
        return m_cloneCacheHintPtr;
     }

std::vector< std::string > const * edm::service::SiteLocalConfigService::sourceNativeProtocols ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 303 of file SiteLocalConfigService.cc.

References m_nativeProtocolsPtr.

                                                         {
        return m_nativeProtocolsPtr;
     }

std::string const * edm::service::SiteLocalConfigService::sourceReadHint ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 278 of file SiteLocalConfigService.cc.

References m_readHintPtr.

                                                  {
        return m_readHintPtr;
     }

unsigned int const * edm::service::SiteLocalConfigService::sourceTimeout ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 288 of file SiteLocalConfigService.cc.

References m_timeoutPtr.

                                                 {
        return m_timeoutPtr;
     }

unsigned int const * edm::service::SiteLocalConfigService::sourceTTreeCacheSize ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 283 of file SiteLocalConfigService.cc.

References m_ttreeCacheSizePtr.

                                                        {
        return m_ttreeCacheSizePtr;
     }

struct addrinfo const * edm::service::SiteLocalConfigService::statisticsDestination ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 308 of file SiteLocalConfigService.cc.

References m_statisticsAddrInfo.

                                                         {
        return m_statisticsAddrInfo;
     }

std::set< std::string > const * edm::service::SiteLocalConfigService::statisticsInfo ( ) const

overridevirtual

Implements edm::SiteLocalConfig.

Definition at line 313 of file SiteLocalConfigService.cc.

References m_statisticsInfo, m_statisticsInfoAvail, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                  {
        return m_statisticsInfoAvail ? &m_statisticsInfo : nullptr;
     }

Member Data Documentation

std::string edm::service::SiteLocalConfigService::m_cacheHint

private

Definition at line 67 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

std::string const* edm::service::SiteLocalConfigService::m_cacheHintPtr

private

Definition at line 68 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceCacheHint().

double edm::service::SiteLocalConfigService::m_cacheMinFree

private

Definition at line 65 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

double const* edm::service::SiteLocalConfigService::m_cacheMinFreePtr

private

Definition at line 66 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceCacheMinFree().

std::string edm::service::SiteLocalConfigService::m_cacheTempDir

private

Definition at line 63 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

std::string const* edm::service::SiteLocalConfigService::m_cacheTempDirPtr

private

Definition at line 64 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceCacheTempDir().

std::string edm::service::SiteLocalConfigService::m_cloneCacheHint

private

Definition at line 69 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

std::string const* edm::service::SiteLocalConfigService::m_cloneCacheHintPtr

private

Definition at line 70 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceCloneCacheHint().

bool edm::service::SiteLocalConfigService::m_connected

private

Definition at line 62 of file SiteLocalConfigService.h.

Referenced by dataCatalog(), fallbackDataCatalog(), frontierConnect(), and parse().

std::string edm::service::SiteLocalConfigService::m_dataCatalog

private

Definition at line 58 of file SiteLocalConfigService.h.

Referenced by dataCatalog(), and parse().

unsigned int edm::service::SiteLocalConfigService::m_debugLevel

private

Definition at line 77 of file SiteLocalConfigService.h.

Referenced by debugLevel(), and SiteLocalConfigService().

bool edm::service::SiteLocalConfigService::m_enablePrefetching

private

Definition at line 78 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

bool const* edm::service::SiteLocalConfigService::m_enablePrefetchingPtr

private

Definition at line 79 of file SiteLocalConfigService.h.

Referenced by enablePrefetching(), parse(), and SiteLocalConfigService().

std::string edm::service::SiteLocalConfigService::m_fallbackDataCatalog

private

Definition at line 59 of file SiteLocalConfigService.h.

Referenced by fallbackDataCatalog(), and parse().

std::string edm::service::SiteLocalConfigService::m_frontierConnect

private

Definition at line 60 of file SiteLocalConfigService.h.

Referenced by frontierConnect(), and parse().

std::vector<std::string> edm::service::SiteLocalConfigService::m_nativeProtocols

private

Definition at line 80 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

std::vector<std::string> const* edm::service::SiteLocalConfigService::m_nativeProtocolsPtr

private

Definition at line 81 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceNativeProtocols().

std::string edm::service::SiteLocalConfigService::m_readHint

private

Definition at line 71 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

std::string const* edm::service::SiteLocalConfigService::m_readHintPtr

private

Definition at line 72 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceReadHint().

std::string edm::service::SiteLocalConfigService::m_rfioType

private

Definition at line 61 of file SiteLocalConfigService.h.

Referenced by parse(), and rfioType().

std::string edm::service::SiteLocalConfigService::m_siteName

private

Definition at line 87 of file SiteLocalConfigService.h.

Referenced by parse(), and siteName().

edm::propagate_const<struct addrinfo*> edm::service::SiteLocalConfigService::m_statisticsAddrInfo

private

Definition at line 83 of file SiteLocalConfigService.h.

Referenced by computeStatisticsDestination(), statisticsDestination(), and ~SiteLocalConfigService().

const std::string edm::service::SiteLocalConfigService::m_statisticsDefaultPort = "3334"

staticprivate

Definition at line 84 of file SiteLocalConfigService.h.

Referenced by computeStatisticsDestination().

std::string edm::service::SiteLocalConfigService::m_statisticsDestination

private

Definition at line 82 of file SiteLocalConfigService.h.

Referenced by computeStatisticsDestination(), parse(), and SiteLocalConfigService().

std::set<std::string> edm::service::SiteLocalConfigService::m_statisticsInfo

private

Definition at line 85 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and statisticsInfo().

bool edm::service::SiteLocalConfigService::m_statisticsInfoAvail

private

Definition at line 86 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and statisticsInfo().

unsigned int edm::service::SiteLocalConfigService::m_timeout

private

Definition at line 75 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

unsigned int const* edm::service::SiteLocalConfigService::m_timeoutPtr

private

Definition at line 76 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceTimeout().

unsigned int edm::service::SiteLocalConfigService::m_ttreeCacheSize

private

Definition at line 73 of file SiteLocalConfigService.h.

Referenced by parse(), and SiteLocalConfigService().

unsigned int const* edm::service::SiteLocalConfigService::m_ttreeCacheSizePtr

private

Definition at line 74 of file SiteLocalConfigService.h.

Referenced by parse(), SiteLocalConfigService(), and sourceTTreeCacheSize().

std::string edm::service::SiteLocalConfigService::m_url

private

Definition at line 57 of file SiteLocalConfigService.h.

Referenced by dataCatalog(), frontierConnect(), and SiteLocalConfigService().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation