python.BeamSpotUpdate Namespace Reference

Classes
class	BeamSpotWriteAlg
class	Config

Functions
def	setBeamSpot (run, lb, x, y, z, status=7, dbname='sqlite://;schema=beampos.db;dbname=CONDBR2', tag='IndetBeamposOnl-HLT-UPD1-001-00')
def	addFolderUpdate (event)
def	modify (event)
def	setup ()
def	run (flags)

Variables
	folderList
	log
	parser
	description
	metavar
	nargs
	help
	type
	int
	default
	str
	args
	dr
	output
	core_name
	run_number
	trigger_type
	detector_mask
	beam_type
	beam_energy
	meta_data_strings
	compression
	i
	newevt

Function Documentation

addFolderUpdate()

def python.BeamSpotUpdate.addFolderUpdate

(

event

)

Add COOL folder update to event

Definition at line 78 of file BeamSpotUpdate.py.

def addFolderUpdate(event):
   """Add COOL folder update to event"""
   
   ctp_robs = [rob for rob in event if rob.source_id().subdetector_id()==eformat.helper.SubDetector.TDAQ_CTP]
 
   if len(ctp_robs)==0:
      log.error("Cannot find CTP ROB in event")
      return event
 
   # Copy event except CTP ROBs
   new_event = eformat.write.FullEventFragment()
   new_event.copy_header(event)
   for r in event:
      if r.source_id().subdetector_id() != eformat.helper.SubDetector.TDAQ_CTP:
         new_event.append(eformat.write.ROBFragment(r))
 
   # Set the CTP extra payload      
   for rob in ctp_robs:
      x = CTPfragment.ExtraPayload()  # start from empty payload object
      for f in folderList: x.updateFolder(f)
      new_ctp_rob = CTPfragment.setHltExtraPayloadWords(rob, [d for d in x.serialize()])
      new_event.append(eformat.write.ROBFragment(new_ctp_rob))
      
   return new_event
 
   

modify()

def python.BeamSpotUpdate.modify

(

event

)

Definition at line 104 of file BeamSpotUpdate.py.

def modify(event):
   event = eformat.write.FullEventFragment(event)
 
   # Modify LB and HLT counter in CTP fragment
   newevt = trigbs_modifyEvent.modify(event)
   lb = newevt.lumi_block()
 
   # Write conditions update into CTP fragment
   if lb in Config.lb_updateBeamspot:
      lb_for_update,status = Config.lb_updateBeamspot.pop(lb)
 
      fe = CTPfragment.FolderEntry()
      fe.folderIndex = 0  # /Indet/Onl/Beampos
      fe.lumiBlock = lb_for_update
      folderList.append(fe)
      log.info('Added COOL folder update to event: folderIndex=%d, LB=%d', fe.folderIndex,fe.lumiBlock)
      
   return addFolderUpdate(newevt).readonly()
 
 

run()

def python.BeamSpotUpdate.run

(

flags

)

CA cfg function to be used from athenaHLT

Definition at line 139 of file BeamSpotUpdate.py.

def run(flags):
   """CA cfg function to be used from athenaHLT"""
 
   from AthenaCommon.Constants import DEBUG
   from AthenaConfiguration.ComponentAccumulator import ComponentAccumulator
   from AthenaConfiguration.ComponentFactory import CompFactory
   from IOVDbSvc.IOVDbSvcConfig import addFolders
 
   from pathlib import Path
 
   flags.lock()
   cfg = ComponentAccumulator()
 
   # addFolders requires at least an empty sqlite file
   Path('beampos.db').touch()
 
   # These folders are filled in Testing/condStopStart.trans
   cfg.merge( addFolders(flags, '/Indet/Onl/Beampos <key>/Indet/Beampos</key>',
                         detDb='beampos.db',
                         tag='IndetBeamposOnl-HLT-UPD1-001-00',
                         className='AthenaAttributeList',
                         extensible=True) )
 
   cfg.addEventAlgo( BeamSpotWriteAlg() )
   cfg.addEventAlgo( CompFactory.InDet.InDetBeamSpotReader(VxContainer = "") )
   cfg.addCondAlgo( CompFactory.BeamSpotCondAlg(OutputLevel = DEBUG) )
 
   return cfg
 
 
# For standalone running and writing a new output file

setBeamSpot()

