Monitor.Monitoring Class Reference

Collaboration diagram for Monitor.Monitoring:

Public Member Functions
	__init__ (self, options, FairTasks)
	GetEntries (self)
	updateSource (self, fname)
	GetEvent (self, n)
	publishRootFile (self)
	purgeMonitorHistos (self)
	updateHtml (self)
	cleanUpHtml (self, destination="online")
	checkAlarm (self, minEntries=1000)
	sendAlarm (self)
	systemAndOrientation (self, s, plane)
	getAverageZpositions (self)
	smallSiPMchannel (self, i)
	Scifi_xPos (self, detID)
	MuFilter_PlaneBars (self, detID)
	map2Dict (self, aHit, T='GetAllSignals', mask=True)
	fit_langau (self, hist, o, bmin, bmax, opt='')
	twoLangaufun (self, x, par)
	langaufun (self, x, par)
	myPrint (self, tc, name, subdir='', withRootFile=True)
	fillHist1 (self, hname, parx)
	fillHist2 (self, hname, parx, pary)

Public Attributes
	options
	EventNumber
	TStart
	TEnd
	MonteCarlo
	Weight
	myclient
	snd_geo
	MuFilter
	Scifi
	systemAndPlanes
	systemAndBars
	systemAndChannels
	sdict
	freq
	TDC2ns
	zPos
	h
	runNr
	FairTasks
	converter
	fsdict
	hasBunchInfo
	eventTree
	trackTask
	Reco_MuonTracks
	clusMufi
	clusScifi
	run
	Nbunches
	div
	sink
	xing
	alarms

Static Public Attributes
bool	notOK = True
int	nIter = 0
	fiN
	Nkeys = self.converter.fiN.ReadKeys()
list	listOfKeys = []
int	first = -1
	nentries = eval("self.converter.fiN."+name+".GetEntries()")
	first
str	wwwPath = "/eos/experiment/sndlhc/www/online"
	rc = os.system("xrdcp -f "+self.presenterFile.GetName()+" "+os.environ['EOSSHIP']+wwwPath)
	presenterFile
float	invsq2pi = 0.3989422804014
float	mpshift = -0.22278298
float	np = 100.0
float	sc = 5.0
float	summe = 0.0
float	mpc = par[1] - mpshift * par[0]
	xlow = max(0,x[0] - sc * par[3])
float	xupp = x[0] + sc * par[3]
tuple	step = (xupp-xlow) / np
float	i = 1.0
tuple	xx = xlow + (i-.5) * step
	fland = ROOT.TMath.Landau(xx,mpc,par[0]) / par[0]
float	xx = xupp - (i-.5) * step

Detailed Description

Definition at line 66 of file Monitor.py.

Constructor & Destructor Documentation

__init__()

Monitor.Monitoring.__init__	(		self,
			options,
			FairTasks
	)

Definition at line 68 of file Monitor.py.

   def __init__(self,options,FairTasks):
        self.options = options
        self.EventNumber = -1
        self.TStart = -1
        self.TEnd   = -1
        self.MonteCarlo = False
        self.Weight = 1
 
        path     = options.path
        self.myclient = None
        if path.find('eos')>0:
             path  = options.server+options.path
        if options.online:
             path = path.replace("raw_data","convertedData").replace("data/","")
             self.myclient = client.FileSystem(options.server)
# setup geometry
        if (options.geoFile).find('../')<0: self.snd_geo = SndlhcGeo.GeoInterface(path+options.geoFile)
        else:                                         self.snd_geo = SndlhcGeo.GeoInterface(options.geoFile[3:])
        self.MuFilter = self.snd_geo.modules['MuFilter']
        self.Scifi       = self.snd_geo.modules['Scifi']
 
# MuFilter mapping of planes and bars 
        self.systemAndPlanes   = {1:self.MuFilter.GetConfParI("MuFilter/NVetoPlanes"),
                     2:self.MuFilter.GetConfParI("MuFilter/NUpstreamPlanes"),
                     3:2*self.MuFilter.GetConfParI("MuFilter/NDownstreamPlanes")-1} # to arrive at 7 DS planes
        self.systemAndBars     = {1:self.MuFilter.GetConfParI("MuFilter/NVetoBars"),
                     2:self.MuFilter.GetConfParI("MuFilter/NUpstreamBars"),
                     3:self.MuFilter.GetConfParI("MuFilter/NDownstreamBars")}
        self.systemAndChannels = {1:[self.MuFilter.GetConfParI("MuFilter/VetonSiPMs"),0],
                     2:[self.MuFilter.GetConfParI("MuFilter/UpstreamnSiPMs")-2,2],
                     3:[self.MuFilter.GetConfParI("MuFilter/DownstreamnSiPMs"),0]}
        self.sdict                     = {0:'Scifi',1:'Veto',2:'US',3:'DS'}
 
        self.freq      =  160.316E6
        self.TDC2ns = 1E9/self.freq
 
        self.zPos = self.getAverageZpositions()
 
        self.h = {}   # histogram storage
 
        self.runNr   = str(options.runNumber).zfill(6)
