test
CMS 3D CMS Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
Classes | Functions | Variables
o2o Namespace Reference

Classes

class  O2OJob
 
class  O2OJobMgr
 
class  O2OMgr
 
class  O2ORun
 
class  O2ORunMgr
 

Functions

def get_db_credentials
 
def get_iovs
 
def get_tags
 
def guess_condition_from_tag
 
def make_popcon_config_file
 
def run_popcon
 

Variables

string __author__ = 'Giacomo Govi'
 
tuple _Base = sqlalchemy.ext.declarative.declarative_base()
 
string authPathEnvVar = 'O2O_AUTH_PATH'
 
string base_dir = "."
 
list condition_type = guessed_condition['condition_type']
 
list dev_db_service = ['cms_orcoff_prep','o2o_dev']
 
string dropbox_comment = 'generated by CaloOnlineTools/HcalOnlineDb/test/o2o.py script'
 
string dropbox_destination_db = 'oracle://cms_orcon_prod/CMS_COND_31X_HCAL'
 
string dropbox_dir = "./dropbox"
 
tuple dropbox_file_name_prefix = str(output_dir)
 
tuple dropbox_txt_file = open(dropbox_txt_file_name, "w")
 
tuple dropbox_txt_file_name = str(dropbox_file_name_prefix)
 
string fmt_str = "[%(asctime)s] %(levelname)s: %(message)s"
 
tuple gotten_iovs = get_iovs(tag, input_pool_connect_string, mode)
 
tuple guessed_condition = guess_condition_from_tag(tag)
 
int i = 0
 
string input_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"
 
tuple iov = int(line)
 
list isnewtag = gotten_iovs['newtag']
 
list levStr = os.environ[messageLevelEnvVar]
 
string logFolderEnvVar = 'O2O_LOG_FOLDER'
 
tuple logFormatter = logging.Formatter(fmt_str)
 
 logLevel = logging.INFO
 
string messageLevelEnvVar = 'O2O_LOG_LEVEL'
 
string mode = 'online'
 
list o2o_iovs = gotten_iovs['iovs']
 
string o2o_tag_list_file = "o2o_tag_list.txt"
 
string omds_accessor_string = "occi://CMS_HCL_APPUSER_R@anyhost/cms_omds_lb?PASSWORD=HCAL_Reader_44"
 
string oracle_tpl = 'oracle://%s:%s@%s'
 
string output_dir = "."
 
string output_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"
 
string pool_auth_path = "/nfshome0/popcondev/conddb"
 
 pool_iov = iov
 
string pool_logconnect = "sqlite_file:/nfshome0/kukartse/hcal/dcs/log.db"
 
list pool_record = guessed_condition['pool_record']
 
string private_db = 'sqlite:///o2o_jobs.db'
 
list prod_db_service = ['cms_orcon_prod','o2o_prod']
 
string python_popcon_file = "dbwrite_o2o.py"
 
string python_popcon_template_file = "dbwrite_o2o_template.py"
 
tuple query = query_file.read()
 
tuple query_file = open(query_file_name, "r")
 
list query_file_name = guessed_condition['query_file_name']
 
 query_save = query
 
tuple run_result = run_popcon()
 
string schema_name = 'CMS_CONDITIONS'
 
int startStatus = -1
 
tuple tag = tag_name.strip()
 
tuple tags = get_tags(base_dir+"/"+o2o_tag_list_file)
 
string use_dropbox = 'false'
 

Function Documentation

def o2o.get_db_credentials (   db_service,
  authFile 
)

Definition at line 49 of file o2o.py.

Referenced by o2o.O2OMgr.getSession().

49 
50 def get_db_credentials( db_service, authFile ):
51  pwd = None
52  if authFile is None:
53  if authPathEnvVar in os.environ:
54  authPath = os.environ[authPathEnvVar]
55  authFile = os.path.join(authPath,'.netrc')
56  logging.debug('Retrieving credentials from file %s' %authFile )
57  (username, account, pwd) = netrc.netrc( authFile ).authenticators(db_service[1])
58  return username,pwd
59 
o2o.get_db_credentials
def get_db_credentials
Definition: o2o.py:49
def o2o.get_iovs (   tag,
  input_pool_connect_string,
  mode 
)

Definition at line 171 of file o2o.py.

References bitset_utilities.append(), and communicate().

