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

Diff Legend

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