# presenter file
        if hasattr(self, "saveTo") and options.saveTo!="":
          name = options.saveTo+'run'+self.runNr+'_'+str(options.nStart//1000000)+'.root'
        else:
           name = 'run'+self.runNr+'.root'
        if options.interactive: name = 'I-'+name
        self.presenterFile = ROOT.TFile(name,'recreate')
        for role in ['','shifter', 'expert']:
          self.presenterFile.mkdir('scifi/'+role)
          self.presenterFile.mkdir('mufilter/'+role)
          self.presenterFile.mkdir('daq/'+role)
          if options.interactive: self.presenterFile.mkdir('eventdisplay/'+role)
        self.FairTasks = {}
        for x in FairTasks:   #  keeps extended methods if from python class
                 self.FairTasks[x.GetName()] = x
 
# setup input
        if options.online:
            import ConvRawData
            options.chi2Max = 2000.
            options.saturationLimit  = 0.95
            options.stop = False
            options.withGeoFile = True
            self.converter = ConvRawData.ConvRawDataPY()
            self.converter.Init(options)
            self.options.online = self.converter
            self.fsdict = False
            self.hasBunchInfo = False
            self.eventTree = options.online.fSink.GetOutTree()
            self.Nkeys = 38   # need to find a way to get this number automatically
            if self.converter.newFormat: self.Nkeys = 1
            for t in self.FairTasks:
               T = self.FairTasks[t]
               self.converter.run.AddTask(T)
               if t=='simpleTracking':  
                   T.Init(self.converter)
                   self.trackTask = self.FairTasks[t]
                   self.Reco_MuonTracks = T.fittedTracks
                   self.clusMufi        = T.clusMufi
                   self.clusScifi       = T.clusScifi
               else: T.Init()
            self.run = self.converter.run
            if self.eventTree.EventHeader.GetAccMode()==12: # ion runs
               self.Nbunches = 1782
               self.div = 8
            else: # proton runs
               self.Nbunches = 3564
               self.div = 4
            return
        else:
            if options.fname:
                f=ROOT.TFile.Open(options.fname)
                eventChain = f.Get('rawConv')
                if not eventChain:   
                    eventChain = f.cbmsim
                    if eventChain.GetBranch('MCTrack'): self.MonteCarlo = True
                partitions = []
            else:
              partitions = 0
              if options.partition < 0:
                 partitions = []
                 if path.find('eos')>0:
# check for partitions
                    dirlist  = str( subprocess.check_output("xrdfs "+options.server+" ls "+options.path+"run_"+self.runNr,shell=True) )
                    for x in dirlist.split('\\n'):
                       ix = x.find('sndsw_raw-')
                       if ix<0: continue
                       partitions.append(x[ix:])
                 else:
# check for partitions
                   dirlist  = os.listdir(options.path+"run_"+self.runNr)
                   for x in dirlist:
                     if not x.find('sndsw_raw-')<0:
                          partitions.append(x)
              else:
                 partitions = ["sndsw_raw-"+ str(options.partition).zfill(4)+".root"]
              if options.runNumber>0:
                eventChain = ROOT.TChain('rawConv')
                for p in partitions:
                       eventChain.Add(path+'run_'+self.runNr+'/'+p)
 
            rc = eventChain.GetEvent(0)
            self.TStart = eventChain.EventHeader.GetEventTime()
            if options.nEvents <0:
               rc = eventChain.GetEvent(eventChain.GetEntries()-1)
            else:
               rc = eventChain.GetEvent(options.nEvents-1)
            self.TEnd = eventChain.EventHeader.GetEventTime()
            rc = eventChain.GetEvent(0)
# start FairRunAna
            self.run  = ROOT.FairRunAna()
            ioman = ROOT.FairRootManager.Instance()
            ioman.SetTreeName(eventChain.GetName())
            outFile = ROOT.TMemFile('dummy','CREATE')
            source = ROOT.FairFileSource(eventChain.GetCurrentFile())
            for i in range(1,len(partitions)):
                  p = partitions[i]
                  source.AddFile(path+'run_'+self.runNr+'/'+p)
            self.run.SetSource(source)
            self.sink = ROOT.FairRootFileSink(outFile)
            self.run.SetSink(self.sink)
 
            for t in FairTasks: 
                self.run.AddTask(t)
 
#avoiding some error messages
            xrdb = ROOT.FairRuntimeDb.instance()
            xrdb.getContainer("FairBaseParSet").setStatic()
            xrdb.getContainer("FairGeoParSet").setStatic()
 
            self.run.Init()
            if len(partitions)>0:  self.eventTree = ioman.GetInChain()
            else:                 self.eventTree = ioman.GetInTree()
#fitted tracks
            if "simpleTracking" in self.FairTasks:
               self.trackTask = self.FairTasks["simpleTracking"]
               self.Reco_MuonTracks = self.trackTask.fittedTracks
               self.clusMufi        = self.trackTask.clusMufi
               self.clusScifi       = self.trackTask.clusScifi
               self.trackTask.DSnPlanes = 3
 
# initialize detector class for access to eventheader
        rc = eventChain.GetEvent(0)
        if not self.MonteCarlo:
           self.snd_geo.modules['Scifi'].InitEvent(eventChain.EventHeader)
           self.snd_geo.modules['MuFilter'].InitEvent(eventChain.EventHeader)
 
        # define the number of bunches in the LHC
        if eventChain.EventHeader.GetAccMode()==12: # ion runs
          self.Nbunches = 1782
          self.div = 8
        else: # proton runs
          self.Nbunches = 3564
          self.div = 4
        
        # get filling scheme, only necessary if not encoded in EventHeader, before 2022 reprocessing
        self.hasBunchInfo = False
        self.fsdict = False
        if hasattr(eventChain.EventHeader,"GetBunchType"):
           if not eventChain.EventHeader.GetBunchType()<0:
                self.hasBunchInfo = True
                print('take bunch info from event header')
        if not self.hasBunchInfo:
         try:
           fg  = ROOT.TFile.Open(options.server+options.path+'FSdict.root')
           pkl = Unpickler(fg)
           FSdict = pkl.load('FSdict')
           fg.Close()
           if options.runNumber in FSdict: self.fsdict = FSdict[options.runNumber]
         except:
           print('continue without knowing filling scheme',options.server+options.path)
         if self.fsdict: 
           print('extract bunch info from filling scheme')
        if self.fsdict or self.hasBunchInfo: 
          for x in ['B1only','B2noB1','noBeam']:
            for role in ['shifter', 'expert']:
             self.presenterFile.mkdir('mufilter/'+role+'/'+x)
             self.presenterFile.mkdir('scifi/'+role+'/'+x)
 

Member Function Documentation

checkAlarm()

Monitor.Monitoring.checkAlarm	(		self,
			minEntries = 1000
	)

Definition at line 470 of file Monitor.py.

   def checkAlarm(self,minEntries=1000):
      self.alarms = {'scifi':[]}
      # check for empty histograms in scifi signal
      entries = {}
      for mat in range(30):
           entries[mat] = self.h['scifi-mat_'+str(mat)].GetEntries()
      res = sorted(entries.items(), key=operator.itemgetter(1),reverse=True)
      if res[0][1]>minEntries: # choose limit which makes it sensitive to check for empty mats
          for mat in range(30):
              if entries[mat] < 1:
                   s = mat//6 + 1
                   if mat%6 < 3 : p='H'
                   else : p='V'
                   e = str(s)+p+str(mat%3)
                   self.alarms['scifi'].append(e)
      if len(self.alarms['scifi']) > 0:  self.sendAlarm()
 
      self.alarms['Veto']=[]
      # check for empty histograms in veto signal
      entries = {}
      s = 1
      for p in range(2):
         for side in ['L','R']:
             entries[str(10*s+p)+side] = self.h['mufi-sig'+p+str(10*s+p)].GetEntries()
      res = sorted(entries.items(), key=operator.itemgetter(1),reverse=True)
      if res[0][1]>minEntries: # choose limit which makes it sensitive to check for empty boards
       for p in range(2):
         for side in ['L','R']:
             if entries[str(10*s+p)+side] < 1:
                self.alarms['Veto'].append(str(10*s+p)+side())
      # check for empty histograms in US signal
      entries = {}
      s = 2
      for p in range(5):
         for side in ['L','R']:
             entries[str(s*10+p)+side] = self.h['mufi-sig2'+p+str(s*10+p)].GetEntries()
      res = sorted(entries.items(), key=operator.itemgetter(1),reverse=True)
      if res[0][1]>1000: # choose limit which makes it sensitive to check for empty boards
       for p in range(5):
         for side in ['L','R']:
             if entries[str(s*10+p)+side] < 1:
                self.alarms['Veto'].append(str(s*10+p)+side())
 
 

cleanUpHtml()

Monitor.Monitoring.cleanUpHtml	(		self,
			destination = "online"
	)

Definition at line 448 of file Monitor.py.

   def cleanUpHtml(self,destination="online"):
      rc = os.system("xrdcp -f "+os.environ['EOSSHIP']+"/eos/experiment/sndlhc/www/"+destination+".html  . ")
      old = open(destination+".html")
      oldL = old.readlines()
      old.close()
      tmp = open("tmp.html",'w')
      dirlist  = str( subprocess.check_output("xrdfs "+os.environ['EOSSHIP']+" ls /eos/experiment/sndlhc/www/"+destination+"/",shell=True) ) 
      for L in oldL:
           OK = True
           if L.find("https://snd-lhc-monitoring.web.cern.ch/"+destination)>0:
              k = L.find("file=")+5
              m =  L.find(".root")+5
              R = L[k:m]
              if not R in dirlist: OK = False  
           if OK: tmp.write(L)
      tmp.close()
      os.system('cp tmp.html '+destination+'.html')
      try:
            rc = os.system("xrdcp -f "+destination+".html  "+os.environ['EOSSHIP']+"/eos/experiment/sndlhc/www/")
      except:
            print("copy of html failed. Token expired?")
 

fillHist1()

Monitor.Monitoring.fillHist1	(		self,
			hname,
			parx
	)

Definition at line 676 of file Monitor.py.

   def fillHist1(self,hname,parx):
      for x in ['','B1only','B2noB1','noBeam']:
         if x=='':  
             rc = self.h[hname].Fill(parx,self.Weight)
         elif self.xing[x]:
             rc = self.h[hname+x].Fill(parx,self.Weight)

fillHist2()

Monitor.Monitoring.fillHist2	(		self,
			hname,
			parx,
			pary
	)

Definition at line 682 of file Monitor.py.

   def fillHist2(self,hname,parx,pary):
      for x in ['','B1only','B2noB1','noBeam']:
         if x=='':  
             rc = self.h[hname].Fill(parx,pary,self.Weight)
         elif self.xing[x]:
             rc = self.h[hname+x].Fill(parx,pary,self.Weight)
 

fit_langau()

Monitor.Monitoring.fit_langau	(		self,
			hist,
			o,
			bmin,
			bmax,
			opt = ''
	)

Definition at line 587 of file Monitor.py.

   def fit_langau(self,hist,o,bmin,bmax,opt=''):
      if opt == 2:
         params = {0:'Width(scale)',1:'mostProbable',2:'norm',3:'sigma',4:'N2'}
         F = ROOT.TF1('langau',langaufun,0,200,len(params))
      else:
         params = {0:'Width(scale)',1:'mostProbable',2:'norm',3:'sigma'}
         F = ROOT.TF1('langau',twoLangaufun,0,200,len(params))
      for p in params: F.SetParName(p,params[p])
      rc = hist.Fit('landau','S'+o,'',bmin,bmax)
      res = rc.Get()
      if not res: return res
      F.SetParameter(2,res.Parameter(0))
      F.SetParameter(1,res.Parameter(1))
      F.SetParameter(0,res.Parameter(2))
      F.SetParameter(3,res.Parameter(2))
      F.SetParameter(4,0)
      F.SetParLimits(0,0,100)
      F.SetParLimits(1,0,100)
      F.SetParLimits(3,0,10)
      rc = hist.Fit(F,'S'+o,'',bmin,bmax)
      res = rc.Get()
      return res
 

getAverageZpositions()

Monitor.Monitoring.getAverageZpositions

(

self

)

Definition at line 522 of file Monitor.py.

   def getAverageZpositions(self):
      zPos={'MuFilter':{},'Scifi':{}}
      for s in self.systemAndPlanes:
          for plane in range(self.systemAndPlanes[s]):
             bar = 4
             p = plane
             if s==3 and (plane%2==0 or plane==7): 
                bar = 90
                p = plane//2
             elif s==3 and plane%2==1:
                bar = 30
                p = plane//2
             self.MuFilter.GetPosition(s*10000+p*1000+bar,A,B)
             zPos['MuFilter'][s*10+plane] = (A.Z()+B.Z())/2.
      for s in range(1,6):
         mat   = 1
         sipm = 1
         channel = 64
         for o in range(2):
             self.Scifi.GetPosition(channel+1000*sipm+10000*mat+100000*o+1000000*s,A,B)
             zPos['Scifi'][s*10+o] = (A.Z()+B.Z())/2.
      return zPos
 

GetEntries()

Monitor.Monitoring.GetEntries

(

self

)

Definition at line 268 of file Monitor.py.

   def GetEntries(self):
       if  self.options.online:
         if  self.converter.newFormat:  return self.converter.fiN.Get('data').GetEntries()
         else:                                   return self.converter.fiN.event.GetEntries()
       else:
           return self.eventTree.GetEntries()
 

GetEvent()

Monitor.Monitoring.GetEvent	(		self,
			n
	)

Definition at line 317 of file Monitor.py.

   def GetEvent(self,n):
      if not self.options.online:   # offline, FairRoot in charge
 
         if self.eventTree.GetBranchStatus('Reco_MuonTracks'):
            for aTrack in self.eventTree.Reco_MuonTracks:
                if aTrack: aTrack.Delete()
            self.eventTree.Reco_MuonTracks.Delete()
         if "simpleTracking" in self.FairTasks:
            self.Reco_MuonTracks.Delete()
 
      if self.options.online:
            online = self.options.online
            online.executeEvent(n)
            self.Reco_MuonTracks.Delete()
            if self.options.FairTask_convRaw:
                self.options.online.sTree.GetEvent(self.options.online.sTree.GetEntries()-1)
            for t in self.FairTasks: self.FairTasks[t].ExecuteTask()
            self.eventTree = self.options.online.sTree
      else: 
            self.eventTree.GetEvent(n)
            if not self.MonteCarlo:
              # initialize detector class for access to eventheader
              self.snd_geo.modules['Scifi'].InitEvent(self.eventTree.EventHeader)
              self.snd_geo.modules['MuFilter'].InitEvent(self.eventTree.EventHeader)
            if self.MonteCarlo: self.Weight = self.eventTree.MCTrack[0].GetWeight()
            for t in self.FairTasks: self.FairTasks[t].ExecuteTask()
      self.EventNumber = n
 
# check for bunch xing type
      self.xing = {'all':True,'B1only':False,'B2noB1':False,'noBeam':False}
      if self.hasBunchInfo:
             binfo = self.eventTree.EventHeader
             self.xing['IP1']  = binfo.isIP1()
             self.xing['IP2']  = binfo.isIP2()
             self.xing['B1']   = binfo.isB1()
             self.xing['B2']   = binfo.isB2()
             self.xing['B1only']  = binfo.isB1Only()
             self.xing['B2noB1']  = binfo.isB2noB1()
             self.xing['noBeam']  = binfo.isNoBeam()
      elif self.fsdict:
             T   = self.eventTree.EventHeader.GetEventTime()
             bunchNumber = int((T%(self.div*self.Nbunches))/self.div+0.5)
             nb1 = (self.Nbunches + bunchNumber - self.fsdict['phaseShift1'])%self.Nbunches
             nb2 = (self.Nbunches + bunchNumber - self.fsdict['phaseShift1']- self.fsdict['phaseShift2'])%self.Nbunches
             b1 = nb1 in self.fsdict['B1']
             b2 = nb2 in self.fsdict['B2']
             IP1 = False
             IP2 = False
             if b1:
                IP1 =  self.fsdict['B1'][nb1]['IP1']
             if b2:
                IP2 =  self.fsdict['B2'][nb2]['IP2']
             self.xing['IP1']  = IP1
             self.xing['IP2']  = IP2
             self.xing['B1']   = b1
             self.xing['B2']   = b2
             self.xing['B1only']   = b1 and not IP1 and not b2
             self.xing['B2noB1']  = b2 and not b1
             self.xing['noBeam'] = not b1 and not b2
             if self.xing['B1only']  and self.xing['B2noB1']  or self.xing['B1only'] and self.xing['noBeam'] : print('error with b1only assignment',self.xing)
             if self.xing['B2noB1']  and self.xing['noBeam'] : print('error with b2nob1 assignment',self.xing)
 
      return self.eventTree
 

langaufun()

Monitor.Monitoring.langaufun	(		self,
			x,
			par
	)

Definition at line 616 of file Monitor.py.

   def  langaufun(self,x,par):

map2Dict()

Monitor.Monitoring.map2Dict	(		self,
			aHit,
			T = 'GetAllSignals',
			mask = True
	)

Definition at line 569 of file Monitor.py.

   def map2Dict(self,aHit,T='GetAllSignals',mask=True):
      if T=="SumOfSignals":
         key = Tkey
      elif T=="GetAllSignals" or T=="GetAllTimes":
         key = Ikey
      else: 
           print('use case not known',T)
           1/0
      key.clear()
      Value.clear()
      if T=="GetAllTimes": ROOT.fixRootT(aHit,key,Value,mask)
      else:                         ROOT.fixRoot(aHit,key,Value,mask)
      theDict = {}
      for k in range(key.size()):
          if T=="SumOfSignals": theDict[key[k].Data()] = Value[k]
          else: theDict[key[k]] = Value[k]
      return theDict
 

MuFilter_PlaneBars()

Monitor.Monitoring.MuFilter_PlaneBars	(		self,
			detID
	)

Definition at line 558 of file Monitor.py.

   def MuFilter_PlaneBars(self,detID):
         s = detID//10000
         l  = (detID%10000)//1000  # plane number
         bar = (detID%1000)
         if s>2:
             l=2*l
             if bar>59:
                  bar=bar-60
                  if l<6: l+=1
         return {'station':s,'plane':l,'bar':bar}
 

myPrint()

Monitor.Monitoring.myPrint	(		self,
			tc,
			name,
			subdir = '',
			withRootFile = True
	)

Definition at line 663 of file Monitor.py.

   def myPrint(self,tc,name,subdir='',withRootFile=True):
     srun = 'run'+str(self.options.runNumber)
     if isinstance(tc, ROOT.TCanvas) :
       tc.Update()
     if withRootFile:
         self.presenterFile.cd(subdir)
         tc.Write()
     else:
         if not os.path.isdir(srun): os.system('mkdir '+srun)
         pname = srun+'/'+name+'-'+srun
         tc.Print(pname+'.png')
         tc.Print(pname+'.pdf')
 

publishRootFile()

Monitor.Monitoring.publishRootFile

(

self

)

Definition at line 381 of file Monitor.py.

   def publishRootFile(self):

purgeMonitorHistos()

Monitor.Monitoring.purgeMonitorHistos

(

self

)

Definition at line 397 of file Monitor.py.

   def purgeMonitorHistos(self):
        wwwPath = "/eos/experiment/sndlhc/www/online/"
        for r in self.options.runNumbers.split(','):
            if r!= '': runList.append(int(r))
        for r in runList:
              runNr   = str(r).zfill(6)+'.root'
              f = ROOT.TFile.Open(options.server+wwwPath+ runNr)
              g = ROOT.TFile('tmp.root','recreate')
              for d in f.GetListOfKeys():
                  D = f.Get(d.GetName())
                  D.Purge()
              for d in f.GetListOfKeys():
                name = d.GetName()
                s = f.Get(name)
                g.mkdir(name)
                g.cd(name)
                for x in s.GetListOfKeys():
                    s.Get(x.GetName()).Write()
        g.Close()
        f.Close()
        os.system('xrdcp -f tmp.root  '+self.options.server+options.path+rName)
 

Scifi_xPos()

Monitor.Monitoring.Scifi_xPos	(		self,
			detID
	)

Definition at line 550 of file Monitor.py.

   def Scifi_xPos(self,detID):
        orientation = (detID//100000)%10
        nStation = 2*(detID//1000000-1)+orientation
        mat   = (detID%100000)//10000
        X = detID%1000+(detID%10000)//1000*128
        return [nStation,mat,X]   # even numbers are Y (horizontal plane), odd numbers X (vertical plane)
 
# decode MuFilter detID

sendAlarm()

Monitor.Monitoring.sendAlarm

(

self

)

Definition at line 514 of file Monitor.py.

   def sendAlarm(self):
       print('ALARM',self.alarms)
 

smallSiPMchannel()

Monitor.Monitoring.smallSiPMchannel	(		self,
			i
	)

Definition at line 545 of file Monitor.py.

   def smallSiPMchannel(self,i):
      if i==2 or i==5 or i==10 or i==13: return True
      else: return False
 
#  Scifi specific code

systemAndOrientation()

Monitor.Monitoring.systemAndOrientation	(		self,
			s,
			plane
	)

Definition at line 517 of file Monitor.py.

   def systemAndOrientation(self,s,plane):
      if s==1 or s==2: return "horizontal"
      if plane%2==1 or plane == 6: return "vertical"
      return "horizontal"
 

twoLangaufun()

Monitor.Monitoring.twoLangaufun	(		self,
			x,
			par
	)

Definition at line 610 of file Monitor.py.

   def twoLangaufun(self,x,par):
      N1 = self.langaufun(x,par)
      par2 = [par[0],par[1]*2,par[4],par[3]]
      N2 = self.langaufun(x,par2)
      return N1+abs(N2)
 

updateHtml()

Monitor.Monitoring.updateHtml

(

self

)

Definition at line 419 of file Monitor.py.

   def updateHtml(self):
      if self.options.online: destination="online"
      elif self.options.path.find('2022')>0: destination="reprocessing"
      else: destination="offline"
      rc = os.system("xrdcp -f "+os.environ['EOSSHIP']+"/eos/experiment/sndlhc/www/"+destination+".html  . ")
      old = open(destination+".html")
      oldL = old.readlines()
      old.close()
      tmp = open("tmp.html",'w')
      found = False
      for L in oldL:
           if not L.find(self.runNr)<0: return
           if L.find("https://snd-lhc-monitoring.web.cern.ch/"+destination+"/run.html?file=run")>0 and not found:
              r = str(self.options.runNumber)
              Lnew = '            <li> <a href="https://snd-lhc-monitoring.web.cern.ch/'+destination+'/run.html?file=run'
              Lnew+= self.runNr+'.root&lastcycle">run '+r+' </a>'+self.options.startTime
              if self.options.postScale>1: Lnew+="  post scaled:"+str(self.options.postScale)
              Lnew+='\n'
              tmp.write(Lnew)
              found = True
           tmp.write(L)
      tmp.close()
      os.system('cp '+destination+'.html '+destination+time.ctime().replace(' ','')+'.html ')  # make backup
      os.system('cp tmp.html '+destination+'.html')
      try:
            rc = os.system("xrdcp -f "+destination+".html  "+os.environ['EOSSHIP']+"/eos/experiment/sndlhc/www/")
      except:
            print("copy of html failed. Token expired?")
 

updateSource()

Monitor.Monitoring.updateSource	(		self,
			fname
	)

Definition at line 275 of file Monitor.py.

   def updateSource(self,fname):

Member Data Documentation

alarms

Monitor.Monitoring.alarms

Definition at line 471 of file Monitor.py.

clusMufi

Monitor.Monitoring.clusMufi

Definition at line 147 of file Monitor.py.

clusScifi

Monitor.Monitoring.clusScifi

Definition at line 148 of file Monitor.py.

converter

Monitor.Monitoring.converter

Definition at line 132 of file Monitor.py.

div

Monitor.Monitoring.div

Definition at line 153 of file Monitor.py.

EventNumber

Monitor.Monitoring.EventNumber

Definition at line 70 of file Monitor.py.

eventTree

Monitor.Monitoring.eventTree

Definition at line 137 of file Monitor.py.

FairTasks

Monitor.Monitoring.FairTasks

Definition at line 121 of file Monitor.py.

fiN

Monitor.Monitoring.fiN

static

Definition at line 286 of file Monitor.py.

first [1/2]

int Monitor.Monitoring.first = -1

static

Definition at line 301 of file Monitor.py.

first [2/2]

Monitor.Monitoring.first

static

Definition at line 304 of file Monitor.py.

fland

Monitor.Monitoring.fland = ROOT.TMath.Landau(xx,mpc,par[0]) / par[0]

static

Definition at line 654 of file Monitor.py.

freq

Monitor.Monitoring.freq

Definition at line 101 of file Monitor.py.

fsdict

Monitor.Monitoring.fsdict

Definition at line 135 of file Monitor.py.

h

Monitor.Monitoring.h

Definition at line 106 of file Monitor.py.

hasBunchInfo

Monitor.Monitoring.hasBunchInfo

Definition at line 136 of file Monitor.py.

i

float Monitor.Monitoring.i = 1.0

static

Definition at line 649 of file Monitor.py.

invsq2pi

float Monitor.Monitoring.invsq2pi = 0.3989422804014

static

Definition at line 629 of file Monitor.py.

listOfKeys

list Monitor.Monitoring.listOfKeys = []

static

Definition at line 296 of file Monitor.py.

MonteCarlo

Monitor.Monitoring.MonteCarlo

Definition at line 73 of file Monitor.py.

mpc

float Monitor.Monitoring.mpc = par[1] - mpshift * par[0]

static

Definition at line 640 of file Monitor.py.

mpshift

float Monitor.Monitoring.mpshift = -0.22278298

static

Definition at line 630 of file Monitor.py.

MuFilter

Monitor.Monitoring.MuFilter

Definition at line 86 of file Monitor.py.

myclient

Monitor.Monitoring.myclient

Definition at line 77 of file Monitor.py.

Nbunches

Monitor.Monitoring.Nbunches

Definition at line 152 of file Monitor.py.

nentries

Monitor.Monitoring.nentries = eval("self.converter.fiN."+name+".GetEntries()")

static

Definition at line 303 of file Monitor.py.

nIter

int Monitor.Monitoring.nIter = 0

static

Definition at line 278 of file Monitor.py.

Nkeys

Monitor.Monitoring.Nkeys = self.converter.fiN.ReadKeys()

static

Definition at line 289 of file Monitor.py.

notOK

bool Monitor.Monitoring.notOK = True

static

Definition at line 277 of file Monitor.py.

np

float Monitor.Monitoring.np = 100.0

static

Definition at line 633 of file Monitor.py.

options

Monitor.Monitoring.options

Definition at line 69 of file Monitor.py.

presenterFile

Monitor.Monitoring.presenterFile

static

Definition at line 395 of file Monitor.py.

rc

Monitor.Monitoring.rc = os.system("xrdcp -f "+self.presenterFile.GetName()+" "+os.environ['EOSSHIP']+wwwPath)

static

Definition at line 392 of file Monitor.py.

Reco_MuonTracks

Monitor.Monitoring.Reco_MuonTracks

Definition at line 146 of file Monitor.py.

run

Monitor.Monitoring.run

Definition at line 150 of file Monitor.py.

runNr

Monitor.Monitoring.runNr

Definition at line 108 of file Monitor.py.

sc

float Monitor.Monitoring.sc = 5.0

static

Definition at line 634 of file Monitor.py.

Scifi

Monitor.Monitoring.Scifi

Definition at line 87 of file Monitor.py.

sdict

Monitor.Monitoring.sdict

Definition at line 99 of file Monitor.py.

sink

Monitor.Monitoring.sink

Definition at line 208 of file Monitor.py.

snd_geo

Monitor.Monitoring.snd_geo

Definition at line 84 of file Monitor.py.

step

tuple Monitor.Monitoring.step = (xupp-xlow) / np

static

Definition at line 646 of file Monitor.py.

summe

float Monitor.Monitoring.summe = 0.0

static

Definition at line 637 of file Monitor.py.

systemAndBars

Monitor.Monitoring.systemAndBars

Definition at line 93 of file Monitor.py.

systemAndChannels

Monitor.Monitoring.systemAndChannels

Definition at line 96 of file Monitor.py.

systemAndPlanes

Monitor.Monitoring.systemAndPlanes

Definition at line 90 of file Monitor.py.

TDC2ns

Monitor.Monitoring.TDC2ns

Definition at line 102 of file Monitor.py.

TEnd

Monitor.Monitoring.TEnd

Definition at line 72 of file Monitor.py.

trackTask

Monitor.Monitoring.trackTask

Definition at line 145 of file Monitor.py.

TStart

Monitor.Monitoring.TStart

Definition at line 71 of file Monitor.py.

Weight

Monitor.Monitoring.Weight

Definition at line 74 of file Monitor.py.

wwwPath

str Monitor.Monitoring.wwwPath = "/eos/experiment/sndlhc/www/online"

static

Definition at line 385 of file Monitor.py.

xing

Monitor.Monitoring.xing

Definition at line 346 of file Monitor.py.

xlow

Monitor.Monitoring.xlow = max(0,x[0] - sc * par[3])

static

Definition at line 643 of file Monitor.py.

xupp

float Monitor.Monitoring.xupp = x[0] + sc * par[3]

static

Definition at line 644 of file Monitor.py.

xx [1/2]

tuple Monitor.Monitoring.xx = xlow + (i-.5) * step

static

Definition at line 653 of file Monitor.py.

xx [2/2]

float Monitor.Monitoring.xx = xupp - (i-.5) * step

static

Definition at line 657 of file Monitor.py.

zPos

Monitor.Monitoring.zPos

Definition at line 104 of file Monitor.py.

---

The documentation for this class was generated from the following file:

• shipLHC/scripts/Monitor.py