171 
172 def get_iovs(tag, input_pool_connect_string, mode):
173  result = "fail" # default
174  newtag = False # default
175  # nominal mode of operations
176  if mode == "online" or mode == "online_dropbox":
177  try:
178  iovs = subprocess.Popen(["./xmlToolsRun", "--list-iovs-for-o2o", "--tag-name", tag, "--pool-connect-string", input_pool_connect_string, "--pool-auth-path", pool_auth_path], stdout=subprocess.PIPE).communicate()[0]
179  iov_list = iovs.splitlines()
180  result = "success"
181  except:
182  print "ERROR: Cannot get the IOV update list for tag", tag+". This tag will not be updated. Now continue to the next tag..."
183  iov_list=[]
184  result = "fail"
185 
186  # script development mode, DB interfaces substituted with dummies
187  if mode == "offline_development":
188  #iovs = subprocess.Popen(["cat", tag+"_iov_to_update.devel"], stdout=subprocess.PIPE).communicate()[0]
189  try:
190  iov_list_file = open(base_dir+"/o2o/"+tag+"_iov_to_update.devel")
191  except:
192  print "ERROR: Cannot open file with the IOV list for tag", tag+". This tag will not be updated. Now continue to the next tag..."
193  result = "fail"
194  result = "success"
195  iov_list = []
196  for line in iov_list_file:
197  iov_list . append(line.strip())
198  iov_list_file.close()
199  # now parse iov_list.
200  # May contain various important output. Prefix defines the type of instruction.
201  # IOVs start with O2O_IOV_LIST:
202  # CONNECTION ERROR: indicates problems with connection to Pool and invalidates
203  # the IOV list
204  iovs=[]
205  for line in iov_list:
206  line_stripped = line.strip()
207  if line.strip()[0:13] == "O2O_IOV_LIST:":
208  iovs.append(line.lstrip("O2O_IOV_LIST:"))
209  if line_stripped[0:line_stripped.find(":")] == "CONNECTION ERROR":
210  result = "fail_connect"
211  if line_stripped[0:line_stripped.find(":")] == "NEW_POOL_TAG_TRUE":
212  newtag = True
213  return {'iovs':iovs,
214  'result':result,
215  'newtag':newtag}
216 
#_____ run PopCon
bitset_utilities::append
boost::dynamic_bitset append(const boost::dynamic_bitset<> &bs1, const boost::dynamic_bitset<> &bs2)
this method takes two bitsets bs1 and bs2 and returns result of bs2 appended to the end of bs1 ...
Definition: bitset_append.cc:10
communicate
static void * communicate(void *obj)
Definition: DQMNet.cc:1246
o2o.get_iovs
def get_iovs
Definition: o2o.py:171
def o2o.get_tags (   tag_list_file_name)

Definition at line 157 of file o2o.py.

References bitset_utilities.append().

157 
158 def get_tags(tag_list_file_name):
159  try:
160  tag_list_file = open(tag_list_file_name)
161  except:
162  print "Cannot open the file with the list of tags, exiting..."
163  sys.exit()
164  tag_list = []
165  for line in tag_list_file:
166  tag_list . append(line)
167  tag_list_file.close()
168  #tags = subprocess.Popen(["cat", tag_list], stdout=subprocess.PIPE).communicate()[0]
169  return tag_list
170 
#_____ get list of IOVs that need updating, from comparison of OMDS and ORCON
bitset_utilities::append
boost::dynamic_bitset append(const boost::dynamic_bitset<> &bs1, const boost::dynamic_bitset<> &bs2)
this method takes two bitsets bs1 and bs2 and returns result of bs2 appended to the end of bs1 ...
Definition: bitset_append.cc:10
o2o.get_tags
def get_tags
Definition: o2o.py:157
def o2o.guess_condition_from_tag (   tagname)

Definition at line 76 of file o2o.py.

76 
77 def guess_condition_from_tag(tagname):
78  guessed_type = tagname[0:tagname.find("_")]
79  # FIXME: gak is a temporary debugging case
80  if guessed_type == "gak":
81  guessed_type = "HcalChannelQuality"
82  guessed_query_file_name = base_dir+"/HcalChannelQuality.sql"
83  guessed_pool_record = "HcalChannelQualityRcd"
84 
85  elif guessed_type == "HcalDcsValues":
86  guessed_type = "DcsValues"
87  guessed_query_file_name = base_dir+"/HcalDcsValues.sql"
88  guessed_pool_record = "HcalDcsRcd"
89 
90  elif guessed_type == "HcalChannelQuality":
91  guessed_type = "ChannelQuality"
92  guessed_query_file_name = base_dir+"/HcalChannelQuality.sql"
93  guessed_pool_record = "HcalChannelQualityRcd"
94 
95  elif guessed_type == "HcalLutMetadata":
96  guessed_type = "LutMetadata"
97  guessed_query_file_name = base_dir+"/HcalLutMetadata.sql"
98  guessed_pool_record = "HcalLutMetadataRcd"
99 
100  elif guessed_type == "HcalRespCorrs":
101  guessed_type = "RespCorrs"
102  guessed_query_file_name = base_dir+"/HcalRespCorrs.sql"
103  guessed_pool_record = "HcalRespCorrsRcd"
104 
105  elif guessed_type == "HcalValidationCorrs":
106  guessed_type = "ValidationCorrs"
107  guessed_query_file_name = base_dir+"/HcalValidationCorrs.sql"
108  guessed_pool_record = "HcalValidationCorrsRcd"
109 
110  elif guessed_type == "HcalPedestals":
111  guessed_type = "Pedestals"
112  guessed_query_file_name = base_dir+"/HcalPedestals.sql"
113  guessed_pool_record = "HcalPedestalsRcd"
114 
115  elif guessed_type == "HcalPedestalWidths":
116  guessed_type = "PedestalWidths"
117  guessed_query_file_name = base_dir+"/HcalPedestalWidths.sql"
118  guessed_pool_record = "HcalPedestalWidthsRcd"
119 
120  elif guessed_type == "HcalGains":
121  guessed_type = "Gains"
122  guessed_query_file_name = base_dir+"/HcalGains.sql"
123  guessed_pool_record = "HcalGainsRcd"
124 
125  elif guessed_type == "HcalGainWidths":
126  guessed_type = "GainWidths"
127  guessed_query_file_name = base_dir+"/HcalGainWidths.sql"
128  guessed_pool_record = "HcalGainWidthsRcd"
129 
130  elif guessed_type == "HcalQIEData":
131  guessed_type = "QIEData"
132  guessed_query_file_name = base_dir+"/HcalQieData.sql"
133  guessed_pool_record = "HcalQIEDataRcd"
134 
135  elif guessed_type == "HcalElectronicsMap":
136  guessed_type = "ElectronicsMap"
137  guessed_query_file_name = base_dir+"/HcalEmap.sql"
138  guessed_pool_record = "HcalElectronicsMapRcd"
139 
140  elif guessed_type == "HcalZSThresholds":
141  guessed_type = "ZSThresholds"
142  guessed_query_file_name = base_dir+"/HcalZSThresholds.sql"
143  guessed_pool_record = "HcalZSThresholdsRcd"
144 
145  elif guessed_type == "HcalL1TriggerObjects":
146  guessed_type = "L1TriggerObjects"
147  guessed_query_file_name = base_dir+"/HcalL1TriggerObjects.sql"
148  guessed_pool_record = "HcalL1TriggerObjectsRcd"
149 
150  else:
151  print "Cannot guess condition type"
152 
153  return {'condition_type':guessed_type,
154  'query_file_name':guessed_query_file_name,
155  'pool_record':guessed_pool_record}
156 
#_____ get list of IOVs that need updating, from comparison of OMDS and ORCON
o2o.guess_condition_from_tag
def guess_condition_from_tag
Definition: o2o.py:76
def o2o.make_popcon_config_file (   filename)

Definition at line 52 of file o2o.py.

52 
53 def make_popcon_config_file(filename):
54  py_templ_file = open(base_dir+"/"+python_popcon_template_file)
55  py_file = open(str(filename), "w")
56  for line in py_templ_file:
57  line=line.replace('CONNECT_STRING', output_pool_connect_string)
58  line=line.replace('POOL_AUTH_PATH', pool_auth_path)
59  line=line.replace('CONDITION_TYPE', condition_type)
60  line=line.replace('OMDS_CONDITION_TAG', tag)
61  line=line.replace('OMDS_IOV', str(iov))
62  line=line.replace('OMDS_ACCESSOR_STRING', omds_accessor_string)
63  line=line.replace('OMDS_QUERY', query)
64  line=line.replace('POOL_LOGCONNECT', pool_logconnect)
65  line=line.replace('POOL_RECORD', pool_record)
66  line=line.replace('POOL_OUTPUT_TAG', tag)
67  line=line.replace('POOL_IOV', str(pool_iov))
68  py_file.write(line)
69  py_file.close()
70 
71 #
72 # HCAL conditions have a rigid naming scheme:
73 # RECORD_VERSION_USE, e.g. HcalChannelQuality_v1.00_mc
74 # or
75 # RECORD_UNIT_VERSION_USE, e.g. HcalPedestals_ADC_v2.31_offline
#
o2o.make_popcon_config_file
def make_popcon_config_file
Definition: o2o.py:52
def o2o.run_popcon ( )

Definition at line 217 of file o2o.py.

217 
218 def run_popcon():
219  status = "fail"
220  try:
221  print "iov=", iov
222  if mode == "online" or mode == "online_dropbox":
223  subprocess.call(["cmsRun", str(python_popcon_file)])
224  else:
225  print "In online mode would run Popcon now:", "cmsRun", str(python_popcon_file)
226  status = "success"
227  except OSError:
228  print "Cannot execute cmsRun. Further processing of this tag is stopped, going to the next tag..."
229  #break
230  except:
231  print "Cannot execute cmsRun. Further processing of this tag is stopped, going to the next tag..."
232  #break
233 
234  #
235  #_____ copy to the Dropbox area (optional)
236  #
237  if use_dropbox == "true" or use_dropbox == "True" or use_dropbox == "TRUE":
238  try:
239  retcall_meta = subprocess.call(['mv', str(output_dir)+'/'+str(dropbox_file_name_prefix)+'.txt', str(dropbox_dir)+'/'])
240  retcall_sql = subprocess.call(['mv', str(output_dir)+'/'+str(dropbox_file_name_prefix)+'.sql', str(dropbox_dir)+'/'])
241  except:
242  print "ERROR: Cannot copy files to the dropbox area"
243 
244  return {'status':status}
245 #
246 #_____ end of helper functions __________________________________________
247 
o2o.run_popcon
def run_popcon
Definition: o2o.py:217

Variable Documentation

string o2o.__author__ = 'Giacomo Govi'

Definition at line 1 of file o2o.py.

tuple o2o._Base = sqlalchemy.ext.declarative.declarative_base()

Definition at line 22 of file o2o.py.

string o2o.authPathEnvVar = 'O2O_AUTH_PATH'

Definition at line 18 of file o2o.py.

string o2o.base_dir = "."

Definition at line 32 of file o2o.py.

list o2o.condition_type = guessed_condition['condition_type']

Definition at line 257 of file o2o.py.

list o2o.dev_db_service = ['cms_orcoff_prep','o2o_dev']

Definition at line 13 of file o2o.py.

string o2o.dropbox_comment = 'generated by CaloOnlineTools/HcalOnlineDb/test/o2o.py script'

Definition at line 43 of file o2o.py.

string o2o.dropbox_destination_db = 'oracle://cms_orcon_prod/CMS_COND_31X_HCAL'

Definition at line 42 of file o2o.py.

string o2o.dropbox_dir = "./dropbox"

Definition at line 41 of file o2o.py.

tuple o2o.dropbox_file_name_prefix = str(output_dir)

Definition at line 277 of file o2o.py.

tuple o2o.dropbox_txt_file = open(dropbox_txt_file_name, "w")

Definition at line 280 of file o2o.py.

tuple o2o.dropbox_txt_file_name = str(dropbox_file_name_prefix)

Definition at line 279 of file o2o.py.

string o2o.fmt_str = "[%(asctime)s] %(levelname)s: %(message)s"

Definition at line 24 of file o2o.py.

tuple o2o.gotten_iovs = get_iovs(tag, input_pool_connect_string, mode)

Definition at line 293 of file o2o.py.

tuple o2o.guessed_condition = guess_condition_from_tag(tag)

Definition at line 256 of file o2o.py.

int o2o.i = 0

Definition at line 304 of file o2o.py.

string o2o.input_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"

Definition at line 27 of file o2o.py.

tuple o2o.iov = int(line)

Definition at line 307 of file o2o.py.

