ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/UserCode/RateMonShiftTool_dev/AddTableInfo_db.py
(Generate patch)

Comparing UserCode/RateMonShiftTool_dev/AddTableInfo_db.py (file contents):
Revision 1.32 by grchrist, Mon Jul 2 12:48:31 2012 UTC vs.
Revision 1.40 by grchrist, Wed Oct 3 11:36:09 2012 UTC

# Line 2 | Line 2 | import sys
2   from colors import *
3   from DatabaseParser import *
4   from termcolor import colored, cprint
5 + from StreamMonitor import *
6 + import time
7 +
8 +
9   write = sys.stdout.write
10  
11 < NHighExpress=0
12 < NHighStreamA=0
11 > NHighStreamA = 0
12 > NHighExpress = 0
13  
14   def MoreTableInfo(parser,LumiRange,config,isCol=True):
15      print "Monitoring Run %d" % (parser.RunNumber,)
16 <    print "len=",len(LumiRange)
17 <    print "LSRange=", LumiRange
16 >    localtime = time.asctime( time.localtime(time.time()) )
17 >    print "Local current time :", localtime
18 >    #print "Lumisections used=", LumiRange
19      if len(LumiRange)>0:
20          
21          [AvInstLumi, AvLiveLumi, AvDeliveredLumi, AvDeadTime,PSCols] = parser.GetAvLumiInfo(LumiRange)
22          deadtimebeamactive=parser.GetDeadTimeBeamActive(LumiRange)*100
23 +        
24          ##print "dtba=",deadtimebeamactive
25      else:
26          print "no lumisections to monitor"
27          return
28 +  ## check if lumi is being filled
29 +    if parser.LastLSParsed > 4 and isCol:
30 +        if set(parser.InstLumiByLS.values()) == set([None]):
31 +            write(colored("\n\nLUMI INFORMATION NOT BEING SENT!\n",'red',attrs=['reverse']))
32 +            write(colored("Check with Shift Leader if this is expected\n",'red',attrs=['reverse']))
33 +            write(colored("If not, HFLUMI needs to be red-recycled\n\n\n",'red',attrs=['reverse']))
34 +            write(colored("If in doubt, call Lumi DOC\n\n\n",'red',attrs=['reverse']))
35 +            #return
36 +                                                                                                                                                                                                                                                                    
37 +    try:
38 +        #print "trying v3"
39 +        lograte=parser.GetTriggerRatesByLS("HLT_LogMonitor_v3")
40 +        #print lograte
41 +        if not len(lograte):
42 +            #print "trying v4"
43 +            lograte=parser.GetTriggerRatesByLS("HLT_LogMonitor_v4")
44 +            
45 +        #print lograte
46 +        for lumi in lograte.iterkeys():
47 +            #print lumi, lograte[lumi]
48 +            if lograte[lumi]>config.MaxLogMonRate:
49 +                write(bcolors.WARNING)
50 +                print lograte[lumi], "post to elog. LogMonitor rate is high."
51 +                write(bcolors.ENDC+"\n")
52 +    except:
53 +        write(bcolors.WARNING)
54 +        print "problem getting log monitor rates"
55 +        write(bcolors.ENDC+"\n")
56 +
57      try:
58          LastPSCol = PSCols[-1]
59      except:
60          LastPSCol = -1
26 –    if isCol:
27 –        
28 –        aRates = parser.GetTriggerRatesByLS("AOutput")
29 –        bRates = parser.GetTriggerRatesByLS("BOutput")
30 –        if len(bRates) == 0:
31 –            realARates = aRates
32 –        else:
33 –            realARates={}
34 –            for k,v in bRates.iteritems():
35 –                realARates[k]=aRates[k]-bRates[k]*20
36 –                #realARates = aRates - bRates*20;
37 –    else:
38 –        if len(parser.GetTriggerRatesByLS("AOutput"))>0:
39 –            aRates = parser.GetTriggerRatesByLS("AOutput")
40 –            bRates = parser.GetTriggerRatesByLS("BOutput")
41 –        else:
42 –            aRates = parser.GetTriggerRatesByLS("AForPPOutput")
43 –            bRates = parser.GetTriggerRatesByLS("BForPPOutput")
44 –            
61      
62      expressRates = {}
63      if isCol:
64          expressRates = parser.GetTriggerRatesByLS("ExpressOutput")
65      else:
66          if len(parser.GetTriggerRatesByLS("ExpressOutput"))>0:
67 <            expressRates=parser.GetTriggerRatesByLS("ExpressOutput")
67 >            expressRates=parser.GetTriggerRatesByLS("else")
68          else:
69              expressRates = parser.GetTriggerRatesByLS("ExpressForCosmicsOutput")
70 +
71      ExpRate=0
72      PeakRate=0
73      AvgExpRate=0
74      
58 –    ARate=0
59 –    PeakRateA=0
60 –    AvgRateA=0
61 –    
62 –    realARate=0
63 –    realPeakRateA=0
64 –    realAvgRateA=0
65 –    
75      if len(expressRates.values()) > 20:
76          AvgExpRate = sum(expressRates.values())/len(expressRates.values())
77 +    counter=0    
78  
79      for ls in LumiRange:  ## Find the sum and peak express stream rates
80          thisR = expressRates.get(ls,0)
# Line 72 | Line 82 | def MoreTableInfo(parser,LumiRange,confi
82          if thisR>PeakRate:
83              PeakRate=thisR
84  
85 <        thisRateA=aRates.get(ls,0)
76 <        ARate+=thisRateA
77 <        if thisRateA>PeakRateA:
78 <            PeakRateA=thisRateA
79 <
80 <        thisRealRateA = aRates.get(ls,0) - bRates.get(ls,0)*20
81 <        realARate+=thisRealRateA
82 <        if thisRealRateA > realPeakRateA:
83 <            realReakRateA = thisRealRateA
84 <        #ARate+=aRates.get(ls,0)
85 >
86      ## Print Stream A Rate --moved see below
87      ##print "Current Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
88  
# Line 90 | Line 91 | def MoreTableInfo(parser,LumiRange,confi
91      ##########################################
92      ## Check if the express stream is too high or low
93      ##########################################
94 <    global NHighExpress
94 <    badExpress = ((ExpRate/len(LumiRange) > config.MaxExpressRate) or ExpRate/len(LumiRange)<0.1) ## avg express stream rate too high?
94 >    badExpress = ((ExpRate/len(LumiRange) > config.MaxExpressRate) or (ExpRate/len(LumiRange)<0.1 and isCol)) ## avg express stream rate too high?
95      baseText = "\nCurrent Express Stream rate is: %0.1f Hz" % (ExpRate/len(LumiRange),) ## text to display
96      if badExpress:
97          text = colored(baseText,'red',attrs=['reverse'])  ## bad, make the text white on red
# Line 121 | Line 121 | def MoreTableInfo(parser,LumiRange,confi
121      ##Check if Stream A is too high
122      #########################################
123      global NHighStreamA
124 <    badStreamA =realARate/len(LumiRange) > config.MaxStreamARate ##Cosmics Express Rate 300 Hz max
125 <    baseTextA= "\nCurrent Steam A Rate is: %0.1f Hz" % (ARate/len(LumiRange),)
126 <    baseTextRealA= "\nCurrent PROMPT Steam A Rate is: %0.1f Hz" % (realARate/len(LumiRange),)
127 <    if badStreamA:
128 <        textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
129 <        textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
130 <        NHighStreamA+=1
131 <    else:
132 <        textA=baseTextA
133 <        textRealA=baseTextRealA
134 <        NHighStreamA=0
135 <
136 <    write(textA)
137 <    write(textRealA)
138 <    if badStreamA:
139 <        if len(LumiRange)>1:
140 <            if (realARate-realPeakRateA)/(len(LumiRange)-1) <=config.MaxStreamARate: ## one lumisection causes this
124 >    stream_mon = StreamMonitor()
125 >    core_a_rates = stream_mon.getStreamACoreRatesByLS(parser,LumiRange,config,isCol).values()
126 >    a_rates = stream_mon.getStreamARatesByLS(parser,LumiRange).values()
127 >    peak_core_a_rate = max(core_a_rates)
128 >
129 >    if len(LumiRange) > 0:
130 >        avg_core_a_rate = sum(core_a_rates)/len(LumiRange)
131 >        avg_a_rate = sum(a_rates)/len(LumiRange)
132 >        badStreamA = stream_mon.compareStreamARate(config, avg_core_a_rate, LumiRange,AvInstLumi,isCol)
133 >
134 >        baseTextA= "\nCurrent Stream A Rate is: %0.1f Hz" % (avg_a_rate)
135 >        baseTextRealA= "\nCurrent PROMPT Stream A Rate is: %0.1f Hz" % (avg_core_a_rate)
136 >
137 >        if badStreamA:
138 >            textA=colored(baseTextA,'red',attrs=['reverse'])  ## bad, make the text white on red
139 >            textRealA=colored(baseTextRealA,'red',attrs=['reverse'])  ## bad, make the text white on red
140 >            NHighStreamA+=1
141 >        else:
142 >            textA=baseTextA
143 >            textRealA=baseTextRealA
144 >
145 >        write(textA)
146 >        write(textRealA)
147 >    
148 >        if badStreamA and len(LumiRange) > 1:
149 >            trimmed_core_a_rates = core_a_rates
150 >            trimmed_core_a_rates.remove(peak_core_a_rate)
151 >            if sum(trimmed_core_a_rates)/(len(LumiRange)-1) <= config.MaxStreamARate: ## one lumisection causes this
152                  write("  <<  This appears to be due to a 1 lumisection spike, please monitor\n")
153              else:
154 <                if NHighStreamA >1: ##Call HLT doc!
154 >                if NHighStreamA > 1: ##Call HLT doc!
155                      write(colored("  <<  WARNING: Current Stream A rate is too high!",'red',attrs=['reverse']) )
156                      Warn = True
157      write("\n\n")
# Line 156 | Line 167 | def MoreTableInfo(parser,LumiRange,confi
167  
168          write( colored(line,'red',attrs=['reverse','blink']) )
169          write( colored("*"*cols+"\n",'red',attrs=['reverse','blink']) )
170 <    
170 >        
171      
172      PrescaleColumnString=''
173      PSCols = list(set(PSCols))

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines