Reference Manual

CMS 3D

Inheritance diagram for o2o_db_cfgmap.DbManagerDAQ:

Public Member Functions
def	__init__ (self, db, authFile=None)

def	update_hashmap (self, input_path)

Public Attributes
	ConfigToPayloadMap

	ConfigToPayloadMapSqlite

Detailed Description

Definition at line 22 of file o2o_db_cfgmap.py.

Constructor & Destructor Documentation

def o2o_db_cfgmap.DbManagerDAQ.__init__	(		self,
			db,
			authFile = `None`
	)

Definition at line 23 of file o2o_db_cfgmap.py.

     def __init__(self, db, authFile=None):
         DbManager.__init__(self, db, authFile)
         self.ConfigToPayloadMap = make_dbtype(ConfigToPayloadMapDef, self.schema)
         if self.schema:
             self.ConfigToPayloadMapSqlite = make_dbtype(ConfigToPayloadMapDef, schema=None)
         else:
             self.ConfigToPayloadMapSqlite = self.ConfigToPayloadMap
 

Member Function Documentation

def o2o_db_cfgmap.DbManagerDAQ.update_hashmap	(		self,
			input_path
	)

Definition at line 31 of file o2o_db_cfgmap.py.

References o2o_db_manager.DbManager.check_table(), o2o_db_cfgmap.DbManagerDAQ.ConfigToPayloadMap, o2o_db_cfgmap.DbManagerDAQ.ConfigToPayloadMapSqlite, ConnectionManager.connect(), RPCDBCom.connect(), conditionUploadTest.DB.connect(), l1t::DataManager.connect(), HCALConfigDB.connect(), TestBase.connect(), ReadBase.connect(), ShallowTree::BranchConnector.connect(), dqmservices::DQMMonitoringService.connect(), SimActivityRegistry.connect(), sim_act::Signaler< BeginOfRun >.connect(), sim_act::Signaler< BeginOfEvent >.connect(), sim_act::Signaler< BeginOfTrack >.connect(), sim_act::Signaler< DDDWorld >.connect(), sim_act::Signaler< BeginOfJob >.connect(), sim_act::Signaler< EndOfRun >.connect(), sim_act::Signaler< EndOfEvent >.connect(), sim_act::Signaler< T >.connect(), sim_act::Signaler< EndOfTrack >.connect(), sim_act::Signaler< G4Step >.connect(), ShallowTree::TypedBranchConnector< T >.connect(), edm::ServiceToken.connect(), edm::signalslot::Signal< void(service::SystemBounds const &)>.connect(), edm::signalslot::Signal< void(PathsAndConsumesOfModulesBase const &, ProcessContext const &)>.connect(), edm::signalslot::Signal< void(const edmplugin::PluginFactoryBase *)>.connect(), edm::signalslot::Signal< void(GlobalContext const &)>.connect(), edm::signalslot::Signal< void(StreamContext const &, PathContext const &, HLTPathStatus const &)>.connect(), edm::signalslot::Signal< void(StreamContext const &, PathContext const &)>.connect(), edm::signalslot::Signal< void(edm::BranchDescription const &)>.connect(), edm::signalslot::Signal< void(const edmplugin::SharedLibrary &)>.connect(), edm::signalslot::Signal< void(LuminosityBlockIndex)>.connect(), edm::signalslot::Signal< void(eventsetup::ComponentDescription const *, eventsetup::EventSetupRecordKey const &, eventsetup::DataKey const &)>.connect(), edm::signalslot::Signal< void(GlobalContext const &, ModuleCallingContext const &)>.connect(), edm::signalslot::Signal< void(RunIndex)>.connect(), edm::signalslot::Signal< void(std::string const &, bool)>.connect(), edm::signalslot::Signal< void()>.connect(), edm::signalslot::Signal< void(edm::StreamContext const &, edm::ModuleCallingContext const &)>.connect(), edm::signalslot::Signal< void(TerminationOrigin)>.connect(), edm::signalslot::Signal< void(const std::string &, const edmplugin::PluginInfo &)>.connect(), edm::signalslot::Signal< T >.connect(), edm::signalslot::Signal< void(StreamContext const &)>.connect(), edm::signalslot::Signal< void(const std::string &, const std::string &)>.connect(), edm::signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>.connect(), edm::signalslot::Signal< void(StreamID)>.connect(), edm::signalslot::Signal< void(GlobalContext const &, TerminationOrigin)>.connect(), edm::signalslot::Signal< void(const boost::filesystem::path &)>.connect(), edm::signalslot::Signal< void(ModuleDescription const &)>.connect(), edm::signalslot::Signal< void(StreamContext const &, TerminationOrigin)>.connect(), o2o_db_manager.DbManager.connect(), PFCandConnector.connect(), L1TOMDSHelper.connect(), confdbOfflineConverter.OfflineConverter.connect, DDTOBRodAlgo.connect, GlobalTag.GlobalTag.connect(), edm::signalslot::ObsoleteSignal< void(LuminosityBlockID const &, Timestamp const &)>.connect(), edm::signalslot::ObsoleteSignal< void(std::string const &)>.connect(), edm::signalslot::ObsoleteSignal< void(Run const &, EventSetup const &)>.connect(), edm::signalslot::ObsoleteSignal< T >.connect(), edm::signalslot::ObsoleteSignal< void(LuminosityBlock const &, EventSetup const &)>.connect(), edm::signalslot::ObsoleteSignal< void(EventID const &, Timestamp const &)>.connect(), edm::signalslot::ObsoleteSignal< void(std::string const &, HLTPathStatus const &)>.connect(), edm::signalslot::ObsoleteSignal< void(Event const &, EventSetup const &)>.connect(), edm::signalslot::ObsoleteSignal< void(ModuleDescription const &)>.connect(), edm::signalslot::ObsoleteSignal< void(RunID const &, Timestamp const &)>.connect(), SiStripGainFromCalibTree.connect(), edm::serviceregistry::ServicesManager.connect(), conddb_version_mgr.conddb_tool.connect(), o2olib.O2OJobMgr.connect(), cond::service::PoolDBOutputService.connect(), l1t::OMDSReader.connect(), edm::ActivityRegistry.connect(), and plotBeamSpotDB.first.

     def update_hashmap(self, input_path):
         if not os.path.exists(input_path):
             logging.info('No config-to-payload map file at %s. Skipping.' % input_path)
             return
         session = self.connect('sqlite:///%s' % input_path)
         entry = session.query(self.ConfigToPayloadMapSqlite).first()
         if entry:
             self.check_table(ConfigToPayloadMapDef, self.ConfigToPayloadMap)
             destSession = self.connect()
             cfgmap = self.ConfigToPayloadMap(config_hash=entry.config_hash,
                                              payload_hash=entry.payload_hash,
                                              payload_type=entry.payload_type,
                                              config_string=entry.config_string,
                                              insertion_time=entry.insertion_time)
             destSession.add(cfgmap)
             destSession.commit()
             logging.info('Updated config-to-payload map for %s' % cfgmap.payload_type)
             logging.info('... config_hash = %s, payload_hash = %s' % (cfgmap.config_hash, cfgmap.payload_hash))
         else:
             raise RuntimeError('No entry found in config-to-payload map file %s' % input_path)

Member Data Documentation

o2o_db_cfgmap.DbManagerDAQ.ConfigToPayloadMap

Definition at line 25 of file o2o_db_cfgmap.py.

Referenced by o2o_db_cfgmap.DbManagerDAQ.update_hashmap().

o2o_db_cfgmap.DbManagerDAQ.ConfigToPayloadMapSqlite

Definition at line 27 of file o2o_db_cfgmap.py.

Referenced by o2o_db_cfgmap.DbManagerDAQ.update_hashmap().