Referenced by copyObject(), cond::persistency.copyTag(), HcalDQMDbInterface.createIOV(), SiStripDetVOffTrendPlotter.dumpCSV(), LMFCorrCoefDat.fetch(), LMFCorrCoefDat.fetchBetween(), LMFRunIOV.fetchBySequence(), RunPTMTempDat.fetchData(), RunDat.fetchData(), RunCrystalErrorsDat.fetchData(), RunMemChErrorsDat.fetchData(), RunMemTTErrorsDat.fetchData(), RunPNErrorsDat.fetchData(), RunTTErrorsDat.fetchData(), RunConfigDat.fetchData(), RunFEConfigDat.fetchData(), MonH4TablePositionDat.fetchData(), RunLaserRunDat.fetchData(), RunTPGConfigDat.fetchData(), CaliGeneralDat.fetchData(), DCUVFETempDat.fetchData(), DCUCapsuleTempDat.fetchData(), MonShapeQualityDat.fetchData(), RunCommentDat.fetchData(), DCUIDarkPedDat.fetchData(), MODCCSFEDat.fetchData(), MODCCSTRDat.fetchData(), DCUIDarkDat.fetchData(), MODDCCOperationDat.fetchData(), CaliHVScanRatioDat.fetchData(), DCUCapsuleTempRawDat.fetchData(), CaliGainRatioDat.fetchData(), MonDelaysTTDat.fetchData(), RunH4TablePositionDat.fetchData(), CaliTempDat.fetchData(), CaliCrystalIntercalDat.fetchData(), MonLaserStatusDat.fetchData(), MonOccupancyDat.fetchData(), DCULVRBTempsDat.fetchData(), DCULVRTempsDat.fetchData(), MonPedestalsOnlineDat.fetchData(), MonLaserPulseDat.fetchData(), MonRunDat.fetchData(), MonPedestalOffsetsDat.fetchData(), FEConfigBadTTDat.fetchData(), MonCrystalConsistencyDat.fetchData(), MonLaserRedDat.fetchData(), MonLed1Dat.fetchData(), MonLed2Dat.fetchData(), ODWeightsSamplesDat.fetchData(), MonLaserBlueDat.fetchData(), MonLaserIRedDat.fetchData(), MonPNPedDat.fetchData(), ODDelaysDat.fetchData(), MonLaserGreenDat.fetchData(), FEConfigBadStripDat.fetchData(), FEConfigBadXTDat.fetchData(), ODBadTTDat.fetchData(), ODBadXTDat.fetchData(), MonMemChConsistencyDat.fetchData(), ODTowersToByPassDat.fetchData(), ODVfeToRejectDat.fetchData(), MODCCSHFDat.fetchData(), MonTTConsistencyDat.fetchData(), MonMemTTConsistencyDat.fetchData(), MonPedestalsDat.fetchData(), MonTestPulseDat.fetchData(), ODGolBiasCurrentDat.fetchData(), ODPedestalOffsetsDat.fetchData(), MonPNBlueDat.fetchData(), MonPNIRedDat.fetchData(), MonPNLed1Dat.fetchData(), MonPNLed2Dat.fetchData(), MonPNMGPADat.fetchData(), MonPNRedDat.fetchData(), MonPNGreenDat.fetchData(), MonPulseShapeDat.fetchData(), ODWeightsDat.fetchData(), MODDCCDetailsDat.fetchData(), DCULVRVoltagesDat.fetchData(), DCUCCSDat.fetchData(), ITimingDat.fetchData(), EcalCondDBInterface.fetchDataSet(), EcalCondDBInterface.fetchDataSetWithMap(), EcalCondDBInterface.fetchFEDelaysForRun(), LMFCorrCoefDat.fetchLastInsertedRun(), EcalCondDBInterface.fetchRunIOV(), LMFCorrCoefDat.find(), cond::persistency::IOVEditor.flush(), HcalO2OManager.getListOfUpdateIovs(), LMFLmrSubIOV.getLMFIOV(), LMFCorrCoefDatComponent.getLMFLmrSubIOV(), LMFDat.getLMFRunIOVID(), popcon::EcalLaser_weekly_Handler.getNewObjects(), popcon::PopCon.initialize(), EcalCondDBInterface.insertDataArraySet(), EcalCondDBInterface.insertDataSet(), EcalCondDBInterface.insertDCUIOV(), EcalCondDBInterface.insertLmfIOV(), EcalCondDBInterface.insertLmfLmrSubIOV(), EcalCondDBInterface.insertLmfRunIOV(), EcalCondDBInterface.insertLmfSeq(), EcalCondDBInterface.insertMonRunIOV(), EcalCondDBInterface.insertRunIOV(), XMLDocument.makeElementIOV(), HcalDQMDbInterface.makeMapIOV(), XMLDocument.makeMapIOV(), l1t::DataWriter.payloadToken(), l1t::DataWriterExt.payloadToken(), printRuns(), TStorageFactoryFile.ReadBufferAsync(), TStorageFactoryFile.ReadBuffers(), TStorageFactoryFile.ReadBuffersSync(), DTConfigDBProducer.readDTCCBConfig(), MODRunIOV.setRunIOV(), LMFSeqDat.setRunIOV(), MonRunIOV.setRunIOV(), cond::service::PoolDBOutputService.tagInfo(), EcalCondDBInterface.updateRunIOV(), EcalCondDBInterface.updateRunIOVEndTime(), EcalCondDBInterface.updateRunIOVStartTime(), MODCCSFEDat.writeArrayDB(), MODCCSTRDat.writeArrayDB(), MODDCCOperationDat.writeArrayDB(), DCUVFETempDat.writeArrayDB(), DCUIDarkDat.writeArrayDB(), DCUCapsuleTempDat.writeArrayDB(), MonShapeQualityDat.writeArrayDB(), DCUIDarkPedDat.writeArrayDB(), DCUCapsuleTempRawDat.writeArrayDB(), MonH4TablePositionDat.writeArrayDB(), MonOccupancyDat.writeArrayDB(), MonPedestalsOnlineDat.writeArrayDB(), DCULVRBTempsDat.writeArrayDB(), MonLaserPulseDat.writeArrayDB(), CaliGainRatioDat.writeArrayDB(), MonPedestalOffsetsDat.writeArrayDB(), MonDelaysTTDat.writeArrayDB(), FEConfigBadTTDat.writeArrayDB(), ODDelaysDat.writeArrayDB(), CaliTempDat.writeArrayDB(), CaliCrystalIntercalDat.writeArrayDB(), MonPNPedDat.writeArrayDB(), ODWeightsSamplesDat.writeArrayDB(), MonLaserRedDat.writeArrayDB(), MonLed1Dat.writeArrayDB(), MonLed2Dat.writeArrayDB(), MonLaserBlueDat.writeArrayDB(), MonLaserGreenDat.writeArrayDB(), MonLaserIRedDat.writeArrayDB(), ODBadTTDat.writeArrayDB(), ODBadXTDat.writeArrayDB(), FEConfigBadStripDat.writeArrayDB(), FEConfigBadXTDat.writeArrayDB(), MonMemChConsistencyDat.writeArrayDB(), ODTowersToByPassDat.writeArrayDB(), ODVfeToRejectDat.writeArrayDB(), MODCCSHFDat.writeArrayDB(), MonTTConsistencyDat.writeArrayDB(), MonMemTTConsistencyDat.writeArrayDB(), MonPedestalsDat.writeArrayDB(), MonTestPulseDat.writeArrayDB(), MonCrystalConsistencyDat.writeArrayDB(), ODGolBiasCurrentDat.writeArrayDB(), ODPedestalOffsetsDat.writeArrayDB(), MonPNMGPADat.writeArrayDB(), MonPNBlueDat.writeArrayDB(), MonPNGreenDat.writeArrayDB(), MonPNLed2Dat.writeArrayDB(), MonPNIRedDat.writeArrayDB(), MonPNLed1Dat.writeArrayDB(), MonPNRedDat.writeArrayDB(), ODWeightsDat.writeArrayDB(), MODDCCDetailsDat.writeArrayDB(), DCULVRVoltagesDat.writeArrayDB(), DCUCCSDat.writeArrayDB(), ITimingDat.writeArrayDB(), RunPTMTempDat.writeDB(), MODCCSTRDat.writeDB(), MODCCSFEDat.writeDB(), RunDat.writeDB(), MODDCCOperationDat.writeDB(), RunCrystalErrorsDat.writeDB(), RunMemTTErrorsDat.writeDB(), MonShapeQualityDat.writeDB(), DCUCapsuleTempDat.writeDB(), DCUVFETempDat.writeDB(), RunTTErrorsDat.writeDB(), RunPNErrorsDat.writeDB(), RunMemChErrorsDat.writeDB(), DCUIDarkDat.writeDB(), DCUIDarkPedDat.writeDB(), RunFEConfigDat.writeDB(), RunLaserRunDat.writeDB(), RunConfigDat.writeDB(), MonH4TablePositionDat.writeDB(), RunTPGConfigDat.writeDB(), RunCommentDat.writeDB(), DCUCapsuleTempRawDat.writeDB(), CaliGeneralDat.writeDB(), CaliHVScanRatioDat.writeDB(), MonOccupancyDat.writeDB(), MonPedestalsOnlineDat.writeDB(), CaliGainRatioDat.writeDB(), DCULVRTempsDat.writeDB(), DCULVRBTempsDat.writeDB(), MonDelaysTTDat.writeDB(), MonLaserStatusDat.writeDB(), MonLaserPulseDat.writeDB(), RunH4TablePositionDat.writeDB(), MonPedestalOffsetsDat.writeDB(), CaliTempDat.writeDB(), CaliCrystalIntercalDat.writeDB(), MonRunDat.writeDB(), MonPNPedDat.writeDB(), MonLaserBlueDat.writeDB(), MonLaserRedDat.writeDB(), MonLaserGreenDat.writeDB(), MonLed2Dat.writeDB(), MonLaserIRedDat.writeDB(), MonLed1Dat.writeDB(), MonCrystalConsistencyDat.writeDB(), MonMemChConsistencyDat.writeDB(), MODCCSHFDat.writeDB(), MonPedestalsDat.writeDB(), MonTTConsistencyDat.writeDB(), MonMemTTConsistencyDat.writeDB(), MonTestPulseDat.writeDB(), MonPNGreenDat.writeDB(), MonPNIRedDat.writeDB(), MonPNMGPADat.writeDB(), MonPNLed1Dat.writeDB(), MonPNBlueDat.writeDB(), MonPNLed2Dat.writeDB(), MonPNRedDat.writeDB(), MonPulseShapeDat.writeDB(), MODDCCDetailsDat.writeDB(), DCULVRVoltagesDat.writeDB(), ITimingDat.writeDB(), and DCUCCSDat.writeDB().

list o2o.isnewtag = gotten_iovs['newtag']

Definition at line 303 of file o2o.py.

list o2o.levStr = os.environ[messageLevelEnvVar]

Definition at line 27 of file o2o.py.

string o2o.logFolderEnvVar = 'O2O_LOG_FOLDER'

Definition at line 20 of file o2o.py.

tuple o2o.logFormatter = logging.Formatter(fmt_str)

Definition at line 30 of file o2o.py.

o2o.logLevel = logging.INFO

Definition at line 25 of file o2o.py.

string o2o.messageLevelEnvVar = 'O2O_LOG_LEVEL'

Definition at line 19 of file o2o.py.

string o2o.mode = 'online'

Definition at line 24 of file o2o.py.

list o2o.o2o_iovs = gotten_iovs['iovs']

Definition at line 302 of file o2o.py.

string o2o.o2o_tag_list_file = "o2o_tag_list.txt"

Definition at line 34 of file o2o.py.

string o2o.omds_accessor_string = "occi://CMS_HCL_APPUSER_R@anyhost/cms_omds_lb?PASSWORD=HCAL_Reader_44"

Definition at line 31 of file o2o.py.

string o2o.oracle_tpl = 'oracle://%s:%s@%s'

Definition at line 15 of file o2o.py.

string o2o.output_dir = "."