def python.BeamSpotUpdate.setBeamSpot	(		run,
			lb,
			x,
			y,
			z,
			status = 7,
			dbname = 'sqlite://;schema=beampos.db;dbname=CONDBR2',
			tag = 'IndetBeamposOnl-HLT-UPD1-001-00'
	)

Definition at line 62 of file BeamSpotUpdate.py.

def setBeamSpot(run,lb,x,y,z,
                status=7,
                dbname='sqlite://;schema=beampos.db;dbname=CONDBR2',                tag='IndetBeamposOnl-HLT-UPD1-001-00'):
 
   log.info('============================= Creating new beamspot in COOL ===================================')
   log.info('run=%d, lb=%d, x=%f, y=%f, z=%f', run, lb, x, y, z)
   sys.stdout.flush()
   os.system("beamSpotOnl_set.py --output=sqlite:beampos.db --run=%d --lbn=%d %d %f %f %f" % (run,lb,status,x,y,z))
   if log.level<=logging.DEBUG:
      log.info('Current content of beampos.db sqlite file:')
      os.system("AtlCoolConsole.py 'sqlite://;schema=beampos.db;dbname=CONDBR2' <<< 'more Indet/Onl/Beampos'")
   log.info('===============================================================================================')
   sys.stdout.flush()   
 
 
 

setup()

def python.BeamSpotUpdate.setup

(

)

Initial setup

Definition at line 124 of file BeamSpotUpdate.py.

def setup():
   """Initial setup"""
 
   log.info('Will perform beamspot udpate on these LBs (LB,status): %s', sorted(Config.lb_updateBeamspot.values()))
 
   # Delete any previous sqlite file
   try:
      os.remove('beampos.db')
   except OSError:
      pass
 
   # Create an open-ended IOV with a default beamspot
   setBeamSpot(1,0,0.06,1.06,-4.6,4)
 
 

Variable Documentation

args

python.BeamSpotUpdate.args

Definition at line 179 of file BeamSpotUpdate.py.

beam_energy

python.BeamSpotUpdate.beam_energy

Definition at line 186 of file BeamSpotUpdate.py.

beam_type

python.BeamSpotUpdate.beam_type

Definition at line 185 of file BeamSpotUpdate.py.

compression

python.BeamSpotUpdate.compression

Definition at line 188 of file BeamSpotUpdate.py.

core_name

python.BeamSpotUpdate.core_name

Definition at line 181 of file BeamSpotUpdate.py.

default

python.BeamSpotUpdate.default

Definition at line 176 of file BeamSpotUpdate.py.

description

python.BeamSpotUpdate.description

Definition at line 174 of file BeamSpotUpdate.py.

detector_mask

python.BeamSpotUpdate.detector_mask

Definition at line 184 of file BeamSpotUpdate.py.

dr

python.BeamSpotUpdate.dr

Definition at line 180 of file BeamSpotUpdate.py.

folderList

python.BeamSpotUpdate.folderList

Definition at line 35 of file BeamSpotUpdate.py.

help

python.BeamSpotUpdate.help

Definition at line 175 of file BeamSpotUpdate.py.

i

python.BeamSpotUpdate.i

Definition at line 190 of file BeamSpotUpdate.py.

int

python.BeamSpotUpdate.int

Definition at line 176 of file BeamSpotUpdate.py.

log

python.BeamSpotUpdate.log

Definition at line 36 of file BeamSpotUpdate.py.

meta_data_strings

python.BeamSpotUpdate.meta_data_strings

Definition at line 187 of file BeamSpotUpdate.py.

metavar

python.BeamSpotUpdate.metavar

Definition at line 175 of file BeamSpotUpdate.py.

nargs

python.BeamSpotUpdate.nargs

Definition at line 175 of file BeamSpotUpdate.py.

newevt

python.BeamSpotUpdate.newevt

Definition at line 195 of file BeamSpotUpdate.py.

output

python.BeamSpotUpdate.output

Definition at line 181 of file BeamSpotUpdate.py.

parser

python.BeamSpotUpdate.parser

Definition at line 174 of file BeamSpotUpdate.py.

run_number

python.BeamSpotUpdate.run_number

Definition at line 182 of file BeamSpotUpdate.py.

str

python.BeamSpotUpdate.str

Definition at line 177 of file BeamSpotUpdate.py.

trigger_type

python.BeamSpotUpdate.trigger_type

Definition at line 183 of file BeamSpotUpdate.py.

type

python.BeamSpotUpdate.type

Definition at line 176 of file BeamSpotUpdate.py.