Definition at line 33 of file o2o.py.

Referenced by L1TCSCTFClient.dqmEndJob(), and L1TCSCTFClient.initialize().

string o2o.output_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"

Definition at line 28 of file o2o.py.

string o2o.pool_auth_path = "/nfshome0/popcondev/conddb"

Definition at line 29 of file o2o.py.

int o2o.pool_iov = iov

Definition at line 308 of file o2o.py.

string o2o.pool_logconnect = "sqlite_file:/nfshome0/kukartse/hcal/dcs/log.db"

Definition at line 30 of file o2o.py.

list o2o.pool_record = guessed_condition['pool_record']

Definition at line 259 of file o2o.py.

string o2o.private_db = 'sqlite:///o2o_jobs.db'

Definition at line 16 of file o2o.py.

list o2o.prod_db_service = ['cms_orcon_prod','o2o_prod']

Definition at line 12 of file o2o.py.

string o2o.python_popcon_file = "dbwrite_o2o.py"

Definition at line 36 of file o2o.py.

string o2o.python_popcon_template_file = "dbwrite_o2o_template.py"

Definition at line 35 of file o2o.py.

tuple o2o.query = query_file.read()

Definition at line 269 of file o2o.py.

Referenced by MonitorElementsDb.analyze(), l1t::OMDSReader.basicQuery(), l1t::OMDSReader.basicQueryGenericKey(), l1t::OMDSReader.basicQueryView(), ora::OraMappingSchema.containerForMappingVersion(), SiStripCoralIface.doNameQuery(), SiStripCoralIface.doQuery(), SiStripCoralIface.doSettingsQuery(), cond::CredentialStore.exportAll(), HcalLutManager.get_brickSet_from_oracle(), ora::OraNamingServiceTable.getAllNames(), ora::CondMetadataTable.getAllNames(), RunDCSLVDat.getBarrelRset(), RunDCSHVDat.getBarrelRset(), HcalChannelQualityXml.getBaseLineFromOmds(), ora::OraMappingSchema.getClassVersionListForContainer(), ora::PoolMappingSchema.getClassVersionListForContainer(), ora::OraMappingSchema.getClassVersionListForMappingVersion(), ora::PoolMappingSchema.getClassVersionListForMappingVersion(), ora::OraContainerHeaderTable.getContainerData(), ora::PoolContainerHeaderTable.getContainerData(), ora::OraMappingSchema.getContainerTableMap(), ora::OraMappingSchema.getDependentClassesInContainerMapping(), RunDCSHVDat.getEndcapAnodeRset(), RunDCSHVDat.getEndcapDynodeRset(), RunDCSLVDat.getEndcapRset(), HcalQIEManager.getHfQieTable(), HcalChannelQualityXml.getIovsFromOmds(), ora::OraSequenceTable.getLastId(), ora::PoolSequenceTable.getLastId(), HcalAssistant.getListOfChannelsFromDb(), HcalO2OManager.getListOfOmdsIovs(), HcalO2OManager.getListOfOmdsTags(), DBlmapReader.GetLMAP(), RunDCSMagnetDat.getMagnetRset(), ora::OraMappingSchema.getMapping(), ora::PoolMappingSchema.getMapping(), ora::OraMappingSchema.getMappingVersionListForContainer(), ora::PoolMappingSchema.getMappingVersionListForContainer(), ora::OraMappingSchema.getMappingVersionListForTable(), ora::OraNamingServiceTable.getNamesForContainer(), ora::CondMetadataTable.getNamesForContainer(), ora::OraNamingServiceTable.getNamesForObject(), ora::CondMetadataTable.getNamesForObject(), getNextSequenceValue(), ora::OraNamingServiceTable.getObjectByName(), ora::CondMetadataTable.getObjectByName(), HCALConfigDB.getOnlineLUT(), HCALConfigDB.getOnlineLUTFromXML(), ora::OraMainTable.getParameters(), HcalQIEManager.getTableFromDb(), HcalChannelQualityXml.getTagsFromOmds(), ora::OraMappingSchema.getVersionList(), ora::PoolMappingSchema.getVersionList(), cond::CredentialStore.listConnections(), cond::CredentialStore.listPrincipals(), ora::Serializer.lock(), ora::OraContainerHeaderTable.lockContainer(), ora::PoolContainerHeaderTable.lockContainer(), cond::persistency::DefineQueryOutput< T >.make(), cond::persistency::DefineQueryOutput< cond::Binary >.make(), cond::persistency::DefineQueryOutput< boost::posix_time::ptime >.make(), cond::persistency::DefineQueryOutput< cond::TimeType >.make(), cond::persistency::DefineQueryOutput< cond::SynchronizationType >.make(), cond::persistency::DefineQueryOutput< std::array< char, n > >.make(), L1CaloHcalScaleConfigOnlineProd.newObject(), SiStripPayloadHandler< SiStripPayload >.queryConfigMap(), RunInfoRead.readData(), DQMSummaryReader.readData(), cond.selectAuthorization(), cond.selectConnection(), cond::CredentialStore.selectForUser(), ora::OraMappingSchema.selectMappingVersion(), ora::PoolMappingSchema.selectMappingVersion(), cond::CredentialStore.selectPermissions(), cond.selectPrincipal(), and cond::CredentialStore.startSession().

tuple o2o.query_file = open(query_file_name, "r")

Definition at line 268 of file o2o.py.

string o2o.query_file_name = guessed_condition['query_file_name']

Definition at line 258 of file o2o.py.

o2o.query_save = query

Definition at line 318 of file o2o.py.

tuple o2o.run_result = run_popcon()

Definition at line 325 of file o2o.py.

string o2o.schema_name = 'CMS_CONDITIONS'

Definition at line 14 of file o2o.py.

int o2o.startStatus = -1

Definition at line 17 of file o2o.py.

tuple o2o.tag = tag_name.strip()

Definition at line 251 of file o2o.py.

tuple o2o.tags = get_tags(base_dir+"/"+o2o_tag_list_file)

Definition at line 248 of file o2o.py.

Referenced by pat::CandidateSummaryTable.analyze(), MixCollectionValidation.bookHistograms(), edm::CFWriter.CFWriter(), ChainedJetCorrectorProducer.ChainedJetCorrectorProducer(), HLTConfigData.dump(), models.generate(), EDMtoMEConverter.getData(), SiStripSummaryCreator.getSummaryME(), MonitorElement.getTags(), GoodSeedProducer.GoodSeedProducer(), FWPSetTableManager.handleEntry(), edm::HiMixingModule.HiMixingModule(), HLTMuonIsoFilter.HLTMuonIsoFilter(), HLTMuonPFIsoFilter.HLTMuonPFIsoFilter(), cond::persistency::GLOBAL_TAG_MAP::Table.insert(), L1Comparator.L1Comparator(), LightPFTrackProducer.LightPFTrackProducer(), edm::MixingModule.MixingModule(), edm.operator<<(), PFLinker.PFLinker(), PFNuclearProducer.PFNuclearProducer(), PFProducer.PFProducer(), PFTrackProducer.PFTrackProducer(), PFV0Producer.PFV0Producer(), MEtoEDM< TH1F >.putMEtoEdmObject(), pathelpers::RecordCache.RecordCache(), cond::persistency::GLOBAL_TAG_MAP::Table.select(), SimHitTPAssociationProducer.SimHitTPAssociationProducer(), and TrackingTruthAccumulator.TrackingTruthAccumulator().

string o2o.use_dropbox = 'false'

Definition at line 40 of file o2o.py.

Generated for CMSSW Reference Manual by doxygen 1.8.5